Versions in this module Expand all Collapse all v0 v0.19.1 Dec 15, 2015 v0.19.0 Dec 10, 2015 Changes in this version + func NewKafkaSink(uri *url.URL, _ extpoints.HeapsterConf) ([]sink_api.ExternalSink, error) + type KafkaSinkEvent struct + EventCount int + EventInvolvedObject interface{} + EventMessage string + EventReason string + EventSource interface{} + EventTimestamp time.Time + type KafkaSinkPoint struct + MetricsName string + MetricsTags map[string]string + MetricsTimestamp time.Time + MetricsValue interface{}
Go to main page