Skip to content

Instantly share code, notes, and snippets.

@rafrombrc
Created July 7, 2015 18:19
Show Gist options
  • Save rafrombrc/2f64e7738f7bee09eb35 to your computer and use it in GitHub Desktop.
Save rafrombrc/2f64e7738f7bee09eb35 to your computer and use it in GitHub Desktop.

Revisions

  1. rafrombrc created this gist Jul 7, 2015.
    17 changes: 17 additions & 0 deletions hekad.toml
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,17 @@
    [hekad]
    share_dir = "/home/rob/go/heka/build/heka/share/heka"

    [StatsdInput]

    [StatAccumInput]
    emit_in_fields = true
    ticker_interval = 1

    [PayloadEncoder]

    [CarbonTcpOutput]
    encoder = "PayloadEncoder"
    address = "localhost:2003"
    type = "TcpOutput"
    message_matcher = "Type == 'heka.statmetric'"
    keep_alive = true
    49 changes: 49 additions & 0 deletions output.txt
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,49 @@
    thor [heka] git:dev ~/go/heka/build $ hekad -config=../etc/carbon.toml
    2015/07/07 11:16:11 Pre-loading: [CarbonTcpOutput]
    2015/07/07 11:16:11 Pre-loading: [StatsdInput]
    2015/07/07 11:16:11 Pre-loading: [StatAccumInput]
    2015/07/07 11:16:11 Pre-loading: [PayloadEncoder]
    2015/07/07 11:16:11 Pre-loading: [ProtobufDecoder]
    2015/07/07 11:16:11 Loading: [ProtobufDecoder]
    2015/07/07 11:16:11 Pre-loading: [ProtobufEncoder]
    2015/07/07 11:16:11 Loading: [ProtobufEncoder]
    2015/07/07 11:16:11 Pre-loading: [TokenSplitter]
    2015/07/07 11:16:11 Loading: [TokenSplitter]
    2015/07/07 11:16:11 Pre-loading: [HekaFramingSplitter]
    2015/07/07 11:16:11 Loading: [HekaFramingSplitter]
    2015/07/07 11:16:11 Pre-loading: [NullSplitter]
    2015/07/07 11:16:11 Loading: [NullSplitter]
    2015/07/07 11:16:11 Loading: [PayloadEncoder]
    2015/07/07 11:16:11 Loading: [StatsdInput]
    2015/07/07 11:16:11 Loading: [StatAccumInput]
    2015/07/07 11:16:11 Loading: [CarbonTcpOutput]
    2015/07/07 11:16:11 Starting hekad...
    2015/07/07 11:16:11 Output started: CarbonTcpOutput
    2015/07/07 11:16:11 MessageRouter started.
    2015/07/07 11:16:11 Input started: StatsdInput
    2015/07/07 11:16:11 Input started: StatAccumInput
    2015/07/07 11:16:24 Plugin 'CarbonTcpOutput' error: writing to localhost:2003: write tcp 127.0.0.1:2003: broken pipe
    2015/07/07 11:16:25 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
    2015/07/07 11:16:26 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
    2015/07/07 11:16:27 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
    2015/07/07 11:16:29 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused






    2015/07/07 11:16:46 Plugin 'CarbonTcpOutput' error: writing to localhost:2003: write tcp 127.0.0.1:2003: broken pipe
    2015/07/07 11:16:47 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
    2015/07/07 11:16:48 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
    2015/07/07 11:16:49 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
    2015/07/07 11:16:51 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
    2015/07/07 11:16:53 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused





    ^C2015/07/07 11:16:59 Shutdown initiated.
    2015/07/07 11:16:59 Stop message sent to input 'StatsdInput'
    2015/07/07 11:16:59 Stop message sent to input 'StatAccumInput'