blob: 0d3d9a4b0713f52ff2725303784f782ac1689386 (
plain) (
blame)
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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
|
syntax = "proto3";
option cc_enable_arenas = true;
package NKikimrKeyValue;
option java_package = "ru.yandex.kikimr.proto";
option java_outer_classname = "KeyValueProtos";
option java_multiple_files = true;
message Priorities {
enum Priority {
PRIORITY_UNSPECIFIED = 0;
// High priority for user-initiated operations.
PRIORITY_REALTIME = 1;
// Low prioroty for background system activity.
PRIORITY_BACKGROUND = 2;
}
}
message Statuses {
enum ReplyStatus {
RSTATUS_UNSPECIFIED = 0;
RSTATUS_OK = 1;
RSTATUS_ERROR = 2;
RSTATUS_TIMEOUT = 3;
RSTATUS_INTERNAL_ERROR = 4;
RSTATUS_NOT_FOUND = 5;
RSTATUS_OVERRUN = 6;
RSTATUS_WRONG_LOCK_GENERATION = 7;
}
}
message StorageStatusFlags {
}
message Flags {
bool disk_space_cyan = 1;
bool disk_space_light_yellow_move = 2;
bool disk_space_yellow_stop = 3;
bool disk_space_light_orange = 4;
bool disk_space_orange = 5;
bool disk_space_red = 6;
bool disk_space_black = 7;
}
message StorageChannel {
enum StatusFlag {
STATUS_FLAG_UNSPECIFIED = 0;
STATUS_FLAG_GREEN = 10;
STATUS_FLAG_YELLOW_STOP = 20;
STATUS_FLAG_ORANGE_OUT_SPACE = 30;
}
Statuses.ReplyStatus status = 1;
uint32 storage_channel = 2;
StatusFlag status_flag = 3;
}
message KVRange {
oneof from_bound {
string from_key_inclusive = 1;
string from_key_exclusive = 2;
}
oneof to_bound {
string to_key_inclusive = 3;
string to_key_exclusive = 4;
}
}
message ReadRequest {
uint64 tablet_id = 1;
optional uint64 lock_generation = 2;
string key = 3;
uint64 offset = 4;
uint64 size = 5;
uint64 cookie = 6;
Priorities.Priority priority = 7;
uint64 deadline_instant_ms = 8;
uint64 limit_bytes = 9;
}
message ReadResult {
string requested_key = 1;
uint64 requested_offset = 2;
uint64 requested_size = 3;
bytes value = 4;
string msg = 5;
Statuses.ReplyStatus status = 6;
uint64 cookie = 7;
uint64 node_id = 8;
}
message ReadRangeRequest {
uint64 tablet_id = 1;
optional uint64 lock_generation = 2;
KVRange range = 3;
bool include_data = 4;
uint64 limit_bytes = 5;
Priorities.Priority priority = 6;
uint64 cookie = 7;
uint64 deadline_instant_ms = 8;
}
message ReadRangeResult {
message KeyValuePair {
string key = 1;
bytes value = 2;
uint32 value_size = 3;
// Unix time of the creation of the key-value pair (in ms).
uint64 creation_unix_time = 4;
uint32 storage_channel = 5; // Returns the _actual_ storage channel
Statuses.ReplyStatus status = 6;
}
Statuses.ReplyStatus status = 1;
string msg = 2;
repeated KeyValuePair pair = 3;
uint64 cookie = 4;
uint64 node_id = 5;
}
message ExecuteTransactionRequest {
message Command {
message Rename {
string old_key = 1;
string new_key = 2;
}
message Concat {
repeated string input_keys = 1;
string output_key = 2;
bool keep_inputs = 3;
}
message CopyRange {
KVRange range = 1;
string prefix_to_remove = 2;
string prefix_to_add = 3;
}
message Write {
enum Tactic {
TACTIC_UNSPECIFIED = 0;
TACTIC_MAX_THROUGHPUT = 1;
TACTIC_MIN_LATENCY = 2;
}
string key = 1;
bytes value = 2;
uint32 storage_channel = 3;
Priorities.Priority priority = 4;
Tactic tactic = 5;
}
message DeleteRange {
KVRange range = 1;
}
oneof action {
DeleteRange delete_range = 1;
Rename rename = 2;
CopyRange copy_range = 3;
Concat concat = 4;
Write write = 5;
}
}
uint64 tablet_id = 1;
optional uint64 lock_generation = 2;
repeated Command commands = 3;
uint64 cookie = 4;
uint64 deadline_instant_ms = 5;
}
message ExecuteTransactionResult {
repeated StorageChannel storage_channel = 1;
Statuses.ReplyStatus status = 2;
string msg = 3;
uint64 cookie = 4;
uint64 node_id = 5;
}
message GetStorageChannelStatusRequest {
uint64 tablet_id = 1;
optional uint64 lock_generation = 2;
repeated uint32 storage_channel = 3;
uint64 deadline_instant_ms = 4;
}
message GetStorageChannelStatusResult {
repeated StorageChannel storage_channel = 1;
Statuses.ReplyStatus status = 2;
string msg = 3;
uint64 node_id = 4;
}
message AcquireLockRequest {
uint64 tablet_id = 1;
uint64 cookie = 2;
}
message AcquireLockResult {
uint64 lock_generation = 1;
uint64 cookie = 2;
uint64 node_id = 3;
}
|
