tcp

Documentation

Index

• Constants
• Variables
• func NewDirectTransport(ctx context.Context, config config.GossipTransportConfig, ...) *directTransport
• func NewTransportQueue(maxSizeBytes int, maxSizeMessages int, metricFactory metric.Factory) *transportQueue

Constants

const MAX_PAYLOADS_IN_MESSAGE = 100000

const MAX_PAYLOAD_SIZE_BYTES = 20 * 1024 * 1024

const NETWORK_SIZE = 3

const SEND_QUEUE_MAX_BYTES = 20 * 1024 * 1024

const SEND_QUEUE_MAX_MESSAGES = 1000

Variables

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

Functions

func NewDirectTransport

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

func NewTransportQueue

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