adapter

Documentation

Index

• Constants
• Variables
• func NewMemoryTransport(ctx context.Context, logger log.BasicLogger, ...) *memoryTransport
• type ErrCorruptData
  • func (e *ErrCorruptData) Error() string
• type ErrTransportFailed
  • func (e *ErrTransportFailed) Error() string
• type MockTransportListener
  • func (l *MockTransportListener) ExpectNotReceive()
  • func (l *MockTransportListener) ExpectReceive(payloads [][]byte)
  • func (l *MockTransportListener) OnTransportMessageReceived(ctx context.Context, payloads [][]byte)
  • func (l *MockTransportListener) WhenOnTransportMessageReceived(arg interface{}) *mock.MockFunction
• type Transport
  • func NewDirectTransport(ctx context.Context, config config.GossipTransportConfig, ...) Transport
• type TransportData
• type TransportListener

Constants

const MAX_PAYLOADS_IN_MESSAGE = 100000

const MAX_PAYLOAD_SIZE_BYTES = 10 * 1024 * 1024

const NETWORK_SIZE = 3

Variables

var LogTag = log.String("adapter", "gossip")

Functions

func NewMemoryTransport

func NewMemoryTransport(ctx context.Context, logger log.BasicLogger, federation map[string]config.FederationNode) *memoryTransport

Package adapter provides an in-memory implementation of the Gossip Transport adapter, meant for usage in fast tests that should not use the TCP-based adapter, such as acceptance tests or sociable unit tests, or in other in-process network use cases

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 MockTransportListener

type MockTransportListener struct {
	mock.Mock
}

func (*MockTransportListener) ExpectNotReceive

func (l *MockTransportListener) ExpectNotReceive()

func (*MockTransportListener) ExpectReceive

func (l *MockTransportListener) ExpectReceive(payloads [][]byte)

func (*MockTransportListener) OnTransportMessageReceived

func (l *MockTransportListener) OnTransportMessageReceived(ctx context.Context, payloads [][]byte)

func (*MockTransportListener) WhenOnTransportMessageReceived

func (l *MockTransportListener) WhenOnTransportMessageReceived(arg interface{}) *mock.MockFunction

type Transport

type Transport interface {
	RegisterListener(listener TransportListener, listenerNodeAddress primitives.NodeAddress)
	Send(ctx context.Context, data *TransportData) error
}

func NewDirectTransport

func NewDirectTransport(ctx context.Context, config config.GossipTransportConfig, logger log.BasicLogger, registry metric.Registry) Transport

type TransportData

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

type TransportListener

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