river-data-core 0.11.0

Client, sync runner, and shared types for the river-data platform
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

mod annotations;
mod backend;
mod config;
mod protocol;
mod replicates;
mod status;
mod streams;

pub use annotations::{AnnotationMapping, AnnotationUpsert, NoteMapping, NoteUpsert};
pub use backend::{
    DeclinedChannel, SourceCandidate, SourceInventory, SourceWindow, StreamDescriptor,
    StreamFetchRequest, StreamReadings, StreamStatusEvents,
};
pub use config::RunnerConfig;
pub use protocol::{
    CommandUpdateRequest, EnrollRequest, EnrollResponse, HeartbeatRequest, HeartbeatResponse,
    PendingCommand, SyncEventCreate, SyncEventRef, SyncEventUpdate, SyncResult, SyncTrigger,
};
pub use replicates::{
    ColumnAssignment, CurveMapping, GroupAudit, ReplicateSpec, SensorMapping, SensorUpsert,
    StandardCurveUpsert,
};
pub use status::{CommandStatus, ServiceStatus, SyncEventStatus, SyncEventType};
pub use streams::{DataStream, IngestReading, IngestStatusEvent, RegisterStreamRequest};