Struct EcsDeploy 

pub struct EcsDeploy;

Available on crate features deploy and ecs_deploy only.

Represents an aws ecs deployment.

Implementations

impl EcsDeploy

pub fn new() -> Self

Creates a new ecs deployment.

pub fn add_ecs_process(&mut self) -> EcsDeployProcessSpec

Add an internal ecs process to the deployment.

pub fn add_ecs_cluster(&mut self, count: usize) -> EcsDeployClusterSpec

Add an internal ecs cluster to the deployment.

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

Add an external process to the deployment.

pub fn export_for_cdk(&self, nodes: &DeployResult<'_, Self>) -> HydroManifest

Export deployment configuration for CDK consumption.

This generates a manifest with build instructions that can be consumed by CDK constructs. CDK will handle building the binaries and Docker images.

Trait Implementations

impl<'a> ClusterSpec<'a, EcsDeploy> for EcsDeployClusterSpec

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

Available on crate feature build only.

impl Default for EcsDeploy

fn default() -> Self

Returns the “default value” for a type.

impl<'a> Deploy<'a> for EcsDeploy

type InstantiateEnv = EcsDeploy

Available on crate feature build only.

type Process = EcsDeployProcess

Available on crate feature build only.

type Cluster = EcsDeployCluster

Available on crate feature build only.

type External = EcsDeployExternal

Available on crate feature build only.

type Meta = ()

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: LocationKey, ) -> 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, EcsDeploy> for EcsDeployExternalSpec

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

Available on crate feature build only.

impl<'a> ProcessSpec<'a, EcsDeploy> for EcsDeployProcessSpec

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

Available on crate feature build only.

impl<'a> RegisterPort<'a, EcsDeploy> for EcsDeployExternal

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.