Struct Runtime 

pub struct Runtime { /* private fields */ }

Runtime system that manages all resources necessary to run graphs.

The runtime system manages a collection of Workers and routes requests to run nodes to the appropriate workers depending on which functions they support.

This struct can be efficiently cloned to be passed around and cleans up its resources after the last copy has been dropped.

Implementations

impl Runtime

pub fn builder() -> RuntimeBuilder

Create a new RuntimeBuilder.

pub fn function_declarations( &self, ) -> impl Iterator<Item = &FunctionDeclaration>

Returns the signatures of all functions available to the runtime.

pub fn function_declaration( &self, name: FunctionName, ) -> Option<&FunctionDeclaration>

Returns the signature for a function.

pub fn signature(&self) -> Signature

Lists all the functions known to this runtime; equivalent to Self::signature_in_loc with Location::local

pub async fn signature_in_loc( &self, loc: Location, ) -> Result<ListFunctionsResponse>

Lists the functions known in a specified location (and sub-locations thereof).

pub fn infer_type<T>( &self, to_check: &T, ) -> Result<(TypeScheme, T::Annotated), TypeErrors>

where T: Typeable,

Infer the type of a graph or value using the signature provided by the runtime’s workers.

Errors

Returns an error in case the type inference fails.

pub async fn infer_type_in_loc( &self, to_check: Value, location: Location, ) -> Result<InferTypeResponse>

Infers the type that a Value would have if it were seen in a particular location, i.e. a descendant RuntimeWorker (able to run Graphs).

Errors

• If location does not identify a worker able to type-check graphs
• Any type error in to_check, for example, using functions not available at location.

pub async fn execute_graph_remote( &self, graph: Graph, inputs: HashMap<Label, Value>, type_check: bool, remote_loc: (LocationName, Location), escape: Callback, ) -> Result<HashMap<Label, Value>, RunGraphError>

Run a graph to completion with a given collection of inputs, at a non-local Location.

pub async fn execute_graph_cb( &self, graph: Graph, inputs: HashMap<Label, Value>, type_check: bool, callback: Callback, escape: EscapeHatch, ) -> Result<HashMap<Label, Value>, RunGraphError>

Run a graph to completion with a given collection of inputs, locally, optionally after type-checking.

callback should be a connection-point (for child workers) to connect to this runtime.

escape may be a forwarding chain to the root of a chain of servers, but note that if type_check is true, then we will never need to escape above this server (as successful type-checking guarantees the graph uses only functions known to this server).

pub fn start_graph( &self, graph: Graph, inputs: HashMap<Label, Value>, type_check: bool, callback: Callback, escape: EscapeHatch, checkpoint_client: Option<CheckpointClient>, ) -> Result<TaskHandle, TypeErrors>

Starts running a graph (locally, on this Runtime), optionally type-checking the graph and inputs first.

If type-checking succeeds (or is not requested), returns a handle to the graph-executing process which will continue in the background.

See execute_graph_cb for more detail on callback + escape

pub fn run_function_with_loc( &self, function: &FunctionName, loc: &Location, ) -> Option<RuntimeOperation>

Runs a function at a specific location (local or otherwise). If the location is non-local, will definitely return Some RuntimeOperation (one that fails when run if the indicated remote can’t run the function). If the location is local, may return None if the function name is not known.

pub fn run_graph_remote( &self, graph: Graph, loc: (LocationName, Location), ) -> Option<RuntimeOperation>

Runs a graph in a runtime that is a strict descendant of this one. (A non-local Location with at least one LocationName.)

Trait Implementations

impl Clone for Runtime

fn clone(&self) -> Runtime

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Runtime

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.