Module models

Structs§

CommandUpdateRequest
DataStream
EnrollRequest
EnrollResponse
HeartbeatRequest
HeartbeatResponse
IngestReading
IngestStatusEvent
PendingCommand
RegisterStreamRequest
RunnerConfig
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.