rabbitmq

Documentation

Index

• Constants
• Variables
• type RabbitMQ
  • func New(opts *opts.ConnectionOptions) (*RabbitMQ, error)
  • func (r *RabbitMQ) Close(_ context.Context) error
  • func (r *RabbitMQ) DisplayError(msg *records.ErrorRecord) error
  • func (r *RabbitMQ) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error
  • func (r *RabbitMQ) Dynamic(ctx context.Context, opts *opts.DynamicOptions, dynamicSvc dynamic.IDynamic) error
  • func (r *RabbitMQ) Name() string
  • func (r *RabbitMQ) Read(ctx context.Context, readOpts *opts.ReadOptions, ...) error
  • func (r *RabbitMQ) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, ...) error
  • func (r *RabbitMQ) Test(_ context.Context) error
  • func (r *RabbitMQ) Write(ctx context.Context, writeOpts *opts.WriteOptions, ...) error

Constants

const (
	BackendName = "rabbitmq"
)

Variables

var (
	ErrEmptyRoutingKey   = errors.New("routing key cannot be empty")
	ErrEmptyExchangeName = errors.New("exchange name cannot be empty")
	ErrEmptyQueueName    = errors.New("queue name cannot be empty")
	ErrEmptyBindingKey   = errors.New("binding key cannot be empty")
)

Types

type RabbitMQ

type RabbitMQ struct {
	// 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 *opts.ConnectionOptions) (*RabbitMQ, error)

func (*RabbitMQ) Close

func (r *RabbitMQ) Close(_ context.Context) error

func (*RabbitMQ) DisplayError

func (r *RabbitMQ) DisplayError(msg *records.ErrorRecord) error

DisplayError will parse an Error record and print (pretty) output to STDOUT

func (*RabbitMQ) DisplayMessage

func (r *RabbitMQ) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error

DisplayMessage will parse a Read record and print (pretty) output to STDOUT

func (*RabbitMQ) Dynamic

func (r *RabbitMQ) Dynamic(ctx context.Context, opts *opts.DynamicOptions, dynamicSvc dynamic.IDynamic) error

func (*RabbitMQ) Name

func (r *RabbitMQ) Name() string

func (*RabbitMQ) Read

func (r *RabbitMQ) Read(ctx context.Context, readOpts *opts.ReadOptions, resultsChan chan *records.ReadRecord, errorChan chan *records.ErrorRecord) error

func (*RabbitMQ) Relay

func (r *RabbitMQ) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh chan interface{}, errorCh chan *records.ErrorRecord) error

func (*RabbitMQ) Test

func (r *RabbitMQ) Test(_ context.Context) error

func (*RabbitMQ) Write

func (r *RabbitMQ) Write(ctx context.Context, writeOpts *opts.WriteOptions, errorCh chan *records.ErrorRecord, messages ...*records.WriteRecord) error