Struct RedisCacheDatabase 

pub struct RedisCacheDatabase {
    pub con: ConnectionManager,
    pub trader_id: TraderId,
    pub trader_key: String,
    pub encoding: SerializationEncoding,
    /* private fields */
}

Fields

con: ConnectionManager

trader_id: TraderId

trader_key: String

encoding: SerializationEncoding

Implementations

impl RedisCacheDatabase

pub async fn new( trader_id: TraderId, instance_id: UUID4, config: CacheConfig, ) -> Result<Self>

Creates a new RedisCacheDatabase instance for the given trader_id, instance_id, and config.

Errors

Returns an error if:

• The database configuration is missing in config.
• Establishing the Redis connection fails.
• The command processing task cannot be spawned.

pub const fn get_encoding(&self) -> SerializationEncoding

pub fn get_trader_key(&self) -> &str

pub fn close(&mut self)

pub async fn flushdb(&mut self)

pub async fn keys(&mut self, pattern: &str) -> Result<Vec<String>>

Retrieves all keys matching the given pattern from Redis for this trader.

Errors

Returns an error if the underlying Redis scan operation fails.

pub async fn read(&mut self, key: &str) -> Result<Vec<Bytes>>

Reads the value(s) associated with key for this trader from Redis.

Errors

Returns an error if the underlying Redis read operation fails.

pub fn insert(&mut self, key: String, payload: Option<Vec<Bytes>>) -> Result<()>

Sends an insert command for key with optional payload to Redis via the background task.

Errors

Returns an error if the command cannot be sent to the background task channel.

pub fn update(&mut self, key: String, payload: Option<Vec<Bytes>>) -> Result<()>

Sends an update command for key with optional payload to Redis via the background task.

Errors

Returns an error if the command cannot be sent to the background task channel.

pub fn delete(&mut self, key: String, payload: Option<Vec<Bytes>>) -> Result<()>

Sends a delete command for key with optional payload to Redis via the background task.

Errors

Returns an error if the command cannot be sent to the background task channel.

pub fn delete_order(&self, client_order_id: &ClientOrderId) -> Result<()>

Delete the given order from the database with comprehensive index cleanup.

Errors

Returns an error if the command cannot be sent to the background task channel.

pub fn delete_position(&self, position_id: &PositionId) -> Result<()>

Delete the given position from the database with comprehensive index cleanup.

Errors

Returns an error if the command cannot be sent to the background task channel.

pub fn delete_account_event( &self, account_id: &AccountId, event_id: &str, ) -> Result<()>

Delete the given account event from the database.

Errors

Returns an error if the command cannot be sent to the background task channel.

Trait Implementations

impl Debug for RedisCacheDatabase

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'py> IntoPyObject<'py> for RedisCacheDatabase

type Target = RedisCacheDatabase

The Python output type

type Output = Bound<'py, <RedisCacheDatabase as IntoPyObject<'py>>::Target>

The smart pointer type to use.

type Error = PyErr

The type returned in the event of a conversion error.

fn into_pyobject( self, py: Python<'py>, ) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>

Performs the conversion.

impl PyClass for RedisCacheDatabase

type Frozen = False

Whether the pyclass is frozen.

impl PyClassImpl for RedisCacheDatabase

const IS_BASETYPE: bool = false

#[pyclass(subclass)]

const IS_SUBCLASS: bool = false

#[pyclass(extends=…)]

const IS_MAPPING: bool = false

#[pyclass(mapping)]

const IS_SEQUENCE: bool = false

#[pyclass(sequence)]

const IS_IMMUTABLE_TYPE: bool = false

#[pyclass(immutable_type)]

type BaseType = PyAny

Base class

type ThreadChecker = SendablePyClass<RedisCacheDatabase>

This handles following two situations:

type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::MutableChild

Immutable or mutable

type Dict = PyClassDummySlot

Specify this class has #[pyclass(dict)] or not.

type WeakRef = PyClassDummySlot

Specify this class has #[pyclass(weakref)] or not.

type BaseNativeType = PyAny

The closest native ancestor. This is PyAny by default, and when you declare #[pyclass(extends=PyDict)], it’s PyDict.

fn items_iter() -> PyClassItemsIter

fn doc(py: Python<'_>) -> PyResult<&'static CStr>

Rendered class doc

fn lazy_type_object() -> &'static LazyTypeObject<Self>

fn dict_offset() -> Option<isize>

fn weaklist_offset() -> Option<isize>

impl PyClassNewTextSignature<RedisCacheDatabase> for PyClassImplCollector<RedisCacheDatabase>

fn new_text_signature(self) -> Option<&'static str>

impl<'a, 'py> PyFunctionArgument<'a, 'py, false> for &'a RedisCacheDatabase

type Holder = Option<PyRef<'py, RedisCacheDatabase>>

fn extract( obj: &'a Bound<'py, PyAny>, holder: &'a mut Self::Holder, ) -> PyResult<Self>

impl<'a, 'py> PyFunctionArgument<'a, 'py, false> for &'a mut RedisCacheDatabase

type Holder = Option<PyRefMut<'py, RedisCacheDatabase>>

fn extract( obj: &'a Bound<'py, PyAny>, holder: &'a mut Self::Holder, ) -> PyResult<Self>

impl PyMethods<RedisCacheDatabase> for PyClassImplCollector<RedisCacheDatabase>

fn py_methods(self) -> &'static PyClassItems

impl PyTypeInfo for RedisCacheDatabase

const NAME: &'static str = "RedisCacheDatabase"

Class name.

const MODULE: Option<&'static str>

Module name, if any.

fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject

Returns the PyTypeObject instance for this type.

fn type_object(py: Python<'_>) -> Bound<'_, PyType>

Returns the safe abstraction over the type object.

fn is_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type or a subclass of this type.

fn is_exact_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type.

impl DerefToPyAny for RedisCacheDatabase