metrics

package
v0.0.0-...-99dc620 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 5, 2016 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const MetricsLogTypeId int64 = 7

Logtypeid field value for LogLine indicating Metrics data

Variables

This section is empty.

Functions

This section is empty.

Types

type CodahaleKafkaReporter

type CodahaleKafkaReporter struct {
	// contains filtered or unexported fields
}

func NewCodahaleKafkaReporter

func NewCodahaleKafkaReporter(topic string, schemaRegistryUrl string, producerConfig *producer.ProducerConfig, connectorConfig *siesta.ConnectorConfig) (*CodahaleKafkaReporter, error)

func (*CodahaleKafkaReporter) Write

func (c *CodahaleKafkaReporter) Write(bytes []byte) (n int, err error)

type KafkaWriter

type KafkaWriter struct {
	// contains filtered or unexported fields
}

func NewKafkaWriter

func NewKafkaWriter(topic string, producerConfig *producer.ProducerConfig, connectorConfig *siesta.ConnectorConfig) (*KafkaWriter, error)

func (*KafkaWriter) Write

func (k *KafkaWriter) Write(bytes []byte) (n int, err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL