Struct TasksState 

pub struct TasksState { /* private fields */ }

Materialized view over the tasks log.

Serialize / Deserialize are derived so the state can be snapshotted via super::super::CortexAdapter::snapshot and restored via super::super::CortexAdapter::open_from_snapshot.

Implementations

impl TasksState

pub fn query(&self) -> TasksQuery<'_>

Start a fluent query over this state snapshot.

impl TasksState

pub fn new() -> Self

Create an empty state.

pub fn get(&self, id: TaskId) -> Option<&Task>

Look up a task by id.

pub fn len(&self) -> usize

Total number of tasks currently retained.

pub fn is_empty(&self) -> bool

True if no tasks are retained.

pub fn contains(&self, id: TaskId) -> bool

True if a task with id exists.

pub fn all(&self) -> impl Iterator<Item = &Task>

Iterate over every retained task.

pub fn pending(&self) -> impl Iterator<Item = &Task>

Iterate over tasks currently Pending.

pub fn completed(&self) -> impl Iterator<Item = &Task>

Iterate over tasks currently Completed.

pub fn find_unique(&self, id: TaskId) -> Option<&Task>

Look up a task by id. Alias of Self::get, named to match the Prisma-style NetDB surface.

pub fn find_many(&self, filter: &TasksFilter) -> Vec<Task>

Collect all tasks matching filter (cloned), respecting order + limit.

pub fn count_where(&self, filter: &TasksFilter) -> usize

Count tasks matching filter. Ignores limit.

pub fn exists_where(&self, filter: &TasksFilter) -> bool

True if any task matches filter. Short-circuits on first hit.

Trait Implementations

impl Clone for TasksState

fn clone(&self) -> TasksState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TasksState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TasksState

fn default() -> TasksState

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for TasksState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl RedexFold<TasksState> for TasksFold

fn apply( &mut self, ev: &RedexEvent, state: &mut TasksState, ) -> Result<(), RedexError>

Apply one event to state. Return an error to stop the fold.

impl Serialize for TasksState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.