azure

Documentation

Index

• func NewClient(opts *cli.Options) (*servicebus.Namespace, error)
• func Read(opts *cli.Options) error
• func Write(opts *cli.Options) error
• type AzureServiceBus
  • func (a *AzureServiceBus) Read() error
  • func (a *AzureServiceBus) Write(ctx context.Context, value []byte) error

Functions

func NewClient

func NewClient(opts *cli.Options) (*servicebus.Namespace, error)

NewClient returns a properly configured service bus client

func Read

func Read(opts *cli.Options) error

func Write

func Write(opts *cli.Options) error

Write performs necessary setup and calls AzureServiceBus.Write() to write the actual message

Types

type AzureServiceBus

type AzureServiceBus struct {
	Options *cli.Options
	MsgDesc *desc.MessageDescriptor
	Client  *servicebus.Namespace
	Queue   *servicebus.Queue
	Topic   *servicebus.Topic
	// contains filtered or unexported fields
}

func (*AzureServiceBus) Read

func (a *AzureServiceBus) Read() error

func (*AzureServiceBus) Write

func (a *AzureServiceBus) Write(ctx context.Context, value []byte) error

Write writes a message to an ASB topic or queue, depending on which is specified