go/go-micro
1
0
Fork 0
mirror of https://github.com/go-micro/go-micro.git synced 2024-11-24 08:02:32 +02:00
Code Issues Releases Activity

Replace Nodes with Peers

Browse Source
This commit is contained in:
Asim Aslam 2019-09-19 16:32:15 +01:00
parent ee74e26582
commit 7e05d2c440
2 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
network/default.go
View File

@ -73,7 +73,7 @@ func newNetwork(opts ...Option) Network {
// init tunnel address to the network bind address
options.Tunnel.Init(
tunnel.Address(options.Address),
tunnel.Nodes(options.Nodes...),
tunnel.Nodes(options.Peers...),
)
// init router Id to the network id
@ -169,7 +169,7 @@ func (n *network) resolveNodes() ([]string, error) {
}
// append seed nodes if we have them
for _, node := range n.options.Nodes {
for _, node := range n.options.Peers {
if _, ok := nodeMap[node]; !ok {
nodes = append(nodes, node)
}

11
network/options.go
View File

@ -22,8 +22,8 @@ type Options struct {
Address string
// Advertise sets the address to advertise
Advertise string
// Nodes is a list of seed nodes
Nodes []string
// Peers is a list of peers to connect to
Peers []string
// Tunnel is network tunnel
Tunnel tunnel.Tunnel
// Router is network router
@ -62,11 +62,10 @@ func Advertise(a string) Option {
}
}
// Nodes is a list of seed nodes used along
// with resolved node
func Nodes(n ...string) Option {
// Peers is a list of peers to connect to
func Peers(n ...string) Option {
return func(o *Options) {
o.Nodes = n
o.Peers = n
}
}