sink

Sep 4, 2018

Changes in this version

+ type MongodbSink struct

+ func NewMongodb() (*MongodbSink, error)

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

+ func (s *MongodbSink) Start() error

+ func (s *MongodbSink) Stop()

Mar 7, 2018

Changes in this version

+ type RedisSink struct

+ func NewRedis() (*RedisSink, error)

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

+ func (s *RedisSink) Start() error

+ func (s *RedisSink) Stop()

Nov 1, 2017

Changes in this version

+ type KafkaSink struct

+ Brokers []string

+ Topic string

+ func NewKafka() (*KafkaSink, error)

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

+ func (s *KafkaSink) Start() error

+ func (s *KafkaSink) Stop()

+ type NSQSink struct

+ func NewNSQ() (*NSQSink, error)

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

+ func (s *NSQSink) Start() error

+ func (s *NSQSink) Stop()

Jul 13, 2017

Changes in this version

+ type Sink interface

+ Put func(data []byte) error

+ Start func() error

+ Stop func()

+ func GetSink() (Sink, error)

Jul 12, 2017

Changes in this version

+ type KinesisSink struct

+ func NewKinesis() (*KinesisSink, error)

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

+ func (s *KinesisSink) Start() error

+ func (s *KinesisSink) Stop()

+ type RabbitmqSink struct

+ func NewRabbitmq() (*RabbitmqSink, error)

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

+ func (s *RabbitmqSink) Start() error

+ func (s *RabbitmqSink) Stop()

+ type StdoutSink struct

+ func NewStdout() (*StdoutSink, error)

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

+ func (s *StdoutSink) Start() error

+ func (s *StdoutSink) Stop()