kafka

Documentation

Index

• Constants
• func Meta() *plugin.PluginMeta
• func NewKafkaPublisher() *kafkaPublisher
• type MetricToPublish

Constants

const (
	PluginName    = "kafka"
	PluginVersion = 9
	PluginType    = plugin.PublisherPluginType
)

Functions

func Meta

func Meta() *plugin.PluginMeta

func NewKafkaPublisher

func NewKafkaPublisher() *kafkaPublisher

Types

type MetricToPublish

type MetricToPublish struct {
	// The timestamp from when the metric was created.
	Timestamp time.Time         `json:"timestamp"`
	Namespace string            `json:"namespace"`
	Data      interface{}       `json:"data"`
	Unit      string            `json:"unit"`
	Tags      map[string]string `json:"tags"`
	Version_  int               `json:"version"`
	// Last advertised time is the last time the snap agent was told about a metric.
	LastAdvertisedTime time.Time `json:"last_advertised_time"`
}