Struct DropActor 

pub struct DropActor { /* private fields */ }

Implementations

impl DropActor

pub fn new( config: DropWorkerConfig, storage: MultiCommitBufferTier, event_bus: EventBus, clock: Clock, ) -> Self

pub fn spawn( system: &ActorSystem, config: DropWorkerConfig, storage: MultiCommitBufferTier, event_bus: EventBus, clock: Clock, ) -> ActorRef<DropMessage>

Trait Implementations

impl Actor for DropActor

type State = DropActorState

type Message = DropMessage

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 post_stop(&self)

fn config(&self) -> ActorConfig

fn idle(&self, ctx: &Context<Self::Message>) -> Directive