inputs

package
v0.0.1-alpha.0...-67e42e2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 26, 2016 License: Apache-2.0 Imports: 2 Imported by: 9

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL