Module models 

Structs

ColumnAssignment

One source column’s pinned replicate index, as the API’s register response reports it (and as stream metadata persists it under replicates.assignments). Sync services assign each value’s replicate_index by looking its source column up here.

CommandUpdateRequest

CurveMapping

The API-side identity a registered curve resolved to.

DataStream

EnrollRequest

EnrollResponse

GroupAudit

Portal-precomputed mean/sd for one replicate group, sent alongside the group’s readings so the API can compare server-side.

HeartbeatRequest

HeartbeatResponse

IngestReading

IngestStatusEvent

PendingCommand

RegisterStreamRequest

ReplicateSpec

Replicate-family declaration on a stream registration. The API pins each column’s replicate_index server-side (append-only across re-registrations) and returns the authoritative mapping as ColumnAssignments on the register response; source_columns order is provenance, not the index. The API requires at least two unique columns and measurement_type: "spot" on the request.

RunnerConfig

SourceWindow

A completeness claim over one stream: the readings sent alongside are the COMPLETE content of the source for this stream over [from, to), read from source_rows_read source rows. The server diffs stored content against the payload and converges (new / changed / withdrawn); without a window the request is a bare append, exactly the old semantics.

StandardCurveUpsert

One portal standard curve to register. source_key identifies the curve within the source system; registration is idempotent per (source_system, source_key).

StreamDescriptor

Describes a data stream to register with river-data.

StreamFetchRequest

Asks a backend for readings for one stream since a cursor.

StreamReadings

Readings fetched for one stream, ready to ingest.

StreamStatusEvents

Status events fetched for one stream.

SyncEventCreate

SyncEventRef

SyncEventUpdate

SyncResult

Outcome of one sync cycle. The runner fills full_sync and duration_ms; a SyncService only reports counts, errors and log lines.

Enums

CommandStatus

ServiceStatus

SyncEventStatus

SyncEventType

SyncTrigger