aggregatorshardhash

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()

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()