kafka

Documentation

Index

• func NewKafka(logger logger.Logger) pubsub.PubSub
• type PubSub
  • func (p *PubSub) Close() (err error)
  • func (p *PubSub) Features() []pubsub.Feature
  • func (p *PubSub) Init(metadata pubsub.Metadata) error
  • func (p *PubSub) Publish(req *pubsub.PublishRequest) error
  • func (p *PubSub) Subscribe(ctx context.Context, req pubsub.SubscribeRequest, handler pubsub.Handler) error

Functions

func NewKafka

func NewKafka(logger logger.Logger) pubsub.PubSub

NewKafka returns a new kafka pubsub instance.

Types

type PubSub

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

func (*PubSub) Close

func (p *PubSub) Close() (err error)

func (*PubSub) Features

func (p *PubSub) Features() []pubsub.Feature

func (*PubSub) Init

func (p *PubSub) Init(metadata pubsub.Metadata) error

func (*PubSub) Publish

func (p *PubSub) Publish(req *pubsub.PublishRequest) error

Publish message to Kafka cluster.

func (*PubSub) Subscribe

func (p *PubSub) Subscribe(ctx context.Context, req pubsub.SubscribeRequest, handler pubsub.Handler) error