qfilter_metrics

README

filter-metrics

Filter to transform certain messages to metrics.

Documentation

Index

• func AddEngineDims(dims map[string]string, eng *types.Info) map[string]string
• func AssembleJSONDefaultDimensions(cnt *types.ContainerJSON) map[string]string
• func AssembleJSONServiceSlot(cnt *types.ContainerJSON) string
• func AssembleJSONTaskSlot(cnt *types.ContainerJSON) string
• func RewriteDims(rw map[string]string, dims map[string]string) map[string]string
• type Plugin
  • func New(qChan qtypes_qchannel.QChan, cfg *config.Config, name string) (p Plugin, err error)
  • func (p *Plugin) Run()

Functions

func AddEngineDims

func AddEngineDims(dims map[string]string, eng *types.Info) map[string]string

func AssembleJSONDefaultDimensions

func AssembleJSONDefaultDimensions(cnt *types.ContainerJSON) map[string]string

AssembleDefaultDimensions derives a set of dimensions from the container information.

func AssembleJSONServiceSlot

func AssembleJSONServiceSlot(cnt *types.ContainerJSON) string

AssembleServiceSlot create {{.Service.Name}}.{{.Task.Slot}}

func AssembleJSONTaskSlot

func AssembleJSONTaskSlot(cnt *types.ContainerJSON) string

AssembleServiceSlot create {{.Service.Name}}.{{.Task.Slot}}

func RewriteDims

func RewriteDims(rw map[string]string, dims map[string]string) map[string]string

Types

type Plugin

type Plugin struct {
	*qtypes_plugin.Plugin
}

func New

func New(qChan qtypes_qchannel.QChan, cfg *config.Config, name string) (p Plugin, err error)

func (*Plugin) Run

func (p *Plugin) Run()

Run fetches everything from the Data channel and flushes it to stdout