stdout

Documentation

Index

• func New(shutdownHandler shutdown.ShutdownHandler, ...) []*transport.Transporter

Functions

func New

func New(shutdownHandler shutdown.ShutdownHandler,
	txnsWritten chan<- *ordered_map.OrderedMap,
	statsChan chan stats.Stat,
	workers int,
	inputChans []<-chan transport.Batch) []*transport.Transporter

New creates a stdout transport which has stdout batching and stdout transporting, connected by channels