Struct DockerDeploy 

pub struct DockerDeploy { /* private fields */ }

Available on crate features deploy and docker_deploy only.

For deploying to a local docker instance

Implementations

impl DockerDeploy

pub fn new(network: DockerNetwork) -> Self

Create a new deployment

pub fn add_localhost_docker( &mut self, compilation_options: Option<String>, config: Vec<String>, ) -> DockerDeployProcessSpec

Add an internal docker service to the deployment.

pub fn add_localhost_docker_cluster( &mut self, compilation_options: Option<String>, config: Vec<String>, count: usize, ) -> DockerDeployClusterSpec

Add an internal docker cluster to the deployment.

pub fn add_external(&self, name: String) -> DockerDeployExternalSpec

Add an external process to the deployment.

pub fn get_deployment_instance(&self) -> String

Get the deployment instance from this deployment.

pub async fn provision( &self, nodes: &DeployResult<'_, Self>, ) -> Result<(), Error>

Create docker images.

pub async fn start(&self, nodes: &DeployResult<'_, Self>) -> Result<(), Error>

Start the deployment, tell docker to create containers from the existing provisioned images.

pub async fn stop( &mut self, nodes: &DeployResult<'_, Self>, ) -> Result<(), Error>

Stop the deployment, destroy all containers

pub async fn cleanup( &mut self, nodes: &DeployResult<'_, Self>, ) -> Result<(), Error>

remove containers, images, and networks.

Trait Implementations

impl<'a> ClusterSpec<'a, DockerDeploy> for DockerDeployClusterSpec

fn build( self, id: usize, name_hint: &str, ) -> <DockerDeploy as Deploy<'a>>::Cluster

Available on crate feature build only.

impl<'a> Deploy<'a> for DockerDeploy

type Meta = ()

Available on crate feature build only.

type InstantiateEnv = DockerDeploy

Available on crate feature build only.

type Process = DockerDeployProcess

Available on crate feature build only.

type Cluster = DockerDeployCluster

Available on crate feature build only.

type External = DockerDeployExternal

Available on crate feature build only.

fn o2o_sink_source( p1: &Self::Process, p1_port: &<Self::Process as Node>::Port, p2: &Self::Process, p2_port: &<Self::Process as Node>::Port, ) -> (Expr, Expr)

Available on crate feature build only.

fn o2o_connect( p1: &Self::Process, p1_port: &<Self::Process as Node>::Port, p2: &Self::Process, p2_port: &<Self::Process as Node>::Port, ) -> Box<dyn FnOnce()>

Available on crate feature build only.

fn o2m_sink_source( p1: &Self::Process, p1_port: &<Self::Process as Node>::Port, c2: &Self::Cluster, c2_port: &<Self::Cluster as Node>::Port, ) -> (Expr, Expr)

Available on crate feature build only.

fn o2m_connect( p1: &Self::Process, p1_port: &<Self::Process as Node>::Port, c2: &Self::Cluster, c2_port: &<Self::Cluster as Node>::Port, ) -> Box<dyn FnOnce()>

Available on crate feature build only.

fn m2o_sink_source( c1: &Self::Cluster, c1_port: &<Self::Cluster as Node>::Port, p2: &Self::Process, p2_port: &<Self::Process as Node>::Port, ) -> (Expr, Expr)

Available on crate feature build only.

fn m2o_connect( c1: &Self::Cluster, c1_port: &<Self::Cluster as Node>::Port, p2: &Self::Process, p2_port: &<Self::Process as Node>::Port, ) -> Box<dyn FnOnce()>

Available on crate feature build only.

fn m2m_sink_source( c1: &Self::Cluster, c1_port: &<Self::Cluster as Node>::Port, c2: &Self::Cluster, c2_port: &<Self::Cluster as Node>::Port, ) -> (Expr, Expr)

Available on crate feature build only.

fn m2m_connect( c1: &Self::Cluster, c1_port: &<Self::Cluster as Node>::Port, c2: &Self::Cluster, c2_port: &<Self::Cluster as Node>::Port, ) -> Box<dyn FnOnce()>

Available on crate feature build only.

fn e2o_many_source( extra_stmts: &mut Vec<Stmt>, p2: &Self::Process, p2_port: &<Self::Process as Node>::Port, _codec_type: &Type, shared_handle: String, ) -> Expr

Available on crate feature build only.

fn e2o_many_sink(shared_handle: String) -> Expr

Available on crate feature build only.

fn e2o_source( extra_stmts: &mut Vec<Stmt>, p1: &Self::External, p1_port: &<Self::External as Node>::Port, p2: &Self::Process, p2_port: &<Self::Process as Node>::Port, _codec_type: &Type, shared_handle: String, ) -> Expr

Available on crate feature build only.

fn e2o_connect( p1: &Self::External, p1_port: &<Self::External as Node>::Port, p2: &Self::Process, p2_port: &<Self::Process as Node>::Port, many: bool, server_hint: NetworkHint, ) -> Box<dyn FnOnce()>

Available on crate feature build only.

fn o2e_sink( p1: &Self::Process, p1_port: &<Self::Process as Node>::Port, p2: &Self::External, p2_port: &<Self::External as Node>::Port, shared_handle: String, ) -> Expr

Available on crate feature build only.

fn cluster_ids( of_cluster: usize, ) -> impl QuotedWithContext<'a, &'a [TaglessMemberId], ()> + Clone + 'a

Available on crate feature build only.

fn cluster_self_id() -> impl QuotedWithContext<'a, TaglessMemberId, ()> + Clone + 'a

Available on crate feature build only.

fn cluster_membership_stream( location_id: &LocationId, ) -> impl QuotedWithContext<'a, Box<dyn Stream<Item = (TaglessMemberId, MembershipEvent)> + Unpin>, ()>

Available on crate feature build only.

impl<'a> ExternalSpec<'a, DockerDeploy> for DockerDeployExternalSpec

fn build( self, id: usize, name_hint: &str, ) -> <DockerDeploy as Deploy<'a>>::External

Available on crate feature build only.

impl<'a> ProcessSpec<'a, DockerDeploy> for DockerDeployProcessSpec

fn build( self, id: usize, name_hint: &str, ) -> <DockerDeploy as Deploy<'a>>::Process

Available on crate feature build only.

impl<'a> RegisterPort<'a, DockerDeploy> for DockerDeployExternal

fn register(&self, external_port_id: ExternalPortId, port: Self::Port)

Available on crate feature build only.

fn as_bytes_bidi( &self, external_port_id: ExternalPortId, ) -> impl Future<Output = (Pin<Box<dyn Stream<Item = Result<BytesMut, Error>>>>, Pin<Box<dyn Sink<Bytes, Error = Error>>>)> + 'a

Available on crate feature build only.

fn as_bincode_bidi<InT, OutT>( &self, external_port_id: ExternalPortId, ) -> impl Future<Output = (Pin<Box<dyn Stream<Item = OutT>>>, Pin<Box<dyn Sink<InT, Error = Error>>>)> + 'a

where InT: Serialize + 'static, OutT: DeserializeOwned + 'static,

Available on crate feature build only.

fn as_bincode_sink<T>( &self, external_port_id: ExternalPortId, ) -> impl Future<Output = Pin<Box<dyn Sink<T, Error = Error>>>> + 'a

where T: Serialize + 'static,

Available on crate feature build only.

fn as_bincode_source<T>( &self, external_port_id: ExternalPortId, ) -> impl Future<Output = Pin<Box<dyn Stream<Item = T>>>> + 'a

where T: DeserializeOwned + 'static,

Available on crate feature build only.