kafka

Documentation

Index

• type Kafka
  • func NewKafka(logger logger.Logger) *Kafka
  • func (k *Kafka) Close() error
  • func (k *Kafka) Init(metadata bindings.Metadata) error
  • func (k *Kafka) Invoke(req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)
  • func (k *Kafka) Operations() []bindings.OperationKind
  • func (k *Kafka) Read(handler func(*bindings.ReadResponse) ([]byte, error)) error

Types

type Kafka

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

Kafka allows reading/writing to a Kafka consumer group

func NewKafka

func NewKafka(logger logger.Logger) *Kafka

NewKafka returns a new kafka binding instance

func (*Kafka) Close

func (k *Kafka) Close() error

func (*Kafka) Init

func (k *Kafka) Init(metadata bindings.Metadata) error

Init does metadata parsing and connection establishment

func (*Kafka) Invoke

func (k *Kafka) Invoke(req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

func (*Kafka) Operations

func (k *Kafka) Operations() []bindings.OperationKind

func (*Kafka) Read

func (k *Kafka) Read(handler func(*bindings.ReadResponse) ([]byte, error)) error