network

type Network interface {
	network.PipeManager

	Start() error

	Stop() error

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

	// SendWithStream sends message using existed stream
	SendWithStream(network.Stream, *pb.Message) error

	PeerID() string

	// CountConnectedValidators counts connected validator numbers
	CountConnectedValidators() uint64

	// RegisterMsgHandler registers one message type handler
	RegisterMsgHandler(messageType pb.Message_Type, handler func(network.Stream, *pb.Message)) error

	// RegisterMultiMsgHandler registers multi message type handler
	RegisterMultiMsgHandler(messageTypes []pb.Message_Type, handler func(network.Stream, *pb.Message)) error
}

type Pipe interface {
	fmt.Stringer
	Send(ctx context.Context, to string, data []byte) error
	Broadcast(ctx context.Context, targets []string, data []byte) error
	Receive(ctx context.Context) *network.PipeMsg
}