Documentation
¶
Index ¶
- Constants
- type AggregatorRouter
- func (p *AggregatorRouter) Add(log *protocol.Log, ctx map[string]interface{}) error
- func (*AggregatorRouter) Description() string
- func (p *AggregatorRouter) Flush() []*protocol.LogGroup
- func (p *AggregatorRouter) Init(context pipeline.Context, que pipeline.LogGroupQueue) (int, error)
- func (p *AggregatorRouter) Reset()
- type SubAgg
Constants ¶
View Source
const ( MaxLogCount = 1024 MaxLogGroupSize = 3 * 1024 * 1024 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AggregatorRouter ¶
type AggregatorRouter struct {
MaxLogGroupCount int
MaxLogCount int
PackFlag bool
Topic string
DropDisMatch bool
SourceKey string
NoMatchError bool
RouterRegex []string
RouterLogstore []string
Lock *sync.Mutex
// contains filtered or unexported fields
}
func NewAggregatorRouter ¶
func NewAggregatorRouter() *AggregatorRouter
func (*AggregatorRouter) Add ¶
func (p *AggregatorRouter) Add(log *protocol.Log, ctx map[string]interface{}) error
Add adds @log to aggregator. If @log has a key equal to aggregator.SourceKey (or SourceKey is empty), it passes @log to matched sub aggregator by calling route function. If @log don't have specified key but aggregator.DropDisMatch is not set, it passed @log to default aggregator, otherwise, it returns error when aggregator.NoMatchError is set. Add returns any error encountered, nil means success.
func (*AggregatorRouter) Description ¶
func (*AggregatorRouter) Description() string
func (*AggregatorRouter) Flush ¶
func (p *AggregatorRouter) Flush() []*protocol.LogGroup
func (*AggregatorRouter) Init ¶
func (p *AggregatorRouter) Init(context pipeline.Context, que pipeline.LogGroupQueue) (int, error)
func (*AggregatorRouter) Reset ¶
func (p *AggregatorRouter) Reset()
Source Files
Click to show internal directories.
Click to hide internal directories.