pub struct NoopSyncEventHandler;Trait Implementations§
Source§impl SyncEventHandler<OverlordEvent, OverlordState> for NoopSyncEventHandler
impl SyncEventHandler<OverlordEvent, OverlordState> for NoopSyncEventHandler
type Context = ()
Source§fn handles_event(&self, _event: &OverlordEvent) -> bool
fn handles_event(&self, _event: &OverlordEvent) -> bool
Returns true if this event should be handled by the sync handler (requires DB context).
async fn create_context_for_batch( &self, _state: &OverlordState, ) -> Result<Self::Context>
async fn handle_event( &self, _context: &Self::Context, _event: &OverlordEvent, _meta: SyncEventMeta, state: OverlordState, ) -> Result<EventHandleResult<OverlordEvent, OverlordState>>
async fn handle_side_effect_event( &self, _context: &Self::Context, _event: &OverlordEvent, _output_events: &[OverlordEvent], _new_state: &OverlordState, ) -> Result<()>
async fn finalize_state( &self, _context: &Self::Context, _state: &mut OverlordState, ) -> Result<()>
Source§async fn persist_in_memory_state(
&self,
_context: &Self::Context,
_state: &OverlordState,
) -> Result<()>
async fn persist_in_memory_state( &self, _context: &Self::Context, _state: &OverlordState, ) -> Result<()>
Persist in-memory state to DB context before commit.
Called by flush_state to save changes accumulated without DB context (e.g. fight ticks).
Auto Trait Implementations§
impl Freeze for NoopSyncEventHandler
impl RefUnwindSafe for NoopSyncEventHandler
impl Send for NoopSyncEventHandler
impl Sync for NoopSyncEventHandler
impl Unpin for NoopSyncEventHandler
impl UnwindSafe for NoopSyncEventHandler
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
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].