Versions in this module Expand all Collapse all v2 v2.9.4 Aug 5, 2020 v2.9.3 Aug 5, 2020 Changes in this version + var AnnounceTime = 1 * 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 ErrPeerMaxExceeded = errors.New("peer max errors exceeded") + var ErrPeerNotFound = errors.New("peer not found") + var KeepAliveTime = 30 * time.Second + var MaxConnections = 3 + var MaxDepth uint = 3 + var MaxPeerErrors = 3 + var NetworkChannel = "network" + var PruneTime = 90 * time.Second + var ResolveTime = 1 * time.Minute + var SyncTime = 1 * time.Minute + func PeersToProto(node Node, depth uint) *pb.Peer + func UnpackPeerTopology(pbPeer *pb.Peer, lastSeen time.Time, depth uint) *node + type Error interface + Count func() int + Msg func() string + 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 + Status func() Status + 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 Nodes(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 + Nodes []string + Proxy proxy.Proxy + Resolver resolver.Resolver + Router router.Router + Tunnel tunnel.Tunnel + func DefaultOptions() Options + type Status interface + Error func() Error
Go to main page