pub struct RpcHandler { /* private fields */ }Expand description
RPC handler for function invocations.
Implementations§
Source§impl RpcHandler
impl RpcHandler
Sourcepub fn new(registry: FunctionRegistry, db: Database) -> Self
pub fn new(registry: FunctionRegistry, db: Database) -> Self
Create a new RPC handler.
Sourcepub fn with_dispatch(
registry: FunctionRegistry,
db: Database,
job_dispatcher: Option<Arc<dyn JobDispatch>>,
workflow_dispatcher: Option<Arc<dyn WorkflowDispatch>>,
) -> Self
pub fn with_dispatch( registry: FunctionRegistry, db: Database, job_dispatcher: Option<Arc<dyn JobDispatch>>, workflow_dispatcher: Option<Arc<dyn WorkflowDispatch>>, ) -> Self
Create a new RPC handler with dispatch capabilities.
Sourcepub async fn handle(
&self,
request: RpcRequest,
auth: AuthContext,
metadata: RequestMetadata,
) -> RpcResponse
pub async fn handle( &self, request: RpcRequest, auth: AuthContext, metadata: RequestMetadata, ) -> RpcResponse
Handle an RPC request.
Trait Implementations§
Source§impl Clone for RpcHandler
impl Clone for RpcHandler
Source§fn clone(&self) -> RpcHandler
fn clone(&self) -> RpcHandler
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for RpcHandler
impl !RefUnwindSafe for RpcHandler
impl Send for RpcHandler
impl Sync for RpcHandler
impl Unpin for RpcHandler
impl !UnwindSafe for RpcHandler
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request