#[non_exhaustive]pub struct WorkerCallbacks {
pub heartbeat: HeartbeatCallback,
pub heartbeat_success: Option<HeartbeatSuccessCallback>,
pub cancel_activity: Option<CancelActivityCallback>,
}Expand description
Bundles all per-worker callbacks registered with the SharedNamespaceWorker.
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.heartbeat: HeartbeatCallbackCallback to collect heartbeat data from the worker.
heartbeat_success: Option<HeartbeatSuccessCallback>Callback acknowledging successful delivery of the collected heartbeat.
cancel_activity: Option<CancelActivityCallback>Callback to cancel an activity by task token.
Implementations§
Source§impl WorkerCallbacks
impl WorkerCallbacks
Sourcepub fn new(
heartbeat: HeartbeatCallback,
heartbeat_success: Option<HeartbeatSuccessCallback>,
cancel_activity: Option<CancelActivityCallback>,
) -> Self
pub fn new( heartbeat: HeartbeatCallback, heartbeat_success: Option<HeartbeatSuccessCallback>, cancel_activity: Option<CancelActivityCallback>, ) -> Self
Creates a callback bundle for a worker.
Auto Trait Implementations§
impl !RefUnwindSafe for WorkerCallbacks
impl !UnwindSafe for WorkerCallbacks
impl Freeze for WorkerCallbacks
impl Send for WorkerCallbacks
impl Sync for WorkerCallbacks
impl Unpin for WorkerCallbacks
impl UnsafeUnpin for WorkerCallbacks
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