communication

type GeneralMessageEventHandler interface {
	Handle(msgEvent *message.GeneralMessageEvent)
}

type GeneralMessageHandlerPlugin interface {
	SupportedMessageTypes() []message.GeneralMessageType
	SupportedEventHandlers() []eventbus.EventHandlerRegisterInfo
	GetMessageEventHandler() GeneralMessageEventHandler
	SetOutgoing(GeneralPeerCommunicatorOutgoing)
	Start()
	Stop()
}

type GeneralPeerCommunicatorIncoming interface {
	GetPipeIn() chan *message.GeneralMessageEvent
	GetPipeOut() chan *message.GeneralMessageEvent
}

type GeneralPeerCommunicatorOutgoing interface {
	Broadcast(msg message.GeneralMessage)
	Multicast(msg message.GeneralMessage, peers []message.GeneralPeer)
	Unicast(msg message.GeneralMessage, peer message.GeneralPeer)
}