Struct Replayer 

pub struct Replayer { /* private fields */ }

Runs workflow code against exported journals.

Implementations

impl Replayer

pub fn new() -> Self

pub fn with_codec(self, codec: Arc<dyn Codec>) -> Self

Reads journals written with payload encryption.

pub fn register<I, O, F, Fut>( &self, workflow: impl AsWorkflow<I, O>, f: F, ) -> &Self

where I: Serialize + DeserializeOwned + 'static, O: Serialize + DeserializeOwned + 'static, F: Fn(Ctx, I) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<O>> + 'static,

Registers a workflow type’s code (at the reference’s version, else version 1), as Engine::register does.

pub fn replay(&self, journal: &ExportedJournal) -> ReplayReport

Replays one journal.

pub fn replay_file(&self, path: &Path) -> Result<ReplayReport>

pub fn replay_dir(&self, dir: &Path) -> Result<Vec<(PathBuf, ReplayReport)>>

Replays every .fjnl file in dir.

Trait Implementations

impl Default for Replayer

fn default() -> Self

Returns the “default value” for a type.