Struct GrpcWorker 

pub struct GrpcWorker { /* private fields */ }

gRPC-based Worker implementation that forwards calls to a remote Worker service

Implementations

impl GrpcWorker

pub async fn new( binding_name: String, grpc_endpoint: String, ) -> Result<GrpcWorker, AlienError<ErrorData>>

Create a new gRPC Worker client

pub async fn new_from_channel( channel: Channel, binding_name: String, ) -> Result<GrpcWorker, AlienError<ErrorData>>

Create a new gRPC Worker client from an existing channel

Trait Implementations

impl Binding for GrpcWorker

impl Debug for GrpcWorker

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

Formats the value using the given formatter.

impl Worker for GrpcWorker

fn invoke<'life0, 'async_trait>( &'life0 self, request: WorkerInvokeRequest, ) -> Pin<Box<dyn Future<Output = Result<WorkerInvokeResponse, AlienError<ErrorData>>> + Send + 'async_trait>>

where 'life0: 'async_trait, GrpcWorker: 'async_trait,

Invoke a worker with HTTP request data.

fn get_worker_url<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, AlienError<ErrorData>>> + Send + 'async_trait>>

where 'life0: 'async_trait, GrpcWorker: 'async_trait,

Get the public URL of the worker, if available.

fn as_any(&self) -> &(dyn Any + 'static)

Get a reference to this object as Any for dynamic casting