eventhubs

Documentation

Index

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

Functions

func NewAzureEventHubs

func NewAzureEventHubs(logger logger.Logger) pubsub.PubSub

NewAzureEventHubs returns a new Azure Event hubs instance.

Types

type AzureEventHubs

type AzureEventHubs struct {
	*impl.AzureEventHubs
}

AzureEventHubs allows sending/receiving Azure Event Hubs events.

func (*AzureEventHubs) BulkPublish

func (aeh *AzureEventHubs) BulkPublish(ctx context.Context, req *pubsub.BulkPublishRequest) (pubsub.BulkPublishResponse, error)

BulkPublish sends data to Azure Event Hubs in bulk.

func (*AzureEventHubs) Close

func (aeh *AzureEventHubs) Close() (err error)

func (*AzureEventHubs) Features

func (aeh *AzureEventHubs) Features() []pubsub.Feature

func (*AzureEventHubs) Init

func (aeh *AzureEventHubs) Init(metadata pubsub.Metadata) error

Init the object.

func (*AzureEventHubs) Publish

func (aeh *AzureEventHubs) Publish(ctx context.Context, req *pubsub.PublishRequest) error

Publish sends a message to Azure Event Hubs.

func (*AzureEventHubs) Subscribe

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

Subscribe receives data from Azure Event Hubs.