heapster – k8s.io/heapster/metrics/sinks/kafka Index | Files

package kafka

import "k8s.io/heapster/metrics/sinks/kafka"

Index

Functions

func NewKafkaSink 

func NewKafkaSink(uri *url.URL) (core.DataSink, error)

Types

type KafkaSinkPoint 

type KafkaSinkPoint struct {
	MetricsName      string
	MetricsValue     interface{}
	MetricsTimestamp time.Time
	MetricsTags      map[string]string
}

Source Files

driver.go

Version
v1.5.4 (latest)
Published
Jul 26, 2018
Platform
linux/amd64
Imports
6 packages
Last checked
1 week ago –

Tools for package owners.