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)
type KafkaWriter ¶
type KafkaWriter struct {
// contains filtered or unexported fields
}
func NewKafkaWriter ¶
func NewKafkaWriter(topic string, producerConfig *producer.ProducerConfig, connectorConfig *siesta.ConnectorConfig) (*KafkaWriter, error)
Click to show internal directories.
Click to hide internal directories.