sink

Documentation

Index

• type HttpSink
  • func NewHttp() (*HttpSink, error)
  • func (s *HttpSink) Put(data []byte) error
  • func (s *HttpSink) Start() error
  • func (s *HttpSink) Stop()
• 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 SQSSink
  • func NewSQS(groupId string) (*SQSSink, error)
  • func (s *SQSSink) Put(data []byte) error
  • func (s *SQSSink) Start() error
  • func (s *SQSSink) Stop()
• type Sink
  • func GetSink(resourceName string) (Sink, error)
• type StdoutSink
  • func NewStdout() (*StdoutSink, error)
  • func (s *StdoutSink) Put(data []byte) error
  • func (s *StdoutSink) Start() error
  • func (s *StdoutSink) Stop()
• type SyslogSink
  • func NewSyslog() (*SyslogSink, error)
  • func (s *SyslogSink) Put(data []byte) error
  • func (s *SyslogSink) Start() error
  • func (s *SyslogSink) Stop()

Types

type HttpSink

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

HttpSink ...

func NewHttp

func NewHttp() (*HttpSink, error)

NewHttp ...

func (*HttpSink) Put

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

Put ..

func (*HttpSink) Start

func (s *HttpSink) Start() error

Start ...

func (*HttpSink) Stop

func (s *HttpSink) Stop()

Stop ...

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 SQSSink

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

SQS ...

func NewSQS

func NewSQS(groupId string) (*SQSSink, error)

NNewSQS ...

func (*SQSSink) Put

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

Put ..

func (*SQSSink) Start

func (s *SQSSink) Start() error

Start ...

func (*SQSSink) Stop

func (s *SQSSink) Stop()

Stop ...

type Sink

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

Sink ...

func GetSink

func GetSink(resourceName string) (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 ...

type SyslogSink

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

func NewSyslog

func NewSyslog() (*SyslogSink, error)

NewSyslog ...

func (*SyslogSink) Put

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

Put ..

func (*SyslogSink) Start

func (s *SyslogSink) Start() error

Start ...

func (*SyslogSink) Stop

func (s *SyslogSink) Stop()

Stop ...