1
2
3
4
5
6
7 package envoy_service_trace_v3
8
9 import (
10 context "context"
11 v1 "github.com/census-instrumentation/opencensus-proto/gen-go/trace/v1"
12 _ "github.com/cncf/udpa/go/udpa/annotations"
13 v3 "github.com/datawire/ambassador/v2/pkg/api/envoy/config/core/v3"
14 _ "github.com/envoyproxy/protoc-gen-validate/validate"
15 proto "github.com/golang/protobuf/proto"
16 _ "google.golang.org/genproto/googleapis/api/annotations"
17 grpc "google.golang.org/grpc"
18 codes "google.golang.org/grpc/codes"
19 status "google.golang.org/grpc/status"
20 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
21 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
22 reflect "reflect"
23 sync "sync"
24 )
25
26 const (
27
28 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
29
30 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
31 )
32
33
34
35 const _ = proto.ProtoPackageIsVersion4
36
37 type StreamTracesResponse struct {
38 state protoimpl.MessageState
39 sizeCache protoimpl.SizeCache
40 unknownFields protoimpl.UnknownFields
41 }
42
43 func (x *StreamTracesResponse) Reset() {
44 *x = StreamTracesResponse{}
45 if protoimpl.UnsafeEnabled {
46 mi := &file_envoy_service_trace_v3_trace_service_proto_msgTypes[0]
47 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
48 ms.StoreMessageInfo(mi)
49 }
50 }
51
52 func (x *StreamTracesResponse) String() string {
53 return protoimpl.X.MessageStringOf(x)
54 }
55
56 func (*StreamTracesResponse) ProtoMessage() {}
57
58 func (x *StreamTracesResponse) ProtoReflect() protoreflect.Message {
59 mi := &file_envoy_service_trace_v3_trace_service_proto_msgTypes[0]
60 if protoimpl.UnsafeEnabled && x != nil {
61 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
62 if ms.LoadMessageInfo() == nil {
63 ms.StoreMessageInfo(mi)
64 }
65 return ms
66 }
67 return mi.MessageOf(x)
68 }
69
70
71 func (*StreamTracesResponse) Descriptor() ([]byte, []int) {
72 return file_envoy_service_trace_v3_trace_service_proto_rawDescGZIP(), []int{0}
73 }
74
75 type StreamTracesMessage struct {
76 state protoimpl.MessageState
77 sizeCache protoimpl.SizeCache
78 unknownFields protoimpl.UnknownFields
79
80
81
82
83 Identifier *StreamTracesMessage_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
84
85 Spans []*v1.Span `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"`
86 }
87
88 func (x *StreamTracesMessage) Reset() {
89 *x = StreamTracesMessage{}
90 if protoimpl.UnsafeEnabled {
91 mi := &file_envoy_service_trace_v3_trace_service_proto_msgTypes[1]
92 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
93 ms.StoreMessageInfo(mi)
94 }
95 }
96
97 func (x *StreamTracesMessage) String() string {
98 return protoimpl.X.MessageStringOf(x)
99 }
100
101 func (*StreamTracesMessage) ProtoMessage() {}
102
103 func (x *StreamTracesMessage) ProtoReflect() protoreflect.Message {
104 mi := &file_envoy_service_trace_v3_trace_service_proto_msgTypes[1]
105 if protoimpl.UnsafeEnabled && x != nil {
106 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
107 if ms.LoadMessageInfo() == nil {
108 ms.StoreMessageInfo(mi)
109 }
110 return ms
111 }
112 return mi.MessageOf(x)
113 }
114
115
116 func (*StreamTracesMessage) Descriptor() ([]byte, []int) {
117 return file_envoy_service_trace_v3_trace_service_proto_rawDescGZIP(), []int{1}
118 }
119
120 func (x *StreamTracesMessage) GetIdentifier() *StreamTracesMessage_Identifier {
121 if x != nil {
122 return x.Identifier
123 }
124 return nil
125 }
126
127 func (x *StreamTracesMessage) GetSpans() []*v1.Span {
128 if x != nil {
129 return x.Spans
130 }
131 return nil
132 }
133
134 type StreamTracesMessage_Identifier struct {
135 state protoimpl.MessageState
136 sizeCache protoimpl.SizeCache
137 unknownFields protoimpl.UnknownFields
138
139
140 Node *v3.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
141 }
142
143 func (x *StreamTracesMessage_Identifier) Reset() {
144 *x = StreamTracesMessage_Identifier{}
145 if protoimpl.UnsafeEnabled {
146 mi := &file_envoy_service_trace_v3_trace_service_proto_msgTypes[2]
147 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
148 ms.StoreMessageInfo(mi)
149 }
150 }
151
152 func (x *StreamTracesMessage_Identifier) String() string {
153 return protoimpl.X.MessageStringOf(x)
154 }
155
156 func (*StreamTracesMessage_Identifier) ProtoMessage() {}
157
158 func (x *StreamTracesMessage_Identifier) ProtoReflect() protoreflect.Message {
159 mi := &file_envoy_service_trace_v3_trace_service_proto_msgTypes[2]
160 if protoimpl.UnsafeEnabled && x != nil {
161 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
162 if ms.LoadMessageInfo() == nil {
163 ms.StoreMessageInfo(mi)
164 }
165 return ms
166 }
167 return mi.MessageOf(x)
168 }
169
170
171 func (*StreamTracesMessage_Identifier) Descriptor() ([]byte, []int) {
172 return file_envoy_service_trace_v3_trace_service_proto_rawDescGZIP(), []int{1, 0}
173 }
174
175 func (x *StreamTracesMessage_Identifier) GetNode() *v3.Node {
176 if x != nil {
177 return x.Node
178 }
179 return nil
180 }
181
182 var File_envoy_service_trace_v3_trace_service_proto protoreflect.FileDescriptor
183
184 var file_envoy_service_trace_v3_trace_service_proto_rawDesc = []byte{
185 0x0a, 0x2a, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
186 0x74, 0x72, 0x61, 0x63, 0x65, 0x2f, 0x76, 0x33, 0x2f, 0x74, 0x72, 0x61, 0x63, 0x65, 0x5f, 0x73,
187 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x16, 0x65, 0x6e,
188 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x72, 0x61, 0x63,
189 0x65, 0x2e, 0x76, 0x33, 0x1a, 0x1f, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x63, 0x6f, 0x6e, 0x66,
190 0x69, 0x67, 0x2f, 0x63, 0x6f, 0x72, 0x65, 0x2f, 0x76, 0x33, 0x2f, 0x62, 0x61, 0x73, 0x65, 0x2e,
191 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70,
192 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72,
193 0x6f, 0x74, 0x6f, 0x1a, 0x25, 0x6f, 0x70, 0x65, 0x6e, 0x63, 0x65, 0x6e, 0x73, 0x75, 0x73, 0x2f,
194 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x74,
195 0x72, 0x61, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x75, 0x64, 0x70, 0x61,
196 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x73, 0x74, 0x61,
197 0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x21, 0x75, 0x64, 0x70, 0x61, 0x2f,
198 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x76, 0x65, 0x72, 0x73,
199 0x69, 0x6f, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x76, 0x61,
200 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x2f, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x2e,
201 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x4a, 0x0a, 0x14, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54,
202 0x72, 0x61, 0x63, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x3a, 0x32, 0x9a,
203 0xc5, 0x88, 0x1e, 0x2d, 0x0a, 0x2b, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76,
204 0x69, 0x63, 0x65, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x32, 0x2e, 0x53, 0x74, 0x72,
205 0x65, 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
206 0x65, 0x22, 0xde, 0x02, 0x0a, 0x13, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63,
207 0x65, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x56, 0x0a, 0x0a, 0x69, 0x64, 0x65,
208 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x36, 0x2e,
209 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x72,
210 0x61, 0x63, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72, 0x61,
211 0x63, 0x65, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74,
212 0x69, 0x66, 0x69, 0x65, 0x72, 0x52, 0x0a, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65,
213 0x72, 0x12, 0x35, 0x0a, 0x05, 0x73, 0x70, 0x61, 0x6e, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b,
214 0x32, 0x1f, 0x2e, 0x6f, 0x70, 0x65, 0x6e, 0x63, 0x65, 0x6e, 0x73, 0x75, 0x73, 0x2e, 0x70, 0x72,
215 0x6f, 0x74, 0x6f, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x70, 0x61,
216 0x6e, 0x52, 0x05, 0x73, 0x70, 0x61, 0x6e, 0x73, 0x1a, 0x84, 0x01, 0x0a, 0x0a, 0x49, 0x64, 0x65,
217 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x12, 0x38, 0x0a, 0x04, 0x6e, 0x6f, 0x64, 0x65, 0x18,
218 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x63, 0x6f,
219 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x63, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x4e, 0x6f, 0x64,
220 0x65, 0x42, 0x08, 0xfa, 0x42, 0x05, 0x8a, 0x01, 0x02, 0x10, 0x01, 0x52, 0x04, 0x6e, 0x6f, 0x64,
221 0x65, 0x3a, 0x3c, 0x9a, 0xc5, 0x88, 0x1e, 0x37, 0x0a, 0x35, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
222 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x32,
223 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x4d, 0x65, 0x73,
224 0x73, 0x61, 0x67, 0x65, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x3a,
225 0x31, 0x9a, 0xc5, 0x88, 0x1e, 0x2c, 0x0a, 0x2a, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65,
226 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x32, 0x2e, 0x53,
227 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61,
228 0x67, 0x65, 0x32, 0x7d, 0x0a, 0x0c, 0x54, 0x72, 0x61, 0x63, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69,
229 0x63, 0x65, 0x12, 0x6d, 0x0a, 0x0c, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63,
230 0x65, 0x73, 0x12, 0x2b, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69,
231 0x63, 0x65, 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65,
232 0x61, 0x6d, 0x54, 0x72, 0x61, 0x63, 0x65, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x1a,
233 0x2c, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e,
234 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54,
235 0x72, 0x61, 0x63, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28,
236 0x01, 0x42, 0x46, 0x0a, 0x24, 0x69, 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f,
237 0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
238 0x2e, 0x74, 0x72, 0x61, 0x63, 0x65, 0x2e, 0x76, 0x33, 0x42, 0x11, 0x54, 0x72, 0x61, 0x63, 0x65,
239 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x88, 0x01,
240 0x01, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x02, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f,
241 0x33,
242 }
243
244 var (
245 file_envoy_service_trace_v3_trace_service_proto_rawDescOnce sync.Once
246 file_envoy_service_trace_v3_trace_service_proto_rawDescData = file_envoy_service_trace_v3_trace_service_proto_rawDesc
247 )
248
249 func file_envoy_service_trace_v3_trace_service_proto_rawDescGZIP() []byte {
250 file_envoy_service_trace_v3_trace_service_proto_rawDescOnce.Do(func() {
251 file_envoy_service_trace_v3_trace_service_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_trace_v3_trace_service_proto_rawDescData)
252 })
253 return file_envoy_service_trace_v3_trace_service_proto_rawDescData
254 }
255
256 var file_envoy_service_trace_v3_trace_service_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
257 var file_envoy_service_trace_v3_trace_service_proto_goTypes = []interface{}{
258 (*StreamTracesResponse)(nil),
259 (*StreamTracesMessage)(nil),
260 (*StreamTracesMessage_Identifier)(nil),
261 (*v1.Span)(nil),
262 (*v3.Node)(nil),
263 }
264 var file_envoy_service_trace_v3_trace_service_proto_depIdxs = []int32{
265 2,
266 3,
267 4,
268 1,
269 0,
270 4,
271 3,
272 3,
273 3,
274 0,
275 }
276
277 func init() { file_envoy_service_trace_v3_trace_service_proto_init() }
278 func file_envoy_service_trace_v3_trace_service_proto_init() {
279 if File_envoy_service_trace_v3_trace_service_proto != nil {
280 return
281 }
282 if !protoimpl.UnsafeEnabled {
283 file_envoy_service_trace_v3_trace_service_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
284 switch v := v.(*StreamTracesResponse); i {
285 case 0:
286 return &v.state
287 case 1:
288 return &v.sizeCache
289 case 2:
290 return &v.unknownFields
291 default:
292 return nil
293 }
294 }
295 file_envoy_service_trace_v3_trace_service_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
296 switch v := v.(*StreamTracesMessage); i {
297 case 0:
298 return &v.state
299 case 1:
300 return &v.sizeCache
301 case 2:
302 return &v.unknownFields
303 default:
304 return nil
305 }
306 }
307 file_envoy_service_trace_v3_trace_service_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
308 switch v := v.(*StreamTracesMessage_Identifier); i {
309 case 0:
310 return &v.state
311 case 1:
312 return &v.sizeCache
313 case 2:
314 return &v.unknownFields
315 default:
316 return nil
317 }
318 }
319 }
320 type x struct{}
321 out := protoimpl.TypeBuilder{
322 File: protoimpl.DescBuilder{
323 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
324 RawDescriptor: file_envoy_service_trace_v3_trace_service_proto_rawDesc,
325 NumEnums: 0,
326 NumMessages: 3,
327 NumExtensions: 0,
328 NumServices: 1,
329 },
330 GoTypes: file_envoy_service_trace_v3_trace_service_proto_goTypes,
331 DependencyIndexes: file_envoy_service_trace_v3_trace_service_proto_depIdxs,
332 MessageInfos: file_envoy_service_trace_v3_trace_service_proto_msgTypes,
333 }.Build()
334 File_envoy_service_trace_v3_trace_service_proto = out.File
335 file_envoy_service_trace_v3_trace_service_proto_rawDesc = nil
336 file_envoy_service_trace_v3_trace_service_proto_goTypes = nil
337 file_envoy_service_trace_v3_trace_service_proto_depIdxs = nil
338 }
339
340
341 var _ context.Context
342 var _ grpc.ClientConnInterface
343
344
345
346 const _ = grpc.SupportPackageIsVersion6
347
348
349
350
351 type TraceServiceClient interface {
352
353
354
355 StreamTraces(ctx context.Context, opts ...grpc.CallOption) (TraceService_StreamTracesClient, error)
356 }
357
358 type traceServiceClient struct {
359 cc grpc.ClientConnInterface
360 }
361
362 func NewTraceServiceClient(cc grpc.ClientConnInterface) TraceServiceClient {
363 return &traceServiceClient{cc}
364 }
365
366 func (c *traceServiceClient) StreamTraces(ctx context.Context, opts ...grpc.CallOption) (TraceService_StreamTracesClient, error) {
367 stream, err := c.cc.NewStream(ctx, &_TraceService_serviceDesc.Streams[0], "/envoy.service.trace.v3.TraceService/StreamTraces", opts...)
368 if err != nil {
369 return nil, err
370 }
371 x := &traceServiceStreamTracesClient{stream}
372 return x, nil
373 }
374
375 type TraceService_StreamTracesClient interface {
376 Send(*StreamTracesMessage) error
377 CloseAndRecv() (*StreamTracesResponse, error)
378 grpc.ClientStream
379 }
380
381 type traceServiceStreamTracesClient struct {
382 grpc.ClientStream
383 }
384
385 func (x *traceServiceStreamTracesClient) Send(m *StreamTracesMessage) error {
386 return x.ClientStream.SendMsg(m)
387 }
388
389 func (x *traceServiceStreamTracesClient) CloseAndRecv() (*StreamTracesResponse, error) {
390 if err := x.ClientStream.CloseSend(); err != nil {
391 return nil, err
392 }
393 m := new(StreamTracesResponse)
394 if err := x.ClientStream.RecvMsg(m); err != nil {
395 return nil, err
396 }
397 return m, nil
398 }
399
400
401 type TraceServiceServer interface {
402
403
404
405 StreamTraces(TraceService_StreamTracesServer) error
406 }
407
408
409 type UnimplementedTraceServiceServer struct {
410 }
411
412 func (*UnimplementedTraceServiceServer) StreamTraces(TraceService_StreamTracesServer) error {
413 return status.Errorf(codes.Unimplemented, "method StreamTraces not implemented")
414 }
415
416 func RegisterTraceServiceServer(s *grpc.Server, srv TraceServiceServer) {
417 s.RegisterService(&_TraceService_serviceDesc, srv)
418 }
419
420 func _TraceService_StreamTraces_Handler(srv interface{}, stream grpc.ServerStream) error {
421 return srv.(TraceServiceServer).StreamTraces(&traceServiceStreamTracesServer{stream})
422 }
423
424 type TraceService_StreamTracesServer interface {
425 SendAndClose(*StreamTracesResponse) error
426 Recv() (*StreamTracesMessage, error)
427 grpc.ServerStream
428 }
429
430 type traceServiceStreamTracesServer struct {
431 grpc.ServerStream
432 }
433
434 func (x *traceServiceStreamTracesServer) SendAndClose(m *StreamTracesResponse) error {
435 return x.ServerStream.SendMsg(m)
436 }
437
438 func (x *traceServiceStreamTracesServer) Recv() (*StreamTracesMessage, error) {
439 m := new(StreamTracesMessage)
440 if err := x.ServerStream.RecvMsg(m); err != nil {
441 return nil, err
442 }
443 return m, nil
444 }
445
446 var _TraceService_serviceDesc = grpc.ServiceDesc{
447 ServiceName: "envoy.service.trace.v3.TraceService",
448 HandlerType: (*TraceServiceServer)(nil),
449 Methods: []grpc.MethodDesc{},
450 Streams: []grpc.StreamDesc{
451 {
452 StreamName: "StreamTraces",
453 Handler: _TraceService_StreamTraces_Handler,
454 ClientStreams: true,
455 },
456 },
457 Metadata: "envoy/service/trace/v3/trace_service.proto",
458 }
459
View as plain text