transporter

Documentation

Index

• Variables
• func NewTransporter(shutdownHandler shutdown.ShutdownHandler, inputChan <-chan transport.Batch, ...) transport.Transporter
• func NewTransporterWithInterface(shutdownHandler shutdown.ShutdownHandler, inputChan <-chan transport.Batch, ...) transport.Transporter
• type KinesisTransporter
  • func (t *KinesisTransporter) StartTransporting()

Variables

var (
	TimeSource utils.TimeSource = utils.RealTime{}
)

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,
	streamName string,
	retryPolicy backoff.BackOff,
	awsRegion *string,
	awsAccessKeyId *string,
	awsSecretAccessKey *string,
	endpoint *string) transport.Transporter

NewTransporter returns a kinesis transporter

func NewTransporterWithInterface

func NewTransporterWithInterface(shutdownHandler shutdown.ShutdownHandler,
	inputChan <-chan transport.Batch,
	txnsWritten chan<- *ordered_map.OrderedMap,
	statsChan chan stats.Stat,
	log logrus.Entry,
	id int,
	streamName string,
	client kinesisiface.KinesisAPI,
	retryPolicy backoff.BackOff) transport.Transporter

Types

type KinesisTransporter

type KinesisTransporter struct {
	// contains filtered or unexported fields
}

func (*KinesisTransporter) StartTransporting

func (t *KinesisTransporter) StartTransporting()

StartTransporting reads in message batches, outputs its data to Kinesis and then sends a progress report on the batch