NO_ERROR = 0
The request did not have an error.
KEY_DNE = 1
The requested key does not exist.
WRONG_THREAD = 2
The request was sent to the wrong thread, which is not responsible for the key.
TIMEOUT = 3
The request timed out.
LATTICE = 4
The lattice type was not correctly specified or conflicted with an existing key.
NO_SERVERS = 5
This error is returned by the routing tier if no servers are in the cluster.

string app_name = 1
repeated string functions = 2
repeated DataDependency dependencies = 3

Used in: FunctionRequest

bytes body = 1
uint32 arg_flag = 2
string data_address = 3

Used in: KeyNotifyRequest, KeyQueryRequest, KeyQueryResponse

string bucket = 2
The specified key.
string key = 3
string session = 4
repeated string ips = 5
The IPs of the set of servers responsible for this key.
bytes payload = 6
uint32 count = 6;

A protobuf to represent an individual key, both for requests and responses.

string bucket = 1
The key name for this request/response.
string key = 2
string session = 3
bytes payload = 4

BucketOperationType operation_type = 1
string app_name = 2
string bucket_name = 3
string request_id = 4
string response_address = 5

BucketOperationType operation_type = 1
string bucket_name = 2
string response_id = 3
KVSError error = 4

Used in: BucketOperationRequest, BucketOperationResponse

CREATE_BUCKET = 0
create bucket.
DELETE_BUCKET = 1
delete bucket

string function = 1
The function to trigger, can be name, http endpoint, etc.
uint32 count = 2

string function = 1
The function to trigger, can be name, http endpoint, etc.
string key_name = 2

string function = 1
The function to trigger, can be name, http endpoint, etc.
repeated string key_set = 2

string function = 1
The function to trigger, can be name, http endpoint, etc.
uint32 time_window = 2

string application = 1
string request_id = 2

string coord_ip = 1
uint32 thread_id = 2
string request_id = 3

string public_ip = 1
string private_ip = 2
uint32 thread_id = 3
uint32 workload = 4
optional

Used in: AppRegistration, UpdateCoordMsg

DependencyType type = 1
repeated string src_functions = 2
repeated string tgt_functions = 3
bytes description = 4

Used in: DataDependency

DIRECT = 0
MANY_TO_ONE = 1
K_OUT_OF_N = 2
PERIODIC = 3
CONDITION = 4;

string function = 1
repeated string control_group = 2

string name = 1
The name of this function.
FunctionLang lang = 2
bytes body = 3
The serialized representation of this function.

A request to execute a pre-registered function a single time.

string app_name = 1
The name of the fucntion to execute.
repeated FunctionRequest requests = 2
string source = 3
the worker issuing internal call (optional)
string request_id = 4
A unique ID used to match asynchronous requests to responses.
string resp_address = 5
the client address, used for synchronous requests.
string session_id = 6
the session ID generated by platform
bool sync_data_status = 7
internal field used for indicating the need of synchronizations between scheduler and coordinator

string app_name = 1
string request_id = 2
bytes output = 3
string response_key = 3;
uint32 error_no = 4

Used in: Function

CPP = 0
PYTHON = 1

Used in: FunctionCall

string name = 1
repeated Argument arguments = 2
The arguments to be passed into the function.

REMOTE_GET = 0
remote Get reponse
NOTIF_PUT = 1
put notifying reponse

string function = 1
The function to trigger, can be name, http endpoint, etc.

Used in: BucketOperationResponse, KeyNotifyResponse, KeyQueryResponse, TriggerOperationResponse

SUCCESS = 0
The request did not have an error.
BUCKET_NE = 1
The requested bucket/key does not exist, which are given by coordinator.
KEY_NE = 2
SESSION_NE = 3
KVS_ND = 4
The remote servers have no (requested) data, which are given by remote KVS.
TYPE_NM = 5
The value type does not match.
BUCKET_EXIST = 6
the bucket exists, which may be caused by bucket creation.
REQ_TIMEOUT = 7
The request timed out.

A request to the routing tier to retrieve server addresses corresponding to individual keys.

string response_address = 1
The IP-port pair at which the client will await a response.
repeated string keys = 2
The names of the requested keys.
string request_id = 3
A unique ID used by the client to match asynchornous requests with responses.

