batpak 0.7.0

Event sourcing with causal graphs and policy gates. Sync API, zero async.
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

pub use crate::artifact::{
    ArtifactEnvelopeFinding, ArtifactEnvelopeIdentity, ArtifactHash, ArtifactVerificationReport,
    AttestationRef, CanonicalArtifactEnvelope, SignatureEnvelope, SignatureRef,
    ARTIFACT_ENVELOPE_FRAMING_VERSION,
};
pub use crate::coordinate::DagPosition;
pub use crate::coordinate::{Coordinate, CoordinateError, KindFilter, Region};
pub use crate::event::sourcing::{MultiDispatchError, MultiReactive, Reactive, TypedReactive};
pub use crate::event::{
    revalidate_event_payload_registry, validate_event_payload_registry, DecodeSource, DecodeTyped,
    Event, EventHeader, EventKind, EventKindError, EventPayload, EventPayloadKindCollision,
    EventPayloadRegistryError, EventPayloadValidation, EventSourced, HashChain, JsonValueInput,
    ProjectionEvent, ProjectionInput, ProjectionPayload, RawMsgpackInput, ReplayLane, StoredEvent,
    TypedDecodeError,
};
pub use crate::guard::{Denial, Gate, GateSet, Receipt};
pub use crate::id::{CausationId, CorrelationId, EventId};
pub use crate::outcome::{ErrorKind, Outcome, OutcomeError};
pub use crate::pipeline::{CommitMetadata, Committed, Pipeline, Proposal};
pub use crate::schema::{
    compare_schema_snapshot, SchemaChangeClass, SchemaSnapshot, SchemaSnapshotEvidenceReport,
    SchemaSnapshotFinding, SchemaSnapshotReportBody, SchemaSnapshotReportError,
    SCHEMA_SNAPSHOT_REPORT_SCHEMA_VERSION,
};
pub use crate::store::delivery::cursor::{
    CursorWorkerAction, CursorWorkerConfig, CursorWorkerHandle,
};
pub use crate::store::delivery::subscription::{Subscription, SubscriptionOps};
pub use crate::store::{
    AppendOptions, AppendPositionHint, AppendReceipt, AppendTicket, BatchAppendItem,
    BatchAppendTicket, BatchConfig, CausationRef, ChainWalkEvidenceReport, ChainWalkFinding,
    ChainWalkMode, ChainWalkReportBody, ChainWalkReportError, ChainWalkRequest, ChainWalkStartRef,
    Closed, CompactionConfig, CompactionStrategy, Cursor, DiskPos, DurabilityGate, Freshness,
    HlcPoint, IndexConfig, IndexEntry, IndexTopology, LossPrecision, NoCache, Notification, Open,
    ProjectionRunCacheStatus, ProjectionRunCheckpointRef, ProjectionRunEvidenceReport,
    ProjectionRunFinding, ProjectionRunFreshnessStatus, ProjectionRunFrontierKind,
    ProjectionRunInputFrontier, ProjectionRunOutputHash, ProjectionRunReplayMode,
    ProjectionRunReportBody, ProjectionRunReportError, ProjectionRunRequestedFreshness,
    ProjectionSourceRef, ReactionBatch, ReactorConfig, ReactorError, ReadOnly,
    ReadWalkDroppedCount, ReadWalkEvidenceReport, ReadWalkFinding, ReadWalkFreshnessIntent,
    ReadWalkFrontierKind, ReadWalkInputFrontier, ReadWalkProofRef, ReadWalkProofRefs,
    ReadWalkReplayMode, ReadWalkReportBody, ReadWalkReportError, ReadWalkRequest,
    ReadWalkSourceRef, RestartPolicy, Store, StoreConfig, StoreError, StoreResourceEnvelope,
    StoreResourceEvidenceReport, StoreResourceFrontierBody, StoreResourceHash,
    StoreResourceReportBody, StoreResourceReportError, StoreResourceRestartPolicyShape,
    SubscriberDeliveryState, SubscriberFrontierEvidenceReport, SubscriberFrontierFinding,
    SubscriberFrontierReportBody, SubscriberFrontierReportError, SubscriberFrontierRequest,
    SubscriberFrontierSource, SyncConfig, SyncMode, TypedReactorHandle, WatermarkKind,
    WriterConfig, WriterPressure, CHAIN_WALK_REPORT_SCHEMA_VERSION,
    PROJECTION_RUN_REPORT_SCHEMA_VERSION, READ_WALK_REPORT_SCHEMA_VERSION,
    STORE_RESOURCE_REPORT_SCHEMA_VERSION, SUBSCRIBER_FRONTIER_REPORT_SCHEMA_VERSION,
};
pub use batpak_macros::{EventPayload, EventSourced, MultiEventReactor};