Struct CertifierService

Source

pub struct CertifierService {
    pub suffix: Suffix<CandidateMessage>,
    pub certifier: Certifier,
    pub system: System,
    pub message_channel_rx: Receiver<ChannelMessage<CandidateMessage>>,
    pub commit_offset: Arc<AtomicI64>,
    pub decision_outbox_tx: Sender<DecisionOutboxChannelMessage>,
    pub config: CertifierServiceConfig,
}

Fields§

§suffix: Suffix<CandidateMessage>§certifier: Certifier§system: System§message_channel_rx: Receiver<ChannelMessage<CandidateMessage>>§commit_offset: Arc<AtomicI64>§decision_outbox_tx: Sender<DecisionOutboxChannelMessage>§config: CertifierServiceConfig

Struct CertifierService Copy item path

Fields§

Implementations§

impl CertifierService

pub fn new( message_channel_rx: Receiver<ChannelMessage<CandidateMessage>>, decision_outbox_tx: Sender<DecisionOutboxChannelMessage>, commit_offset: Arc<AtomicI64>, system: System, config: Option<CertifierServiceConfig>, ) -> Self

pub async fn process_message( &mut self, channel_message: &Option<ChannelMessage<CandidateMessage>>, ) -> ServiceResult

Trait Implementations§

impl SystemService for CertifierService

fn run<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ServiceResult> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Auto Trait Implementations§

impl !RefUnwindSafe for CertifierService

impl !UnwindSafe for CertifierService

impl Freeze for CertifierService

impl Send for CertifierService

impl Sync for CertifierService

impl Unpin for CertifierService

impl UnsafeUnpin for CertifierService

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct CertifierService

fn run<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ServiceResult> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,