kafka

Documentation

Index

• Variables
• type Kafka
  • func New(source *datastore.Source, handler datastore.PubSubHandler, log log.StdLogger) *Kafka
  • func (k *Kafka) Consume()
  • func (k *Kafka) Start()
  • func (k *Kafka) Stop()
  • func (k *Kafka) Verify() error

Variables

var ErrInvalidCredentials = errors.New("your kafka credentials are invalid. please verify you're providing the correct credentials")

Types

type Kafka

type Kafka struct {
	Cfg *datastore.KafkaPubSubConfig
	// contains filtered or unexported fields
}

func New

func New(source *datastore.Source, handler datastore.PubSubHandler, log log.StdLogger) *Kafka

func (*Kafka) Consume

func (k *Kafka) Consume()

func (*Kafka) Start

func (k *Kafka) Start()

func (*Kafka) Stop

func (k *Kafka) Stop()

func (*Kafka) Verify

func (k *Kafka) Verify() error