A 1-to-1 response from the routing tier for individual KeyAddressRequests.

repeated KeyAddressResponse.KeyAddress addresses = 1
A batch of responses for individual keys.
AnnaError error = 2
An error reported by the routing tier. This should only ever be a timeout.
string response_id = 3
A unique ID used by the client to match asynchronous requests with responses.

A mapping from individual keys to the set of servers responsible for that key.

Used in: KeyAddressResponse

string key = 1
The specified key.
repeated string ips = 2
The IPs of the set of servers responsible for this key.

string response_address = 1
The IP-port pair at which the client will await a response.
repeated BucketKeyAddress addresses = 2
The names of the requested keys.
repeated string active_trigger_names = 3
string request_id = 4
A unique ID used by the client to match asynchornous requests with responses.

KVSError error = 1
repeated uint32 key_counts = 2
string response_id = 3
A unique ID used by the client to match asynchronous requests with responses.

string response_address = 1
The IP-port pair at which the client will await a response.
repeated BucketKeyAddress addresses = 2
The names of the requested keys.
string request_id = 3
A unique ID used by the client to match asynchornous requests with responses.

repeated BucketKeyAddress addresses = 1
A batch of responses for individual keys.
KVSError error = 2
An error reported by the routing tier.
string response_id = 3
A unique ID used by the client to match asynchronous requests with responses.

An individual GET or PUT request; each request can batch multiple keys.

RequestType type = 1
The type of this request (see RequestType).
repeated KeyTuple tuples = 2
A list of KeyTuples batched in this request.
string response_address = 3
The IP-port pair at which the client is waiting for the server's response.
string request_id = 4
A client-specific ID used to match asynchronous requests with responses.

FETCH = 0
fetch remote data (tmp).

A response to a KeyRequest.

RequestType type = 1
The type of response being sent back to the client (see RequestType).
repeated KeyTuple tuples = 2
The individual response pairs associated with this request. There is a 1-to-1 mapping between these and the KeyTuples in the corresponding KeyRequest.
string response_id = 3
The request_id specified in the corresponding KeyRequest. Used to associate asynchornous requests and responses.
AnnaError error = 4
Any errors associated with the whole request. Individual tuple errors are captured in the corresponding KeyTuple. This will only be set if the whole request times out.

A protobuf to represent an individual key, both for requests and responses.

Used in: KeyRequest, KeyResponse

string key = 1
The key name for this request/response.
LatticeType lattice_type = 2
The lattice type for this key. Only required for server responses and PUT requests.
AnnaError error = 3
The error type specified by the server (see AnnaError).
bytes payload = 4
The data associated with this key.
uint32 address_cache_size = 5
The number of server addresses the client is aware of for a particular key; used for DHT membership change optimization.
bool invalidate = 6
A boolean set by the server if the client's address_cache_size does not match the metadata stored by the server.

A message representing a pointer to a particular version of a particular key.

Used in: KeyVersionList, MultiKeyCausalValue

string key = 1
The name of the key we are referencing.
map<string, uint32> vector_clock = 2
A vector clock for the version of the key we are referencing.

A wrapper message for a list of KeyVersions.

repeated KeyVersion keys = 1
The list of KeyVersion references.

Serialization of last-write wins lattices.

uint64 timestamp = 1
The last-writer wins timestamp associated with this data.
bytes value = 2
The actual data stored by this LWWValue.

Used in: KeyTuple

NONE = 0
No lattice type specified
LWW = 1
Last-writer wins lattice
SET = 2
Unordered set lattice
SINGLE_CAUSAL = 3
Single-key causal lattice
MULTI_CAUSAL = 4
Multi-key causal lattice
ORDERED_SET = 5
Ordered-set lattice
PRIORITY = 6
Priority lattice

An individual multi-key causal lattice, along with its associated dependencies.

map<string, uint32> vector_clock = 1
The vector clock associated with this particular key.
repeated KeyVersion dependencies = 2
The mapping from keys to vector clocks for each of the direct causal dependencies this key has.
repeated bytes values = 3
The set of potentially causally concurrent values for this key.

Used in: TriggerEntity, TriggerOperationRequest

IMMEDIATE = 0
BY_NAME = 1
BY_BATCH_SIZE = 2
BY_SET = 3
DYNAMIC_GROUP = 4
REDUNDANT = 5
BY_TIME = 6

