DataStreamService class abstract

Store and retrieve data streams for study deployments.

Constructors

DataStreamService()

Properties

hashCode → int

The hash code for this object.

no setter, inherited

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

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