backend

Documentation

Index

• func NewRepeaterBackend(addr string) (*repeaterBackend, error)
• type KafkaBackend
  • func NewKafkaBackend(brokers []string, topic string) (*KafkaBackend, error)
  • func (backend *KafkaBackend) Write(data *types.TimeSeriesData) error
• type OpentsdbBackend
  • func NewOpentsdbBackend(addr string) (*OpentsdbBackend, error)
  • func (this *OpentsdbBackend) Write(data *types.TimeSeriesData) error

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