river-data-core 0.10.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

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

pub use annotations::{AnnotationMapping, AnnotationUpsert};
pub use backend::{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, StandardCurveUpsert,
};
pub use status::{CommandStatus, ServiceStatus, SyncEventStatus, SyncEventType};
pub use streams::{DataStream, IngestReading, IngestStatusEvent, RegisterStreamRequest};