Struct LocalHookService 

pub struct LocalHookService { /* private fields */ }

Implementations

impl LocalHookService

pub fn new(inner: GrpcLocalService) -> Self

Trait Implementations

impl Clone for LocalHookService

fn clone(&self) -> LocalHookService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl HookService for LocalHookService

type SubscribeHookEventsStream = Pin<Box<dyn Stream<Item = Result<HookEvent, Status>> + Send>>

Server streaming response type for the SubscribeHookEvents method.

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

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

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

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

fn list_hooks<'life0, 'async_trait>( &'life0 self, _request: Request<ListHooksRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListHooksResponse>, Status>> + Send + 'async_trait>>

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

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

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

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

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

Server-streamed live event delivery. Each event carries an opaque hook_event_id correlator that the subscriber echoes back to RespondToHook. Read-shaped — no idempotency.

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

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

Deliver the hook’s reply (or veto via abort) for a previously received event. State-changing — caller supplies client_operation_id for retry safety, though the broker will also dedup on hook_event_id since each id is single-shot.