wfe-core 1.9.2

Core traits, models, builder, and executor for the WFE workflow engine
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

use async_trait::async_trait;

use crate::models::service::{ServiceDefinition, ServiceEndpoint};

/// Provides infrastructure services (databases, caches, etc.) for workflows.
///
/// Implementations handle provisioning, readiness checking, and teardown
/// of services on a specific platform (Kubernetes, containerd, etc.).
#[async_trait]
pub trait ServiceProvider: Send + Sync {
    /// Check if this provider can provision the given services.
    ///
    /// Returns false if any service cannot be handled by this provider.
    fn can_provision(&self, services: &[ServiceDefinition]) -> bool;

    /// Provision all services for a workflow.
    ///
    /// Creates the service containers/pods, waits for them to be ready,
    /// and returns endpoint information for each service.
    async fn provision(
        &self,
        workflow_id: &str,
        services: &[ServiceDefinition],
    ) -> crate::Result<Vec<ServiceEndpoint>>;

    /// Tear down all services for a workflow.
    ///
    /// Called on workflow completion, failure, or termination.
    /// Should be idempotent -- safe to call multiple times.
    async fn teardown(&self, workflow_id: &str) -> crate::Result<()>;
}