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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) GetConfig ¶
func (l *RedisInput) GetConfig() inputs.MothershipConfig
func (*RedisInput) GroupEvents ¶
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
Source Files
Click to show internal directories.
Click to hide internal directories.