rafrombrc

[LogstreamerInput]
log_directory = "/var/log"
file_match = 'auth\.log'

[PayloadEncoder]
append_newlines = false

[LogOutput]
message_matcher = "TRUE"
encoder = "PayloadEncoder"

rafrombrc

value = "overwrite"

rafrombrc

package main

import (
	"log"
	"net"
	"time"
)

func accept(l net.Listener, sigBack chan struct{}) {
	conn, err := l.Accept()

rafrombrc

require "cjson"

local fields = {
    values = {},
    interval = 0,
    plugin = "",
    plugin_instance = "",
    ["type"] = "",
    type_instance = ""
}

rafrombrc

var tmp map[string]interface{}
tmp, ok = v.(map[string]interface{})
if !ok {
    return result, errors.New("invalid path")
}
v, ok = tmp[ss[1]]
if !ok {
    return result, errors.New("invalid path")
}

rafrombrc

[TcpInput]
address = ":8325"

[StatsToFieldsDecoder]

[scribble_statmetric]
type = "ScribbleDecoder"
    [scribble_statmetric.message_fields]
    Type = "heka.statmetric"

rafrombrc

[TcpInput]
address = ":8325"
decoder = "StatsToFieldsDecoder"
parser_type = "regexp"
delimiter = 'pdxnplogmq01\.ping\.ping_droprate\.127_0_0_1'
delimiter_location = "start"

[StatsToFieldsDecoder]

[stat_graph]

rafrombrc

[hekad]
maxprocs = 2

[TcpInput]
address = "127.0.0.1:5565"
parser_type = "message.proto"
decoder = "ProtobufDecoder"

[StatAccumInput]

rafrombrc

#!/bin/sh
#
# hekad <summary>
#
# chkconfig:   2345 80 20
# description: Starts and stops a single heka instance on this system 
#

### BEGIN INIT INFO
# Provides: Heka

rafrombrc

require "string"
require "math"
require "table"
require "cjson"

local status_codes = {}
local request_times = {}

local ticker_interval = read_config("ticker_interval") or error("must provide ticker_interval")
local percent_thresh = read_config("percent_threshold") or 90