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) BulkSubscribe(ctx context.Context, req pubsub.SubscribeRequest, handler pubsub.BulkHandler) error
  • func (aeh *AzureEventHubs) Close() (err error)
  • func (aeh *AzureEventHubs) Features() []pubsub.Feature
  • func (aeh *AzureEventHubs) GetComponentMetadata() (metadataInfo metadata.MetadataMap)
  • func (aeh *AzureEventHubs) Init(_ context.Context, 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) BulkSubscribe

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

BulkSubscribe receives bulk messages from Azure Event Hubs.

func (*AzureEventHubs) Close

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

func (*AzureEventHubs) Features

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

func (*AzureEventHubs) GetComponentMetadata

func (aeh *AzureEventHubs) GetComponentMetadata() (metadataInfo metadata.MetadataMap)

GetComponentMetadata returns the metadata of the component.

func (*AzureEventHubs) Init

func (aeh *AzureEventHubs) Init(_ context.Context, 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 messages from Azure Event Hubs.