dep

Documentation

Index

• type LocalGeneralPeerCommunicator
  • func NewLocalGeneralPeerCommunicator(myid int, incoming chan *message.GeneralMessageEvent, ...) *LocalGeneralPeerCommunicator
  • func (d *LocalGeneralPeerCommunicator) Broadcast(msg message.GeneralMessage)
  • func (d *LocalGeneralPeerCommunicator) GetPipeIn() chan *message.GeneralMessageEvent
  • func (d *LocalGeneralPeerCommunicator) GetPipeOut() chan *message.GeneralMessageEvent
  • func (d *LocalGeneralPeerCommunicator) HandleIncomingMessage(msgEvent *message.GeneralMessageEvent)
  • func (d *LocalGeneralPeerCommunicator) Multicast(msg message.GeneralMessage, peers []message.GeneralPeer)
  • func (d *LocalGeneralPeerCommunicator) Unicast(msg message.GeneralMessage, peer message.GeneralPeer)

Types

type LocalGeneralPeerCommunicator

type LocalGeneralPeerCommunicator struct {
	Myid    int
	PeerIns []chan *message.GeneralMessageEvent
	// contains filtered or unexported fields
}

LocalGeneralPeerCommunicator is the place for change GeneralMessage locally.

func NewLocalGeneralPeerCommunicator

func NewLocalGeneralPeerCommunicator(myid int, incoming chan *message.GeneralMessageEvent, peers []chan *message.GeneralMessageEvent) *LocalGeneralPeerCommunicator

func (*LocalGeneralPeerCommunicator) Broadcast

func (d *LocalGeneralPeerCommunicator) Broadcast(msg message.GeneralMessage)

func (*LocalGeneralPeerCommunicator) GetPipeIn

func (d *LocalGeneralPeerCommunicator) GetPipeIn() chan *message.GeneralMessageEvent

func (*LocalGeneralPeerCommunicator) GetPipeOut

func (d *LocalGeneralPeerCommunicator) GetPipeOut() chan *message.GeneralMessageEvent

func (*LocalGeneralPeerCommunicator) HandleIncomingMessage

func (d *LocalGeneralPeerCommunicator) HandleIncomingMessage(msgEvent *message.GeneralMessageEvent)

func (*LocalGeneralPeerCommunicator) Multicast

func (d *LocalGeneralPeerCommunicator) Multicast(msg message.GeneralMessage, peers []message.GeneralPeer)

func (*LocalGeneralPeerCommunicator) Unicast

func (d *LocalGeneralPeerCommunicator) Unicast(msg message.GeneralMessage, peer message.GeneralPeer)