servicebusqueues

Documentation

Index

• type AzureServiceBusQueues
  • func NewAzureServiceBusQueues() *AzureServiceBusQueues
  • func (a *AzureServiceBusQueues) Init(metadata bindings.Metadata) error
  • func (a *AzureServiceBusQueues) Read(handler func(*bindings.ReadResponse) error) error
  • func (a *AzureServiceBusQueues) Write(req *bindings.WriteRequest) error

Types

type AzureServiceBusQueues

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

AzureServiceBusQueues is an input/output binding reading from and sending events to Azure Service Bus queues

func NewAzureServiceBusQueues

func NewAzureServiceBusQueues() *AzureServiceBusQueues

NewAzureServiceBusQueues returns a new AzureServiceBusQueues instance

func (*AzureServiceBusQueues) Init

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

Init parses connection properties and creates a new Service Bus Queue client

func (*AzureServiceBusQueues) Read

func (a *AzureServiceBusQueues) Read(handler func(*bindings.ReadResponse) error) error

func (*AzureServiceBusQueues) Write

func (a *AzureServiceBusQueues) Write(req *bindings.WriteRequest) error