eventhubs

Documentation

Index

• func NewAzureEventHubs(logger logger.Logger) pubsub.PubSub
• type AzureEventHubs
  • func (aeh *AzureEventHubs) Close() (err error)
  • func (aeh *AzureEventHubs) Features() []pubsub.Feature
  • func (aeh *AzureEventHubs) Init(metadata pubsub.Metadata) error
  • func (aeh *AzureEventHubs) Publish(req *pubsub.PublishRequest) error
  • func (aeh *AzureEventHubs) Subscribe(subscribeCtx context.Context, req pubsub.SubscribeRequest, ...) 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 {
	// contains filtered or unexported fields
}

AzureEventHubs allows sending/receiving Azure Event Hubs events.

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 connects to Azure Event Hubs.

func (*AzureEventHubs) Publish

func (aeh *AzureEventHubs) Publish(req *pubsub.PublishRequest) error

Publish sends data to Azure Event Hubs.

func (*AzureEventHubs) Subscribe

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

Subscribe receives data from Azure Event Hubs.