kafka

package
v0.0.0-...-a5a367c Latest Latest
Warning

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

 Go to latest Published: Dec 4, 2018 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client struct {
	DataCollector     sarama.SyncProducer
	AccessLogProducer sarama.AsyncProducer
}

func NewClient 

func NewClient(brokers string, verbose bool, certFile string, keyFile string, caFile string, verifySsl bool) *Client

NewClient Mestre Bimba Blablabla

func (*Client) Close 

func (c *Client) Close() error

func (Client) Name 

func (c Client) Name() string

Name identifies the client as an kafka client.

func (*Client) Write 

func (c *Client) Write(samples model.Samples) error

type Metric 

type Metric struct {
	Value     float64                `json:"value"`
	Timestamp time.Time              `json:"@timestamp"`
	Labels    map[string]interface{} `json:"labels"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.