Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 2 additions & 4 deletions ring/example/local/local.go
Original file line number Diff line number Diff line change
Expand Up @@ -162,10 +162,8 @@ func SimpleMemberlistKV(bindaddr string, bindport int, joinmembers []string) *me
config.Codecs = []codec.Codec{ring.GetCodec()}

// TCPTransport defines what addr and port this particular peer should listen on.
config.TCPTransport = memberlist.TCPTransportConfig{
BindPort: bindport,
BindAddrs: []string{bindaddr},
}
config.TCPTransport.BindPort = bindport
config.TCPTransport.BindAddrs = []string{bindaddr}

// joinmembers are the addresses of peers who are already in the memberlist group.
// Usually provided if this peer is trying to join an existing cluster.
Expand Down