Creates a GlobalConfigStruct object populated w/ default values.

Expects either an absolute or relative file path.

Given a regular expression, return the string resulting from interpolating variables that exist in matchParts Example input to a formatRegexp: Reported at %Hostname% by %Reporter% Assuming there are entries in matchParts for 'Hostname' and 'Reporter', the returned string will then be: Reported at Somehost by Jonathon.

If `configable` supports the `HasConfigStruct` interface this will use said interface to fetch a config struct object and populate it w/ the values in provided `config`.

Creates and returns a new (but not yet started) DecoderRunner for the provided Decoder plugin.

Create and return a new diagnostic tracker.

Creates and returns foRunner pointer for use as either a FilterRunner or an OutputRunner.

Creates and returns a new (not yet started) InputRunner associated w/ the provided Input.

Creates and returns a new MatchRunner if possible, or a relevant error if not.

Creates and returns a (not yet started) Heka message router.

Create a new blank PacketTracking.

Creates and initializes a PipelineConfig object.

Returns a new PipelinePack pointer that will recycle itself onto the provided channel when a message has completed processing.

Creates and returns a RetryHelper pointer to be used when retrying plugin restarts or other parts that require exponential backoff.

Creates or opens the relevant whisper db file, and returns running WhisperRunner that will write to that file.

Given a PluginRunner and a Message struct, this function will populate the Message struct's field values with the plugin's input channel length and capacity, plus any additional data that the plugin might provide through implementation of the `ReportingPlugin` interface defined above.

Adds a plugin to the set of usable Heka plugins that can be referenced from a Heka config file.

Main function driving Heka execution.

Set a sample rate for match and message processing timing i.e.

Control channel event types used by go-notify.

Returns global pipeline config values.

Connection tracker that stores the actual AMQP Connection object along with its usage waitgroup (tracks if channels are still in use) along with a connection waitgroup (for users to wait on so the connection closing can be synchronized).

AMQP Input config struct.

AMQP Output config struct.

Output plugin that sends statmetric messages via TCP.

ConfigStruct for CarbonOutput plugin.

Clean message formatter reformats the Heka message in a more friendly ElasticSearch/Kibana way.

A CommandChain lets you execute an ordered set of subprocesses and pipe stdout to stdin for each stage.

Filter that counts the number of messages flowing through and provides primitive aggregation counts.

CounterFilter config struct, used only for specifying default ticker interval and message matcher values.

A diagnostic tracker that can track pipeline packs and do accounting to determine possible leaks.

ElasticSearchCoordinates stores the coordinates (_index, _type, _id) of an ElasticSearch document.

Output plugin that index messages to an elasticsearch cluster.

ConfigStruct for ElasticSearchOutput plugin.

FileMonitor, manages a group of FileTailers Handles the actual mechanics of finding, watching, and reading from file system files.

Output plugin that writes message contents to a file on the file system.

ConfigStruct for FileOutput plugin.

Struct for holding global pipeline config values.

A HttpBulkIndexer uses the HTTP REST Bulk Api of ElasticSearch in order to index documents.

Heka Input plugin that reads files from the filesystem, converts each line into a fully decoded Message object with the line contents as the payload, and passes the generated message on to the Router for delivery to any matching Filter or Output plugins.

ConfigStruct for LogfileInput plugin.

Output plugin that writes message contents out using Go standard library's `log` package.

ManagedCmd extends exec.Cmd to support killing of a subprocess if a timeout has been exceeded.

Encapsulates the mechanics of testing messages against a specific plugin's message_matcher value.

Protobuf record parser.

ConfigStruct for NetworkInput plugins.

Diagnostic object for packet tracking.

Payload message formatter just returns the contents of the message payload.

Master config object encapsulating the entire heka/pipeline configuration.

Main Heka pipeline data structure containing raw message data, a Message object, and other Heka related message metadata.

