peerlist

Oct 31, 2019

Changes in this version

type ListOption

+ func FailFast() ListOption

Aug 6, 2018

Changes in this version

+ type Implementation interface

+ Add func(peer.StatusPeer, peer.Identifier) peer.Subscriber

+ Choose func(context.Context, *transport.Request) peer.StatusPeer

+ Remove func(peer.StatusPeer, peer.Identifier, peer.Subscriber)

+ type List struct

+ func New(name string, transport peer.Transport, availableChooser Implementation, ...) *List

+ func (pl *List) Available(p peer.Identifier) bool

+ func (pl *List) Choose(ctx context.Context, req *transport.Request) (peer.Peer, func(error), error)

+ func (pl *List) Introspect() introspection.ChooserStatus

+ func (pl *List) IsRunning() bool

+ func (pl *List) NotifyStatusChanged(pid peer.Identifier)

+ func (pl *List) NumAvailable() int

+ func (pl *List) NumUnavailable() int

+ func (pl *List) NumUninitialized() int

+ func (pl *List) Peers() []peer.Peer

+ func (pl *List) Start() error

+ func (pl *List) Stop() error

+ func (pl *List) Uninitialized(p peer.Identifier) bool

+ func (pl *List) Update(updates peer.ListUpdates) error

+ type ListOption interface

+ func Capacity(capacity int) ListOption

+ func NoShuffle() ListOption

+ func Seed(seed int64) ListOption