Struct FlushActor 

pub struct FlushActor { /* private fields */ }

Implementations

impl FlushActor

pub fn new( commit: MultiCommitBufferTier, persistent: MultiPersistentTier, flush_interval: Duration, persistence: Arc<OnceLock<Arc<dyn ShapePersistence>>>, eviction_watermark: Arc<RwLock<Option<Arc<dyn EvictionWatermark>>>>, read: Option<MultiReadBufferTier>, ) -> Self

pub fn spawn( spawner: &ActorSpawner, commit: MultiCommitBufferTier, persistent: MultiPersistentTier, flush_interval: Duration, persistence: Arc<OnceLock<Arc<dyn ShapePersistence>>>, eviction_watermark: Arc<RwLock<Option<Arc<dyn EvictionWatermark>>>>, read: Option<MultiReadBufferTier>, ) -> ActorRef<FlushMessage>

Trait Implementations

impl Actor for FlushActor

Available on crate feature sqlite and non-WebAssembly only.

type State = FlushActorState

type Message = FlushMessage

fn init(&self, ctx: &Context<FlushMessage>) -> FlushActorState

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

fn post_stop(&self)

fn config(&self) -> ActorConfig

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