state

type ConnectedClients ¶

type ConnectedClients struct {
	Peer  uint64
	CRC64 uint64
	// contains filtered or unexported fields
}

ConnectedClients is used when memberlist does TCP push/pull state synchronization. It is used to notify the querying peer with a binary fuse filter.

func NewConnectedClients(peer uint64, clients []uint64) (*ConnectedClients, error)

func (c *ConnectedClients) Has(client uint64) bool

func (c *ConnectedClients) MarshalBinary() ([]byte, error)

func (c *ConnectedClients) UnmarshalBinary(b []byte) error

type PeerGraph ¶

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

func NewPeerGraph(self uint64) *PeerGraph

func (p *PeerGraph) Remove(peer uint64)

func (p *PeerGraph) Replace(c ConnectedClients) (modified bool)

func (p *PeerGraph) Who(client uint64) (peer uint64)

type PeerMap ¶

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

PeerMap maintains the mapping between a Peer and their corresponding *multiplexer.Peer connection. Although Peers are discovered via gossip, who gets to initiate the connection is decided by the ordinality of their PeerIDs. If they happened to have the same PeerID, they will panic to restart.

func NewPeerMap(logger *zap.Logger, self uint64) *PeerMap

func (s *PeerMap) CRC64() uint64

func (s *PeerMap) Get(peer uint64) multiplexer.Peer

func (s *PeerMap) Has(peer uint64) bool

func (s *PeerMap) Len() int

func (s *PeerMap) NewPeer(ctx context.Context, proto protocol.Protocol, conf multiplexer.Config) error

func (s *PeerMap) Notify() <-chan multiplexer.Peer

func (s *PeerMap) Print()

func (s *PeerMap) Remove(peer uint64) error

func (s *PeerMap) Snapshot() []uint64