Enum Subject 

pub enum Subject {
    Home,
    Board,
    Session(SessionSlot),
    Usage,
    DictateModels,
    Extensions,
}

What a client can watch. A subscription names one of these and is answered with that subject’s snapshot.

Variants

Home

Board

Every project’s board detail: its rows, its schedules and its connector subscriptions.

A subject of its own rather than fields of Subject::Home because the board is its own page’s data: the home is a glance at the fleet, and carrying every project’s rows made a home read about 708 KB, most of it board data a home page draws none of (#2517).

Session(SessionSlot)

Usage

The token/cost pool, scanned on the ask.

It belongs to no seat - the report is the whole session-JSONL pool, bucketed by project and model - and no update carries it: the pool changes as transcripts are written, and nothing in the stream says a transcript’s tokens moved. So a subscription is answered with one scan and hears nothing after it, and a client asks again by subscribing again.

DictateModels

The models page’s read: the pinned models, the catalogue check, the feed’s rows and the updates it proposes.

Carried as a subject of its own rather than inside Home because the rows are the whole catalogue and only the models page draws them. Unlike Usage it does hear updates: a check landing, boot’s or a page’s own, arrives as SessionUpdate::DictateModelsChanged.

Extensions

The Extensions page’s read: the plugin inventory, the marketplace health and the last update run.

A subject of its own for DictateModels’ reason - only the Extensions page draws any of it - and it hears the whole Plugins* family: an action’s outcome, a run’s progress, and the refreshed inventory are all news about what this subscription is showing.

Implementations

impl Subject

pub fn covers(&self, update: &SessionUpdate) -> bool

Whether an update belongs to what this subscription asked for.

A session subscription is a seat, so the workspace is ASKED which seat a variant routes to rather than this matching the variants itself.

A home subscription is a row per seat plus the App-level facts, and it takes the classification that already exists for the row half: fleet_news, which is what the view folding this stream draws the fleet from. It is narrow on purpose - a row states a seat’s lifecycle, its status and its pending state, and no row shows a word of its conversation - so a second table of variants here would both drift and hand a home subscriber every token of every seat in the fleet.

The fleet region is not the whole home. Two home fields carry no slot and are not fleet news: the service status and the fatal error. They come with the slot-less arm below, and without it a client would draw what it read once at subscribe for the life of the connection. The account pool is a home field too, but its announcement is also a fleet redraw, so it arrives through the first arm.

That arm is wider than the client’s read rule, by the plugin family. The plugin records cross to a home subscriber only because they name no seat; no field of the home snapshot carries them, their reader is the extensions subject, and coversHome (client/src/wire/fleet.ts) declines the home read for them on purpose. Delivery here is the superset.

Trait Implementations

impl Clone for Subject

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Subject

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Subject

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Subject

impl PartialEq for Subject

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for Subject

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 Subject