Struct DriverHandler

pub struct DriverHandler { /* private fields */ }

The DriverHandler handles incoming gRPC requests. This is effectively what ‘drives’ the driver.

Implementations

impl DriverHandler

pub fn new( node_config_path: impl Into<PathBuf>, proxy: Arc<ProxyClient>, ) -> Self

Constructor for the DriverHandler.

Arguments

• node_config_path: The path to the node.yml file that describes this node’s environment. For the handler, this is the path to the infra.yml file (and an optional secrets.yml) and the topic to send commands to the planner on.
• proxy: The (shared) ProxyClient that we use to connect to/through brane-prx.
• planner: The InstancePlanner that handles our side of planning.

Returns

A new DriverHandler instance.

Trait Implementations

impl Clone for DriverHandler

fn clone(&self) -> DriverHandler

Returns a copy of the value.

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

Performs copy-assignment from source.

impl DriverService for DriverHandler

fn create_session<'life0, 'async_trait>( &'life0 self, _request: Request<CreateSessionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateSessionReply>, Status>> + Send + 'async_trait>>

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

Creates a new BraneScript session.

Arguments

• request: The request to create a response to.

Returns

The response to the request, which only contains a new AppId.

Errors

This function doesn’t typically error.

fn check<'life0, 'async_trait>( &'life0 self, request: Request<CheckRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CheckReply>, Status>> + Send + 'async_trait>>

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

Checks a workflow’s validity in the backing instance.

Arguments

• request: The request with the new (already compiled) snippet to validate.

Returns

The response to the request, which contains the verdict of all checkers.

Errors

This function may error for any reason a job might fail.

fn execute<'life0, 'async_trait>( &'life0 self, request: Request<ExecuteRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::ExecuteStream>, Status>> + Send + 'async_trait>>

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

Executes a new job in an existing BraneScript session.

Arguments

• request: The request with the new (already compiled) snippet to execute.

Returns

The response to the request, which contains the result of this workflow (if any).

Errors

This function may error for any reason a job might fail.

type ExecuteStream = ReceiverStream<Result<ExecuteReply, Status>>

The response type for stream returned by DriverService::execute().