kafka

Documentation

Index

• func NewKafka(logger logger.Logger) pubsub.PubSub
• type PubSub
  • func (p *PubSub) BulkPublish(ctx context.Context, req *pubsub.BulkPublishRequest) (pubsub.BulkPublishResponse, error)
  • func (p *PubSub) BulkSubscribe(ctx context.Context, req pubsub.SubscribeRequest, handler pubsub.BulkHandler) error
  • func (p *PubSub) Close() (err error)
  • func (p *PubSub) Features() []pubsub.Feature
  • func (p *PubSub) GetComponentMetadata() (metadataInfo metadata.MetadataMap)
  • func (p *PubSub) Init(ctx context.Context, metadata pubsub.Metadata) error
  • func (p *PubSub) Publish(ctx context.Context, 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) BulkPublish

func (p *PubSub) BulkPublish(ctx context.Context, req *pubsub.BulkPublishRequest) (pubsub.BulkPublishResponse, error)

BatchPublish messages to Kafka cluster.

func (*PubSub) BulkSubscribe

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

func (*PubSub) Close

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

func (*PubSub) Features

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

func (*PubSub) GetComponentMetadata

func (p *PubSub) GetComponentMetadata() (metadataInfo metadata.MetadataMap)

GetComponentMetadata returns the metadata of the component.

func (*PubSub) Init

func (p *PubSub) Init(ctx context.Context, metadata pubsub.Metadata) error

func (*PubSub) Publish

func (p *PubSub) Publish(ctx context.Context, 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