Skip to content

Instantly share code, notes, and snippets.

@rafrombrc

rafrombrc/message_types.md

Last active October 26, 2016 20:14
Show Gist options
  • Star 4 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save rafrombrc/55752c9bba6fc80c502f to your computer and use it in GitHub Desktop.
Save rafrombrc/55752c9bba6fc80c502f to your computer and use it in GitHub Desktop.
Download ZIP
Heka internal message types
Raw
message_types.md

  • heka.counter-output: Generated by CounterFilter. Usually picked up by a LogOutput for writing to stdout.

  • heka.plugin-report: Used inside the reporting infrastructure for plugins to provide report data to the dashboard, typically not injected into the router at all.

  • heka.input-report: Used inside the reporting infrastructure for the input recycle chan to provide report data to the dashboard, typically not injected into the router at all.

  • heka.inject-report: Used inside the reporting infrastructure for the inject recycle chan to provide report data to the dashboard, typically not injected into the router at all.

  • heka.router-report: Used inside the reporting infrastructure for the router to provide report data to the dashboard, typically not injected into the router at all.

  • heka.memstat: Generated by the reporting infrastructure, contains info on Heka's current memory usage. Usually picked up by a Heka Memory Statistics filter which will generate cbuf graph data for a DashboardOutput.

  • heka.all-report: Generated by the reporting infrastructure. Used by the DashboardOutput to generate the Heka health status.

  • heka.statmetric: Generated by StatAccumInput, contains aggregated stats data in the payload and/or message fields. Often picked up by a CarbonOutput for delivery to Graphite, an HttpOutput for delivery to InfluxDB, or a Stats Graph filter which will send cbuf graph data to a DashboardOutput.

  • heka.sandbox-output: Standard type given to messages that are generated by sandbox filters. Automatically picked up by DashboardOutput and used to generate graphs and other sandbox output, depending on the contents of the generated message.

  • heka.sandbox-terminated: Generated by Heka when a sandbox filter terminates. Picked up by DashboardOutput for display on the termination report.

  • heka.file.polling: Standard type for messages generated by the FilePollingInput. Can be overwritten by a decoder.

  • heka.httpinput.data: Standard type for messages generated by successful requests made by HttpInput. Can be overwritten by a decoder.

  • heka.httpinput.error: Standard type for messages generated by failed requests made by HttpInput. Can be overwritten by a decoder.

  • heka.httpdata.request: Standard type for messages generated by HttpListenInput. Can be overwritten by a decoder.

  • heka.control.sandbox: Generated by heka-sbmgr command line utility for delivery to a TcpInput listening on a running Heka instance. Usually signed, and picked up by a SandboxManagerFilter. Messages contain commands for loading and unloading dynamically managed SandboxFilters.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment