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