factory

Documentation

Index

• func NewTransport(shutdownHandler shutdown.ShutdownHandler, ...) (*batcher.Batcher, []*transport.Transporter)

Functions

func NewTransport

func NewTransport(shutdownHandler shutdown.ShutdownHandler,
	transportType transport.TransportType,
	transportConfig map[string]interface{},
	inputChan <-chan *marshaller.MarshalledMessage,
	txnsSeen chan<- *progress.Seen,
	txnsWritten chan<- *ordered_map.OrderedMap,
	statsChan chan stats.Stat,
	workers int,
	flushBatchUpdateAge int,
	flushBatchMaxAge int,
	batchQueueDepth int,
	batcherMemorySoftLimit int64,
	routingMethod batcher.BatchRouting) (*batcher.Batcher, []*transport.Transporter)

NewTransport returns out a transport (batcher, transporters) based on the type