aggregate

Sep 16, 2020

Changes in this version

+ var File_aggregate_aggregate_proto protoreflect.FileDescriptor

+ type AggregatedRecord struct

+ ExplicitHashKeyTable []string

+ PartitionKeyTable []string

+ Records []*Record

+ func (*AggregatedRecord) Descriptor() ([]byte, []int)

+ func (*AggregatedRecord) ProtoMessage()

+ func (x *AggregatedRecord) GetExplicitHashKeyTable() []string

+ func (x *AggregatedRecord) GetPartitionKeyTable() []string

+ func (x *AggregatedRecord) GetRecords() []*Record

+ func (x *AggregatedRecord) ProtoReflect() protoreflect.Message

+ func (x *AggregatedRecord) Reset()

+ func (x *AggregatedRecord) String() string

+ type Aggregator struct

+ func NewAggregator() *Aggregator

+ func (a *Aggregator) AddRecord(partitionKey string, data []byte) (entry *kinesis.PutRecordsRequestEntry, err error)

+ func (a *Aggregator) AggregateRecords() (entry *kinesis.PutRecordsRequestEntry, err error)

+ func (a *Aggregator) GetRecordCount() int

+ type Record struct

+ Data []byte

+ ExplicitHashKeyIndex *uint64

+ PartitionKeyIndex *uint64

+ Tags []*Tag

+ func (*Record) Descriptor() ([]byte, []int)

+ func (*Record) ProtoMessage()

+ func (x *Record) GetData() []byte

+ func (x *Record) GetExplicitHashKeyIndex() uint64

+ func (x *Record) GetPartitionKeyIndex() uint64

+ func (x *Record) GetTags() []*Tag

+ func (x *Record) ProtoReflect() protoreflect.Message

+ func (x *Record) Reset()

+ func (x *Record) String() string

+ type Tag struct

+ Key *string

+ Value *string

+ func (*Tag) Descriptor() ([]byte, []int)

+ func (*Tag) ProtoMessage()

+ func (x *Tag) GetKey() string

+ func (x *Tag) GetValue() string

+ func (x *Tag) ProtoReflect() protoreflect.Message

+ func (x *Tag) Reset()

+ func (x *Tag) String() string