Struct RedisStateStore 

pub struct RedisStateStore { /* private fields */ }

Implementations

impl RedisStateStore

pub fn new(redis_url: impl AsRef<str>) -> Result<Self>

pub fn checkpoint_key(task_id: &str) -> String

pub fn checkpoint_to_json(checkpoint: &Checkpoint) -> Result<String>

pub fn checkpoint_from_json(raw: &str) -> Result<Checkpoint>

Trait Implementations

impl Debug for RedisStateStore

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

Formats the value using the given formatter.

impl StateStore for RedisStateStore

fn save_checkpoint(&self, checkpoint: Checkpoint) -> Result<()>

fn load_checkpoint(&self, task_id: &str) -> Result<Option<Checkpoint>>

fn delete_checkpoint(&self, task_id: &str) -> Result<()>

fn list_checkpoints(&self) -> Result<Vec<String>>