Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsoleReporter ¶
type ConsoleReporter struct {
// contains filtered or unexported fields
}
ConsoleReporter represents a console reporter.
func NewConsoleReporter ¶
func NewConsoleReporter(w io.Writer) *ConsoleReporter
NewConsoleReporter creates and returns a new ConsoleReporter.
func (ConsoleReporter) ReportBrokerMetadata ¶ added in v1.0.0
func (r ConsoleReporter) ReportBrokerMetadata(m *store.BrokerMetadata)
ReportBrokerMetadata reports a snapshot of the broker metadata.
func (ConsoleReporter) ReportBrokerOffsets ¶
func (r ConsoleReporter) ReportBrokerOffsets(o *store.BrokerOffsets)
ReportBrokerOffsets reports a snapshot of the broker offsets.
func (ConsoleReporter) ReportConsumerOffsets ¶
func (r ConsoleReporter) ReportConsumerOffsets(o *store.ConsumerOffsets)
ReportConsumerOffsets reports a snapshot of the consumer group offsets.
type InfluxReporter ¶
type InfluxReporter struct {
// contains filtered or unexported fields
}
InfluxReporter represents an InfluxDB reporter.
func NewInfluxReporter ¶
func NewInfluxReporter(client client.Client, opts ...InfluxReporterFunc) *InfluxReporter
NewInfluxReporter creates and returns a new NewInfluxReporter.
func (InfluxReporter) ReportBrokerMetadata ¶ added in v1.0.0
func (r InfluxReporter) ReportBrokerMetadata(m *store.BrokerMetadata)
ReportBrokerMetadata reports a snapshot of the broker metadata.
func (InfluxReporter) ReportBrokerOffsets ¶
func (r InfluxReporter) ReportBrokerOffsets(o *store.BrokerOffsets)
ReportBrokerOffsets reports a snapshot of the broker offsets.
func (InfluxReporter) ReportConsumerOffsets ¶
func (r InfluxReporter) ReportConsumerOffsets(o *store.ConsumerOffsets)
ReportConsumerOffsets reports a snapshot of the consumer group offsets.
type InfluxReporterFunc ¶
type InfluxReporterFunc func(c *InfluxReporter)
InfluxReporterFunc represents a configuration function for InfluxReporter.
func Database ¶
func Database(db string) InfluxReporterFunc
Database configures the database on an InfluxReporter.
func Log ¶
func Log(log log15.Logger) InfluxReporterFunc
Log configures the logger on an InfluxReporter.
func Metric ¶
func Metric(metric string) InfluxReporterFunc
Metric configures the metric name on an InfluxReporter.
func Policy ¶ added in v0.2.0
func Policy(policy string) InfluxReporterFunc
Policy configures the retention policy name on an InfluxReporter.
func Tags ¶
func Tags(tags map[string]string) InfluxReporterFunc
Tags configures the additional tags on an InfluxReporter.
Source Files