ranvier-runtime 0.37.0

Async Execution Engine for Ranvier
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

#![allow(deprecated)]

pub mod axon;
pub mod closure_transition;
pub mod cluster;
#[cfg(feature = "streaming")]
pub mod streaming_axon;
pub mod distributed;
pub mod llm;
pub mod persistence;
pub mod replay;
pub mod retry;
pub mod testkit;

pub mod prelude {
    pub use crate::axon::{Axon, BoxFuture, ExecutionMode, ParallelStrategy, SchematicExportRequest};
    pub use crate::{InfallibleAxon, SimpleAxon, TypedAxon};
    pub use crate::cluster::{ClusterManager, LeaderElection, LockBasedElection};
    pub use crate::distributed::{
        DistributedError, DistributedLock, DistributedStore, Guard, LockOptions,
    };
    pub use crate::llm::{LlmError, LlmProvider, LlmTemplateVars, LlmTransition, MockLlmConfig};
    pub use crate::persistence::{
        CompensationAutoTrigger, CompensationContext, CompensationHandle, CompensationHook,
        CompensationIdempotencyHandle, CompensationIdempotencyStore, CompensationRetryPolicy,
        CompletionState, InMemoryCompensationIdempotencyStore, InMemoryPersistenceStore,
        PersistedTrace, PersistenceAutoComplete, PersistenceEnvelope, PersistenceHandle,
        PersistenceStore, PersistenceTraceId, ResumeCursor,
    };
    #[cfg(feature = "persistence-postgres")]
    pub use crate::persistence::{PostgresCompensationIdempotencyStore, PostgresPersistenceStore};
    #[cfg(feature = "persistence-redis")]
    pub use crate::persistence::{RedisCompensationIdempotencyStore, RedisPersistenceStore};
    pub use crate::replay::ReplayEngine;
    pub use crate::retry::{BackoffStrategy, RetryPolicy};
    pub use crate::testkit::AxonTestKit;
    #[cfg(feature = "streaming")]
    pub use crate::streaming_axon::{StreamingAxon, StreamingAxonError, StreamTimeoutKind};
}

/// Axon with `String` error — the most common pattern for examples and prototyping.
pub type SimpleAxon<In, Out, Res = ()> = Axon<In, Out, String, Res>;

/// Axon with `RanvierError` — typed error categories without a custom enum.
pub type TypedAxon<In, Out, Res = ()> = Axon<In, Out, ranvier_core::error::RanvierError, Res>;

/// Axon with `Never` error — for pipelines that cannot fail.
///
/// Uses `ranvier_core::Never` instead of `std::convert::Infallible`
/// because `Never` satisfies the `Serialize + DeserializeOwned` bounds
/// required by `Axon`.
pub type InfallibleAxon<In, Out, Res = ()> = Axon<In, Out, ranvier_core::Never, Res>;

pub use axon::{Axon, ParallelStrategy, SchematicExportRequest};
pub use closure_transition::ClosureTransition;
pub use cluster::{ClusterManager, LeaderElection, LockBasedElection};
pub use distributed::{DistributedError, DistributedLock, DistributedStore, Guard, LockOptions};
pub use llm::{LlmError, LlmProvider, LlmTemplateVars, LlmTransition, MockLlmConfig};
pub use persistence::{
    CompensationAutoTrigger, CompensationContext, CompensationHandle, CompensationHook,
    CompensationIdempotencyHandle, CompensationIdempotencyStore, CompensationRetryPolicy,
    CompletionState, InMemoryCompensationIdempotencyStore, InMemoryPersistenceStore,
    PersistedTrace, PersistenceAutoComplete, PersistenceEnvelope, PersistenceHandle,
    PersistenceStore, PersistenceTraceId, ResumeCursor,
};
#[cfg(feature = "persistence-postgres")]
pub use persistence::{PostgresCompensationIdempotencyStore, PostgresPersistenceStore};
#[cfg(feature = "persistence-redis")]
pub use persistence::{RedisCompensationIdempotencyStore, RedisPersistenceStore};
pub use replay::ReplayEngine;
pub use retry::{BackoffStrategy, RetryPolicy};
pub use testkit::AxonTestKit;
#[cfg(feature = "streaming")]
pub use streaming_axon::{StreamingAxon, StreamingAxonError, StreamTimeoutKind};