peerlist

Mar 13, 2018

Changes in this version

type ListOption

+ func NoShuffle() ListOption

+ func Seed(seed int64) ListOption

Nov 22, 2017

Changes in this version

+ type List struct

+ func New(name string, transport peer.Transport, ...) *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