adapter

Documentation

Index

• type InterceptableTransport
• type InterceptorFunc
• type TransmitFunc
• type Transport
• type TransportData
  • func (d *TransportData) Clone() *TransportData
  • func (d *TransportData) TotalSize() (res int)
• type TransportListener

Types

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
}

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)
}