counter

Feb 23, 2022

Changes in this version

+ type CountOutput struct

+ func (co *CountOutput) Process(_ context.Context, _ *entry.Entry) error

+ func (co *CountOutput) Start() error

+ func (co *CountOutput) Stop() error

+ type CountOutputConfig struct

+ Duration helper.Duration

+ Path string

+ func NewCounterOutputConfig(operatorID string) *CountOutputConfig

+ func (c CountOutputConfig) Build(bc operator.BuildContext) ([]operator.Operator, error)