package
0.0.0-20250110163926-c2d6b841ea78
Repository: https://github.com/clbs-io/octopusmq.git
Documentation: pkg.go.dev
# Constants
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Variables
No description provided by the author
Enum value maps for StatusCode.
Enum value maps for StatusCode.
# Structs
CommitRequest sends an array of item IDs to commit.
CommitResponse returns the number of items that were committed.
CommitSingleRequest.
CommitSingleResponse returns true if the item was committed.
CreateQueueRequest message contains the data to create a new queue.
No description provided by the author
DeleteQueueRequest message contains the identification of the queue to delete.
DeleteRequest message sends an array of item IDs to delete.
DeleteResponse message returns the number of items that were deleted.
DeleteSingleRequest message contains the ID of the item to delete.
DeleteSingleResponse message returns true if the item was deleted.
No description provided by the author
EnqueueRequest contains the item to be prepended and duration of the timeout.
EnqueueResponse sends back only item ID.
No description provided by the author
No description provided by the author
ListQueueItem message contains the queue info.
ListQueuesResponse message contains an array of queues that are running on the server.
No description provided by the author
No description provided by the author
No description provided by the author
ResumeQueueRequest message contains the identification of the queue to resume.
PullRequest message: batchSize: number of items to pull, timeout: for how long should request wait for items if the queue is empty.
PullResponse message has array of pulled items.
PullSingleRequest message contains duration, for how long should request wait for item if the queue is empty.
PullSingleResponse message contains the item pulled from the queue.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Requeue item consists of id and ttl as unix absolute time in ms when requeued item is ready to be pulled, 0 means immediately.
RequeueRequest message sends an array of item IDs to requeue.
RequeueResponse message returns the number of items that were requeued.
RequeueSingleRequest message contains the ID of the item to requeue.
RequeueSingleResponse message returns true if the item was requeued.
No description provided by the author
ResumeQueueRequest message contains the identification of the queue to resume.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Type aliases
No description provided by the author