Documentation
¶
Index ¶
- type AggregatorMetadataGroup
- func (g *AggregatorMetadataGroup) Description() string
- func (g *AggregatorMetadataGroup) GetResult(ctx pipeline.PipelineContext) error
- func (g *AggregatorMetadataGroup) Init(context pipeline.Context, que pipeline.LogGroupQueue) (int, error)
- func (g *AggregatorMetadataGroup) Record(event *models.PipelineGroupEvents, ctx pipeline.PipelineContext) error
- func (g *AggregatorMetadataGroup) Reset()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AggregatorMetadataGroup ¶
type AggregatorMetadataGroup struct {
GroupMetadataKeys []string `json:"GroupMetadataKeys,omitempty" comment:"group by metadata keys"`
GroupMaxEventLength int `json:"GroupMaxEventLength,omitempty" comment:"max count of events in a pipelineGroupEvents"`
GroupMaxByteLength int `json:"GroupMaxByteLength,omitempty" comment:"max sum of byte length of events in a pipelineGroupEvents"`
DropOversizeEvent bool `json:"DropOversizeEvent,omitempty" comment:"drop event when the event over GroupMaxByteLength"`
// contains filtered or unexported fields
}
func NewAggregatorMetadataGroup ¶
func NewAggregatorMetadataGroup() *AggregatorMetadataGroup
func (*AggregatorMetadataGroup) Description ¶
func (g *AggregatorMetadataGroup) Description() string
func (*AggregatorMetadataGroup) GetResult ¶
func (g *AggregatorMetadataGroup) GetResult(ctx pipeline.PipelineContext) error
func (*AggregatorMetadataGroup) Init ¶
func (g *AggregatorMetadataGroup) Init(context pipeline.Context, que pipeline.LogGroupQueue) (int, error)
func (*AggregatorMetadataGroup) Record ¶
func (g *AggregatorMetadataGroup) Record(event *models.PipelineGroupEvents, ctx pipeline.PipelineContext) error
func (*AggregatorMetadataGroup) Reset ¶
func (g *AggregatorMetadataGroup) Reset()
Source Files
Click to show internal directories.
Click to hide internal directories.