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() map[string]string
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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) GetComponentMetadata ¶
GetComponentMetadata returns the metadata of the component.
Click to show internal directories.
Click to hide internal directories.