pub struct AppCallbackService { /* private fields */ }Implementations§
Source§impl AppCallbackService
impl AppCallbackService
pub fn new() -> AppCallbackService
pub fn add_handler(&mut self, handler: Handler)
Trait Implementations§
Source§impl AppCallback for AppCallbackService
impl AppCallback for AppCallbackService
Source§fn on_invoke<'life0, 'async_trait>(
&'life0 self,
_request: Request<InvokeRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<InvokeResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn on_invoke<'life0, 'async_trait>(
&'life0 self,
_request: Request<InvokeRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<InvokeResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Invokes service method with InvokeRequest.
Source§fn list_topic_subscriptions<'life0, 'async_trait>(
&'life0 self,
_request: Request<()>,
) -> Pin<Box<dyn Future<Output = Result<Response<ListTopicSubscriptionsResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn list_topic_subscriptions<'life0, 'async_trait>(
&'life0 self,
_request: Request<()>,
) -> Pin<Box<dyn Future<Output = Result<Response<ListTopicSubscriptionsResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Lists all topics subscribed by this app.
Source§fn on_topic_event<'life0, 'async_trait>(
&'life0 self,
request: Request<TopicEventRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<TopicEventResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn on_topic_event<'life0, 'async_trait>(
&'life0 self,
request: Request<TopicEventRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<TopicEventResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Subscribes events from Pubsub
Source§fn list_input_bindings<'life0, 'async_trait>(
&'life0 self,
_request: Request<()>,
) -> Pin<Box<dyn Future<Output = Result<Response<ListInputBindingsResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn list_input_bindings<'life0, 'async_trait>(
&'life0 self,
_request: Request<()>,
) -> Pin<Box<dyn Future<Output = Result<Response<ListInputBindingsResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Lists all input bindings subscribed by this app.
Source§fn on_binding_event<'life0, 'async_trait>(
&'life0 self,
_request: Request<BindingEventRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<BindingEventResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn on_binding_event<'life0, 'async_trait>(
&'life0 self,
_request: Request<BindingEventRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<BindingEventResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Listens events from the input bindings Read more
Auto Trait Implementations§
impl Freeze for AppCallbackService
impl !RefUnwindSafe for AppCallbackService
impl Send for AppCallbackService
impl Sync for AppCallbackService
impl Unpin for AppCallbackService
impl !UnwindSafe for AppCallbackService
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> 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> 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