Documentation ¶
Index ¶
Constants ¶
View Source
const ( PluginName = "kafka" PluginVersion = 9 PluginType = plugin.PublisherPluginType )
Variables ¶
This section is empty.
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"` }
Click to show internal directories.
Click to hide internal directories.