1
2
3
4
5
6
7 package v2alpha
8
9 import (
10 _ "github.com/cncf/xds/go/udpa/annotations"
11 core "github.com/emissary-ingress/emissary/v3/pkg/api/envoy/api/v2/core"
12 timestamp "github.com/golang/protobuf/ptypes/timestamp"
13 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
14 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
15 reflect "reflect"
16 sync "sync"
17 )
18
19 const (
20
21 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
22
23 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
24 )
25
26
27 type Connection struct {
28 state protoimpl.MessageState
29 sizeCache protoimpl.SizeCache
30 unknownFields protoimpl.UnknownFields
31
32
33 LocalAddress *core.Address `protobuf:"bytes,2,opt,name=local_address,json=localAddress,proto3" json:"local_address,omitempty"`
34
35 RemoteAddress *core.Address `protobuf:"bytes,3,opt,name=remote_address,json=remoteAddress,proto3" json:"remote_address,omitempty"`
36 }
37
38 func (x *Connection) Reset() {
39 *x = Connection{}
40 if protoimpl.UnsafeEnabled {
41 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[0]
42 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
43 ms.StoreMessageInfo(mi)
44 }
45 }
46
47 func (x *Connection) String() string {
48 return protoimpl.X.MessageStringOf(x)
49 }
50
51 func (*Connection) ProtoMessage() {}
52
53 func (x *Connection) ProtoReflect() protoreflect.Message {
54 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[0]
55 if protoimpl.UnsafeEnabled && x != nil {
56 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
57 if ms.LoadMessageInfo() == nil {
58 ms.StoreMessageInfo(mi)
59 }
60 return ms
61 }
62 return mi.MessageOf(x)
63 }
64
65
66 func (*Connection) Descriptor() ([]byte, []int) {
67 return file_envoy_data_tap_v2alpha_transport_proto_rawDescGZIP(), []int{0}
68 }
69
70 func (x *Connection) GetLocalAddress() *core.Address {
71 if x != nil {
72 return x.LocalAddress
73 }
74 return nil
75 }
76
77 func (x *Connection) GetRemoteAddress() *core.Address {
78 if x != nil {
79 return x.RemoteAddress
80 }
81 return nil
82 }
83
84
85 type SocketEvent struct {
86 state protoimpl.MessageState
87 sizeCache protoimpl.SizeCache
88 unknownFields protoimpl.UnknownFields
89
90
91 Timestamp *timestamp.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
92
93
94
95
96
97
98 EventSelector isSocketEvent_EventSelector `protobuf_oneof:"event_selector"`
99 }
100
101 func (x *SocketEvent) Reset() {
102 *x = SocketEvent{}
103 if protoimpl.UnsafeEnabled {
104 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[1]
105 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
106 ms.StoreMessageInfo(mi)
107 }
108 }
109
110 func (x *SocketEvent) String() string {
111 return protoimpl.X.MessageStringOf(x)
112 }
113
114 func (*SocketEvent) ProtoMessage() {}
115
116 func (x *SocketEvent) ProtoReflect() protoreflect.Message {
117 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[1]
118 if protoimpl.UnsafeEnabled && x != nil {
119 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
120 if ms.LoadMessageInfo() == nil {
121 ms.StoreMessageInfo(mi)
122 }
123 return ms
124 }
125 return mi.MessageOf(x)
126 }
127
128
129 func (*SocketEvent) Descriptor() ([]byte, []int) {
130 return file_envoy_data_tap_v2alpha_transport_proto_rawDescGZIP(), []int{1}
131 }
132
133 func (x *SocketEvent) GetTimestamp() *timestamp.Timestamp {
134 if x != nil {
135 return x.Timestamp
136 }
137 return nil
138 }
139
140 func (m *SocketEvent) GetEventSelector() isSocketEvent_EventSelector {
141 if m != nil {
142 return m.EventSelector
143 }
144 return nil
145 }
146
147 func (x *SocketEvent) GetRead() *SocketEvent_Read {
148 if x, ok := x.GetEventSelector().(*SocketEvent_Read_); ok {
149 return x.Read
150 }
151 return nil
152 }
153
154 func (x *SocketEvent) GetWrite() *SocketEvent_Write {
155 if x, ok := x.GetEventSelector().(*SocketEvent_Write_); ok {
156 return x.Write
157 }
158 return nil
159 }
160
161 func (x *SocketEvent) GetClosed() *SocketEvent_Closed {
162 if x, ok := x.GetEventSelector().(*SocketEvent_Closed_); ok {
163 return x.Closed
164 }
165 return nil
166 }
167
168 type isSocketEvent_EventSelector interface {
169 isSocketEvent_EventSelector()
170 }
171
172 type SocketEvent_Read_ struct {
173 Read *SocketEvent_Read `protobuf:"bytes,2,opt,name=read,proto3,oneof"`
174 }
175
176 type SocketEvent_Write_ struct {
177 Write *SocketEvent_Write `protobuf:"bytes,3,opt,name=write,proto3,oneof"`
178 }
179
180 type SocketEvent_Closed_ struct {
181 Closed *SocketEvent_Closed `protobuf:"bytes,4,opt,name=closed,proto3,oneof"`
182 }
183
184 func (*SocketEvent_Read_) isSocketEvent_EventSelector() {}
185
186 func (*SocketEvent_Write_) isSocketEvent_EventSelector() {}
187
188 func (*SocketEvent_Closed_) isSocketEvent_EventSelector() {}
189
190
191
192 type SocketBufferedTrace struct {
193 state protoimpl.MessageState
194 sizeCache protoimpl.SizeCache
195 unknownFields protoimpl.UnknownFields
196
197
198
199 TraceId uint64 `protobuf:"varint,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
200
201 Connection *Connection `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
202
203 Events []*SocketEvent `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"`
204
205
206 ReadTruncated bool `protobuf:"varint,4,opt,name=read_truncated,json=readTruncated,proto3" json:"read_truncated,omitempty"`
207
208
209 WriteTruncated bool `protobuf:"varint,5,opt,name=write_truncated,json=writeTruncated,proto3" json:"write_truncated,omitempty"`
210 }
211
212 func (x *SocketBufferedTrace) Reset() {
213 *x = SocketBufferedTrace{}
214 if protoimpl.UnsafeEnabled {
215 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[2]
216 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
217 ms.StoreMessageInfo(mi)
218 }
219 }
220
221 func (x *SocketBufferedTrace) String() string {
222 return protoimpl.X.MessageStringOf(x)
223 }
224
225 func (*SocketBufferedTrace) ProtoMessage() {}
226
227 func (x *SocketBufferedTrace) ProtoReflect() protoreflect.Message {
228 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[2]
229 if protoimpl.UnsafeEnabled && x != nil {
230 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
231 if ms.LoadMessageInfo() == nil {
232 ms.StoreMessageInfo(mi)
233 }
234 return ms
235 }
236 return mi.MessageOf(x)
237 }
238
239
240 func (*SocketBufferedTrace) Descriptor() ([]byte, []int) {
241 return file_envoy_data_tap_v2alpha_transport_proto_rawDescGZIP(), []int{2}
242 }
243
244 func (x *SocketBufferedTrace) GetTraceId() uint64 {
245 if x != nil {
246 return x.TraceId
247 }
248 return 0
249 }
250
251 func (x *SocketBufferedTrace) GetConnection() *Connection {
252 if x != nil {
253 return x.Connection
254 }
255 return nil
256 }
257
258 func (x *SocketBufferedTrace) GetEvents() []*SocketEvent {
259 if x != nil {
260 return x.Events
261 }
262 return nil
263 }
264
265 func (x *SocketBufferedTrace) GetReadTruncated() bool {
266 if x != nil {
267 return x.ReadTruncated
268 }
269 return false
270 }
271
272 func (x *SocketBufferedTrace) GetWriteTruncated() bool {
273 if x != nil {
274 return x.WriteTruncated
275 }
276 return false
277 }
278
279
280 type SocketStreamedTraceSegment struct {
281 state protoimpl.MessageState
282 sizeCache protoimpl.SizeCache
283 unknownFields protoimpl.UnknownFields
284
285
286
287 TraceId uint64 `protobuf:"varint,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
288
289
290
291 MessagePiece isSocketStreamedTraceSegment_MessagePiece `protobuf_oneof:"message_piece"`
292 }
293
294 func (x *SocketStreamedTraceSegment) Reset() {
295 *x = SocketStreamedTraceSegment{}
296 if protoimpl.UnsafeEnabled {
297 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[3]
298 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
299 ms.StoreMessageInfo(mi)
300 }
301 }
302
303 func (x *SocketStreamedTraceSegment) String() string {
304 return protoimpl.X.MessageStringOf(x)
305 }
306
307 func (*SocketStreamedTraceSegment) ProtoMessage() {}
308
309 func (x *SocketStreamedTraceSegment) ProtoReflect() protoreflect.Message {
310 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[3]
311 if protoimpl.UnsafeEnabled && x != nil {
312 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
313 if ms.LoadMessageInfo() == nil {
314 ms.StoreMessageInfo(mi)
315 }
316 return ms
317 }
318 return mi.MessageOf(x)
319 }
320
321
322 func (*SocketStreamedTraceSegment) Descriptor() ([]byte, []int) {
323 return file_envoy_data_tap_v2alpha_transport_proto_rawDescGZIP(), []int{3}
324 }
325
326 func (x *SocketStreamedTraceSegment) GetTraceId() uint64 {
327 if x != nil {
328 return x.TraceId
329 }
330 return 0
331 }
332
333 func (m *SocketStreamedTraceSegment) GetMessagePiece() isSocketStreamedTraceSegment_MessagePiece {
334 if m != nil {
335 return m.MessagePiece
336 }
337 return nil
338 }
339
340 func (x *SocketStreamedTraceSegment) GetConnection() *Connection {
341 if x, ok := x.GetMessagePiece().(*SocketStreamedTraceSegment_Connection); ok {
342 return x.Connection
343 }
344 return nil
345 }
346
347 func (x *SocketStreamedTraceSegment) GetEvent() *SocketEvent {
348 if x, ok := x.GetMessagePiece().(*SocketStreamedTraceSegment_Event); ok {
349 return x.Event
350 }
351 return nil
352 }
353
354 type isSocketStreamedTraceSegment_MessagePiece interface {
355 isSocketStreamedTraceSegment_MessagePiece()
356 }
357
358 type SocketStreamedTraceSegment_Connection struct {
359
360 Connection *Connection `protobuf:"bytes,2,opt,name=connection,proto3,oneof"`
361 }
362
363 type SocketStreamedTraceSegment_Event struct {
364
365 Event *SocketEvent `protobuf:"bytes,3,opt,name=event,proto3,oneof"`
366 }
367
368 func (*SocketStreamedTraceSegment_Connection) isSocketStreamedTraceSegment_MessagePiece() {}
369
370 func (*SocketStreamedTraceSegment_Event) isSocketStreamedTraceSegment_MessagePiece() {}
371
372
373 type SocketEvent_Read struct {
374 state protoimpl.MessageState
375 sizeCache protoimpl.SizeCache
376 unknownFields protoimpl.UnknownFields
377
378
379 Data *Body `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
380 }
381
382 func (x *SocketEvent_Read) Reset() {
383 *x = SocketEvent_Read{}
384 if protoimpl.UnsafeEnabled {
385 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[4]
386 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
387 ms.StoreMessageInfo(mi)
388 }
389 }
390
391 func (x *SocketEvent_Read) String() string {
392 return protoimpl.X.MessageStringOf(x)
393 }
394
395 func (*SocketEvent_Read) ProtoMessage() {}
396
397 func (x *SocketEvent_Read) ProtoReflect() protoreflect.Message {
398 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[4]
399 if protoimpl.UnsafeEnabled && x != nil {
400 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
401 if ms.LoadMessageInfo() == nil {
402 ms.StoreMessageInfo(mi)
403 }
404 return ms
405 }
406 return mi.MessageOf(x)
407 }
408
409
410 func (*SocketEvent_Read) Descriptor() ([]byte, []int) {
411 return file_envoy_data_tap_v2alpha_transport_proto_rawDescGZIP(), []int{1, 0}
412 }
413
414 func (x *SocketEvent_Read) GetData() *Body {
415 if x != nil {
416 return x.Data
417 }
418 return nil
419 }
420
421
422 type SocketEvent_Write struct {
423 state protoimpl.MessageState
424 sizeCache protoimpl.SizeCache
425 unknownFields protoimpl.UnknownFields
426
427
428 Data *Body `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
429
430 EndStream bool `protobuf:"varint,2,opt,name=end_stream,json=endStream,proto3" json:"end_stream,omitempty"`
431 }
432
433 func (x *SocketEvent_Write) Reset() {
434 *x = SocketEvent_Write{}
435 if protoimpl.UnsafeEnabled {
436 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[5]
437 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
438 ms.StoreMessageInfo(mi)
439 }
440 }
441
442 func (x *SocketEvent_Write) String() string {
443 return protoimpl.X.MessageStringOf(x)
444 }
445
446 func (*SocketEvent_Write) ProtoMessage() {}
447
448 func (x *SocketEvent_Write) ProtoReflect() protoreflect.Message {
449 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[5]
450 if protoimpl.UnsafeEnabled && x != nil {
451 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
452 if ms.LoadMessageInfo() == nil {
453 ms.StoreMessageInfo(mi)
454 }
455 return ms
456 }
457 return mi.MessageOf(x)
458 }
459
460
461 func (*SocketEvent_Write) Descriptor() ([]byte, []int) {
462 return file_envoy_data_tap_v2alpha_transport_proto_rawDescGZIP(), []int{1, 1}
463 }
464
465 func (x *SocketEvent_Write) GetData() *Body {
466 if x != nil {
467 return x.Data
468 }
469 return nil
470 }
471
472 func (x *SocketEvent_Write) GetEndStream() bool {
473 if x != nil {
474 return x.EndStream
475 }
476 return false
477 }
478
479
480 type SocketEvent_Closed struct {
481 state protoimpl.MessageState
482 sizeCache protoimpl.SizeCache
483 unknownFields protoimpl.UnknownFields
484 }
485
486 func (x *SocketEvent_Closed) Reset() {
487 *x = SocketEvent_Closed{}
488 if protoimpl.UnsafeEnabled {
489 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[6]
490 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
491 ms.StoreMessageInfo(mi)
492 }
493 }
494
495 func (x *SocketEvent_Closed) String() string {
496 return protoimpl.X.MessageStringOf(x)
497 }
498
499 func (*SocketEvent_Closed) ProtoMessage() {}
500
501 func (x *SocketEvent_Closed) ProtoReflect() protoreflect.Message {
502 mi := &file_envoy_data_tap_v2alpha_transport_proto_msgTypes[6]
503 if protoimpl.UnsafeEnabled && x != nil {
504 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
505 if ms.LoadMessageInfo() == nil {
506 ms.StoreMessageInfo(mi)
507 }
508 return ms
509 }
510 return mi.MessageOf(x)
511 }
512
513
514 func (*SocketEvent_Closed) Descriptor() ([]byte, []int) {
515 return file_envoy_data_tap_v2alpha_transport_proto_rawDescGZIP(), []int{1, 2}
516 }
517
518 var File_envoy_data_tap_v2alpha_transport_proto protoreflect.FileDescriptor
519
520 var file_envoy_data_tap_v2alpha_transport_proto_rawDesc = []byte{
521 0x0a, 0x26, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x2f, 0x74, 0x61, 0x70,
522 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f,
523 0x72, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x16, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
524 0x64, 0x61, 0x74, 0x61, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61,
525 0x1a, 0x1f, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x76, 0x32, 0x2f, 0x63,
526 0x6f, 0x72, 0x65, 0x2f, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74,
527 0x6f, 0x1a, 0x23, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x2f, 0x74, 0x61,
528 0x70, 0x2f, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e,
529 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70,
530 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d,
531 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e,
532 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
533 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x90, 0x01, 0x0a, 0x0a, 0x43, 0x6f, 0x6e, 0x6e, 0x65,
534 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x3f, 0x0a, 0x0d, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x5f, 0x61,
535 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x65,
536 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x63, 0x6f, 0x72, 0x65,
537 0x2e, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x52, 0x0c, 0x6c, 0x6f, 0x63, 0x61, 0x6c, 0x41,
538 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x12, 0x41, 0x0a, 0x0e, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65,
539 0x5f, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a,
540 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x63, 0x6f,
541 0x72, 0x65, 0x2e, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x52, 0x0d, 0x72, 0x65, 0x6d, 0x6f,
542 0x74, 0x65, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x22, 0xc0, 0x03, 0x0a, 0x0b, 0x53, 0x6f,
543 0x63, 0x6b, 0x65, 0x74, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x38, 0x0a, 0x09, 0x74, 0x69, 0x6d,
544 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67,
545 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54,
546 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74,
547 0x61, 0x6d, 0x70, 0x12, 0x3e, 0x0a, 0x04, 0x72, 0x65, 0x61, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28,
548 0x0b, 0x32, 0x28, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x74,
549 0x61, 0x70, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x53, 0x6f, 0x63, 0x6b, 0x65,
550 0x74, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x48, 0x00, 0x52, 0x04, 0x72,
551 0x65, 0x61, 0x64, 0x12, 0x41, 0x0a, 0x05, 0x77, 0x72, 0x69, 0x74, 0x65, 0x18, 0x03, 0x20, 0x01,
552 0x28, 0x0b, 0x32, 0x29, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x2e,
553 0x74, 0x61, 0x70, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x53, 0x6f, 0x63, 0x6b,
554 0x65, 0x74, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x48, 0x00, 0x52,
555 0x05, 0x77, 0x72, 0x69, 0x74, 0x65, 0x12, 0x44, 0x0a, 0x06, 0x63, 0x6c, 0x6f, 0x73, 0x65, 0x64,
556 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x64,
557 0x61, 0x74, 0x61, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e,
558 0x53, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x43, 0x6c, 0x6f, 0x73,
559 0x65, 0x64, 0x48, 0x00, 0x52, 0x06, 0x63, 0x6c, 0x6f, 0x73, 0x65, 0x64, 0x1a, 0x38, 0x0a, 0x04,
560 0x52, 0x65, 0x61, 0x64, 0x12, 0x30, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01,
561 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x2e,
562 0x74, 0x61, 0x70, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x42, 0x6f, 0x64, 0x79,
563 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x1a, 0x58, 0x0a, 0x05, 0x57, 0x72, 0x69, 0x74, 0x65, 0x12,
564 0x30, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1c, 0x2e,
565 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x76,
566 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x42, 0x6f, 0x64, 0x79, 0x52, 0x04, 0x64, 0x61, 0x74,
567 0x61, 0x12, 0x1d, 0x0a, 0x0a, 0x65, 0x6e, 0x64, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18,
568 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x09, 0x65, 0x6e, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
569 0x1a, 0x08, 0x0a, 0x06, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x64, 0x42, 0x10, 0x0a, 0x0e, 0x65, 0x76,
570 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x22, 0x81, 0x02, 0x0a,
571 0x13, 0x53, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x42, 0x75, 0x66, 0x66, 0x65, 0x72, 0x65, 0x64, 0x54,
572 0x72, 0x61, 0x63, 0x65, 0x12, 0x19, 0x0a, 0x08, 0x74, 0x72, 0x61, 0x63, 0x65, 0x5f, 0x69, 0x64,
573 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x07, 0x74, 0x72, 0x61, 0x63, 0x65, 0x49, 0x64, 0x12,
574 0x42, 0x0a, 0x0a, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20,
575 0x01, 0x28, 0x0b, 0x32, 0x22, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x64, 0x61, 0x74, 0x61,
576 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x43, 0x6f, 0x6e,
577 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0a, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
578 0x69, 0x6f, 0x6e, 0x12, 0x3b, 0x0a, 0x06, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x18, 0x03, 0x20,
579 0x03, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x64, 0x61, 0x74, 0x61,
580 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x53, 0x6f, 0x63,
581 0x6b, 0x65, 0x74, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x52, 0x06, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x73,
582 0x12, 0x25, 0x0a, 0x0e, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74,
583 0x65, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0d, 0x72, 0x65, 0x61, 0x64, 0x54, 0x72,
584 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x64, 0x12, 0x27, 0x0a, 0x0f, 0x77, 0x72, 0x69, 0x74, 0x65,
585 0x5f, 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x08,
586 0x52, 0x0e, 0x77, 0x72, 0x69, 0x74, 0x65, 0x54, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x64,
587 0x22, 0xcb, 0x01, 0x0a, 0x1a, 0x53, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61,
588 0x6d, 0x65, 0x64, 0x54, 0x72, 0x61, 0x63, 0x65, 0x53, 0x65, 0x67, 0x6d, 0x65, 0x6e, 0x74, 0x12,
589 0x19, 0x0a, 0x08, 0x74, 0x72, 0x61, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28,
590 0x04, 0x52, 0x07, 0x74, 0x72, 0x61, 0x63, 0x65, 0x49, 0x64, 0x12, 0x44, 0x0a, 0x0a, 0x63, 0x6f,
591 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x22,
592 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x74, 0x61, 0x70, 0x2e,
593 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69,
594 0x6f, 0x6e, 0x48, 0x00, 0x52, 0x0a, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e,
595 0x12, 0x3b, 0x0a, 0x05, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32,
596 0x23, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x74, 0x61, 0x70,
597 0x2e, 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x53, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x45,
598 0x76, 0x65, 0x6e, 0x74, 0x48, 0x00, 0x52, 0x05, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x42, 0x0f, 0x0a,
599 0x0d, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x70, 0x69, 0x65, 0x63, 0x65, 0x42, 0x7f,
600 0x0a, 0x24, 0x69, 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e,
601 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x76,
602 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x42, 0x0e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x70, 0x6f, 0x72,
603 0x74, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x3d, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62,
604 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2f,
605 0x67, 0x6f, 0x2d, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x2d, 0x70, 0x6c, 0x61, 0x6e, 0x65,
606 0x2f, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x2f, 0x74, 0x61, 0x70, 0x2f,
607 0x76, 0x32, 0x61, 0x6c, 0x70, 0x68, 0x61, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x01, 0x62,
608 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
609 }
610
611 var (
612 file_envoy_data_tap_v2alpha_transport_proto_rawDescOnce sync.Once
613 file_envoy_data_tap_v2alpha_transport_proto_rawDescData = file_envoy_data_tap_v2alpha_transport_proto_rawDesc
614 )
615
616 func file_envoy_data_tap_v2alpha_transport_proto_rawDescGZIP() []byte {
617 file_envoy_data_tap_v2alpha_transport_proto_rawDescOnce.Do(func() {
618 file_envoy_data_tap_v2alpha_transport_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_data_tap_v2alpha_transport_proto_rawDescData)
619 })
620 return file_envoy_data_tap_v2alpha_transport_proto_rawDescData
621 }
622
623 var file_envoy_data_tap_v2alpha_transport_proto_msgTypes = make([]protoimpl.MessageInfo, 7)
624 var file_envoy_data_tap_v2alpha_transport_proto_goTypes = []interface{}{
625 (*Connection)(nil),
626 (*SocketEvent)(nil),
627 (*SocketBufferedTrace)(nil),
628 (*SocketStreamedTraceSegment)(nil),
629 (*SocketEvent_Read)(nil),
630 (*SocketEvent_Write)(nil),
631 (*SocketEvent_Closed)(nil),
632 (*core.Address)(nil),
633 (*timestamp.Timestamp)(nil),
634 (*Body)(nil),
635 }
636 var file_envoy_data_tap_v2alpha_transport_proto_depIdxs = []int32{
637 7,
638 7,
639 8,
640 4,
641 5,
642 6,
643 0,
644 1,
645 0,
646 1,
647 9,
648 9,
649 12,
650 12,
651 12,
652 12,
653 0,
654 }
655
656 func init() { file_envoy_data_tap_v2alpha_transport_proto_init() }
657 func file_envoy_data_tap_v2alpha_transport_proto_init() {
658 if File_envoy_data_tap_v2alpha_transport_proto != nil {
659 return
660 }
661 file_envoy_data_tap_v2alpha_common_proto_init()
662 if !protoimpl.UnsafeEnabled {
663 file_envoy_data_tap_v2alpha_transport_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
664 switch v := v.(*Connection); i {
665 case 0:
666 return &v.state
667 case 1:
668 return &v.sizeCache
669 case 2:
670 return &v.unknownFields
671 default:
672 return nil
673 }
674 }
675 file_envoy_data_tap_v2alpha_transport_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
676 switch v := v.(*SocketEvent); i {
677 case 0:
678 return &v.state
679 case 1:
680 return &v.sizeCache
681 case 2:
682 return &v.unknownFields
683 default:
684 return nil
685 }
686 }
687 file_envoy_data_tap_v2alpha_transport_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
688 switch v := v.(*SocketBufferedTrace); i {
689 case 0:
690 return &v.state
691 case 1:
692 return &v.sizeCache
693 case 2:
694 return &v.unknownFields
695 default:
696 return nil
697 }
698 }
699 file_envoy_data_tap_v2alpha_transport_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
700 switch v := v.(*SocketStreamedTraceSegment); i {
701 case 0:
702 return &v.state
703 case 1:
704 return &v.sizeCache
705 case 2:
706 return &v.unknownFields
707 default:
708 return nil
709 }
710 }
711 file_envoy_data_tap_v2alpha_transport_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
712 switch v := v.(*SocketEvent_Read); i {
713 case 0:
714 return &v.state
715 case 1:
716 return &v.sizeCache
717 case 2:
718 return &v.unknownFields
719 default:
720 return nil
721 }
722 }
723 file_envoy_data_tap_v2alpha_transport_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
724 switch v := v.(*SocketEvent_Write); i {
725 case 0:
726 return &v.state
727 case 1:
728 return &v.sizeCache
729 case 2:
730 return &v.unknownFields
731 default:
732 return nil
733 }
734 }
735 file_envoy_data_tap_v2alpha_transport_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
736 switch v := v.(*SocketEvent_Closed); i {
737 case 0:
738 return &v.state
739 case 1:
740 return &v.sizeCache
741 case 2:
742 return &v.unknownFields
743 default:
744 return nil
745 }
746 }
747 }
748 file_envoy_data_tap_v2alpha_transport_proto_msgTypes[1].OneofWrappers = []interface{}{
749 (*SocketEvent_Read_)(nil),
750 (*SocketEvent_Write_)(nil),
751 (*SocketEvent_Closed_)(nil),
752 }
753 file_envoy_data_tap_v2alpha_transport_proto_msgTypes[3].OneofWrappers = []interface{}{
754 (*SocketStreamedTraceSegment_Connection)(nil),
755 (*SocketStreamedTraceSegment_Event)(nil),
756 }
757 type x struct{}
758 out := protoimpl.TypeBuilder{
759 File: protoimpl.DescBuilder{
760 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
761 RawDescriptor: file_envoy_data_tap_v2alpha_transport_proto_rawDesc,
762 NumEnums: 0,
763 NumMessages: 7,
764 NumExtensions: 0,
765 NumServices: 0,
766 },
767 GoTypes: file_envoy_data_tap_v2alpha_transport_proto_goTypes,
768 DependencyIndexes: file_envoy_data_tap_v2alpha_transport_proto_depIdxs,
769 MessageInfos: file_envoy_data_tap_v2alpha_transport_proto_msgTypes,
770 }.Build()
771 File_envoy_data_tap_v2alpha_transport_proto = out.File
772 file_envoy_data_tap_v2alpha_transport_proto_rawDesc = nil
773 file_envoy_data_tap_v2alpha_transport_proto_goTypes = nil
774 file_envoy_data_tap_v2alpha_transport_proto_depIdxs = nil
775 }
776
View as plain text