flusso-engine 0.9.1

The flusso sync engine: the resolve, build, flush, and ack pipeline.
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

use thiserror::Error;

/// Result alias for the engine.
pub type Result<T> = std::result::Result<T, EngineError>;

/// A fatal error that stops the sync run. Because the engine confirms a
/// change's source ack only after the change is durably applied, stopping on an
/// error is safe: unconfirmed changes are redelivered when the run restarts.
#[derive(Debug, Error)]
#[non_exhaustive]
pub enum EngineError {
    /// From the source — capturing changes or resolving/assembling documents.
    #[error(transparent)]
    Source(#[from] sources_core::SourceError),

    /// From a sink write.
    #[error(transparent)]
    Sink(#[from] sinks_core::SinkError),

    /// From the work queue.
    #[error(transparent)]
    Queue(#[from] queue_core::QueueError),

    /// A spawned task failed to join (panicked).
    #[error("task failed: {0}")]
    Task(String),

    /// The sink rejected one or more documents at the item level and the
    /// failure policy is [`Stop`](crate::FailurePolicy::Stop). Switch to
    /// `skip` to quarantine such documents and keep the pipeline running.
    #[error(
        "sink rejected {0} document(s) (e.g. {1}); stopping. \
         set on-error=skip to quarantine rejected documents and continue"
    )]
    DocumentsRejected(usize, String),
}