summaryrefslogtreecommitdiffstats
path: root/aclk/aclk-schemas/proto/context/v1/stream.proto
blob: a6e7e3abf28b3dc26d61c0615e89d6321d11e23e (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
syntax = "proto3";

package context.v1;

option go_package = "context/v1;context";

// ContextsCheckpoint is a Command produced by the Cloud, consumed by the Agent.
//
// It informs the Agent the contexts' version_hash that the cloud has for a specific NodeInstance.
message ContextsCheckpoint {
    // claim_id, node_id pair is used to identify the NodeInstance.
    string claim_id = 1;
    string node_id = 2;
    // version_hash tells the Agent the current version hash for the contexts received
    // if the version hash calculated by the Agent is different, Agent will request
    // to re-sync all contexts.
    uint64 version_hash= 3;
}

// StopStreamingContexts is a Command produced by the Cloud, consumed by the Agent.
//
// It instructs the Agent to stop sending ContextsUpdated messages for a NodeInstance
// due to a reason.
message StopStreamingContexts {
    // claim_id, node_id pair is used to identify the node instance
    string claim_id = 1;
    string node_id = 2;
    
    StopStreamingContextsReason reason = 3;
}

enum StopStreamingContextsReason {
  RATE_LIMIT_EXCEEDED = 0;
}