peer_mgr

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 8, 2023 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BasicPeerManager

type BasicPeerManager interface {
	// Start
	Start() error

	// Stop
	Stop() error

	// AsyncSend sends message to peer with peer info.
	AsyncSend(KeyType, *pb.Message) error

	// Send sends message waiting response
	Send(KeyType, *pb.Message) (*pb.Message, error)

	// CountConnectedPeers counts connected peer numbers
	CountConnectedPeers() uint64

	// Peers return all peers including local peer.
	Peers() map[string]*peer.AddrInfo
}

type KeyType

type KeyType interface{}

type OrderMessageEvent

type OrderMessageEvent struct {
	Data []byte
}

type OrderPeerManager

type OrderPeerManager interface {
	BasicPeerManager

	// SubscribeOrderMessage
	SubscribeOrderMessage(ch chan<- OrderMessageEvent) event.Subscription

	// AddNode adds a vp peer.
	AddNode(newNodeID uint64, vpInfo *pb.VpInfo)

	// DelNode deletes a vp peer.
	DelNode(delID uint64)

	// UpdateRouter update the local router to quorum router.
	UpdateRouter(vpInfos map[uint64]*pb.VpInfo, isNew bool) bool

	// OtherPeers return peers except local peer.
	OtherPeers() map[uint64]*peer.AddrInfo

	// Broadcast message to all node
	Broadcast(*pb.Message) error

	// Disconnect disconnect with all vp peers.
	Disconnect(vpInfos map[uint64]*pb.VpInfo)

	// OrderPeers return all OrderPeers include account and id.
	OrderPeers() map[uint64]*pb.VpInfo
}

type TssPeerManager

type TssPeerManager interface {
	// SubscribeTssMessage subscribes to the message of the tss module
	SubscribeTssMessage(ch chan<- *pb.Message) event.Subscription

	// SubscribeTssSignRes subscribes to the sign result
	SubscribeTssSignRes(ch chan<- *pb.Message) event.Subscription

	// SubscribeTssCulprits subscribes to the message of the tss module
	SubscribeTssCulprits(ch chan<- *pb.Message) event.Subscription

	SubscribeTssKeygenReq(ch chan<- *pb.Message) event.Subscription

	// GetLocalID return local id
	GetLocalID() uint64
}

Directories

Path Synopsis
Package mock_orderPeermgr is a generated GoMock package.
Package mock_orderPeermgr is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL