adapter

Documentation

Index

• type ErrCorruptData
  • func (e *ErrCorruptData) Error() string
• type ErrTransportFailed
  • func (e *ErrTransportFailed) Error() string
• type Transport
• type TransportData
  • func (d *TransportData) TotalSize() (res int)
• type TransportListener

Types

type ErrCorruptData

type ErrCorruptData struct {
}

func (*ErrCorruptData) Error

func (e *ErrCorruptData) Error() string

type ErrTransportFailed

type ErrTransportFailed struct {
	Data *TransportData
}

func (*ErrTransportFailed) Error

func (e *ErrTransportFailed) Error() string

type Transport

type Transport interface {
	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) TotalSize

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

type TransportListener

type TransportListener interface {
	OnTransportMessageReceived(ctx context.Context, payloads [][]byte)
}