pub struct FlowDecisionDispatcher { /* private fields */ }Expand description
Enforces production-branch authority and idempotent successful submission.
Implementations§
Source§impl FlowDecisionDispatcher
impl FlowDecisionDispatcher
pub fn new( production_branch_id: impl Into<String>, sink: Arc<dyn FlowDecisionSink>, ) -> Self
pub fn with_ledger( production_branch_id: impl Into<String>, sink: Arc<dyn FlowDecisionSink>, ledger: Arc<dyn FlowDecisionLedger>, ) -> Self
pub fn with_lease_ms(self, lease_ms: u64) -> Self
pub fn health(&self) -> FlowDecisionHealthSnapshot
Sourcepub async fn dispatch(
&self,
request: &FlowDecisionRequest,
) -> Result<bool, FlowDecisionDispatchError>
pub async fn dispatch( &self, request: &FlowDecisionRequest, ) -> Result<bool, FlowDecisionDispatchError>
Returns true only when the sink accepted a new decision.
Auto Trait Implementations§
impl !Freeze for FlowDecisionDispatcher
impl !RefUnwindSafe for FlowDecisionDispatcher
impl !UnwindSafe for FlowDecisionDispatcher
impl Send for FlowDecisionDispatcher
impl Sync for FlowDecisionDispatcher
impl Unpin for FlowDecisionDispatcher
impl UnsafeUnpin for FlowDecisionDispatcher
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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
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 more