domain

Documentation

Index

• type DomainImpl
  • func NewPeerDomain(netProvider peering.NetworkProvider, initialNodes []peering.PeerSender, ...) *DomainImpl
  • func NewPeerDomainByNetIDs(netProvider peering.NetworkProvider, peerNetIDs []string, log *logger.Logger) (*DomainImpl, error)
  • func (d *DomainImpl) AddPeer(netID string) error
  • func (d *DomainImpl) Attach(peeringID *peering.PeeringID, callback func(recv *peering.RecvEvent)) interface{}
  • func (d *DomainImpl) Close()
  • func (d *DomainImpl) Detach(attachID interface{})
  • func (d *DomainImpl) GetRandomPeers(upToNumPeers int) []string
  • func (d *DomainImpl) RemovePeer(netID string)
  • func (d *DomainImpl) ReshufflePeers(seedBytes ...[]byte)
  • func (d *DomainImpl) SendMsgByNetID(netID string, msg *peering.PeerMessage)
  • func (d *DomainImpl) SendMsgToRandomPeers(upToNumPeers uint16, msg *peering.PeerMessage)
  • func (d *DomainImpl) SendMsgToRandomPeersSimple(upToNumPeers uint16, msgType byte, msgData []byte)
  • func (d *DomainImpl) SendSimple(netID string, msgType byte, msgData []byte)

Types

type DomainImpl

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

func NewPeerDomain

func NewPeerDomain(netProvider peering.NetworkProvider, initialNodes []peering.PeerSender, log *logger.Logger) *DomainImpl

NewPeerDomain creates a collection. Ignores self

func NewPeerDomainByNetIDs

func NewPeerDomainByNetIDs(netProvider peering.NetworkProvider, peerNetIDs []string, log *logger.Logger) (*DomainImpl, error)

func (*DomainImpl) AddPeer

func (d *DomainImpl) AddPeer(netID string) error

func (*DomainImpl) Attach

func (d *DomainImpl) Attach(peeringID *peering.PeeringID, callback func(recv *peering.RecvEvent)) interface{}

func (*DomainImpl) Close

func (d *DomainImpl) Close()

func (*DomainImpl) Detach

func (d *DomainImpl) Detach(attachID interface{})

func (*DomainImpl) GetRandomPeers

func (d *DomainImpl) GetRandomPeers(upToNumPeers int) []string

func (*DomainImpl) RemovePeer

func (d *DomainImpl) RemovePeer(netID string)

func (*DomainImpl) ReshufflePeers

func (d *DomainImpl) ReshufflePeers(seedBytes ...[]byte)

func (*DomainImpl) SendMsgByNetID

func (d *DomainImpl) SendMsgByNetID(netID string, msg *peering.PeerMessage)

func (*DomainImpl) SendMsgToRandomPeers

func (d *DomainImpl) SendMsgToRandomPeers(upToNumPeers uint16, msg *peering.PeerMessage)

func (*DomainImpl) SendMsgToRandomPeersSimple

func (d *DomainImpl) SendMsgToRandomPeersSimple(upToNumPeers uint16, msgType byte, msgData []byte)

func (*DomainImpl) SendSimple

func (d *DomainImpl) SendSimple(netID string, msgType byte, msgData []byte)