peers

package

v0.2.1-beta.7 Latest Latest Go to latest Published: Sep 19, 2021 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Option func(*Peers)

Option to modify peers instance.

func WithLog(lg log.Log) Option

WithLog sets logger for Peers instance.

func WithNodeStatesReporter(f func()) Option

WithNodeStatesReporter sets callback to report node status. Callback is invoked after new peer joins or disconnects.

type Peer p2pcrypto.PublicKey

Peer is represented by a p2p identity public key.

type PeerSubscriptionProvider interface {
	SubscribePeerEvents() (conn, disc chan p2pcrypto.PublicKey)
}

PeerSubscriptionProvider is the interface that provides us with peer events channels.

type Peers struct {
	// contains filtered or unexported fields
}

Peers is used by protocols to manage available peers.

func New(opts ...Option) *Peers

New creates a Peers using specified parameters and returns it.

func Start(s PeerSubscriptionProvider, opts ...Option) *Peers

Start creates a Peers instance that is registered to `s`'s events and starts it.

func (p *Peers) Close()

Close stops listening for events and waits for background worker to exit.

func (p *Peers) GetPeers() []Peer

GetPeers returns a snapshot of the connected peers shuffled.

func (p *Peers) PeerCount() uint64

PeerCount returns the number of connected peers.

func (p *Peers) Start(added, expired chan p2pcrypto.PublicKey)

Start listener goroutine in background.

func (p *Peers) WaitPeers(ctx context.Context, n int) ([]Peer, error)

WaitPeers returns with atleast N peers or when context is terminated. Nil slice is returned if Peers is closing.