Struct ReadState 

pub struct ReadState {
    pub type: String,
    pub feed_url: String,
    pub read_through: Option<String>,
    pub read_ids: Vec<String>,
    pub unread_ids: Vec<String>,
    pub updated_at: String,
}

community.lexicon.rss.readState — a batched read high-water-mark for a single feed. Record key: any; the rkey is derived deterministically from the feed (a hash of the feed URL), so there is one record per feed with a stable key, NOT one record per article.

feedUrl + updatedAt are required; readThrough is OPTIONAL — it is a water-mark (“every entry seen/published <= this is read”), so it is written only once a real high-water-mark exists. Omitting it (rather than synthesizing a flush-time value) means a brand-new cursor asserts nothing about the backlog: only the explicit readIds mark entries read. The two capped id-sets carry out-of-order reads and explicit mark-unread exceptions.

Fields

type: String

The $type NSID discriminator; always nsid::READ_STATE.

feed_url: String

The feed this cursor covers. Required.

read_through: Option<String>

High-water-mark: every entry with seen/published time <= this is READ. Optional — omitted from the record when no local high-water-mark exists yet, so a fresh cursor never implicitly marks the backlog read.

read_ids: Vec<String>

Entries newer than readThrough that are ALSO read (out-of-order reads). Capped at 1000 by the lexicon; empty sets are omitted from the record.

unread_ids: Vec<String>

Entries older than readThrough explicitly kept UNREAD (mark-unread). Capped at 1000 by the lexicon; empty sets are omitted from the record.

updated_at: String

Last time this cursor was flushed (ISO-8601 datetime). Required. Intended as the tie-breaker for cross-device merges (newest updatedAt wins); a login-time reconcile that uses it is not implemented yet.

Implementations

impl ReadState

pub const MAX_IDS: usize = 1000

Maximum length of the readIds / unreadIds exception sets, per the lexicon. The flusher enforces this cap before writing (see scheduler::cap).

pub fn new( feed_url: impl Into<String>, read_through: Option<String>, updated_at: impl Into<String>, ) -> Self

Construct a minimal read cursor with only the required fields.

read_through is optional: pass None for a cursor that has no local high-water-mark yet, so the record omits readThrough entirely rather than synthesizing a flush-time value that would mark the backlog read.

Trait Implementations

impl Clone for ReadState

fn clone(&self) -> ReadState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReadState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ReadState

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ReadState

impl PartialEq for ReadState

fn eq(&self, other: &ReadState) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for ReadState

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ReadState