Documentation
¶
Index ¶
- Constants
- type AggregatorContext
- func (p *AggregatorContext) Add(log *protocol.Log, ctx map[string]interface{}) error
- func (*AggregatorContext) Description() string
- func (p *AggregatorContext) Flush() []*protocol.LogGroup
- func (p *AggregatorContext) Init(context ilogtail.Context, que ilogtail.LogGroupQueue) (int, error)
- func (p *AggregatorContext) Reset()
- type LogPackSeqInfo
Constants ¶
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AggregatorContext ¶
type AggregatorContext struct {
MaxLogGroupCount int // the maximum log group count to trigger flush operation
MaxLogCount int // the maximum log in a log group
Topic string // the output topic
ContextPresevationTolerance int
PackFlag bool // whether to add config name as a tag
// contains filtered or unexported fields
}
AggregatorContext is the default aggregator in plugin system. If there is no specific aggregator in plugin config, it will be added.
func NewAggregatorDefault ¶
func NewAggregatorDefault() *AggregatorContext
NewAggregatorDefault create a default aggregator with default value.
func (*AggregatorContext) Add ¶
func (p *AggregatorContext) Add(log *protocol.Log, ctx map[string]interface{}) error
Add adds @log with @ctx to aggregator.
func (*AggregatorContext) Description ¶
func (*AggregatorContext) Description() string
func (*AggregatorContext) Flush ¶
func (p *AggregatorContext) Flush() []*protocol.LogGroup
Flush ...
func (*AggregatorContext) Init ¶
func (p *AggregatorContext) Init(context ilogtail.Context, que ilogtail.LogGroupQueue) (int, error)
Init method would be trigger before working. 1. context store the metadata of this Logstore config 2. que is a transfer channel for flushing LogGroup when reaches the maximum in the cache.
type LogPackSeqInfo ¶
type LogPackSeqInfo struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.