apteryx/apteryx.proto at master · samuelvarley/apteryx · GitHub

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
package apteryx;

message NoResult
{
};

message PathValue
{
    required string path = 1;
    required string value = 2;
}

message OKResult
{
    required int32 result = 1;
};

message ValidateResult
{
    required int32 result = 1;
};

message Set
{
    repeated PathValue sets = 1;
    required uint64 ts = 2;
};

message Get
{
    required string path = 1;
};

message GetResult
{
    required string value = 1;
};

message Search
{
    required string path = 1;
};

message Find
{
    required string path = 1;
    repeated PathValue matches = 2;
}

message SearchResult
{
    repeated string paths = 1;
};

message Traverse
{
    required string path = 1;
};

message TraverseResult
{
    repeated PathValue pv = 1;
};

message Index
{
    required string path = 1;
    required uint64 id = 2;
    required uint64 cb = 3;
};

message Watch
{
    required string path = 1;
    required string value = 2;
    required uint64 id = 3;
    required uint64 cb = 4;
};

message Validate
{
    required string path = 1;
    required string value = 2;
    required uint64 id = 3;
    required uint64 cb = 4;
};

message Provide
{
    required string path = 1;
    required uint64 id = 2;
    required uint64 cb = 3;
};

message Prune
{
    required string path = 1;
};

message TimeStampResult
{
    required uint64 value = 1;
};

service server
{
    rpc set (Set) returns (OKResult);
    rpc get (Get) returns (GetResult);
    rpc search (Search) returns (SearchResult);
    rpc find (Find) returns (SearchResult);
    rpc traverse (Traverse) returns (TraverseResult);
    rpc prune (Prune) returns (OKResult);
    rpc timestamp (Get) returns (TimeStampResult);
}

service client
{
    rpc index (Index) returns (SearchResult);
    rpc watch (Watch) returns (NoResult);
    rpc provide (Provide) returns (GetResult);
    rpc validate (Validate) returns (ValidateResult);
}

message Ping
{
    required string value = 1;
};

service test
{
    rpc ping (Ping) returns (Ping);
}