Enum MaelstromDeploy 

pub enum MaelstromDeploy {}

Available on crate feature maelstrom only.

Deployment backend that targets Maelstrom for distributed systems testing.

This backend compiles Hydro programs to binaries that communicate via Maelstrom’s stdin/stdout JSON protocol. It is restricted to programs with:

• Exactly one cluster (no processes)
• A single external input channel for client communication

Trait Implementations

impl<'a> ClusterSpec<'a, MaelstromDeploy> for MaelstromClusterSpec

Available on crate feature deploy only.

fn build(self, key: LocationKey, name_hint: &str) -> MaelstromCluster

Available on crate feature build only.

impl<'a> Deploy<'a> for MaelstromDeploy

Available on crate feature deploy only.

type Meta = ()

Available on crate feature build only.

type InstantiateEnv = MaelstromDeployment

Available on crate feature build only.

type Process = MaelstromProcess

Available on crate feature build only.

type Cluster = MaelstromCluster

Available on crate feature build only.

type External = MaelstromExternal

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> RegisterPort<'a, MaelstromDeploy> for MaelstromExternal

Available on crate feature deploy only.

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: Serialize + 'static>( &self, _external_port_id: ExternalPortId, ) -> impl Future<Output = Pin<Box<dyn Sink<T, Error = Error>>>> + 'a

Available on crate feature build only.

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

Available on crate feature build only.