diff options
Diffstat (limited to 'aclk/aclk-schemas/proto/chart/v1/stream.proto')
-rw-r--r-- | aclk/aclk-schemas/proto/chart/v1/stream.proto | 86 |
1 files changed, 0 insertions, 86 deletions
diff --git a/aclk/aclk-schemas/proto/chart/v1/stream.proto b/aclk/aclk-schemas/proto/chart/v1/stream.proto deleted file mode 100644 index 9473538f..00000000 --- a/aclk/aclk-schemas/proto/chart/v1/stream.proto +++ /dev/null @@ -1,86 +0,0 @@ -syntax = "proto3"; - -package chart.v1; - -import "google/protobuf/timestamp.proto"; - -import "proto/chart/v1/instance.proto"; -import "proto/chart/v1/dimension.proto"; - -option go_package = "chart/stream/v1;chartstream"; - -// StreamChartsAndDimensions is a Command produced by the Cloud, consumed by the Agent. -// -// It instructs the Agent to start sending ChartsAndDimensionsUpdated messages for a NodeInstance -// after the last sequence_id that the Cloud has successfully ingested. -message StreamChartsAndDimensions { - // claim_id, node_id pair is used to identify the Node Instance - string claim_id = 1; - string node_id = 2; - - // sequence_id last verified sequence sent by the Agent - uint64 sequence_id = 3; - // batch_id identifies the stream_id and gets incremented every time the Cloud sends a new StreamChartsAndDimensions command - uint64 batch_id = 4; - // seq_id_created_at autogenerated timestamp in Agent's DB upon sequence_id creation - google.protobuf.Timestamp seq_id_created_at = 5; -} - - -// ChartsAndDimensionsAck is an Event produced by the Cloud, consumed by the Agent. -// -// This Event is an acknowledgment from the Cloud side that Chart messages up to a specific last_sequence_id -// have been successfully ingested, and could be potentially deleted from the Agent's DB. -message ChartsAndDimensionsAck { - string claim_id = 1; - string node_id = 2; - // the last verified stored message's seq_id - uint64 last_sequence_id = 3; -} - -// ResetChartMessages is a Command produced by the Agent, consumed by the Cloud. -// -// This Command instructs the Cloud to clear its Chart state for a specific NodeInstance and re-sync -// because of a ResetReason. -message ResetChartMessages { - // claim_id, node_id pair is used to identify the Node Instance - string claim_id = 1; - string node_id = 2; - - ResetReason reason = 3; -} - -enum ResetReason { - DB_EMPTY = 0; - SEQ_ID_NOT_EXISTS = 1; - TIMESTAMP_MISMATCH = 2; -} - -// ChartsAndDimensionsUpdated is a wrapper Event (`fat` message) produced by the Agent, consumed by the Cloud. -// -// It potentially includes a collection of ChartInstanceUpdated messages and|or a collection of ChartDimensionUpdated messages. -message ChartsAndDimensionsUpdated { - repeated chart.v1.ChartInstanceUpdated charts = 1; - repeated chart.v1.ChartDimensionUpdated dimensions = 2; - uint64 batch_id = 3; -} - -// RetentionUpdated includes the available retentions (in seconds) of the dimensions - of a specific node instance and memory-mode - -// on a per update_every level. -// This message is sent over upon Agent Database rotation events to inform the Cloud in total about the newly updated data retentions -// of a node instance's dimensions. -message RetentionUpdated { - // claim_id, node_id pair is used to identify the Node Instance - string claim_id = 1; - string node_id = 2; - // the memory_mode used by the node instance's chart instances - chart.v1.MemoryMode memory_mode = 3; - // this mapping identifies the newly updated available retention (in seconds) of the node instance's dimensions - // the keys are the update_every categories of various dimensions (1, 2, 4, 10 etc.), - // and the values are the available retention (in seconds) of each dimension belonging to the update_every category - // denoted by the key - map<uint32, uint32> interval_durations = 4; - // the timestamp when the db rotation event took place. Can be used in conjunction with the interval_durations - // to compute the beginning of each `updated_every` group's retention - google.protobuf.Timestamp rotation_timestamp = 5; -} |