DataStreamService class abstract

Store and retrieve data streams for study deployments.

Constructors

DataStreamService()

Properties

hashCode → int
The hash code for this object.
no setterinherited
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited

Methods

appendToDataStreams(String studyDeploymentId, List<DataStreamBatch> batch) → Future<void>
Append a batch of data measures to corresponding data streams in studyDeploymentId.
closeDataStreams(List<String> studyDeploymentIds) → Future<void>
Stop accepting incoming data for all data streams for each of the studyDeploymentIds.
getDataStream(DataStreamId dataStream, int fromSequenceId, [int? toSequenceIdInclusive]) → Future<List<DataStreamBatch>>
Retrieve all data points in dataStream that fall within the inclusive range defined by fromSequenceId and toSequenceIdInclusive. If toSequenceIdInclusive is null, all data points starting fromSequenceId are returned.
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
openDataStreams(DataStreamsConfiguration configuration) → Future<void>
Start accepting data for a study deployment for data streams configured in configuration.
removeDataStreams(List<String> studyDeploymentIds) → Future<Set<String>>
Close data streams and remove all data for each of the studyDeploymentIds.
toString() → String
A string representation of this object.
inherited

Operators

operator ==(Object other) → bool
The equality operator.
inherited

Constants

API_VERSION → const String