Struct Actor 

pub struct Actor<P: ListRowTtls> { /* private fields */ }

Background actor that periodically scans shapes for expired rows and physically drops them based on TTL configuration.

Implementations

impl<P: ListRowTtls> Actor<P>

pub fn new(store: StandardMultiStore, provider: P) -> Self

pub fn spawn( system: &ActorSystem, store: StandardMultiStore, provider: P, ) -> ActorRef<Message>

Trait Implementations

impl<P: ListRowTtls> Actor for Actor<P>

type State = ActorState

The actor’s internal state (owned, not shared).

type Message = RowTtlMessage

Messages this actor can receive.

fn init(&self, ctx: &Context<Message>) -> ActorState

Create initial state. Called on start and restart.

fn handle( &self, state: &mut ActorState, msg: Message, ctx: &Context<Message>, ) -> Directive

Handle a single message. This is the core of the actor.

fn post_stop(&self)

Called once after actor stops (always called, even on panic).

fn config(&self) -> ActorConfig

Actor configuration. Override for custom settings.

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

Called when the mailbox is empty.