Documentation
¶
Index ¶
- type AggregatorShardHash
- func (s *AggregatorShardHash) Add(log *protocol.Log, ctx map[string]interface{}) error
- func (*AggregatorShardHash) Description() string
- func (s *AggregatorShardHash) Flush() []*protocol.LogGroup
- func (s *AggregatorShardHash) Init(context pipeline.Context, que pipeline.LogGroupQueue) (int, error)
- func (s *AggregatorShardHash) Reset()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AggregatorShardHash ¶
type AggregatorShardHash struct {
SourceKeys []string
ShardCount int
Topic string
Connector string
ErrIfKeyNotFound bool
EnablePackID bool
// contains filtered or unexported fields
}
AggregatorShardHash ... ShardCount is the power of 2, so that we can use bits to represent buckets. For example, 4 needs 2 bits to represent 3 bucket, so 00 to 11 are enough.
func (*AggregatorShardHash) Add ¶
func (s *AggregatorShardHash) Add(log *protocol.Log, ctx map[string]interface{}) error
Add ...
func (*AggregatorShardHash) Description ¶
func (*AggregatorShardHash) Description() string
Description ...
func (*AggregatorShardHash) Flush ¶
func (s *AggregatorShardHash) Flush() []*protocol.LogGroup
func (*AggregatorShardHash) Init ¶
func (s *AggregatorShardHash) Init(context pipeline.Context, que pipeline.LogGroupQueue) (int, error)
func (*AggregatorShardHash) Reset ¶
func (s *AggregatorShardHash) Reset()
Source Files
Click to show internal directories.
Click to hide internal directories.