pub struct CompactActor { /* private fields */ }Implementations§
Source§impl CompactActor
impl CompactActor
pub fn new( config: Arc<dyn GetConfig>, store: SqliteCdcStorage, watermark: CdcProducerWatermark, ) -> Self
Trait Implementations§
Source§impl Actor for CompactActor
impl Actor for CompactActor
type State = ()
type Message = CompactMessage
fn init(&self, ctx: &Context<Self::Message>) -> Self::State
fn handle( &self, _state: &mut Self::State, msg: Self::Message, ctx: &Context<Self::Message>, ) -> Directive
fn config(&self) -> ActorConfig
fn idle(&self, ctx: &Context<Self::Message>) -> Directive
fn post_stop(&self)
Auto Trait Implementations§
impl Freeze for CompactActor
impl !RefUnwindSafe for CompactActor
impl Send for CompactActor
impl Sync for CompactActor
impl Unpin for CompactActor
impl UnsafeUnpin for CompactActor
impl !UnwindSafe for CompactActor
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> 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