Serialization of lowest-priority-wins lattices.

double priority = 1
The priority associated with this data
bytes value = 2
The actual data stored by this PriorityValue

string function = 1
uint32 k = 2
uint32 n = 3

An enum to differentiate between different KVS requests.

Used in: KeyRequest, KeyResponse

RT_UNSPECIFIED = 0
A default type to capture unspecified requests.
GET = 1
A request to retrieve data from the KVS.
PUT = 2
A request to put data into the KVS.

Used in: TriggerEntity, TriggerOperationRequest

string source_function = 1
string source_key = 2
uint32 timeout = 3

Serialization of unordered set lattices.

repeated bytes values = 1
An unordered set of values in this lattice.

Serialization of a single-key causal lattice.

map<string, uint32> vector_clock = 1
The vector clock for this key, which maps from unique client IDs to monotonically increasing integers.
repeated bytes values = 2
The set of values associated with this causal value. There will only be more than one here if there are multiple causally concurrent updates.

An arbitrary set of strings; used for a variety of purposes across the system.

repeated string keys = 1
An unordered set of keys.

Used in: UpdateCoordMsg

string bucket_name = 1
string trigger_name = 2
uint32 trigger_option = 3
PrimitiveType primitive_type = 4
bytes primitive = 5
string session = 6
repeated RerunHint hints = 7

TriggerOperationType operation_type = 1
string app_name = 2
string bucket_name = 3
string trigger_name = 4
uint32 trigger_option = 5
PrimitiveType primitive_type = 6
bytes primitive = 7
string request_id = 8
string response_address = 9
repeated RerunHint hints = 10
hints for re-execution

TriggerOperationType operation_type = 1
string bucket_name = 2
string trigger_name = 3
string response_id = 4
KVSError error = 5

Used in: TriggerOperationRequest, TriggerOperationResponse

ADD_TRIGGER = 0
manage triggers
DELETE_TRIGGER = 1

string ip = 1
uint32 thread_id = 2
string app_name = 3
repeated string functions = 4
repeated DataDependency dependencies = 5
repeated TriggerEntity triggers = 6
uint32 msg_type = 7

message UpdateStatusMessage

operation.proto:276

string ip = 1
uint32 avail_executors = 2
repeated string functions = 3

Default package

enum AnnaError

NO_ERROR = 0

KEY_DNE = 1

WRONG_THREAD = 2

TIMEOUT = 3

LATTICE = 4

NO_SERVERS = 5

message AppRegistration

string app_name = 1

repeated string functions = 2

repeated DataDependency dependencies = 3

message Argument

bytes body = 1

uint32 arg_flag = 2

string data_address = 3

message BucketKeyAddress

string bucket = 2

string key = 3

string session = 4

repeated string ips = 5

bytes payload = 6

message BucketKeyTuple

string bucket = 1

string key = 2

string session = 3

bytes payload = 4

message BucketOperationRequest

BucketOperationType operation_type = 1

string app_name = 2

string bucket_name = 3

string request_id = 4

string response_address = 5

message BucketOperationResponse

BucketOperationType operation_type = 1

string bucket_name = 2

string response_id = 3

KVSError error = 4

enum BucketOperationType

CREATE_BUCKET = 0

DELETE_BUCKET = 1

message ByBatchSizePrimitive

string function = 1

uint32 count = 2

message ByNamePrimitive

string function = 1

string key_name = 2

message BySetPrimitive

string function = 1

repeated string key_set = 2

message ByTimePrimitive

string function = 1

uint32 time_window = 2

message CoordQuery

string application = 1

string request_id = 2

message CoordResponse

string coord_ip = 1

uint32 thread_id = 2

string request_id = 3

message CoordSync

string public_ip = 1

string private_ip = 2

uint32 thread_id = 3

uint32 workload = 4

message DataDependency

DependencyType type = 1

repeated string src_functions = 2

repeated string tgt_functions = 3

bytes description = 4

enum DependencyType

DIRECT = 0

MANY_TO_ONE = 1

K_OUT_OF_N = 2

PERIODIC = 3

message DynamicGroupPrimitive

string function = 1

repeated string control_group = 2

message Function

string name = 1