azure

Documentation

Index

• func NewClient(opts *cli.Options) (*servicebus.Namespace, error)
• func Read(opts *cli.Options) error
• func Relay(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
• type Relayer
  • func (r *Relayer) Relay() 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 Relay

func Relay(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

type Relayer

type Relayer struct {
	Options *cli.Options
	MsgDesc *desc.MessageDescriptor
	RelayCh chan interface{}

	Queue          *servicebus.Queue
	Topic          *servicebus.Topic
	DefaultContext context.Context
	// contains filtered or unexported fields
}

func (*Relayer) Relay

func (r *Relayer) Relay() error