Struct ReadCursor 

pub struct ReadCursor {
    pub did: String,
    pub feed_url: String,
    pub read_through: Option<String>,
    pub read_ids: String,
    pub unread_ids: String,
    pub dirty: bool,
    pub pds_created: bool,
    pub updated_at: String,
}

Per-(did, feed_url) read cursor — the local mirror of the PDS community.lexicon.rss.readState record plus flush bookkeeping.

read_ids / unread_ids are stored as JSON arrays of entry ids (the two bounded exception sets around the read_through high-water-mark); dirty marks that local entry_state has changed since the last PDS flush.

Fields

did: String

feed_url: String

read_through: Option<String>

High-water-mark (RFC3339): every entry seen/published <= this is read.

read_ids: String

JSON array of entry ids newer than read_through that are also read.

unread_ids: String

JSON array of entry ids older than read_through explicitly kept unread.

dirty: bool

Set when entry_state changed since the last flush (debounce trigger).

pds_created: bool

Whether this cursor’s readState record has been CREATED in the PDS yet. The first flush of a feed must emit an applyWrites#create (an #update errors on a record that does not pre-exist, and applyWrites is atomic per-repo, so one not-yet-created cursor would drop the whole DID batch). Flipped to true on the flush that creates it.

updated_at: String

Trait Implementations

impl Clone for ReadCursor

fn clone(&self) -> ReadCursor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReadCursor

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

Formats the value using the given formatter.

impl Eq for ReadCursor

impl<'a, R: Row> FromRow<'a, R> for ReadCursor

where &'a str: ColumnIndex<R>, String: Decode<'a, R::Database> + Type<R::Database>, Option<String>: Decode<'a, R::Database> + Type<R::Database>, bool: Decode<'a, R::Database> + Type<R::Database>,

fn from_row(__row: &'a R) -> Result<Self>

impl PartialEq for ReadCursor

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ReadCursor