input

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 30, 2020 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Overview

Package in provides interfaces, concrete implementations, and utilities to ingest data into metrictank

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConfigSetup added in v0.13.0

func ConfigSetup()

Types

type DefaultHandler

type DefaultHandler struct {
	// contains filtered or unexported fields
}

Default is a base handler for a metrics packet, aimed to be embedded by concrete implementations

func NewDefaultHandler

func NewDefaultHandler(metrics mdata.Metrics, metricIndex idx.MetricIndex, input string) DefaultHandler

func (DefaultHandler) ProcessMetricData

func (in DefaultHandler) ProcessMetricData(md *schema.MetricData, partition int32)

ProcessMetricData assures the data is stored and the metadata is in the index concurrency-safe.

func (DefaultHandler) ProcessMetricPoint

func (in DefaultHandler) ProcessMetricPoint(point schema.MetricPoint, format msg.Format, partition int32)

ProcessMetricPoint updates the index if possible, and stores the data if we have an index entry concurrency-safe.

type Handler

type Handler interface {
	ProcessMetricData(md *schema.MetricData, partition int32)
	ProcessMetricPoint(point schema.MetricPoint, format msg.Format, partition int32)
}

type Plugin

type Plugin interface {
	Name() string
	// Start starts the plugin.
	// The plugin calls cancel should any non-recoverable error occur after Start has returned.
	// if Start returns an error, or cancel is called by the plugin,
	// the caller (e.g. main process) should shut down all its resources and exit.
	// Note that upon fatal close, metrictank will call Stop() on all plugins, also the one that triggered it.
	Start(handler Handler, cancel context.CancelFunc) error
	MaintainPriority()
	ExplainPriority() interface{}
	Stop() // Should block until shutdown is complete.
}

Directories

Path Synopsis
package carbon provides a traditional carbon input for metrictank note: it does not support the "carbon2.0" protocol that serializes metrics2.0 into a plaintext carbon-like protocol
package carbon provides a traditional carbon input for metrictank note: it does not support the "carbon2.0" protocol that serializes metrics2.0 into a plaintext carbon-like protocol

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL