azure_eventhub

Documentation

Index

• func Dynamic(opts *cli.Options) error
• func NewClient(opts *cli.Options) (*eventhub.Hub, error)
• func Read(opts *cli.Options, md *desc.MessageDescriptor) error
• func Write(opts *cli.Options, md *desc.MessageDescriptor) error
• type AzureEventHub
  • func (a *AzureEventHub) Read() error
  • func (a *AzureEventHub) Write(ctx context.Context, value []byte) 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) (*eventhub.Hub, error)

NewClient returns a properly configured service bus client

func Read

func Read(opts *cli.Options, md *desc.MessageDescriptor) 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 AzureEventHub

type AzureEventHub struct {
	Options *cli.Options
	MsgDesc *desc.MessageDescriptor
	Client  *eventhub.Hub
	// contains filtered or unexported fields
}

func (*AzureEventHub) Read

func (a *AzureEventHub) Read() error

func (*AzureEventHub) Write

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

Write writes a message to a random partition on