backend

package
v5.1.0+incompatible Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewRepeaterBackend

func NewRepeaterBackend(addr string) (*repeaterBackend, error)

Types

type KafkaBackend

type KafkaBackend struct {
	Producer sarama.SyncProducer
	Topic    string
}

func NewKafkaBackend

func NewKafkaBackend(brokers []string, topic string) (*KafkaBackend, error)

func (*KafkaBackend) Write

func (backend *KafkaBackend) Write(data *types.TimeSeriesData) error

type OpentsdbBackend

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

func NewOpentsdbBackend

func NewOpentsdbBackend(addr string) (*OpentsdbBackend, error)

func (*OpentsdbBackend) Write

func (this *OpentsdbBackend) Write(data *types.TimeSeriesData) error

Jump to

Keyboard shortcuts

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