Clears all cache data. Called before a full rebuild.
Registers a callback for checkpoint-worthy cache mutations.
Callback invoked after a cache mutation with what it touched.
Function that unregisters the callback.
Records the timestamp of a successful durable save.
ISO timestamp written into the checkpoint.
Nothing.
What a feed's data is, once read.
The feed.
Its facts, or undefined before they are read.
Records what a feed's data is.
The feed.
What its first file said.
Removes a feed and all its instances from the cache.
Every instance the cache holds for a feed, whether or not its parent has arrived: the roll, in id order.
The feed.
The instance ids, ascending.
Returns every instance ID belonging to a feed, walking the anchor tree from its roots (breadth-first). Order is roots-first, then descendants.
Feed to enumerate.
All instance IDs in the feed's anchor tree.
Ends one feed's load annunciation.
The feed whose load finished or failed.
Marks one feed's load as failed where it stopped. The entry stays annunciated for a minute so the failure is seen, then is forgotten; the next visit starts a fresh walk.
The feed whose walk failed.
What the failure said.
When it failed (default now).
The feed load currently worth showing: the earliest still in flight.
The load in progress, or null when none is.
Records progress of one feed's topology load.
The feed being loaded.
Instances fetched so far.
The server's count, or zero while unknown.
One feed's load annunciation, by feed.
The feed in question.
The clock (default now), against which a failure expires.
The load in flight or lately failed, or null.
Every feed load worth showing, earliest first: the walks in flight and the failures still remembered. Two feeds can walk at once (an operator and a pane, or two panes), and each is index movement of its own.
The clock (default now), against which failures expire.
The loads, earliest first; empty when nothing moves.
Searches cached feeds by title or by name: a term is matched
case-insensitively against the title and against the feed's feed_N
name, so a bare id (4389), a name (feed_4389) and a title word all
find their feed.
The search term; empty matches every feed.
The matching feeds, in cache order.
Replaces the visible feed set while preserving topology for retained feeds.
Authoritative feeds visible to the current identity.
IDs requiring topology reconciliation because they are new, their aggregate job counts changed, or they still have active work.
Counts visible feeds in exclusive ownership, sharing, and public buckets.
Ownership takes precedence over public visibility so the buckets sum to the unique feed total.
Authenticated username whose owned feeds form user.
Exclusive scope counts whose components sum to total.
Creates one feed's persistence-safe snapshot: its instances (terminal status only, no params or output paths) and whether its topology is complete. A per-feed checkpoint shard is exactly this.
The feed to snapshot.
The feed's shard content; empty when the feed holds no instances.
Drops a feed's topology — its instances, roots and the loaded mark — and keeps its roster row, so a re-walk starts from nothing the cache remembers about the graph while the feed stays where the roster put it.
The feed whose topology is dropped.
Removes an instance from the topology cache.
Merges observed execution metrics onto an instance. Only defined values land, so a refresh that carries no timing never erases what warmup saw.
Searches cached instances by numeric ID or plugin name substring.
Returns the resolved join parent IDs for an instance, or an empty array when the node has none or they have not been resolved yet.
Instance ID.
Source instance IDs, or [].
Records the resolved topological-join parent IDs for a ts instance. Immutable
data — set once when the feed's join edges are first fetched.
Instance ID of the join (ts) node.
Source instance IDs it merges (beyond its anchor parent).
Returns a copy of the current cache lifecycle metadata.
Current cache state and checkpoint timestamp.
Changes the cache freshness state.
New lifecycle state.
Nothing.
Finds the closest cached job output containing a CFS path.
An output path is a directory boundary: /home/alice/run contains
/home/alice/run/result.txt, but not /home/alice/run-old.
Absolute CFS path to resolve against live-session outputs.
The closest producing instance, or undefined when no output path known in this session contains the path.
Stores the lazily resolved CUBE output path for one instance.
Plugin-instance ID whose output location was resolved.
Absolute CFS output directory, or null when absent.
Nothing.
Updates cached params for an instance (on first cat).
A feed's plugin names by first appearance, root first — the shape its pipeline left. A feed that ran dircopy, then dcm2niix, then fastsurfer shares its first two names with every feed that began the same way.
Read from the feed's roll, not its root walk: while a sweep is still bringing a feed in, an instance whose parent has not arrived counts as depth zero, and the chain settles as the parents land.
The feed.
The names, in order of the shallowest instance that bore each.
A feed's jobs collapsed by plugin per place in the pipeline: the shape with counts for weight. Jobs of one plugin under one parent group are one node; a fan of three hundred conversions is a node of 300.
The feed.
The groups, parents before children, root first.
Declares which folder each kind of feed appears in, so an arrival dirties the one listing whose membership actually changed.
A host may declare only what it knows. An unnamed folder is simply never marked, rather than every folder being marked because the roster could not tell them apart.
Folders by how this identity sees a feed.
Ends the roster's annunciation.
The roster walk in flight, if any.
The kind, or null when the roster is not moving.
Notes that the roster is being brought up to date: a delta (feeds newer than the highest known id) or the ten-minute full walk. Index movement no command announces; the prompt says it while it runs.
Which walk is in flight.
Feed IDs that hold any instances or a loaded mark — the feeds a full checkpoint must shard.
Feed IDs with persistent topology state.
Creates a persistence-safe snapshot without parameters or active statuses.
Serializable feed and terminal-topology state.
Replaces in-memory topology with a validated persistent snapshot.
Previously validated snapshot data.
ISO timestamp when the checkpoint was written.
Nothing.
Updates the cached status for an instance. Terminal (settled) statuses are never overwritten — once finished, a job's status is immutable.
Instance ID.
Fresh status observed from the API.
Removes instances absent from an authoritative topology sweep.
Instance IDs returned by the completed CUBE sweep.
Nothing.
The feeds the index read something of in the last while, each as it stands now: its size so far, its status, and the shape of its pipeline so far.
The clock, for the window.
The landed feeds, earliest landing first.
Marks feeds as NEW since the last visit.
The feeds to mark.
Takes the NEW mark off feeds the operator has looked at.
The feeds seen, or all.
How many marks were taken off.
The feeds marked NEW that the roster still holds.
Their ids.
Stops an unsuccessful warm-up without marking its topology complete.
Nothing.
Resets reconciliation progress while retaining restored topology.
Nothing.
Staticinstance_
Session-scoped cache of feed and instance topology with restorable terminal state.