mqueue_rpc_server

package

v0.51.5 Latest Latest Go to latest Published: May 10, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

MqueueStore implements the server with a MqueueStore.

func NewMqueueStore(store mqueue_store.Store) *MqueueStore

NewMqueueStore constructs a new MqueueStore.

func (s *MqueueStore) GetMqueueMux(ctx context.Context, mqueueID string, _ func()) (srpc.Invoker, func(), error)

GetMqueueMux returns the srpc.Mux for a message queue.

func (s *MqueueStore) ListMqueues(ctx context.Context, req *mqueue_rpc.ListMqueuesRequest) (*mqueue_rpc.ListMqueuesResponse, error)

ListMqueues lists the message queues in the store.

func (s *MqueueStore) MqueueRpc(
	strm mqueue_rpc.SRPCMqueueStore_MqueueRpcStream,
) error

MqueueRpc opens a RpcStream for a Queue.

func (s *MqueueStore) RmMqueue(ctx context.Context, req *mqueue_rpc.RmMqueueRequest) (*mqueue_rpc.RmMqueueResponse, error)

RmMqueue attempts to remove a message queue.

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

Queue implements the message queue.

func NewQueue(queue mqueue.Queue) *Queue

NewQueue constructs a new KvtxQueue service.

func (q *Queue) Ack(ctx context.Context, req *mqueue_rpc.AckRequest) (*mqueue_rpc.AckResponse, error)

Ack acknowledges a message by ID if the ID is the current message at the front of the queue.

func (q *Queue) DeleteQueue(ctx context.Context, req *mqueue_rpc.DeleteQueueRequest) (*mqueue_rpc.DeleteQueueResponse, error)

DeleteQueue deletes a queue and its contents.

func (q *Queue) Peek(ctx context.Context, req *mqueue_rpc.PeekRequest) (*mqueue_rpc.PeekResponse, error)

Peek peeks the next value in the queue without removing it.

func (q *Queue) Push(ctx context.Context, req *mqueue_rpc.PushRequest) (*mqueue_rpc.PushResponse, error)

Push pushes a message to the queue.

func (q *Queue) Wait(ctx context.Context, req *mqueue_rpc.WaitRequest) (*mqueue_rpc.WaitResponse, error)

Wait waits for a message to arrive.