kinesis

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

type HookProducer func(name, streamName, shardID string) KinesisHooker

type KinesisHooker interface {
	OnDrain(bytes, length int64)
	OnPutRecords(batches, spanlists, bytes, putLatencyMS int64, reason string)
	OnPutErr(errCode string)
	OnDropped(batches, spanlists, bytes int64)
	OnSpanEnqueued()
	OnSpanDequeued()
	OnXLSpanDropped(size int)
	OnPutSpanListFlushed(spans, bytes int64)
	OnCompressed(original, compressed int64)
}

type Options struct {
	Name                    string
	StreamName              string
	AWSRegion               string
	AWSRole                 string
	AWSKinesisEndpoint      string
	QueueSize               int
	NumWorkers              int
	MaxListSize             int
	ListFlushInterval       int
	KPLAggregateBatchCount  int
	KPLAggregateBatchSize   int
	KPLBatchSize            int
	KPLBatchCount           int
	KPLBacklogCount         int
	KPLFlushIntervalSeconds int
	KPLMaxConnections       int
	KPLMaxRetries           int
	KPLMaxBackoffSeconds    int
	MaxAllowedSizePerSpan   int
	// to be called if data is put on an unexpected shard
	OnReshard func()
	// if you want to inject your own hooks into the exporter, else th default hooks will be created
	HookProducer HookProducer

	// Encoding defines the format in which spans should be exporter to kinesis
	// only Jaeger is supported right now
	Encoding string
}

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

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