RocksQ Library

class rocksq.StartPosition

Newest = StartPosition.Newest

Oldest = StartPosition.Oldest

rocksq.remove_mpmc_queue(path)

Removes MpmcQueue at the given path. The queue must be closed.

Parameters:: path (str) – The path to the queue to remove.
Raises:: PyRuntimeError – If the queue could not be removed.

rocksq.remove_queue(path)

Removes PersistentQueueWithCapacity at the given path. The queue must be closed.

Parameters:: path (str) – The path to the queue to remove.
Raises:: PyRuntimeError – If the queue could not be removed.

rocksq.version()

Returns the version of the underlying queue_rs library.

Returns:: version – The version of the underlying queue_rs library.
Return type:: str