kubemq_queue

Documentation

Index

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

Constants

const (
	DefaultReadTimeout = 10000 // Milliseconds
	BackendName        = "kubemq"
)

Types

type KubeMQ

type KubeMQ struct {
	// contains filtered or unexported fields
}

func New

func New(opts *opts.ConnectionOptions) (*KubeMQ, error)

func (*KubeMQ) Close

func (k *KubeMQ) Close(_ context.Context) error

func (*KubeMQ) DisplayError

func (k *KubeMQ) DisplayError(msg *records.ErrorRecord) error

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

func (*KubeMQ) DisplayMessage

func (k *KubeMQ) DisplayMessage(cliOpts *opts.CLIOptions, msg *records.ReadRecord) error

func (*KubeMQ) Dynamic

func (k *KubeMQ) Dynamic(ctx context.Context, dynamicOpts *opts.DynamicOptions, dynamicSvc dynamic.IDynamic) error

func (*KubeMQ) Name

func (k *KubeMQ) Name() string

func (*KubeMQ) Read

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

func (*KubeMQ) Relay

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

func (*KubeMQ) Test

func (k *KubeMQ) Test(_ context.Context) error

func (*KubeMQ) Write

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