peer

Documentation

Index

• type Manager
  • func NewManager(register prometheus.Registerer) (*Manager, error)
  • func (pm *Manager) DeRegister(ctx context.Context, peerID string) error
  • func (pm *Manager) Get(ctx context.Context, peerID string) (*types.PeerInfo, error)
  • func (pm *Manager) GetAllPeerIDs(ctx context.Context) (peerIDs []string)
  • func (pm *Manager) List(ctx context.Context, filter *dutil.PageFilter) (peerList []*types.PeerInfo, err error)
  • func (pm *Manager) Register(ctx context.Context, peerCreateRequest *types.PeerCreateRequest) (peerCreateResponse *types.PeerCreateResponse, err error)

Types

type Manager

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

Manager is an implement of the interface of PeerMgr.

func NewManager

func NewManager(register prometheus.Registerer) (*Manager, error)

NewManager returns a new Manager Object.

func (*Manager) DeRegister

func (pm *Manager) DeRegister(ctx context.Context, peerID string) error

DeRegister is a peer from p2p network.

func (*Manager) Get

func (pm *Manager) Get(ctx context.Context, peerID string) (*types.PeerInfo, error)

Get returns the peerInfo of the specified peerID.

func (*Manager) GetAllPeerIDs

func (pm *Manager) GetAllPeerIDs(ctx context.Context) (peerIDs []string)

GetAllPeerIDs returns all peerIDs.

func (*Manager) List

func (pm *Manager) List(ctx context.Context, filter *dutil.PageFilter) (
	peerList []*types.PeerInfo, err error)

List returns all filtered peerInfo by filter.

func (*Manager) Register

func (pm *Manager) Register(ctx context.Context, peerCreateRequest *types.PeerCreateRequest) (peerCreateResponse *types.PeerCreateResponse, err error)

Register a peer and generate a unique ID as returned.