eventhubs

package

v1.5.2 Latest Latest Go to latest Published: Mar 25, 2022 License: MIT Imports: 15 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

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

AzureEventHubs allows sending/receiving Azure Event Hubs events.

func NewAzureEventHubs(logger logger.Logger) *AzureEventHubs

NewAzureEventHubs returns a new Azure Event hubs instance.

func (a *AzureEventHubs) Close() error

func (a *AzureEventHubs) Init(metadata bindings.Metadata) error

Init performs metadata init.

func (a *AzureEventHubs) Invoke(req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

Write posts an event hubs message.

func (a *AzureEventHubs) Operations() []bindings.OperationKind

func (a *AzureEventHubs) Read(handler func(*bindings.ReadResponse) ([]byte, error)) error

Read gets messages from eventhubs in a non-blocking fashion.

func (a *AzureEventHubs) RegisterEventProcessor(handler func(*bindings.ReadResponse) ([]byte, error)) error

RegisterEventProcessor - receive eventhub messages by eventprocessor host by balancing partitions.

func (a *AzureEventHubs) RegisterPartitionedEventProcessor(handler func(*bindings.ReadResponse) ([]byte, error)) error

RegisterPartitionedEventProcessor - receive eventhub messages by partitionID.