azure

Documentation

Index

• func Dynamic(opts *cli.Options) error
• func NewClient(opts *cli.Options) (*servicebus.Namespace, error)
• func Read(opts *cli.Options, md *desc.MessageDescriptor) error
• func Relay(opts *cli.Options, relayCh chan interface{}, shutdownCtx context.Context) (relay.IRelayBackend, error)
• func Write(opts *cli.Options, md *desc.MessageDescriptor) 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 Dynamic

func Dynamic(opts *cli.Options) error

Dynamic starts up a new GRPC client connected to the dProxy service and receives a stream of outbound replay messages which are then written to the message bus.

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, md *desc.MessageDescriptor) error

func Relay

func Relay(opts *cli.Options, relayCh chan interface{}, shutdownCtx context.Context) (relay.IRelayBackend, error)

func Write

func Write(opts *cli.Options, md *desc.MessageDescriptor) 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
	RelayCh chan interface{}

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

func (*Relayer) Relay

func (r *Relayer) Relay() error