kafkasink

Documentation

Index

• type Kfk
  • func New(name string, v *viper.Viper) (s *Kfk, err error)
  • func (k *Kfk) Close() (err error)
  • func (k *Kfk) Name() string
  • func (k *Kfk) ProcessEventsBatch(events []event.Event) (err error)
  • func (k *Kfk) SetLogger(l *common.Logger)
  • func (k *Kfk) Stats() string
  • func (k *Kfk) Status() error
  • func (k *Kfk) Type() string

Types

type Kfk

type Kfk struct {
	*common.Logger
	// contains filtered or unexported fields
}

Kfk is a Kafka sink

func New

func New(name string, v *viper.Viper) (s *Kfk, err error)

New creates a new Kafka sink

func (*Kfk) Close

func (k *Kfk) Close() (err error)

Close shuts down sink

func (*Kfk) Name

func (k *Kfk) Name() string

Name returns Sink's name

func (*Kfk) ProcessEventsBatch

func (k *Kfk) ProcessEventsBatch(events []event.Event) (err error)

ProcessEventsBatch processess the events batch

func (*Kfk) SetLogger

func (k *Kfk) SetLogger(l *common.Logger)

SetLogger sets a logger

func (*Kfk) Stats

func (k *Kfk) Stats() string

Stats returns statistics

func (*Kfk) Status

func (k *Kfk) Status() error

Status returns the current healthcheck state Currently No-op

func (*Kfk) Type

func (k *Kfk) Type() string

Type returns Sink's type