influx

Documentation

Index

• type Config
  • func NewConfig(node *yaml.Node) (conf Config, err error)
• type Plugin
  • 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)

Types

type Config

type Config struct {
	Host   string `json:"host" yaml:"host"`
	Token  string `json:"token" yaml:"token"`
	Org    string `json:"org" yaml:"org"`
	Bucket string `json:"bucket" yaml:"bucket"`

	GroupName  string `json:"group_name" yaml:"group_name"`
	PipelineId int    `json:"pipeline_id" yaml:"pipeline_id"`
}

func NewConfig

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

type Plugin

type Plugin struct {
	// contains filtered or unexported fields
}

func NewPlugin

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

func (*Plugin) IncrementProcessorDroppedMessages

func (p *Plugin) IncrementProcessorDroppedMessages(proc string)

func (*Plugin) IncrementProcessorReceivedMessages

func (p *Plugin) IncrementProcessorReceivedMessages(proc string)

func (*Plugin) IncrementProcessorSentMessages

func (p *Plugin) IncrementProcessorSentMessages(proc string)

func (*Plugin) IncrementReceivedCounter

func (p *Plugin) IncrementReceivedCounter()

func (*Plugin) IncrementSentCounter

func (p *Plugin) IncrementSentCounter()

func (*Plugin) IncrementSinkErrCounter

func (p *Plugin) IncrementSinkErrCounter()

func (*Plugin) IncrementSourceErrCounter

func (p *Plugin) IncrementSourceErrCounter()

func (*Plugin) RegisterProcessors

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

func (*Plugin) SetProcessorExecutionTime

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