tcp

Documentation

Index

• Constants
• Variables
• func NewQueueFullError(bytesAttempted int, bytesInQueue int, queueSize int) error
• func NewTransportQueue(maxSizeBytes int, maxSizeMessages int, metricFactory metric.Factory, ...) *transportQueue
• type DirectTransport
  • func NewDirectTransport(parentCtx context.Context, config config.GossipTransportConfig, ...) *DirectTransport
  • func (t *DirectTransport) GetServerPort() int
  • func (t *DirectTransport) GracefulShutdown(shutdownContext context.Context)
  • func (t *DirectTransport) IsServerListening() bool
  • func (t *DirectTransport) RegisterListener(listener adapter.TransportListener, listenerNodeAddress primitives.NodeAddress)
  • func (t *DirectTransport) Send(ctx context.Context, data *adapter.TransportData) error
  • func (t *DirectTransport) UpdateTopology(bgCtx context.Context, newPeers adapter.TransportPeers)

Constants

const HARNESS_OUTGOING_CONNECTIONS_INIT_TIMEOUT = 3 * time.Second

const HARNESS_PEER_READ_TIMEOUT = 1 * time.Second

const MAX_PAYLOADS_IN_MESSAGE = 100000

const MAX_PAYLOAD_SIZE_BYTES = 20 * 1024 * 1024

const SEND_QUEUE_MAX_BYTES = 20 * 1024 * 1024

const SEND_QUEUE_MAX_MESSAGES = 1000

const TEST_KEEP_ALIVE_INTERVAL = 20 * time.Millisecond

const TEST_NETWORK_TIMEOUT = 1 * time.Second

Variables

var DataExceedsCapacityError = errors.Errorf("Data exceeds allowed size %d", SEND_QUEUE_MAX_BYTES)

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

Functions

func NewQueueFullError

func NewQueueFullError(bytesAttempted int, bytesInQueue int, queueSize int) error

func NewTransportQueue

func NewTransportQueue(maxSizeBytes int, maxSizeMessages int, metricFactory metric.Factory, peerNodeAddress string) *transportQueue

Types

type DirectTransport

type DirectTransport struct {
	govnr.TreeSupervisor
	// contains filtered or unexported fields
}

func NewDirectTransport

func NewDirectTransport(parentCtx context.Context, config config.GossipTransportConfig, parentLogger log.Logger, registry metric.Registry) *DirectTransport

func (*DirectTransport) GetServerPort

func (t *DirectTransport) GetServerPort() int

func (*DirectTransport) GracefulShutdown

func (t *DirectTransport) GracefulShutdown(shutdownContext context.Context)

func (*DirectTransport) IsServerListening

func (t *DirectTransport) IsServerListening() bool

func (*DirectTransport) RegisterListener

func (t *DirectTransport) RegisterListener(listener adapter.TransportListener, listenerNodeAddress primitives.NodeAddress)

func (*DirectTransport) Send

func (t *DirectTransport) Send(ctx context.Context, data *adapter.TransportData) error

func (*DirectTransport) UpdateTopology

func (t *DirectTransport) UpdateTopology(bgCtx context.Context, newPeers adapter.TransportPeers)