Versions in this module Expand all Collapse all v1 v1.16.1 Nov 13, 2019 Changes in this version + var AnnounceTime = 30 * time.Second + var ControlChannel = "control" + var DefaultAddress = ":0" + var DefaultLink = "network" + var DefaultName = "go.micro" + var ErrClientNotFound = errors.New("client not found") + var ErrPeerExists = errors.New("peer already exists") + var ErrPeerLinkNotFound = errors.New("peer link not found") + var ErrPeerNotFound = errors.New("peer not found") + var MaxConnections = 3 + var MaxDepth uint = 3 + var NetworkChannel = "network" + var PruneTime = 90 * time.Second + var ResolveTime = 1 * time.Minute + func PeersToProto(node Node, depth uint) *pb.Peer + func UnpackPeerTopology(pbPeer *pb.Peer, lastSeen time.Time, depth uint) *node + type Network interface + Client func() client.Client + Close func() error + Connect func() error + Init func(...Option) error + Name func() string + Options func() Options + Server func() server.Server + func NewNetwork(opts ...Option) Network + type Node interface + Address func() string + Id func() string + Network func() Network + Peers func() []Node + type Option func(*Options) + func Address(a string) Option + func Advertise(a string) Option + func Id(id string) Option + func Name(n string) Option + func Peers(n ...string) Option + func Proxy(p proxy.Proxy) Option + func Resolver(r resolver.Resolver) Option + func Router(r router.Router) Option + func Tunnel(t tunnel.Tunnel) Option + type Options struct + Address string + Advertise string + Id string + Name string + Peers []string + Proxy proxy.Proxy + Resolver resolver.Resolver + Router router.Router + Tunnel tunnel.Tunnel + func DefaultOptions() Options