inputs

Documentation

Index

• func EmptyFunc(chan common.MapStr)
• func PeriodicTaskRunner(l InputInterface, output chan common.MapStr, ti taskRunner, mi taskRunner, ...)
• type InputInterface
• type MothershipConfig
  • func (l *MothershipConfig) Normalize(global MothershipConfig)

Functions

func EmptyFunc

func EmptyFunc(chan common.MapStr)

empty function useful for passing into PeriodicTaskRunner sometimes

func PeriodicTaskRunner

func PeriodicTaskRunner(l InputInterface, output chan common.MapStr, ti taskRunner, mi taskRunner, ma taskRunner)

Types

type InputInterface

type InputInterface interface {
	// Initialize the input plugin
	Init(config MothershipConfig) error
	// Be able to retrieve the config
	GetConfig() MothershipConfig
	InputType() string
	InputVersion() string
	// Run
	Run(chan common.MapStr) error
}

Functions to be exported by an input plugin

type MothershipConfig

type MothershipConfig struct {
	Enabled        bool
	Host           string
	Port           int
	Key            string
	DB             int
	Flush_interval *int
	Max_retries    *int
	Type           string
	Sleep_interval int
	Tick_interval  int
	Minor_interval int
	Major_interval int
	Filename       string
}

func (*MothershipConfig) Normalize

func (l *MothershipConfig) Normalize(global MothershipConfig)

Normalize a config by pulling in global settings if appropriate, and enforcing absolute minimums