kubemq_queue

Documentation

Index

• func Dynamic(opts *cli.Options) error
• func NewClient(opts *cli.Options) (*queues_stream.QueuesStreamClient, 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 KubeMQQueue
  • func (k *KubeMQQueue) Read() error
  • func (k *KubeMQQueue) Write(writeValues [][]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) (*queues_stream.QueuesStreamClient, error)

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

Types

type KubeMQQueue

type KubeMQQueue struct {
	Options *cli.Options
	Client  *queues_stream.QueuesStreamClient
	Context context.Context
	MsgDesc *desc.MessageDescriptor
	// contains filtered or unexported fields
}

func (*KubeMQQueue) Read

func (k *KubeMQQueue) Read() error

func (*KubeMQQueue) Write

func (k *KubeMQQueue) Write(writeValues [][]byte) error

type Relayer

type Relayer struct {
	Options *cli.Options
	RelayCh chan interface{}

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

func (*Relayer) Relay

func (r *Relayer) Relay() error