util

Documentation

Index

• type Message
• type MessageFan
  • func NewMessageFan() *MessageFan
  • func (fan *MessageFan) GetOutChannel() <-chan *Message
  • func (fan *MessageFan) RegisterChannel(sender *pb.PeerID, channel <-chan *Message)

Types

type Message

type Message struct {
	Msg    *pb.Message
	Sender *pb.PeerID
}

Message encapsulates an OpenchainMessage with sender information

type MessageFan

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

MessageFan contains the reference to the peer's MessageHandlerCoordinator

func NewMessageFan

func NewMessageFan() *MessageFan

NewMessageFan will return an initialized MessageFan

func (*MessageFan) GetOutChannel

func (fan *MessageFan) GetOutChannel() <-chan *Message

GetOutChannel returns a read only channel which the registered channels fan into

func (*MessageFan) RegisterChannel

func (fan *MessageFan) RegisterChannel(sender *pb.PeerID, channel <-chan *Message)

RegisterChannel is intended to be invoked by Handler to add a channel to be fan-ed in