1
2
3
4
5
6
7 package ttrpc
8
9 import (
10 status "google.golang.org/genproto/googleapis/rpc/status"
11 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
12 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
13 reflect "reflect"
14 sync "sync"
15 )
16
17 const (
18
19 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
20
21 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
22 )
23
24 type Request struct {
25 state protoimpl.MessageState
26 sizeCache protoimpl.SizeCache
27 unknownFields protoimpl.UnknownFields
28
29 Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
30 Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
31 Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
32 TimeoutNano int64 `protobuf:"varint,4,opt,name=timeout_nano,json=timeoutNano,proto3" json:"timeout_nano,omitempty"`
33 Metadata []*KeyValue `protobuf:"bytes,5,rep,name=metadata,proto3" json:"metadata,omitempty"`
34 }
35
36 func (x *Request) Reset() {
37 *x = Request{}
38 if protoimpl.UnsafeEnabled {
39 mi := &file_github_com_containerd_ttrpc_request_proto_msgTypes[0]
40 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
41 ms.StoreMessageInfo(mi)
42 }
43 }
44
45 func (x *Request) String() string {
46 return protoimpl.X.MessageStringOf(x)
47 }
48
49 func (*Request) ProtoMessage() {}
50
51 func (x *Request) ProtoReflect() protoreflect.Message {
52 mi := &file_github_com_containerd_ttrpc_request_proto_msgTypes[0]
53 if protoimpl.UnsafeEnabled && x != nil {
54 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
55 if ms.LoadMessageInfo() == nil {
56 ms.StoreMessageInfo(mi)
57 }
58 return ms
59 }
60 return mi.MessageOf(x)
61 }
62
63
64 func (*Request) Descriptor() ([]byte, []int) {
65 return file_github_com_containerd_ttrpc_request_proto_rawDescGZIP(), []int{0}
66 }
67
68 func (x *Request) GetService() string {
69 if x != nil {
70 return x.Service
71 }
72 return ""
73 }
74
75 func (x *Request) GetMethod() string {
76 if x != nil {
77 return x.Method
78 }
79 return ""
80 }
81
82 func (x *Request) GetPayload() []byte {
83 if x != nil {
84 return x.Payload
85 }
86 return nil
87 }
88
89 func (x *Request) GetTimeoutNano() int64 {
90 if x != nil {
91 return x.TimeoutNano
92 }
93 return 0
94 }
95
96 func (x *Request) GetMetadata() []*KeyValue {
97 if x != nil {
98 return x.Metadata
99 }
100 return nil
101 }
102
103 type Response struct {
104 state protoimpl.MessageState
105 sizeCache protoimpl.SizeCache
106 unknownFields protoimpl.UnknownFields
107
108 Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
109 Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
110 }
111
112 func (x *Response) Reset() {
113 *x = Response{}
114 if protoimpl.UnsafeEnabled {
115 mi := &file_github_com_containerd_ttrpc_request_proto_msgTypes[1]
116 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
117 ms.StoreMessageInfo(mi)
118 }
119 }
120
121 func (x *Response) String() string {
122 return protoimpl.X.MessageStringOf(x)
123 }
124
125 func (*Response) ProtoMessage() {}
126
127 func (x *Response) ProtoReflect() protoreflect.Message {
128 mi := &file_github_com_containerd_ttrpc_request_proto_msgTypes[1]
129 if protoimpl.UnsafeEnabled && x != nil {
130 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
131 if ms.LoadMessageInfo() == nil {
132 ms.StoreMessageInfo(mi)
133 }
134 return ms
135 }
136 return mi.MessageOf(x)
137 }
138
139
140 func (*Response) Descriptor() ([]byte, []int) {
141 return file_github_com_containerd_ttrpc_request_proto_rawDescGZIP(), []int{1}
142 }
143
144 func (x *Response) GetStatus() *status.Status {
145 if x != nil {
146 return x.Status
147 }
148 return nil
149 }
150
151 func (x *Response) GetPayload() []byte {
152 if x != nil {
153 return x.Payload
154 }
155 return nil
156 }
157
158 type StringList struct {
159 state protoimpl.MessageState
160 sizeCache protoimpl.SizeCache
161 unknownFields protoimpl.UnknownFields
162
163 List []string `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
164 }
165
166 func (x *StringList) Reset() {
167 *x = StringList{}
168 if protoimpl.UnsafeEnabled {
169 mi := &file_github_com_containerd_ttrpc_request_proto_msgTypes[2]
170 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
171 ms.StoreMessageInfo(mi)
172 }
173 }
174
175 func (x *StringList) String() string {
176 return protoimpl.X.MessageStringOf(x)
177 }
178
179 func (*StringList) ProtoMessage() {}
180
181 func (x *StringList) ProtoReflect() protoreflect.Message {
182 mi := &file_github_com_containerd_ttrpc_request_proto_msgTypes[2]
183 if protoimpl.UnsafeEnabled && x != nil {
184 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
185 if ms.LoadMessageInfo() == nil {
186 ms.StoreMessageInfo(mi)
187 }
188 return ms
189 }
190 return mi.MessageOf(x)
191 }
192
193
194 func (*StringList) Descriptor() ([]byte, []int) {
195 return file_github_com_containerd_ttrpc_request_proto_rawDescGZIP(), []int{2}
196 }
197
198 func (x *StringList) GetList() []string {
199 if x != nil {
200 return x.List
201 }
202 return nil
203 }
204
205 type KeyValue struct {
206 state protoimpl.MessageState
207 sizeCache protoimpl.SizeCache
208 unknownFields protoimpl.UnknownFields
209
210 Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
211 Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
212 }
213
214 func (x *KeyValue) Reset() {
215 *x = KeyValue{}
216 if protoimpl.UnsafeEnabled {
217 mi := &file_github_com_containerd_ttrpc_request_proto_msgTypes[3]
218 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
219 ms.StoreMessageInfo(mi)
220 }
221 }
222
223 func (x *KeyValue) String() string {
224 return protoimpl.X.MessageStringOf(x)
225 }
226
227 func (*KeyValue) ProtoMessage() {}
228
229 func (x *KeyValue) ProtoReflect() protoreflect.Message {
230 mi := &file_github_com_containerd_ttrpc_request_proto_msgTypes[3]
231 if protoimpl.UnsafeEnabled && x != nil {
232 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
233 if ms.LoadMessageInfo() == nil {
234 ms.StoreMessageInfo(mi)
235 }
236 return ms
237 }
238 return mi.MessageOf(x)
239 }
240
241
242 func (*KeyValue) Descriptor() ([]byte, []int) {
243 return file_github_com_containerd_ttrpc_request_proto_rawDescGZIP(), []int{3}
244 }
245
246 func (x *KeyValue) GetKey() string {
247 if x != nil {
248 return x.Key
249 }
250 return ""
251 }
252
253 func (x *KeyValue) GetValue() string {
254 if x != nil {
255 return x.Value
256 }
257 return ""
258 }
259
260 var File_github_com_containerd_ttrpc_request_proto protoreflect.FileDescriptor
261
262 var file_github_com_containerd_ttrpc_request_proto_rawDesc = []byte{
263 0x0a, 0x29, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x63, 0x6f, 0x6e,
264 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x64, 0x2f, 0x74, 0x74, 0x72, 0x70, 0x63, 0x2f, 0x72, 0x65,
265 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x05, 0x74, 0x74, 0x72,
266 0x70, 0x63, 0x1a, 0x12, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
267 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xa5, 0x01, 0x0a, 0x07, 0x52, 0x65, 0x71, 0x75, 0x65,
268 0x73, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x18, 0x01, 0x20,
269 0x01, 0x28, 0x09, 0x52, 0x07, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x16, 0x0a, 0x06,
270 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x6d, 0x65,
271 0x74, 0x68, 0x6f, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x18,
272 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x21,
273 0x0a, 0x0c, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x5f, 0x6e, 0x61, 0x6e, 0x6f, 0x18, 0x04,
274 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x4e, 0x61, 0x6e,
275 0x6f, 0x12, 0x2b, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x05, 0x20,
276 0x03, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x74, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x4b, 0x65, 0x79, 0x56,
277 0x61, 0x6c, 0x75, 0x65, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0x45,
278 0x0a, 0x08, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1f, 0x0a, 0x06, 0x73, 0x74,
279 0x61, 0x74, 0x75, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x07, 0x2e, 0x53, 0x74, 0x61,
280 0x74, 0x75, 0x73, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x70,
281 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x07, 0x70, 0x61,
282 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0x20, 0x0a, 0x0a, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x4c,
283 0x69, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6c, 0x69, 0x73, 0x74, 0x18, 0x01, 0x20, 0x03, 0x28,
284 0x09, 0x52, 0x04, 0x6c, 0x69, 0x73, 0x74, 0x22, 0x32, 0x0a, 0x08, 0x4b, 0x65, 0x79, 0x56, 0x61,
285 0x6c, 0x75, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
286 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02,
287 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x42, 0x1d, 0x5a, 0x1b, 0x67,
288 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69,
289 0x6e, 0x65, 0x72, 0x64, 0x2f, 0x74, 0x74, 0x72, 0x70, 0x63, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
290 0x6f, 0x33,
291 }
292
293 var (
294 file_github_com_containerd_ttrpc_request_proto_rawDescOnce sync.Once
295 file_github_com_containerd_ttrpc_request_proto_rawDescData = file_github_com_containerd_ttrpc_request_proto_rawDesc
296 )
297
298 func file_github_com_containerd_ttrpc_request_proto_rawDescGZIP() []byte {
299 file_github_com_containerd_ttrpc_request_proto_rawDescOnce.Do(func() {
300 file_github_com_containerd_ttrpc_request_proto_rawDescData = protoimpl.X.CompressGZIP(file_github_com_containerd_ttrpc_request_proto_rawDescData)
301 })
302 return file_github_com_containerd_ttrpc_request_proto_rawDescData
303 }
304
305 var file_github_com_containerd_ttrpc_request_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
306 var file_github_com_containerd_ttrpc_request_proto_goTypes = []interface{}{
307 (*Request)(nil),
308 (*Response)(nil),
309 (*StringList)(nil),
310 (*KeyValue)(nil),
311 (*status.Status)(nil),
312 }
313 var file_github_com_containerd_ttrpc_request_proto_depIdxs = []int32{
314 3,
315 4,
316 2,
317 2,
318 2,
319 2,
320 0,
321 }
322
323 func init() { file_github_com_containerd_ttrpc_request_proto_init() }
324 func file_github_com_containerd_ttrpc_request_proto_init() {
325 if File_github_com_containerd_ttrpc_request_proto != nil {
326 return
327 }
328 if !protoimpl.UnsafeEnabled {
329 file_github_com_containerd_ttrpc_request_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
330 switch v := v.(*Request); i {
331 case 0:
332 return &v.state
333 case 1:
334 return &v.sizeCache
335 case 2:
336 return &v.unknownFields
337 default:
338 return nil
339 }
340 }
341 file_github_com_containerd_ttrpc_request_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
342 switch v := v.(*Response); i {
343 case 0:
344 return &v.state
345 case 1:
346 return &v.sizeCache
347 case 2:
348 return &v.unknownFields
349 default:
350 return nil
351 }
352 }
353 file_github_com_containerd_ttrpc_request_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
354 switch v := v.(*StringList); i {
355 case 0:
356 return &v.state
357 case 1:
358 return &v.sizeCache
359 case 2:
360 return &v.unknownFields
361 default:
362 return nil
363 }
364 }
365 file_github_com_containerd_ttrpc_request_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
366 switch v := v.(*KeyValue); i {
367 case 0:
368 return &v.state
369 case 1:
370 return &v.sizeCache
371 case 2:
372 return &v.unknownFields
373 default:
374 return nil
375 }
376 }
377 }
378 type x struct{}
379 out := protoimpl.TypeBuilder{
380 File: protoimpl.DescBuilder{
381 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
382 RawDescriptor: file_github_com_containerd_ttrpc_request_proto_rawDesc,
383 NumEnums: 0,
384 NumMessages: 4,
385 NumExtensions: 0,
386 NumServices: 0,
387 },
388 GoTypes: file_github_com_containerd_ttrpc_request_proto_goTypes,
389 DependencyIndexes: file_github_com_containerd_ttrpc_request_proto_depIdxs,
390 MessageInfos: file_github_com_containerd_ttrpc_request_proto_msgTypes,
391 }.Build()
392 File_github_com_containerd_ttrpc_request_proto = out.File
393 file_github_com_containerd_ttrpc_request_proto_rawDesc = nil
394 file_github_com_containerd_ttrpc_request_proto_goTypes = nil
395 file_github_com_containerd_ttrpc_request_proto_depIdxs = nil
396 }
397
View as plain text