kafkasrc

Documentation

Index

• type Kfk
  • func New(name string, v *viper.Viper) (k *Kfk, err error)
  • func (k *Kfk) Close() (err error)
  • func (k *Kfk) Flush() (err error)
  • func (k *Kfk) Name() string
  • func (k *Kfk) SetLogger(l *common.Logger)
  • func (k *Kfk) Start()
  • func (k *Kfk) Stats() string
  • func (k *Kfk) Status() error
  • func (k *Kfk) Subscribe(s sink.Sink)
  • func (k *Kfk) Type() string

Types

type Kfk

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

Kfk is a Kafka source

func New

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

New returns an instance of Kafka source based on the provided viper subtreee

func (*Kfk) Close

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

Close shuts down Kafka source

func (*Kfk) Flush

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

Flush forces queue flush

func (*Kfk) Name

func (k *Kfk) Name() string

Name returns Source's name

func (*Kfk) SetLogger

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

SetLogger sets a logger

func (*Kfk) Start

func (k *Kfk) Start()

Start starts the worker goroutines

func (*Kfk) Stats

func (k *Kfk) Stats() string

Stats returns statistics

func (*Kfk) Status

func (k *Kfk) Status() error

Status returns source's status

func (*Kfk) Subscribe

func (k *Kfk) Subscribe(s sink.Sink)

Subscribe a sink to events from this source

func (*Kfk) Type

func (k *Kfk) Type() string

Type returns Source's type