Skip to content
Snippets Groups Projects
Commit 6f726d74 authored by capossele's avatar capossele
Browse files

:construction: WIP

parent f8b7c93a
No related branches found
No related tags found
No related merge requests found
......@@ -57,7 +57,7 @@ func start() {
)
host := parameter.NodeConfig.GetString(CFG_ADDRESS)
//localhost := host
localhost := host
apPort := strconv.Itoa(parameter.NodeConfig.GetInt(CFG_PORT))
gossipPort := strconv.Itoa(parameter.NodeConfig.GetInt(gossip.GOSSIP_PORT))
......@@ -72,7 +72,7 @@ func start() {
defer func() { _ = logger.Sync() }() // ignore the returned error
addr, err := net.ResolveUDPAddr("udp", host+":"+apPort)
addr, err := net.ResolveUDPAddr("udp", localhost+":"+apPort)
if err != nil {
log.Fatalf("ResolveUDPAddr: %v", err)
}
......@@ -117,8 +117,8 @@ func start() {
Selection = selection.New(local.INSTANCE, Discovery, selection.Config{
Log: logger.Named("sel"),
Param: &selection.Parameters{
SaltLifetime: selection.DefaultSaltLifetime,
// RequiredService: []string{"gossip"},
SaltLifetime: selection.DefaultSaltLifetime,
RequiredService: []service.Key{service.GossipKey},
},
})
handlers = append(handlers, Selection)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment