adapter

Documentation

Index

• func PeerDiff(oldPeers GossipPeers, newPeers GossipPeers) (peersToRemove GossipPeers, peersToAdd GossipPeers)
• type GossipPeer
  • func NewGossipPeer(gossipPort int, gossipEndpoint string, hexAddress string) GossipPeer
• type GossipPeers
• type InterceptableTransport
• type InterceptorFunc
• type TransmitFunc
• type Transport
• type TransportData
  • func (d *TransportData) Clone() *TransportData
  • func (d *TransportData) TotalSize() (res int)
• type TransportListener

Functions

func PeerDiff

func PeerDiff(oldPeers GossipPeers, newPeers GossipPeers) (peersToRemove GossipPeers, peersToAdd GossipPeers)

Types

type GossipPeer

type GossipPeer interface {
	GossipPort() int
	GossipEndpoint() string
	HexOrbsAddress() string
}

func NewGossipPeer

func NewGossipPeer(gossipPort int, gossipEndpoint string, hexAddress string) GossipPeer

type GossipPeers

type GossipPeers map[string]GossipPeer

type InterceptableTransport

type InterceptableTransport interface {
	Transport
	SendWithInterceptor(ctx context.Context, data *TransportData, intercept InterceptorFunc) error
}

type InterceptorFunc

type InterceptorFunc func(ctx context.Context, peerAddress primitives.NodeAddress, data *TransportData, transmit TransmitFunc) error

type TransmitFunc

type TransmitFunc func(ctx context.Context, peerAddress primitives.NodeAddress, data *TransportData)

type Transport

type Transport interface {
	supervised.GracefulShutdowner
	govnr.ShutdownWaiter
	RegisterListener(listener TransportListener, listenerNodeAddress primitives.NodeAddress)
	Send(ctx context.Context, data *TransportData) error // TODO don't return error. misleading meaning. use panics instead
	UpdateTopology(bgCtx context.Context, newPeers GossipPeers)
}

type TransportData

type TransportData struct {
	SenderNodeAddress      primitives.NodeAddress
	RecipientMode          gossipmessages.RecipientsListMode
	RecipientNodeAddresses []primitives.NodeAddress
	Payloads               [][]byte // the first payload is normally gossipmessages.Header
}

func (*TransportData) Clone

func (d *TransportData) Clone() *TransportData

func (*TransportData) TotalSize

func (d *TransportData) TotalSize() (res int)

type TransportListener

type TransportListener interface {
	fmt.Stringer // TODO smelly
	OnTransportMessageReceived(ctx context.Context, payloads [][]byte)
}