rabbitmq

Documentation

Index

• func Dynamic(opts *cli.Options) error
• func Read(opts *cli.Options) error
• func Relay(opts *cli.Options) error
• func Write(opts *cli.Options) error
• type RabbitMQ
  • func New(opts *cli.Options, md *desc.MessageDescriptor) (*RabbitMQ, error)
  • func (r *RabbitMQ) Read() error
  • func (r *RabbitMQ) 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 Read

func Read(opts *cli.Options) error

Read is the entry point function for performing read operations in RabbitMQ.

This is where we verify that the provided arguments and flag combination makes sense/are valid; this is also where we will perform our initial conn.

func Relay

func Relay(opts *cli.Options) error

func Write

func Write(opts *cli.Options) error

Write is the entry point function for performing write operations in RabbitMQ.

This is where we verify that the passed args and flags combo makes sense, attempt to establish a connection, parse protobuf before finally attempting to perform the write.

Types

type RabbitMQ

type RabbitMQ struct {
	Options  *cli.Options
	Consumer *rabbit.Rabbit
	MsgDesc  *desc.MessageDescriptor
	// contains filtered or unexported fields
}

RabbitMQ holds all attributes required for performing a read/write operations in RabbitMQ. This struct should be instantiated via the rabbitmq.Read(..) or rabbitmq.Write(..) functions.

func New

func New(opts *cli.Options, md *desc.MessageDescriptor) (*RabbitMQ, error)

func (*RabbitMQ) Read

func (r *RabbitMQ) Read() error

Read will attempt to consume one or more messages from the established rabbit channel.

func (*RabbitMQ) Write

func (r *RabbitMQ) Write(ctx context.Context, value []byte) error

Write is a wrapper for amqp Publish method. We wrap it so that we can mock it in tests, add logging etc.

type Relayer

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

	Looper         *director.FreeLooper
	DefaultContext context.Context
	// contains filtered or unexported fields
}

func (*Relayer) Relay

func (r *Relayer) Relay() error