peermanager

Documentation

Index

• Constants
• type PeerManager
• type PeerManagerProvider

Constants

const (
	CName = "common.commonspace.peermanager"
)

Types

type PeerManager

type PeerManager interface {
	app.Component
	// GetResponsiblePeers dials or gets from cache responsible peers
	GetResponsiblePeers(ctx context.Context) (peers []peer.Peer, err error)
	// GetNodePeers dials or gets from cache node peers
	GetNodePeers(ctx context.Context) (peers []peer.Peer, err error)
	// BroadcastMessage sends message to all peers
	BroadcastMessage(ctx context.Context, msg drpc.Message) error
	// SendMessage sends message to peer
	SendMessage(ctx context.Context, peerId string, msg drpc.Message) error
	// KeepAlive sends keepAlive messages to needed peers
	KeepAlive(ctx context.Context)
}

type PeerManagerProvider

type PeerManagerProvider interface {
	app.Component
	NewPeerManager(ctx context.Context, spaceId string) (sm PeerManager, err error)
}