heka_ganglia_output

README

heka-ganglia-output

heka-ganglia-output is a Heka plugin to send accumulated stats to Ganglia.

heka-ganglia-output is released under an MIT-style open source license -- see LICENSE for details.

Uses Jeff Buchbinder's go-gmetric library (https://github.com/jbuchbinder/go-gmetric).

Building Heka with This Plugin

All Heka plugins written in Go must be included in Heka at compile time (see http://hekad.readthedocs.org/en/latest/installing.html#build-include-externals). To build Heka 0.4.2 with this plugin:

1. Clone the Heka repositoy (at version 0.4.2):

   git clone https://github.com/mozilla-services/heka.git --single-branch -b v0.4.2
   
   # or, with older versions of git:
   git clone https://github.com/mozilla-services/heka.git --depth 1
   cd heka
   git checkout v0.4.2 -b v0.4.2
   

2. Add the following lines to heka/cmake/externals.cmake:

   git_clone(https://github.com/jbuchbinder/go-gmetric 999d61122cfc4952463759c54ddfc1f1ee32e341)
   add_external_plugin(git https://github.com/SiftScience/heka-ganglia-output master)
   

3. Build Heka (see http://hekad.readthedocs.org/en/latest/installing.html#from-source for dependencies and additional details):

   cd heka
   source build.sh
   
   # to make a DEB package:
   make deb
   

Documentation

Index

• type GangliaOutput
  • func (o *GangliaOutput) ConfigStruct() interface{}
  • func (o *GangliaOutput) Init(config interface{}) (err error)
  • func (o *GangliaOutput) Run(runner pipeline.FilterRunner, helper pipeline.PluginHelper) (err error)
• type GangliaOutputConfig

Types

type GangliaOutput

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

An output that expects "stat metric" type messages from a StatAccumInput, with the stat values emitted in the message fields (emit_in_fields = true), and sends all received stats to the configured Ganglia gmond server.

func (*GangliaOutput) ConfigStruct

func (o *GangliaOutput) ConfigStruct() interface{}

func (*GangliaOutput) Init

func (o *GangliaOutput) Init(config interface{}) (err error)

func (*GangliaOutput) Run

func (o *GangliaOutput) Run(runner pipeline.FilterRunner, helper pipeline.PluginHelper) (err error)

type GangliaOutputConfig

type GangliaOutputConfig struct {
	Address string // address of the Ganglia gmond server

	Host  string // present as this hostname to Ganglia
	Spoof string // Ganglia spoof string

	Group string // Ganglia metric group
}