metadatagroup

Documentation

Index

• type AggregatorMetadataGroup
  • func NewAggregatorMetadataGroup() *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()

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