eventhubs

Documentation

Index

• type AzureEventHubs
  • func NewAzureEventHubs(logger logger.Logger) *AzureEventHubs
  • func (aeh *AzureEventHubs) Init(metadata pubsub.Metadata) error
  • func (aeh *AzureEventHubs) Publish(req *pubsub.PublishRequest) error
  • func (aeh *AzureEventHubs) Subscribe(req pubsub.SubscribeRequest, handler func(msg *pubsub.NewMessage) error) error

Types

type AzureEventHubs

type AzureEventHubs struct {
	// contains filtered or unexported fields
}

AzureEventHubs allows sending/receiving Azure Event Hubs events

func NewAzureEventHubs

func NewAzureEventHubs(logger logger.Logger) *AzureEventHubs

NewAzureEventHubs returns a new Azure Event hubs instance

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(req pubsub.SubscribeRequest, handler func(msg *pubsub.NewMessage) error) error

Subscribe receives data from Azure Event Hubs