domain

Documentation

Index

• type DomainImpl
  • func NewPeerDomain(netProvider peering.NetworkProvider, peeringID peering.PeeringID, ...) *DomainImpl
  • func (d *DomainImpl) Attach(receiver byte, callback func(recv *peering.PeerMessageIn)) context.CancelFunc
  • func (d *DomainImpl) Close()
  • func (d *DomainImpl) GetRandomOtherPeers(upToNumPeers int) []*cryptolib.PublicKey
  • func (d *DomainImpl) PeerStatus() []peering.PeerStatusProvider
  • func (d *DomainImpl) ReshufflePeers()
  • func (d *DomainImpl) SendMsgByPubKey(pubKey *cryptolib.PublicKey, msgReceiver, msgType byte, msgData []byte)
  • func (d *DomainImpl) UpdatePeers(newPeerPubKeys []*cryptolib.PublicKey)

Types

type DomainImpl

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

func NewPeerDomain

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

NewPeerDomain creates a collection. Ignores self

func (*DomainImpl) Attach

func (d *DomainImpl) Attach(receiver byte, callback func(recv *peering.PeerMessageIn)) context.CancelFunc

func (*DomainImpl) Close

func (d *DomainImpl) Close()

func (*DomainImpl) GetRandomOtherPeers

func (d *DomainImpl) GetRandomOtherPeers(upToNumPeers int) []*cryptolib.PublicKey

func (*DomainImpl) PeerStatus

func (d *DomainImpl) PeerStatus() []peering.PeerStatusProvider

func (*DomainImpl) ReshufflePeers

func (d *DomainImpl) ReshufflePeers()

func (*DomainImpl) SendMsgByPubKey

func (d *DomainImpl) SendMsgByPubKey(pubKey *cryptolib.PublicKey, msgReceiver, msgType byte, msgData []byte)

func (*DomainImpl) UpdatePeers

func (d *DomainImpl) UpdatePeers(newPeerPubKeys []*cryptolib.PublicKey)