p2p

Documentation

Index

• type Communication
  • func NewCommunication(peerMgr peer_mgr.OrderPeerManager, logger logrus.FieldLogger) (*Communication, error)
  • func (c *Communication) ProcessBroadcast()
  • func (c *Communication) Start()
  • func (c *Communication) Stop() error

Types

type Communication

type Communication struct {
	peer_mgr.OrderPeerManager

	SendMsgChan chan *message.SendMsgChan
	// contains filtered or unexported fields
}

Communication use p2p to send messages among all the TSS nodes

func NewCommunication

func NewCommunication(peerMgr peer_mgr.OrderPeerManager, logger logrus.FieldLogger) (*Communication, error)

NewCommunication create a new instance of Communication

func (*Communication) ProcessBroadcast

func (c *Communication) ProcessBroadcast()

func (*Communication) Start

func (c *Communication) Start()

Start will start the communication

func (*Communication) Stop

func (c *Communication) Stop() error

Stop communication