sink

Documentation

Index

• type KafkaSink
  • func NewKafka() (*KafkaSink, error)
  • func (s *KafkaSink) Put(data []byte) error
  • func (s *KafkaSink) Start() error
  • func (s *KafkaSink) Stop()
• type KinesisSink
  • func NewKinesis() (*KinesisSink, error)
  • func (s *KinesisSink) Put(data []byte) error
  • func (s *KinesisSink) Start() error
  • func (s *KinesisSink) Stop()
• type MongodbSink
  • func NewMongodb() (*MongodbSink, error)
  • func (s *MongodbSink) Put(data []byte) error
  • func (s *MongodbSink) Start() error
  • func (s *MongodbSink) Stop()
• type NSQSink
  • func NewNSQ() (*NSQSink, error)
  • func (s *NSQSink) Put(data []byte) error
  • func (s *NSQSink) Start() error
  • func (s *NSQSink) Stop()
• type RabbitmqSink
  • func NewRabbitmq() (*RabbitmqSink, error)
  • func (s *RabbitmqSink) Put(data []byte) error
  • func (s *RabbitmqSink) Start() error
  • func (s *RabbitmqSink) Stop()
• type RedisSink
  • func NewRedis() (*RedisSink, error)
  • func (s *RedisSink) Put(data []byte) error
  • func (s *RedisSink) Start() error
  • func (s *RedisSink) Stop()
• type Sink
  • func GetSink() (Sink, error)
• type StdoutSink
  • func NewStdout() (*StdoutSink, error)
  • func (s *StdoutSink) Put(data []byte) error
  • func (s *StdoutSink) Start() error
  • func (s *StdoutSink) Stop()

Types

type KafkaSink

type KafkaSink struct {
	// Kafka brokers to send metrics to
	Brokers []string
	// Kafka topic
	Topic string
	// contains filtered or unexported fields
}

KafkaSink ...

func NewKafka

func NewKafka() (*KafkaSink, error)

NewKafka ...

func (*KafkaSink) Put

func (s *KafkaSink) Put(data []byte) error

Put ..

func (*KafkaSink) Start

func (s *KafkaSink) Start() error

Start ...

func (*KafkaSink) Stop

func (s *KafkaSink) Stop()

Stop ...

type KinesisSink

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

KinesisSink ...

func NewKinesis

func NewKinesis() (*KinesisSink, error)

NewKinesis ...

func (*KinesisSink) Put

func (s *KinesisSink) Put(data []byte) error

Put ..

func (*KinesisSink) Start

func (s *KinesisSink) Start() error

Start ...

func (*KinesisSink) Stop

func (s *KinesisSink) Stop()

Stop ...

type MongodbSink

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

MongodbSink ...

func NewMongodb

func NewMongodb() (*MongodbSink, error)

NewMongodb ...

func (*MongodbSink) Put

func (s *MongodbSink) Put(data []byte) error

Put ..

func (*MongodbSink) Start

func (s *MongodbSink) Start() error

Start ...

func (*MongodbSink) Stop

func (s *MongodbSink) Stop()

Stop ...

type NSQSink

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

func NewNSQ

func NewNSQ() (*NSQSink, error)

func (*NSQSink) Put

func (s *NSQSink) Put(data []byte) error

func (*NSQSink) Start

func (s *NSQSink) Start() error

func (*NSQSink) Stop

func (s *NSQSink) Stop()

type RabbitmqSink

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

RabbitmqSink ...

func NewRabbitmq

func NewRabbitmq() (*RabbitmqSink, error)

NewRabbitmq ...

func (*RabbitmqSink) Put

func (s *RabbitmqSink) Put(data []byte) error

Put ..

func (*RabbitmqSink) Start

func (s *RabbitmqSink) Start() error

Start ...

func (*RabbitmqSink) Stop

func (s *RabbitmqSink) Stop()

Stop ...

type RedisSink

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

RedisSink ...

func NewRedis

func NewRedis() (*RedisSink, error)

NewStdout ...

func (*RedisSink) Put

func (s *RedisSink) Put(data []byte) error

Put ..

func (*RedisSink) Start

func (s *RedisSink) Start() error

Start ...

func (*RedisSink) Stop

func (s *RedisSink) Stop()

Stop ...

type Sink

type Sink interface {
	Start() error
	Stop()
	Put(data []byte) error
}

Sink ...

func GetSink

func GetSink() (Sink, error)

GetSink ...

type StdoutSink

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

StdoutSink ...

func NewStdout

func NewStdout() (*StdoutSink, error)

NewStdout ...

func (*StdoutSink) Put

func (s *StdoutSink) Put(data []byte) error

Put ..

func (*StdoutSink) Start

func (s *StdoutSink) Start() error

Start ...

func (*StdoutSink) Stop

func (s *StdoutSink) Stop()

Stop ...