nat.plugins.redis.redis_object_store

Attributes

logger

Classes

RedisObjectStore

Implementation of ObjectStore that stores objects in Redis.

Module Contents

logger

class RedisObjectStore(*, bucket_name: str, host: str, port: int, db: int)

Bases: nat.object_store.interfaces.ObjectStore

Implementation of ObjectStore that stores objects in Redis.

Each object is stored as a single binary value at key “nat/object_store/{bucket_name}/{object_key}”.

_bucket_name

_host

_port

_db

_client: redis.asyncio.Redis | None = None

_make_key(key: str) → str

async put_object(key: str, item: nat.object_store.models.ObjectStoreItem)

Save an ObjectStoreItem in the object store with the given key. If the key already exists, raise an error.

Args:

key (str): The key to save the item under. item (ObjectStoreItem): The item to save.

Raises:

KeyAlreadyExistsError: If the key already exists.

async upsert_object(key: str, item: nat.object_store.models.ObjectStoreItem)

Save an ObjectStoreItem in the object store with the given key. If the key already exists, update the item.

Args:

key (str): The key to save the item under. item (ObjectStoreItem): The item to save.

async get_object(key: str) → nat.object_store.models.ObjectStoreItem

Get an ObjectStoreItem from the object store by key.

Args:

key (str): The key to get the item from.

Returns:

ObjectStoreItem: The item retrieved from the object store.

Raises:

NoSuchKeyError: If the item does not exist.

async delete_object(key: str)

Delete an ObjectStoreItem from the object store by key.

Args:

key (str): The key to delete the item from.

Raises:

NoSuchKeyError: If the item does not exist.