kinesis

Aug 24, 2022

Changes in this version

+ const CompressionGzip

+ const CompressionNone

+ const CompressionZlib

+ type CompressionType string

+ type CompressorFunc func([]byte) ([]byte, error)

+ type OutputPlugin struct

+ Concurrency int

+ PluginID int

+ func NewOutputPlugin(...) (*OutputPlugin, error)

+ func (outputPlugin *OutputPlugin) AddRecord(records *[]*kinesis.PutRecordsRequestEntry, record map[interface{}]interface{}, ...) int

+ func (outputPlugin *OutputPlugin) Flush(records *[]*kinesis.PutRecordsRequestEntry) int

+ func (outputPlugin *OutputPlugin) FlushAggregatedRecords(records *[]*kinesis.PutRecordsRequestEntry) int

+ func (outputPlugin *OutputPlugin) FlushConcurrent(count int, records []*kinesis.PutRecordsRequestEntry) int

+ func (outputPlugin *OutputPlugin) FlushWithRetries(count int, records []*kinesis.PutRecordsRequestEntry)

+ func (outputPlugin *OutputPlugin) IsAggregate() bool

+ type PutRecordsClient interface

+ PutRecords func(input *kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)