1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 package streaming
23
24 import (
25 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
26 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
27 emptypb "google.golang.org/protobuf/types/known/emptypb"
28 reflect "reflect"
29 sync "sync"
30 )
31
32 const (
33
34 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
35
36 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
37 )
38
39 type EchoPayload struct {
40 state protoimpl.MessageState
41 sizeCache protoimpl.SizeCache
42 unknownFields protoimpl.UnknownFields
43
44 Seq uint32 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
45 Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
46 }
47
48 func (x *EchoPayload) Reset() {
49 *x = EchoPayload{}
50 if protoimpl.UnsafeEnabled {
51 mi := &file_github_com_containerd_ttrpc_integration_streaming_test_proto_msgTypes[0]
52 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
53 ms.StoreMessageInfo(mi)
54 }
55 }
56
57 func (x *EchoPayload) String() string {
58 return protoimpl.X.MessageStringOf(x)
59 }
60
61 func (*EchoPayload) ProtoMessage() {}
62
63 func (x *EchoPayload) ProtoReflect() protoreflect.Message {
64 mi := &file_github_com_containerd_ttrpc_integration_streaming_test_proto_msgTypes[0]
65 if protoimpl.UnsafeEnabled && x != nil {
66 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
67 if ms.LoadMessageInfo() == nil {
68 ms.StoreMessageInfo(mi)
69 }
70 return ms
71 }
72 return mi.MessageOf(x)
73 }
74
75
76 func (*EchoPayload) Descriptor() ([]byte, []int) {
77 return file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDescGZIP(), []int{0}
78 }
79
80 func (x *EchoPayload) GetSeq() uint32 {
81 if x != nil {
82 return x.Seq
83 }
84 return 0
85 }
86
87 func (x *EchoPayload) GetMsg() string {
88 if x != nil {
89 return x.Msg
90 }
91 return ""
92 }
93
94 type Part struct {
95 state protoimpl.MessageState
96 sizeCache protoimpl.SizeCache
97 unknownFields protoimpl.UnknownFields
98
99 Add int32 `protobuf:"varint,1,opt,name=add,proto3" json:"add,omitempty"`
100 }
101
102 func (x *Part) Reset() {
103 *x = Part{}
104 if protoimpl.UnsafeEnabled {
105 mi := &file_github_com_containerd_ttrpc_integration_streaming_test_proto_msgTypes[1]
106 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
107 ms.StoreMessageInfo(mi)
108 }
109 }
110
111 func (x *Part) String() string {
112 return protoimpl.X.MessageStringOf(x)
113 }
114
115 func (*Part) ProtoMessage() {}
116
117 func (x *Part) ProtoReflect() protoreflect.Message {
118 mi := &file_github_com_containerd_ttrpc_integration_streaming_test_proto_msgTypes[1]
119 if protoimpl.UnsafeEnabled && x != nil {
120 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
121 if ms.LoadMessageInfo() == nil {
122 ms.StoreMessageInfo(mi)
123 }
124 return ms
125 }
126 return mi.MessageOf(x)
127 }
128
129
130 func (*Part) Descriptor() ([]byte, []int) {
131 return file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDescGZIP(), []int{1}
132 }
133
134 func (x *Part) GetAdd() int32 {
135 if x != nil {
136 return x.Add
137 }
138 return 0
139 }
140
141 type Sum struct {
142 state protoimpl.MessageState
143 sizeCache protoimpl.SizeCache
144 unknownFields protoimpl.UnknownFields
145
146 Sum int32 `protobuf:"varint,1,opt,name=sum,proto3" json:"sum,omitempty"`
147 Num int32 `protobuf:"varint,2,opt,name=num,proto3" json:"num,omitempty"`
148 }
149
150 func (x *Sum) Reset() {
151 *x = Sum{}
152 if protoimpl.UnsafeEnabled {
153 mi := &file_github_com_containerd_ttrpc_integration_streaming_test_proto_msgTypes[2]
154 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
155 ms.StoreMessageInfo(mi)
156 }
157 }
158
159 func (x *Sum) String() string {
160 return protoimpl.X.MessageStringOf(x)
161 }
162
163 func (*Sum) ProtoMessage() {}
164
165 func (x *Sum) ProtoReflect() protoreflect.Message {
166 mi := &file_github_com_containerd_ttrpc_integration_streaming_test_proto_msgTypes[2]
167 if protoimpl.UnsafeEnabled && x != nil {
168 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
169 if ms.LoadMessageInfo() == nil {
170 ms.StoreMessageInfo(mi)
171 }
172 return ms
173 }
174 return mi.MessageOf(x)
175 }
176
177
178 func (*Sum) Descriptor() ([]byte, []int) {
179 return file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDescGZIP(), []int{2}
180 }
181
182 func (x *Sum) GetSum() int32 {
183 if x != nil {
184 return x.Sum
185 }
186 return 0
187 }
188
189 func (x *Sum) GetNum() int32 {
190 if x != nil {
191 return x.Num
192 }
193 return 0
194 }
195
196 var File_github_com_containerd_ttrpc_integration_streaming_test_proto protoreflect.FileDescriptor
197
198 var file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDesc = []byte{
199 0x0a, 0x3c, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x63, 0x6f, 0x6e,
200 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x64, 0x2f, 0x74, 0x74, 0x72, 0x70, 0x63, 0x2f, 0x69, 0x6e,
201 0x74, 0x65, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d,
202 0x69, 0x6e, 0x67, 0x2f, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1b,
203 0x74, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f,
204 0x6e, 0x2e, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x1a, 0x1b, 0x67, 0x6f, 0x6f,
205 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70,
206 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x31, 0x0a, 0x0b, 0x45, 0x63, 0x68, 0x6f,
207 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x73, 0x65, 0x71, 0x18, 0x01,
208 0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x73, 0x65, 0x71, 0x12, 0x10, 0x0a, 0x03, 0x6d, 0x73, 0x67,
209 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6d, 0x73, 0x67, 0x22, 0x18, 0x0a, 0x04, 0x50,
210 0x61, 0x72, 0x74, 0x12, 0x10, 0x0a, 0x03, 0x61, 0x64, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05,
211 0x52, 0x03, 0x61, 0x64, 0x64, 0x22, 0x29, 0x0a, 0x03, 0x53, 0x75, 0x6d, 0x12, 0x10, 0x0a, 0x03,
212 0x73, 0x75, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x03, 0x73, 0x75, 0x6d, 0x12, 0x10,
213 0x0a, 0x03, 0x6e, 0x75, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x03, 0x6e, 0x75, 0x6d,
214 0x32, 0xa0, 0x04, 0x0a, 0x09, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x12, 0x5a,
215 0x0a, 0x04, 0x45, 0x63, 0x68, 0x6f, 0x12, 0x28, 0x2e, 0x74, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x69,
216 0x6e, 0x74, 0x65, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x73, 0x74, 0x72, 0x65, 0x61,
217 0x6d, 0x69, 0x6e, 0x67, 0x2e, 0x45, 0x63, 0x68, 0x6f, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64,
218 0x1a, 0x28, 0x2e, 0x74, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x67, 0x72, 0x61,
219 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x2e, 0x45,
220 0x63, 0x68, 0x6f, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x64, 0x0a, 0x0a, 0x45, 0x63,
221 0x68, 0x6f, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x28, 0x2e, 0x74, 0x74, 0x72, 0x70, 0x63,
222 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x73, 0x74, 0x72,
223 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x2e, 0x45, 0x63, 0x68, 0x6f, 0x50, 0x61, 0x79, 0x6c, 0x6f,
224 0x61, 0x64, 0x1a, 0x28, 0x2e, 0x74, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x67,
225 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67,
226 0x2e, 0x45, 0x63, 0x68, 0x6f, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x28, 0x01, 0x30, 0x01,
227 0x12, 0x52, 0x0a, 0x09, 0x53, 0x75, 0x6d, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x21, 0x2e,
228 0x74, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f,
229 0x6e, 0x2e, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x2e, 0x50, 0x61, 0x72, 0x74,
230 0x1a, 0x20, 0x2e, 0x74, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x67, 0x72, 0x61,
231 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x2e, 0x53,
232 0x75, 0x6d, 0x28, 0x01, 0x12, 0x55, 0x0a, 0x0c, 0x44, 0x69, 0x76, 0x69, 0x64, 0x65, 0x53, 0x74,
233 0x72, 0x65, 0x61, 0x6d, 0x12, 0x20, 0x2e, 0x74, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x69, 0x6e, 0x74,
234 0x65, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69,
235 0x6e, 0x67, 0x2e, 0x53, 0x75, 0x6d, 0x1a, 0x21, 0x2e, 0x74, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x69,
236 0x6e, 0x74, 0x65, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x73, 0x74, 0x72, 0x65, 0x61,
237 0x6d, 0x69, 0x6e, 0x67, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x30, 0x01, 0x12, 0x4e, 0x0a, 0x08, 0x45,
238 0x63, 0x68, 0x6f, 0x4e, 0x75, 0x6c, 0x6c, 0x12, 0x28, 0x2e, 0x74, 0x74, 0x72, 0x70, 0x63, 0x2e,
239 0x69, 0x6e, 0x74, 0x65, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x73, 0x74, 0x72, 0x65,
240 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x2e, 0x45, 0x63, 0x68, 0x6f, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61,
241 0x64, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
242 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x28, 0x01, 0x12, 0x56, 0x0a, 0x0e, 0x45,
243 0x63, 0x68, 0x6f, 0x4e, 0x75, 0x6c, 0x6c, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x28, 0x2e,
244 0x74, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x69, 0x6e, 0x74, 0x65, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f,
245 0x6e, 0x2e, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x2e, 0x45, 0x63, 0x68, 0x6f,
246 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
247 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x28,
248 0x01, 0x30, 0x01, 0x42, 0x3d, 0x5a, 0x3b, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f,
249 0x6d, 0x2f, 0x63, 0x6f, 0x6e, 0x74, 0x61, 0x69, 0x6e, 0x65, 0x72, 0x64, 0x2f, 0x74, 0x74, 0x72,
250 0x70, 0x63, 0x2f, 0x69, 0x6e, 0x74, 0x65, 0x67, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2f, 0x73,
251 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x3b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69,
252 0x6e, 0x67, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
253 }
254
255 var (
256 file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDescOnce sync.Once
257 file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDescData = file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDesc
258 )
259
260 func file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDescGZIP() []byte {
261 file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDescOnce.Do(func() {
262 file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDescData = protoimpl.X.CompressGZIP(file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDescData)
263 })
264 return file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDescData
265 }
266
267 var file_github_com_containerd_ttrpc_integration_streaming_test_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
268 var file_github_com_containerd_ttrpc_integration_streaming_test_proto_goTypes = []interface{}{
269 (*EchoPayload)(nil),
270 (*Part)(nil),
271 (*Sum)(nil),
272 (*emptypb.Empty)(nil),
273 }
274 var file_github_com_containerd_ttrpc_integration_streaming_test_proto_depIdxs = []int32{
275 0,
276 0,
277 1,
278 2,
279 0,
280 0,
281 0,
282 0,
283 2,
284 1,
285 3,
286 3,
287 6,
288 0,
289 0,
290 0,
291 0,
292 }
293
294 func init() { file_github_com_containerd_ttrpc_integration_streaming_test_proto_init() }
295 func file_github_com_containerd_ttrpc_integration_streaming_test_proto_init() {
296 if File_github_com_containerd_ttrpc_integration_streaming_test_proto != nil {
297 return
298 }
299 if !protoimpl.UnsafeEnabled {
300 file_github_com_containerd_ttrpc_integration_streaming_test_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
301 switch v := v.(*EchoPayload); i {
302 case 0:
303 return &v.state
304 case 1:
305 return &v.sizeCache
306 case 2:
307 return &v.unknownFields
308 default:
309 return nil
310 }
311 }
312 file_github_com_containerd_ttrpc_integration_streaming_test_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
313 switch v := v.(*Part); i {
314 case 0:
315 return &v.state
316 case 1:
317 return &v.sizeCache
318 case 2:
319 return &v.unknownFields
320 default:
321 return nil
322 }
323 }
324 file_github_com_containerd_ttrpc_integration_streaming_test_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
325 switch v := v.(*Sum); i {
326 case 0:
327 return &v.state
328 case 1:
329 return &v.sizeCache
330 case 2:
331 return &v.unknownFields
332 default:
333 return nil
334 }
335 }
336 }
337 type x struct{}
338 out := protoimpl.TypeBuilder{
339 File: protoimpl.DescBuilder{
340 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
341 RawDescriptor: file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDesc,
342 NumEnums: 0,
343 NumMessages: 3,
344 NumExtensions: 0,
345 NumServices: 1,
346 },
347 GoTypes: file_github_com_containerd_ttrpc_integration_streaming_test_proto_goTypes,
348 DependencyIndexes: file_github_com_containerd_ttrpc_integration_streaming_test_proto_depIdxs,
349 MessageInfos: file_github_com_containerd_ttrpc_integration_streaming_test_proto_msgTypes,
350 }.Build()
351 File_github_com_containerd_ttrpc_integration_streaming_test_proto = out.File
352 file_github_com_containerd_ttrpc_integration_streaming_test_proto_rawDesc = nil
353 file_github_com_containerd_ttrpc_integration_streaming_test_proto_goTypes = nil
354 file_github_com_containerd_ttrpc_integration_streaming_test_proto_depIdxs = nil
355 }
356
View as plain text