contentvaluegroup

Documentation

Index

• type AggregatorContentValueGroup
  • func (g *AggregatorContentValueGroup) Add(log *protocol.Log, ctx map[string]interface{}) error
  • func (*AggregatorContentValueGroup) Description() string
  • func (g *AggregatorContentValueGroup) Flush() []*protocol.LogGroup
  • func (g *AggregatorContentValueGroup) Init(context pipeline.Context, que pipeline.LogGroupQueue) (int, error)
  • func (g *AggregatorContentValueGroup) Reset()

Types

type AggregatorContentValueGroup

type AggregatorContentValueGroup struct {
	GroupKeys        []string // The Keys to group by
	Topic            string   // Topic to attach, if set
	ErrIfKeyNotFound bool     // If logging when group-key not found
	EnablePackID     bool     // If attach PackID
	// contains filtered or unexported fields
}

func (*AggregatorContentValueGroup) Add

func (g *AggregatorContentValueGroup) Add(log *protocol.Log, ctx map[string]interface{}) error

func (*AggregatorContentValueGroup) Description

func (*AggregatorContentValueGroup) Description() string

Description ...

func (*AggregatorContentValueGroup) Flush

func (g *AggregatorContentValueGroup) Flush() []*protocol.LogGroup

func (*AggregatorContentValueGroup) Init

func (g *AggregatorContentValueGroup) Init(context pipeline.Context, que pipeline.LogGroupQueue) (int, error)

func (*AggregatorContentValueGroup) Reset

func (g *AggregatorContentValueGroup) Reset()