Documentation ¶
Index ¶
- Variables
- type DefaultOgMessageAdapter
- func (d *DefaultOgMessageAdapter) AdaptGeneralMessage(incomingMsg general_message.GeneralMessage) (ogMessage message.OgMessage, err error)
- func (d *DefaultOgMessageAdapter) AdaptGeneralPeer(gnrPeer general_message.GeneralPeer) (communication.OgPeer, error)
- func (d *DefaultOgMessageAdapter) AdaptOgMessage(outgoingMsg message.OgMessage) (msg general_message.GeneralMessage, err error)
- func (d *DefaultOgMessageAdapter) AdaptOgPeer(annPeer *communication.OgPeer) (general_message.GeneralPeer, error)
- type GeneralMessageOg
- func (z *GeneralMessageOg) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *GeneralMessageOg) EncodeMsg(en *msgp.Writer) (err error)
- func (g *GeneralMessageOg) GetBytes() []byte
- func (g *GeneralMessageOg) GetType() general_message.GeneralMessageType
- func (z *GeneralMessageOg) MarshalMsg(b []byte) (o []byte, err error)
- func (z *GeneralMessageOg) Msgsize() (s int)
- func (g *GeneralMessageOg) String() string
- func (z *GeneralMessageOg) UnmarshalMsg(bts []byte) (o []byte, err error)
- type OgGeneralMessageHandler
- type OgMessageAdapter
- type OgMessageUnmarshaller
- type OgPlugin
- func (o *OgPlugin) GetMessageEventHandler() general_communication.GeneralMessageEventHandler
- func (o *OgPlugin) SetOutgoing(outgoing general_communication.GeneralPeerCommunicatorOutgoing)
- func (o *OgPlugin) Start()
- func (o *OgPlugin) Stop()
- func (o *OgPlugin) SupportedEventHandlers() []eventbus.EventHandlerRegisterInfo
- func (o *OgPlugin) SupportedMessageTypes() []general_message.GeneralMessageType
- type ProxyOgPeerCommunicator
- func (p *ProxyOgPeerCommunicator) Broadcast(msg message.OgMessage)
- func (p ProxyOgPeerCommunicator) GetPipeIn() chan *communication.OgMessageEvent
- func (p ProxyOgPeerCommunicator) GetPipeOut() chan *communication.OgMessageEvent
- func (p *ProxyOgPeerCommunicator) InitDefault()
- func (p ProxyOgPeerCommunicator) Multicast(msg message.OgMessage, peers []communication.OgPeer)
- func (p ProxyOgPeerCommunicator) Unicast(msg message.OgMessage, peer *communication.OgPeer)
Constants ¶
This section is empty.
Variables ¶
View Source
var MessageTypeOg general_message.GeneralMessageType = 1
Functions ¶
This section is empty.
Types ¶
type DefaultOgMessageAdapter ¶
type DefaultOgMessageAdapter struct {
// contains filtered or unexported fields
}
func (*DefaultOgMessageAdapter) AdaptGeneralMessage ¶
func (d *DefaultOgMessageAdapter) AdaptGeneralMessage(incomingMsg general_message.GeneralMessage) (ogMessage message.OgMessage, err error)
func (*DefaultOgMessageAdapter) AdaptGeneralPeer ¶
func (d *DefaultOgMessageAdapter) AdaptGeneralPeer(gnrPeer general_message.GeneralPeer) (communication.OgPeer, error)
func (*DefaultOgMessageAdapter) AdaptOgMessage ¶
func (d *DefaultOgMessageAdapter) AdaptOgMessage(outgoingMsg message.OgMessage) (msg general_message.GeneralMessage, err error)
func (*DefaultOgMessageAdapter) AdaptOgPeer ¶
func (d *DefaultOgMessageAdapter) AdaptOgPeer(annPeer *communication.OgPeer) (general_message.GeneralPeer, error)
type GeneralMessageOg ¶
type GeneralMessageOg struct { InnerMessageType message.OgMessageType InnerMessage []byte }
func (*GeneralMessageOg) DecodeMsg ¶
func (z *GeneralMessageOg) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (*GeneralMessageOg) EncodeMsg ¶
func (z *GeneralMessageOg) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (*GeneralMessageOg) GetBytes ¶
func (g *GeneralMessageOg) GetBytes() []byte
func (*GeneralMessageOg) GetType ¶
func (g *GeneralMessageOg) GetType() general_message.GeneralMessageType
func (*GeneralMessageOg) MarshalMsg ¶
func (z *GeneralMessageOg) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*GeneralMessageOg) Msgsize ¶
func (z *GeneralMessageOg) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*GeneralMessageOg) String ¶
func (g *GeneralMessageOg) String() string
func (*GeneralMessageOg) UnmarshalMsg ¶
func (z *GeneralMessageOg) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type OgGeneralMessageHandler ¶
type OgGeneralMessageHandler struct { OgPartner *ogcore.OgPartner OgMessageAdapter OgMessageAdapter }
func (OgGeneralMessageHandler) Handle ¶
func (a OgGeneralMessageHandler) Handle(msgEvent *message.GeneralMessageEvent)
type OgMessageAdapter ¶
type OgMessageAdapter interface { AdaptGeneralMessage(incomingMsg general_message.GeneralMessage) (ogMessage message.OgMessage, err error) AdaptGeneralPeer(gnrPeer *general_message.GeneralPeer) (communication.OgPeer, error) AdaptOgMessage(outgoingMsg message.OgMessage) (msg general_message.GeneralMessage, err error) AdaptOgPeer(annPeer *communication.OgPeer) (general_message.GeneralPeer, error) }
type OgMessageUnmarshaller ¶
type OgMessageUnmarshaller struct { }
func (*OgMessageUnmarshaller) Unmarshal ¶
func (a *OgMessageUnmarshaller) Unmarshal( messageType message.OgMessageType, messageBytes []byte) ( outMsg message.OgMessage, err error)
type OgPlugin ¶
type OgPlugin struct { OgPartner *ogcore.OgPartner Communicator *ProxyOgPeerCommunicator TxBuffer *pool.TxBuffer // contains filtered or unexported fields }
func NewOgPlugin ¶
func NewOgPlugin() *OgPlugin
func (*OgPlugin) GetMessageEventHandler ¶
func (o *OgPlugin) GetMessageEventHandler() general_communication.GeneralMessageEventHandler
func (*OgPlugin) SetOutgoing ¶
func (o *OgPlugin) SetOutgoing(outgoing general_communication.GeneralPeerCommunicatorOutgoing)
func (*OgPlugin) SupportedEventHandlers ¶
func (o *OgPlugin) SupportedEventHandlers() []eventbus.EventHandlerRegisterInfo
func (*OgPlugin) SupportedMessageTypes ¶
func (o *OgPlugin) SupportedMessageTypes() []general_message.GeneralMessageType
type ProxyOgPeerCommunicator ¶
type ProxyOgPeerCommunicator struct { OgMessageAdapter OgMessageAdapter // either TrustfulBftAdapter or PlainBftAdapter GeneralOutgoing general_communication.GeneralPeerCommunicatorOutgoing // contains filtered or unexported fields }
func (*ProxyOgPeerCommunicator) Broadcast ¶
func (p *ProxyOgPeerCommunicator) Broadcast(msg message.OgMessage)
func (ProxyOgPeerCommunicator) GetPipeIn ¶
func (p ProxyOgPeerCommunicator) GetPipeIn() chan *communication.OgMessageEvent
func (ProxyOgPeerCommunicator) GetPipeOut ¶
func (p ProxyOgPeerCommunicator) GetPipeOut() chan *communication.OgMessageEvent
func (*ProxyOgPeerCommunicator) InitDefault ¶
func (p *ProxyOgPeerCommunicator) InitDefault()
func (ProxyOgPeerCommunicator) Multicast ¶
func (p ProxyOgPeerCommunicator) Multicast(msg message.OgMessage, peers []communication.OgPeer)
func (ProxyOgPeerCommunicator) Unicast ¶
func (p ProxyOgPeerCommunicator) Unicast(msg message.OgMessage, peer *communication.OgPeer)
Click to show internal directories.
Click to hide internal directories.