Struct ControlGrpcServer 

pub struct ControlGrpcServer { /* private fields */ }

Control gRPC server implementation

Implementations

impl ControlGrpcServer

pub fn new() -> Self

pub async fn get_http_port(&self) -> Option<u16>

Get the registered HTTP port (if any)

pub async fn has_handler(&self, handler_type: &str, resource_name: &str) -> bool

Check if a handler is registered

pub async fn get_handlers(&self) -> Vec<HandlerRegistration>

Get all registered handlers

pub async fn wait_for_http_server(&self) -> Option<u16>

Wait for HTTP server to be registered

pub async fn send_task( &self, task: Task, timeout: Duration, ) -> Result<TaskResult, String>

Send a task to the application and wait for the result. This is used for all task types - the runtime must wait for the app to process before acknowledging to the platform (storage/cron/queue) or submitting responses (commands).

pub fn into_service(self) -> ControlServiceServer<Self>

Convert to tonic service

Trait Implementations

impl Clone for ControlGrpcServer

fn clone(&self) -> ControlGrpcServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ControlService for ControlGrpcServer

type WaitForTasksStream = Pin<Box<dyn Stream<Item = Result<Task, Status>> + Send>>

Server streaming response type for the WaitForTasks method.

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

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

App registers that it has an HTTP server listening on a port

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

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

App registers an event handler for a specific resource

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

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

App waits for tasks - this is a server-streaming RPC Runtime sends tasks as they arrive, app processes them

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

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

App sends result for a processed task

impl Default for ControlGrpcServer

fn default() -> Self

Returns the “default value” for a type.