The TOML spec for plugin configuration options that will be pulled out by Heka itself for runner configuration before the config is passed to the Plugin.Init method.

A helper object to support delayed plugin creation.

Heka Input plugin that runs external programs and processes their output as a stream into Message objects to be passed into the Router for delivery to matching Filter or Output plugins.

Decoder for converting ProtocolBuffer data into Message objects.

Raw message formatter leaves the Heka message untouched.

Regexp line parser using a start or end of line regexp delimiter.

Retry helper, created with a RetryOptions struct Everytime Wait is called, the times this has been used is incremented.

This struct provides a structure for the available retry options for a plugin that supports being restarted.

Decoder for converting structured/unstructured data into Heka messages.

Heka Filter plugin that acts as a wrapper for sandboxed filter scripts.

Heka Filter plugin that listens for (signed) control messages and dynamically creates, manages, and destroys sandboxed filter scripts as instructed.

Config struct for `SandboxManagerFilter`.

Heka Message signer object.

Represents a single stat value in the format expected by the StatAccumInput.

Heka Filter plugin that can accept specific message types, extract data from those messages, and from that data generate statsd messages in a StatsdInput exactly as if a statsd message has come from a networked statsd client.

StatFilter config struct.

A Heka Input plugin that handles statsd metric style input and flushes aggregated values.

StatsInput config struct.

Decoder that expects statsd string format data in the message payload, converts that to identical statsd format data in the message fields, in the same format that a StatAccumInput w/ `emit_in_fields` set to true would use.

Input plugin implementation that listens for Heka protocol messages on a specified TCP socket.

Output plugin that sends messages via TCP using the Heka protocol.

ConfigStruct for TcpOutput plugin.

Byte delimited line parser.

A UDPBulkIndexer uses the Bulk UDP Api of ElasticSearch in order to index documents.

Input plugin implementation that listens for Heka protocol messages on a specified UDP socket.

A WhisperOutput plugin will parse the stats data in the payload of a `statmetric` message and write the data out to a graphite-compatible whisper database file tree structure.

WhisperOutput config struct.

Basic hub that manages AMQP Connections Since multiple channels should be utilized for a single connection, this hub manages the connections, dispensing channels per broker config.

A BulkIndexer is used to index documents in ElasticSearch.

Heka Decoder plugin interface.

Heka PluginRunner for Decoder plugins.

Encapsulates access to a set of DecoderRunners.

Heka Filter plugin type.

Heka PluginRunner interface for Filter type plugins.

Indicates a plug-in has a specific-to-itself config struct that should be passed in to its Init method.

Input plugin interface type.

Heka PluginRunner for Input plugins.

A Message Formatter formats a Heka message in JSON ([]byte) Replace it by client.Encoder ?.

Public interface exposed by the Heka message router.

Heka Output plugin type.

Heka PluginRunner for Output plugins.

Interface for Heka plugins that can be wired up to the config system.

API made available to all plugins providing Heka-wide utility functions.

Base interface for the Heka plugin runners.

Interface for Heka plugins that will provide reporting data.

Indicates a plug-in can handle being restart should it exit before heka is shut-down.

Specialized Input that listens on a provided channel for Stat objects, from which it accumulates and stores statsd-style metrics data, periodically generating and injecting messages with accumulated stats date embedded in either the payload, the message fields, or both.

StreamParser interface to read a spilt a stream into records.

Any decoder that needs access to its DecoderRunner can implement this interface and it will be provided at DecoderRunner start time.

Any decoder that needs to know when the DecoderRunner is exiting can implement this interface and it will called on DecoderRunner exit.

Indicates a plug-in needs its name before it has access to the runner interface.

WhisperRunners listen for *whisper.Point data values to come in on an input channel and write the values out to a single whisper db file as they do.

Common type used to specify a set of values with which to populate a message object.

Generic plugin configuration type that will be used for plugins that don't provide the `HasConfigStruct` interface.