uptime

README

UptimeFilter

Uptime aggregator (per hour) filter for Heka

Build notes

1. Touch cmake/plugin_loader.cmake
2. Edit plugin_loader.cmake and add
   

add_external_plugin(git https://github.com/kamilsmuga/UptimeFilter 84da1151b7570e43a6ca6d43b9e0023344be6033)

where ``` 84da1151b7570e43a6ca6d43b9e0023344be6033 ``` is the commit you want to use

Documentation

Index

• type UptimeFilter
  • func (f *UptimeFilter) CalculateUptimeFor(startHour, endHour int64)
  • func (f *UptimeFilter) FigureOutStartAndEndHour(epoch int64) (startHour, endHour int64)
  • func (f *UptimeFilter) GetEpoch(payload string) (epoch int64)
  • func (f *UptimeFilter) GetUptime(payload string) (uptime int64)
  • func (f *UptimeFilter) Init(config interface{}) error
  • func (f *UptimeFilter) InitFilterForStartHour(startHour int64, payload string)
  • func (f *UptimeFilter) Run(runner pipeline.FilterRunner, helper pipeline.PluginHelper) (err error)

Types

type UptimeFilter

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

func (*UptimeFilter) CalculateUptimeFor

func (f *UptimeFilter) CalculateUptimeFor(startHour, endHour int64)

func (*UptimeFilter) FigureOutStartAndEndHour

func (f *UptimeFilter) FigureOutStartAndEndHour(epoch int64) (startHour, endHour int64)

UDP payloads with uptime can be delivered anytime. There's only a little chance that this will occurr at e.g. 06:00 Need to parse epoch to figure out to which time period (between start and end hour) epoch value belongs Return start and end hour

func (*UptimeFilter) GetEpoch

func (f *UptimeFilter) GetEpoch(payload string) (epoch int64)

func (*UptimeFilter) GetUptime

func (f *UptimeFilter) GetUptime(payload string) (uptime int64)

func (*UptimeFilter) Init

func (f *UptimeFilter) Init(config interface{}) error

func (*UptimeFilter) InitFilterForStartHour

func (f *UptimeFilter) InitFilterForStartHour(startHour int64, payload string)

func (*UptimeFilter) Run

func (f *UptimeFilter) Run(runner pipeline.FilterRunner, helper pipeline.PluginHelper) (err error)