Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTransporter ¶
func NewTransporter(shutdownHandler shutdown.ShutdownHandler, inputChan <-chan transport.Batch, txnsWritten chan<- *ordered_map.OrderedMap, statsChan chan stats.Stat, log logrus.Entry, id int) transport.Transporter
NewTransporter returns a stdout transporter
Types ¶
type StdoutTransporter ¶
type StdoutTransporter struct {
// contains filtered or unexported fields
}
func (StdoutTransporter) StartTransporting ¶
func (t StdoutTransporter) StartTransporting()
StartTransporting reads in message batches, outputs its String to STDOUT and then sends a progress report on the batch
Click to show internal directories.
Click to hide internal directories.