redis

Documentation

Index

• type RedisInput
  • func (l *RedisInput) Filter(event common.MapStr) (common.MapStr, error)
  • func (l *RedisInput) GetConfig() inputs.MothershipConfig
  • func (l *RedisInput) GroupEvents(events []common.MapStr) ([]common.MapStr, error)
  • func (l *RedisInput) Init(config inputs.MothershipConfig) error
  • func (l *RedisInput) InputType() string
  • func (l *RedisInput) InputVersion() string
  • func (l *RedisInput) Run(output chan common.MapStr) error

Types

type RedisInput

type RedisInput struct {
	Config inputs.MothershipConfig
	Host   string /* the host to connect to */
	Port   int    /* the port to connect to */
	DB     int    /* the database to read from */
	Key    string /* the key to POP from */
	Type   string /* the type to add to events */
}

func (*RedisInput) Filter

func (l *RedisInput) Filter(event common.MapStr) (common.MapStr, error)

func (*RedisInput) GetConfig

func (l *RedisInput) GetConfig() inputs.MothershipConfig

func (*RedisInput) GroupEvents

func (l *RedisInput) GroupEvents(events []common.MapStr) ([]common.MapStr, error)

Seperate events by metric_name, average the values for each metric, emit averaged metrics

func (*RedisInput) Init

func (l *RedisInput) Init(config inputs.MothershipConfig) error

func (*RedisInput) InputType

func (l *RedisInput) InputType() string

func (*RedisInput) InputVersion

func (l *RedisInput) InputVersion() string

func (*RedisInput) Run

func (l *RedisInput) Run(output chan common.MapStr) error