Skip to content

Local Time Series Storage Engine

Purpose

The Local Time Series Storage Engine provides local storage and retrieval of time series data.

State

Messages received

GetDataTimeSeriesDBRequest

Get the queried time series data and return it.

Reception:

GetDataTimeSeriesDBRequestV1

Records with fields:

The query that finds the requested time series data in the DB.

Triggers

GetDataTimeSeriesDBResponseV1

Records with fields:

The query that finds the requested time series data in the DB.

The requested time series data.

RecordDataTimeSeriesDBRequest

Add time series data to the DB.

Reception:

RecordDataTimeSeriesDBRequestV1

Records with fields:

The query that expresses the addition of the time series data into the DB.

Triggers

RecordDataTimeSeriesDBResponseV1

Records with fields:

The query that expresses the recording of the time series data into the DB.

The success of the operation, indicating that the KV-pair was stored successfully or not.

DeleteDataTimeSeriesDBRequest

Delete time series data from the DB.

Reception:

DeleteDataTimeSeriesDBRequestV1

Records with fields:

The query that expresses the deletion of the time series data from the DB.

Triggers

DeleteDataTimeSeriesDBResponseV1

Records with fields:

The query that expresses the deletion of the time series data from the DB.

The success of the operation, indicating that the KV-pair was deleted successfully or not.

Notifications sent

DataChangedTimeSeriesDB

When the value in the time series DB changes, engines interested in this information get notified.

Records with fields:

The query that expresses the desire change of the time series DB.

The changed time series data.

The wall clock time of the moment the data was changed.

Message Flow

sequenceDiagram

%% --8<-- [start:sequence]
Any Local Engine ->>+ Local Time Series Storage Engine: GetDataTimeSeriesDBRequest
Local Time Series Storage Engine -->>- Any Local Engine: GetDataTimeSeriesDBResponse
Any Local Engine ->>+ Local Time Series Storage Engine: RecordDataTimeSeriesDBRequest
Local Time Series Storage Engine -->>- Any Local Engine: RecordDataTimeSeriesDBResponse
Any Local Engine ->>+ Local Time Series Storage Engine: DeleteDataTimeSeriesDBRequest
Local Time Series Storage Engine -->>- Any Local Engine: DeleteDataTimeSeriesDBResponse
%% --8<-- [end:sequence]