Struct ExternalWorker 

pub struct ExternalWorker { /* private fields */ }

Connection to an external worker (perhaps a Tierkreis server), that can execute run_function for some defined+reported set of functions.

Implementations

impl ExternalWorker

pub async fn new_spawn( command: impl AsRef<OsStr>, interceptor: ClientInterceptor, ) -> Result<Self>

Spawn a process that runs the specified command, which must print out the socket address for a GRPC server as the first line of stdout. (We expect the command to start a new gRPC server in its own process.)

The socket address could be a hostname + port, or path to a UNIX filesystem socket.

new_spawn then connects to the worker’s gRPC server and requests its signature.

pub async fn new_connect( uri: &Uri, interceptor: ClientInterceptor, ) -> Result<Self>

Connects to an already-running external process given its Uri

Trait Implementations

impl Clone for ExternalWorker

fn clone(&self) -> ExternalWorker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl FunctionWorker for ExternalWorker

fn spawn(&self, function: &FunctionName, loc: &Location) -> RuntimeOperation

Returns a RuntimeOperation that runs the named function; the operation will return an error if the function is unknown.

impl Worker for ExternalWorker

fn signature<'life0, 'async_trait>( &'life0 self, location: Location, ) -> Pin<Box<dyn Future<Output = Result<ListFunctionsResponse>> + Send + 'async_trait>>

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

Returns the signature of the worker.

fn to_runtime_worker(&self) -> Option<&dyn RuntimeWorker>

Return a runtime worker, if it is one