prometheus

May 13, 2024

Changes in this version

+ type Config struct

+ GroupName string

+ PipelineId int

+ func NewConfig(node *yaml.Node) (conf Config, err error)

+ type Plugin struct

+ func NewPlugin(config Config) (*Plugin, error)

+ func (p *Plugin) IncrementProcessorDroppedMessages(proc string)

+ func (p *Plugin) IncrementProcessorReceivedMessages(proc string)

+ func (p *Plugin) IncrementProcessorSentMessages(proc string)

+ func (p *Plugin) IncrementReceivedCounter()

+ func (p *Plugin) IncrementSentCounter()

+ func (p *Plugin) IncrementSinkErrCounter()

+ func (p *Plugin) IncrementSourceErrCounter()

+ func (p *Plugin) RegisterProcessors(processors []string)

+ func (p *Plugin) SetProcessorExecutionTime(proc string, time int64)