sinks

Documentation

Index

• Constants
• type Kafka
  • func (k *Kafka) GetInputChan() chan *events.LookatchEvent
  • func (k *Kafka) Start(_ ...interface{}) error
• type Sink
• type SinkI
  • func New(name string, sinkType string, conf *viper.Viper, stop chan error, ...) (SinkI, error)
• type Stdout
  • func (s *Stdout) GetInputChan() chan *events.LookatchEvent
  • func (s *Stdout) Start(i ...interface{}) (err error)

Constants

const KafkaType = "kafka"

KafkaType type of sink

const MaxRetry = 20

MaxRetry retry max

const OvhKafkaType = "ovhkafka"

OvhKafkaType type of sink

const StdoutType = "stdout"

StdoutType type of sink

Types

type Kafka

type Kafka struct {
	*Sink
	// contains filtered or unexported fields
}

Kafka representation of kafka sink

func (*Kafka) GetInputChan

func (k *Kafka) GetInputChan() chan *events.LookatchEvent

GetInputChan return input channel attach to sink

func (*Kafka) Start

func (k *Kafka) Start(_ ...interface{}) error

Start kafka sink

type Sink

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

Sink representation of sink

type SinkI

type SinkI interface {
	Start(...interface{}) error
	GetInputChan() chan *events.LookatchEvent
}

SinkI sink interface

func New

func New(name string, sinkType string, conf *viper.Viper, stop chan error, eventChan chan *events.LookatchEvent) (SinkI, error)

New create new sink

type Stdout

type Stdout struct {
	*Sink
}

Stdout representation of sink

func (*Stdout) GetInputChan

func (s *Stdout) GetInputChan() chan *events.LookatchEvent

GetInputChan return input channel attach to sink

func (*Stdout) Start

func (s *Stdout) Start(i ...interface{}) (err error)

Start stdout sink