Struct ContainerdServiceProvider 

pub struct ContainerdServiceProvider { /* private fields */ }

Provisions infrastructure services as containerd containers on the host network.

Services are accessible via 127.0.0.1 on their declared ports. Connection info is injected as SVC_{NAME}_HOST / SVC_{NAME}_PORT env vars into workflow data.

Implementations

impl ContainerdServiceProvider

pub fn new(containerd_addr: impl Into<String>) -> Self

pub fn containerd_addr(&self) -> &str

Get the containerd address this provider connects to.

Trait Implementations

impl ServiceProvider for ContainerdServiceProvider

fn can_provision(&self, _services: &[ServiceDefinition]) -> bool

Check if this provider can provision the given services.

fn provision<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, workflow_id: &'life1 str, services: &'life2 [ServiceDefinition], ) -> Pin<Box<dyn Future<Output = Result<Vec<ServiceEndpoint>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Provision all services for a workflow.

fn teardown<'life0, 'life1, 'async_trait>( &'life0 self, workflow_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Tear down all services for a workflow.