1
2
3
4
5
6
7 package tap
8
9 import (
10 duration "github.com/golang/protobuf/ptypes/duration"
11 http_types "github.com/linkerd/linkerd2-proxy-api/go/http_types"
12 net "github.com/linkerd/linkerd2-proxy-api/go/net"
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 type TapEvent_ProxyDirection int32
27
28 const (
29 TapEvent_UNKNOWN TapEvent_ProxyDirection = 0
30 TapEvent_INBOUND TapEvent_ProxyDirection = 1
31 TapEvent_OUTBOUND TapEvent_ProxyDirection = 2
32 )
33
34
35 var (
36 TapEvent_ProxyDirection_name = map[int32]string{
37 0: "UNKNOWN",
38 1: "INBOUND",
39 2: "OUTBOUND",
40 }
41 TapEvent_ProxyDirection_value = map[string]int32{
42 "UNKNOWN": 0,
43 "INBOUND": 1,
44 "OUTBOUND": 2,
45 }
46 )
47
48 func (x TapEvent_ProxyDirection) Enum() *TapEvent_ProxyDirection {
49 p := new(TapEvent_ProxyDirection)
50 *p = x
51 return p
52 }
53
54 func (x TapEvent_ProxyDirection) String() string {
55 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
56 }
57
58 func (TapEvent_ProxyDirection) Descriptor() protoreflect.EnumDescriptor {
59 return file_tap_proto_enumTypes[0].Descriptor()
60 }
61
62 func (TapEvent_ProxyDirection) Type() protoreflect.EnumType {
63 return &file_tap_proto_enumTypes[0]
64 }
65
66 func (x TapEvent_ProxyDirection) Number() protoreflect.EnumNumber {
67 return protoreflect.EnumNumber(x)
68 }
69
70
71 func (TapEvent_ProxyDirection) EnumDescriptor() ([]byte, []int) {
72 return file_tap_proto_rawDescGZIP(), []int{2, 0}
73 }
74
75 type ObserveRequest struct {
76 state protoimpl.MessageState
77 sizeCache protoimpl.SizeCache
78 unknownFields protoimpl.UnknownFields
79
80
81 Limit uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
82
83 Match *ObserveRequest_Match `protobuf:"bytes,2,opt,name=match,proto3" json:"match,omitempty"`
84
85
86 Extract *ObserveRequest_Extract `protobuf:"bytes,3,opt,name=extract,proto3" json:"extract,omitempty"`
87 }
88
89 func (x *ObserveRequest) Reset() {
90 *x = ObserveRequest{}
91 if protoimpl.UnsafeEnabled {
92 mi := &file_tap_proto_msgTypes[0]
93 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
94 ms.StoreMessageInfo(mi)
95 }
96 }
97
98 func (x *ObserveRequest) String() string {
99 return protoimpl.X.MessageStringOf(x)
100 }
101
102 func (*ObserveRequest) ProtoMessage() {}
103
104 func (x *ObserveRequest) ProtoReflect() protoreflect.Message {
105 mi := &file_tap_proto_msgTypes[0]
106 if protoimpl.UnsafeEnabled && x != nil {
107 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
108 if ms.LoadMessageInfo() == nil {
109 ms.StoreMessageInfo(mi)
110 }
111 return ms
112 }
113 return mi.MessageOf(x)
114 }
115
116
117 func (*ObserveRequest) Descriptor() ([]byte, []int) {
118 return file_tap_proto_rawDescGZIP(), []int{0}
119 }
120
121 func (x *ObserveRequest) GetLimit() uint32 {
122 if x != nil {
123 return x.Limit
124 }
125 return 0
126 }
127
128 func (x *ObserveRequest) GetMatch() *ObserveRequest_Match {
129 if x != nil {
130 return x.Match
131 }
132 return nil
133 }
134
135 func (x *ObserveRequest) GetExtract() *ObserveRequest_Extract {
136 if x != nil {
137 return x.Extract
138 }
139 return nil
140 }
141
142 type Eos struct {
143 state protoimpl.MessageState
144 sizeCache protoimpl.SizeCache
145 unknownFields protoimpl.UnknownFields
146
147
148
149
150
151 End isEos_End `protobuf_oneof:"end"`
152 }
153
154 func (x *Eos) Reset() {
155 *x = Eos{}
156 if protoimpl.UnsafeEnabled {
157 mi := &file_tap_proto_msgTypes[1]
158 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
159 ms.StoreMessageInfo(mi)
160 }
161 }
162
163 func (x *Eos) String() string {
164 return protoimpl.X.MessageStringOf(x)
165 }
166
167 func (*Eos) ProtoMessage() {}
168
169 func (x *Eos) ProtoReflect() protoreflect.Message {
170 mi := &file_tap_proto_msgTypes[1]
171 if protoimpl.UnsafeEnabled && x != nil {
172 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
173 if ms.LoadMessageInfo() == nil {
174 ms.StoreMessageInfo(mi)
175 }
176 return ms
177 }
178 return mi.MessageOf(x)
179 }
180
181
182 func (*Eos) Descriptor() ([]byte, []int) {
183 return file_tap_proto_rawDescGZIP(), []int{1}
184 }
185
186 func (m *Eos) GetEnd() isEos_End {
187 if m != nil {
188 return m.End
189 }
190 return nil
191 }
192
193 func (x *Eos) GetGrpcStatusCode() uint32 {
194 if x, ok := x.GetEnd().(*Eos_GrpcStatusCode); ok {
195 return x.GrpcStatusCode
196 }
197 return 0
198 }
199
200 func (x *Eos) GetResetErrorCode() uint32 {
201 if x, ok := x.GetEnd().(*Eos_ResetErrorCode); ok {
202 return x.ResetErrorCode
203 }
204 return 0
205 }
206
207 type isEos_End interface {
208 isEos_End()
209 }
210
211 type Eos_GrpcStatusCode struct {
212 GrpcStatusCode uint32 `protobuf:"varint,1,opt,name=grpc_status_code,json=grpcStatusCode,proto3,oneof"`
213 }
214
215 type Eos_ResetErrorCode struct {
216 ResetErrorCode uint32 `protobuf:"varint,2,opt,name=reset_error_code,json=resetErrorCode,proto3,oneof"`
217 }
218
219 func (*Eos_GrpcStatusCode) isEos_End() {}
220
221 func (*Eos_ResetErrorCode) isEos_End() {}
222
223 type TapEvent struct {
224 state protoimpl.MessageState
225 sizeCache protoimpl.SizeCache
226 unknownFields protoimpl.UnknownFields
227
228 Source *net.TcpAddress `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
229 SourceMeta *TapEvent_EndpointMeta `protobuf:"bytes,5,opt,name=source_meta,json=sourceMeta,proto3" json:"source_meta,omitempty"`
230 RouteMeta *TapEvent_RouteMeta `protobuf:"bytes,7,opt,name=route_meta,json=routeMeta,proto3" json:"route_meta,omitempty"`
231 Destination *net.TcpAddress `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
232 DestinationMeta *TapEvent_EndpointMeta `protobuf:"bytes,4,opt,name=destination_meta,json=destinationMeta,proto3" json:"destination_meta,omitempty"`
233 ProxyDirection TapEvent_ProxyDirection `protobuf:"varint,6,opt,name=proxy_direction,json=proxyDirection,proto3,enum=io.linkerd.proxy.tap.TapEvent_ProxyDirection" json:"proxy_direction,omitempty"`
234
235
236
237 Event isTapEvent_Event `protobuf_oneof:"event"`
238 }
239
240 func (x *TapEvent) Reset() {
241 *x = TapEvent{}
242 if protoimpl.UnsafeEnabled {
243 mi := &file_tap_proto_msgTypes[2]
244 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
245 ms.StoreMessageInfo(mi)
246 }
247 }
248
249 func (x *TapEvent) String() string {
250 return protoimpl.X.MessageStringOf(x)
251 }
252
253 func (*TapEvent) ProtoMessage() {}
254
255 func (x *TapEvent) ProtoReflect() protoreflect.Message {
256 mi := &file_tap_proto_msgTypes[2]
257 if protoimpl.UnsafeEnabled && x != nil {
258 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
259 if ms.LoadMessageInfo() == nil {
260 ms.StoreMessageInfo(mi)
261 }
262 return ms
263 }
264 return mi.MessageOf(x)
265 }
266
267
268 func (*TapEvent) Descriptor() ([]byte, []int) {
269 return file_tap_proto_rawDescGZIP(), []int{2}
270 }
271
272 func (x *TapEvent) GetSource() *net.TcpAddress {
273 if x != nil {
274 return x.Source
275 }
276 return nil
277 }
278
279 func (x *TapEvent) GetSourceMeta() *TapEvent_EndpointMeta {
280 if x != nil {
281 return x.SourceMeta
282 }
283 return nil
284 }
285
286 func (x *TapEvent) GetRouteMeta() *TapEvent_RouteMeta {
287 if x != nil {
288 return x.RouteMeta
289 }
290 return nil
291 }
292
293 func (x *TapEvent) GetDestination() *net.TcpAddress {
294 if x != nil {
295 return x.Destination
296 }
297 return nil
298 }
299
300 func (x *TapEvent) GetDestinationMeta() *TapEvent_EndpointMeta {
301 if x != nil {
302 return x.DestinationMeta
303 }
304 return nil
305 }
306
307 func (x *TapEvent) GetProxyDirection() TapEvent_ProxyDirection {
308 if x != nil {
309 return x.ProxyDirection
310 }
311 return TapEvent_UNKNOWN
312 }
313
314 func (m *TapEvent) GetEvent() isTapEvent_Event {
315 if m != nil {
316 return m.Event
317 }
318 return nil
319 }
320
321 func (x *TapEvent) GetHttp() *TapEvent_Http {
322 if x, ok := x.GetEvent().(*TapEvent_Http_); ok {
323 return x.Http
324 }
325 return nil
326 }
327
328 type isTapEvent_Event interface {
329 isTapEvent_Event()
330 }
331
332 type TapEvent_Http_ struct {
333 Http *TapEvent_Http `protobuf:"bytes,3,opt,name=http,proto3,oneof"`
334 }
335
336 func (*TapEvent_Http_) isTapEvent_Event() {}
337
338 type ObserveRequest_Match struct {
339 state protoimpl.MessageState
340 sizeCache protoimpl.SizeCache
341 unknownFields protoimpl.UnknownFields
342
343
344
345
346
347
348
349
350
351
352
353 Match isObserveRequest_Match_Match `protobuf_oneof:"match"`
354 }
355
356 func (x *ObserveRequest_Match) Reset() {
357 *x = ObserveRequest_Match{}
358 if protoimpl.UnsafeEnabled {
359 mi := &file_tap_proto_msgTypes[3]
360 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
361 ms.StoreMessageInfo(mi)
362 }
363 }
364
365 func (x *ObserveRequest_Match) String() string {
366 return protoimpl.X.MessageStringOf(x)
367 }
368
369 func (*ObserveRequest_Match) ProtoMessage() {}
370
371 func (x *ObserveRequest_Match) ProtoReflect() protoreflect.Message {
372 mi := &file_tap_proto_msgTypes[3]
373 if protoimpl.UnsafeEnabled && x != nil {
374 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
375 if ms.LoadMessageInfo() == nil {
376 ms.StoreMessageInfo(mi)
377 }
378 return ms
379 }
380 return mi.MessageOf(x)
381 }
382
383
384 func (*ObserveRequest_Match) Descriptor() ([]byte, []int) {
385 return file_tap_proto_rawDescGZIP(), []int{0, 0}
386 }
387
388 func (m *ObserveRequest_Match) GetMatch() isObserveRequest_Match_Match {
389 if m != nil {
390 return m.Match
391 }
392 return nil
393 }
394
395 func (x *ObserveRequest_Match) GetAll() *ObserveRequest_Match_Seq {
396 if x, ok := x.GetMatch().(*ObserveRequest_Match_All); ok {
397 return x.All
398 }
399 return nil
400 }
401
402 func (x *ObserveRequest_Match) GetAny() *ObserveRequest_Match_Seq {
403 if x, ok := x.GetMatch().(*ObserveRequest_Match_Any); ok {
404 return x.Any
405 }
406 return nil
407 }
408
409 func (x *ObserveRequest_Match) GetNot() *ObserveRequest_Match {
410 if x, ok := x.GetMatch().(*ObserveRequest_Match_Not); ok {
411 return x.Not
412 }
413 return nil
414 }
415
416 func (x *ObserveRequest_Match) GetSource() *ObserveRequest_Match_Tcp {
417 if x, ok := x.GetMatch().(*ObserveRequest_Match_Source); ok {
418 return x.Source
419 }
420 return nil
421 }
422
423 func (x *ObserveRequest_Match) GetDestination() *ObserveRequest_Match_Tcp {
424 if x, ok := x.GetMatch().(*ObserveRequest_Match_Destination); ok {
425 return x.Destination
426 }
427 return nil
428 }
429
430 func (x *ObserveRequest_Match) GetHttp() *ObserveRequest_Match_Http {
431 if x, ok := x.GetMatch().(*ObserveRequest_Match_Http_); ok {
432 return x.Http
433 }
434 return nil
435 }
436
437 func (x *ObserveRequest_Match) GetDestinationLabel() *ObserveRequest_Match_Label {
438 if x, ok := x.GetMatch().(*ObserveRequest_Match_DestinationLabel); ok {
439 return x.DestinationLabel
440 }
441 return nil
442 }
443
444 func (x *ObserveRequest_Match) GetRouteLabel() *ObserveRequest_Match_Label {
445 if x, ok := x.GetMatch().(*ObserveRequest_Match_RouteLabel); ok {
446 return x.RouteLabel
447 }
448 return nil
449 }
450
451 type isObserveRequest_Match_Match interface {
452 isObserveRequest_Match_Match()
453 }
454
455 type ObserveRequest_Match_All struct {
456 All *ObserveRequest_Match_Seq `protobuf:"bytes,1,opt,name=all,proto3,oneof"`
457 }
458
459 type ObserveRequest_Match_Any struct {
460 Any *ObserveRequest_Match_Seq `protobuf:"bytes,2,opt,name=any,proto3,oneof"`
461 }
462
463 type ObserveRequest_Match_Not struct {
464 Not *ObserveRequest_Match `protobuf:"bytes,3,opt,name=not,proto3,oneof"`
465 }
466
467 type ObserveRequest_Match_Source struct {
468 Source *ObserveRequest_Match_Tcp `protobuf:"bytes,4,opt,name=source,proto3,oneof"`
469 }
470
471 type ObserveRequest_Match_Destination struct {
472 Destination *ObserveRequest_Match_Tcp `protobuf:"bytes,5,opt,name=destination,proto3,oneof"`
473 }
474
475 type ObserveRequest_Match_Http_ struct {
476 Http *ObserveRequest_Match_Http `protobuf:"bytes,6,opt,name=http,proto3,oneof"`
477 }
478
479 type ObserveRequest_Match_DestinationLabel struct {
480 DestinationLabel *ObserveRequest_Match_Label `protobuf:"bytes,7,opt,name=destination_label,json=destinationLabel,proto3,oneof"`
481 }
482
483 type ObserveRequest_Match_RouteLabel struct {
484 RouteLabel *ObserveRequest_Match_Label `protobuf:"bytes,8,opt,name=route_label,json=routeLabel,proto3,oneof"`
485 }
486
487 func (*ObserveRequest_Match_All) isObserveRequest_Match_Match() {}
488
489 func (*ObserveRequest_Match_Any) isObserveRequest_Match_Match() {}
490
491 func (*ObserveRequest_Match_Not) isObserveRequest_Match_Match() {}
492
493 func (*ObserveRequest_Match_Source) isObserveRequest_Match_Match() {}
494
495 func (*ObserveRequest_Match_Destination) isObserveRequest_Match_Match() {}
496
497 func (*ObserveRequest_Match_Http_) isObserveRequest_Match_Match() {}
498
499 func (*ObserveRequest_Match_DestinationLabel) isObserveRequest_Match_Match() {}
500
501 func (*ObserveRequest_Match_RouteLabel) isObserveRequest_Match_Match() {}
502
503 type ObserveRequest_Extract struct {
504 state protoimpl.MessageState
505 sizeCache protoimpl.SizeCache
506 unknownFields protoimpl.UnknownFields
507
508
509
510
511 Extract isObserveRequest_Extract_Extract `protobuf_oneof:"extract"`
512 }
513
514 func (x *ObserveRequest_Extract) Reset() {
515 *x = ObserveRequest_Extract{}
516 if protoimpl.UnsafeEnabled {
517 mi := &file_tap_proto_msgTypes[4]
518 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
519 ms.StoreMessageInfo(mi)
520 }
521 }
522
523 func (x *ObserveRequest_Extract) String() string {
524 return protoimpl.X.MessageStringOf(x)
525 }
526
527 func (*ObserveRequest_Extract) ProtoMessage() {}
528
529 func (x *ObserveRequest_Extract) ProtoReflect() protoreflect.Message {
530 mi := &file_tap_proto_msgTypes[4]
531 if protoimpl.UnsafeEnabled && x != nil {
532 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
533 if ms.LoadMessageInfo() == nil {
534 ms.StoreMessageInfo(mi)
535 }
536 return ms
537 }
538 return mi.MessageOf(x)
539 }
540
541
542 func (*ObserveRequest_Extract) Descriptor() ([]byte, []int) {
543 return file_tap_proto_rawDescGZIP(), []int{0, 1}
544 }
545
546 func (m *ObserveRequest_Extract) GetExtract() isObserveRequest_Extract_Extract {
547 if m != nil {
548 return m.Extract
549 }
550 return nil
551 }
552
553 func (x *ObserveRequest_Extract) GetHttp() *ObserveRequest_Extract_Http {
554 if x, ok := x.GetExtract().(*ObserveRequest_Extract_Http_); ok {
555 return x.Http
556 }
557 return nil
558 }
559
560 type isObserveRequest_Extract_Extract interface {
561 isObserveRequest_Extract_Extract()
562 }
563
564 type ObserveRequest_Extract_Http_ struct {
565 Http *ObserveRequest_Extract_Http `protobuf:"bytes,1,opt,name=http,proto3,oneof"`
566 }
567
568 func (*ObserveRequest_Extract_Http_) isObserveRequest_Extract_Extract() {}
569
570 type ObserveRequest_Match_Seq struct {
571 state protoimpl.MessageState
572 sizeCache protoimpl.SizeCache
573 unknownFields protoimpl.UnknownFields
574
575 Matches []*ObserveRequest_Match `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
576 }
577
578 func (x *ObserveRequest_Match_Seq) Reset() {
579 *x = ObserveRequest_Match_Seq{}
580 if protoimpl.UnsafeEnabled {
581 mi := &file_tap_proto_msgTypes[5]
582 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
583 ms.StoreMessageInfo(mi)
584 }
585 }
586
587 func (x *ObserveRequest_Match_Seq) String() string {
588 return protoimpl.X.MessageStringOf(x)
589 }
590
591 func (*ObserveRequest_Match_Seq) ProtoMessage() {}
592
593 func (x *ObserveRequest_Match_Seq) ProtoReflect() protoreflect.Message {
594 mi := &file_tap_proto_msgTypes[5]
595 if protoimpl.UnsafeEnabled && x != nil {
596 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
597 if ms.LoadMessageInfo() == nil {
598 ms.StoreMessageInfo(mi)
599 }
600 return ms
601 }
602 return mi.MessageOf(x)
603 }
604
605
606 func (*ObserveRequest_Match_Seq) Descriptor() ([]byte, []int) {
607 return file_tap_proto_rawDescGZIP(), []int{0, 0, 0}
608 }
609
610 func (x *ObserveRequest_Match_Seq) GetMatches() []*ObserveRequest_Match {
611 if x != nil {
612 return x.Matches
613 }
614 return nil
615 }
616
617 type ObserveRequest_Match_Label struct {
618 state protoimpl.MessageState
619 sizeCache protoimpl.SizeCache
620 unknownFields protoimpl.UnknownFields
621
622 Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
623 Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
624 }
625
626 func (x *ObserveRequest_Match_Label) Reset() {
627 *x = ObserveRequest_Match_Label{}
628 if protoimpl.UnsafeEnabled {
629 mi := &file_tap_proto_msgTypes[6]
630 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
631 ms.StoreMessageInfo(mi)
632 }
633 }
634
635 func (x *ObserveRequest_Match_Label) String() string {
636 return protoimpl.X.MessageStringOf(x)
637 }
638
639 func (*ObserveRequest_Match_Label) ProtoMessage() {}
640
641 func (x *ObserveRequest_Match_Label) ProtoReflect() protoreflect.Message {
642 mi := &file_tap_proto_msgTypes[6]
643 if protoimpl.UnsafeEnabled && x != nil {
644 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
645 if ms.LoadMessageInfo() == nil {
646 ms.StoreMessageInfo(mi)
647 }
648 return ms
649 }
650 return mi.MessageOf(x)
651 }
652
653
654 func (*ObserveRequest_Match_Label) Descriptor() ([]byte, []int) {
655 return file_tap_proto_rawDescGZIP(), []int{0, 0, 1}
656 }
657
658 func (x *ObserveRequest_Match_Label) GetKey() string {
659 if x != nil {
660 return x.Key
661 }
662 return ""
663 }
664
665 func (x *ObserveRequest_Match_Label) GetValue() string {
666 if x != nil {
667 return x.Value
668 }
669 return ""
670 }
671
672 type ObserveRequest_Match_Tcp struct {
673 state protoimpl.MessageState
674 sizeCache protoimpl.SizeCache
675 unknownFields protoimpl.UnknownFields
676
677
678
679
680
681 Match isObserveRequest_Match_Tcp_Match `protobuf_oneof:"match"`
682 }
683
684 func (x *ObserveRequest_Match_Tcp) Reset() {
685 *x = ObserveRequest_Match_Tcp{}
686 if protoimpl.UnsafeEnabled {
687 mi := &file_tap_proto_msgTypes[7]
688 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
689 ms.StoreMessageInfo(mi)
690 }
691 }
692
693 func (x *ObserveRequest_Match_Tcp) String() string {
694 return protoimpl.X.MessageStringOf(x)
695 }
696
697 func (*ObserveRequest_Match_Tcp) ProtoMessage() {}
698
699 func (x *ObserveRequest_Match_Tcp) ProtoReflect() protoreflect.Message {
700 mi := &file_tap_proto_msgTypes[7]
701 if protoimpl.UnsafeEnabled && x != nil {
702 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
703 if ms.LoadMessageInfo() == nil {
704 ms.StoreMessageInfo(mi)
705 }
706 return ms
707 }
708 return mi.MessageOf(x)
709 }
710
711
712 func (*ObserveRequest_Match_Tcp) Descriptor() ([]byte, []int) {
713 return file_tap_proto_rawDescGZIP(), []int{0, 0, 2}
714 }
715
716 func (m *ObserveRequest_Match_Tcp) GetMatch() isObserveRequest_Match_Tcp_Match {
717 if m != nil {
718 return m.Match
719 }
720 return nil
721 }
722
723 func (x *ObserveRequest_Match_Tcp) GetNetmask() *ObserveRequest_Match_Tcp_Netmask {
724 if x, ok := x.GetMatch().(*ObserveRequest_Match_Tcp_Netmask_); ok {
725 return x.Netmask
726 }
727 return nil
728 }
729
730 func (x *ObserveRequest_Match_Tcp) GetPorts() *ObserveRequest_Match_Tcp_PortRange {
731 if x, ok := x.GetMatch().(*ObserveRequest_Match_Tcp_Ports); ok {
732 return x.Ports
733 }
734 return nil
735 }
736
737 type isObserveRequest_Match_Tcp_Match interface {
738 isObserveRequest_Match_Tcp_Match()
739 }
740
741 type ObserveRequest_Match_Tcp_Netmask_ struct {
742 Netmask *ObserveRequest_Match_Tcp_Netmask `protobuf:"bytes,1,opt,name=netmask,proto3,oneof"`
743 }
744
745 type ObserveRequest_Match_Tcp_Ports struct {
746 Ports *ObserveRequest_Match_Tcp_PortRange `protobuf:"bytes,3,opt,name=ports,proto3,oneof"`
747 }
748
749 func (*ObserveRequest_Match_Tcp_Netmask_) isObserveRequest_Match_Tcp_Match() {}
750
751 func (*ObserveRequest_Match_Tcp_Ports) isObserveRequest_Match_Tcp_Match() {}
752
753 type ObserveRequest_Match_Http struct {
754 state protoimpl.MessageState
755 sizeCache protoimpl.SizeCache
756 unknownFields protoimpl.UnknownFields
757
758
759
760
761
762
763
764 Match isObserveRequest_Match_Http_Match `protobuf_oneof:"match"`
765 }
766
767 func (x *ObserveRequest_Match_Http) Reset() {
768 *x = ObserveRequest_Match_Http{}
769 if protoimpl.UnsafeEnabled {
770 mi := &file_tap_proto_msgTypes[8]
771 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
772 ms.StoreMessageInfo(mi)
773 }
774 }
775
776 func (x *ObserveRequest_Match_Http) String() string {
777 return protoimpl.X.MessageStringOf(x)
778 }
779
780 func (*ObserveRequest_Match_Http) ProtoMessage() {}
781
782 func (x *ObserveRequest_Match_Http) ProtoReflect() protoreflect.Message {
783 mi := &file_tap_proto_msgTypes[8]
784 if protoimpl.UnsafeEnabled && x != nil {
785 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
786 if ms.LoadMessageInfo() == nil {
787 ms.StoreMessageInfo(mi)
788 }
789 return ms
790 }
791 return mi.MessageOf(x)
792 }
793
794
795 func (*ObserveRequest_Match_Http) Descriptor() ([]byte, []int) {
796 return file_tap_proto_rawDescGZIP(), []int{0, 0, 3}
797 }
798
799 func (m *ObserveRequest_Match_Http) GetMatch() isObserveRequest_Match_Http_Match {
800 if m != nil {
801 return m.Match
802 }
803 return nil
804 }
805
806 func (x *ObserveRequest_Match_Http) GetScheme() *http_types.Scheme {
807 if x, ok := x.GetMatch().(*ObserveRequest_Match_Http_Scheme); ok {
808 return x.Scheme
809 }
810 return nil
811 }
812
813 func (x *ObserveRequest_Match_Http) GetMethod() *http_types.HttpMethod {
814 if x, ok := x.GetMatch().(*ObserveRequest_Match_Http_Method); ok {
815 return x.Method
816 }
817 return nil
818 }
819
820 func (x *ObserveRequest_Match_Http) GetAuthority() *ObserveRequest_Match_Http_StringMatch {
821 if x, ok := x.GetMatch().(*ObserveRequest_Match_Http_Authority); ok {
822 return x.Authority
823 }
824 return nil
825 }
826
827 func (x *ObserveRequest_Match_Http) GetPath() *ObserveRequest_Match_Http_StringMatch {
828 if x, ok := x.GetMatch().(*ObserveRequest_Match_Http_Path); ok {
829 return x.Path
830 }
831 return nil
832 }
833
834 type isObserveRequest_Match_Http_Match interface {
835 isObserveRequest_Match_Http_Match()
836 }
837
838 type ObserveRequest_Match_Http_Scheme struct {
839 Scheme *http_types.Scheme `protobuf:"bytes,1,opt,name=scheme,proto3,oneof"`
840 }
841
842 type ObserveRequest_Match_Http_Method struct {
843 Method *http_types.HttpMethod `protobuf:"bytes,3,opt,name=method,proto3,oneof"`
844 }
845
846 type ObserveRequest_Match_Http_Authority struct {
847 Authority *ObserveRequest_Match_Http_StringMatch `protobuf:"bytes,2,opt,name=authority,proto3,oneof"`
848 }
849
850 type ObserveRequest_Match_Http_Path struct {
851 Path *ObserveRequest_Match_Http_StringMatch `protobuf:"bytes,4,opt,name=path,proto3,oneof"`
852 }
853
854 func (*ObserveRequest_Match_Http_Scheme) isObserveRequest_Match_Http_Match() {}
855
856 func (*ObserveRequest_Match_Http_Method) isObserveRequest_Match_Http_Match() {}
857
858 func (*ObserveRequest_Match_Http_Authority) isObserveRequest_Match_Http_Match() {}
859
860 func (*ObserveRequest_Match_Http_Path) isObserveRequest_Match_Http_Match() {}
861
862 type ObserveRequest_Match_Tcp_Netmask struct {
863 state protoimpl.MessageState
864 sizeCache protoimpl.SizeCache
865 unknownFields protoimpl.UnknownFields
866
867 Ip *net.IPAddress `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
868 Mask uint32 `protobuf:"varint,2,opt,name=mask,proto3" json:"mask,omitempty"`
869 }
870
871 func (x *ObserveRequest_Match_Tcp_Netmask) Reset() {
872 *x = ObserveRequest_Match_Tcp_Netmask{}
873 if protoimpl.UnsafeEnabled {
874 mi := &file_tap_proto_msgTypes[9]
875 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
876 ms.StoreMessageInfo(mi)
877 }
878 }
879
880 func (x *ObserveRequest_Match_Tcp_Netmask) String() string {
881 return protoimpl.X.MessageStringOf(x)
882 }
883
884 func (*ObserveRequest_Match_Tcp_Netmask) ProtoMessage() {}
885
886 func (x *ObserveRequest_Match_Tcp_Netmask) ProtoReflect() protoreflect.Message {
887 mi := &file_tap_proto_msgTypes[9]
888 if protoimpl.UnsafeEnabled && x != nil {
889 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
890 if ms.LoadMessageInfo() == nil {
891 ms.StoreMessageInfo(mi)
892 }
893 return ms
894 }
895 return mi.MessageOf(x)
896 }
897
898
899 func (*ObserveRequest_Match_Tcp_Netmask) Descriptor() ([]byte, []int) {
900 return file_tap_proto_rawDescGZIP(), []int{0, 0, 2, 0}
901 }
902
903 func (x *ObserveRequest_Match_Tcp_Netmask) GetIp() *net.IPAddress {
904 if x != nil {
905 return x.Ip
906 }
907 return nil
908 }
909
910 func (x *ObserveRequest_Match_Tcp_Netmask) GetMask() uint32 {
911 if x != nil {
912 return x.Mask
913 }
914 return 0
915 }
916
917
918
919 type ObserveRequest_Match_Tcp_PortRange struct {
920 state protoimpl.MessageState
921 sizeCache protoimpl.SizeCache
922 unknownFields protoimpl.UnknownFields
923
924
925 Min uint32 `protobuf:"varint,1,opt,name=min,proto3" json:"min,omitempty"`
926
927 Max uint32 `protobuf:"varint,2,opt,name=max,proto3" json:"max,omitempty"`
928 }
929
930 func (x *ObserveRequest_Match_Tcp_PortRange) Reset() {
931 *x = ObserveRequest_Match_Tcp_PortRange{}
932 if protoimpl.UnsafeEnabled {
933 mi := &file_tap_proto_msgTypes[10]
934 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
935 ms.StoreMessageInfo(mi)
936 }
937 }
938
939 func (x *ObserveRequest_Match_Tcp_PortRange) String() string {
940 return protoimpl.X.MessageStringOf(x)
941 }
942
943 func (*ObserveRequest_Match_Tcp_PortRange) ProtoMessage() {}
944
945 func (x *ObserveRequest_Match_Tcp_PortRange) ProtoReflect() protoreflect.Message {
946 mi := &file_tap_proto_msgTypes[10]
947 if protoimpl.UnsafeEnabled && x != nil {
948 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
949 if ms.LoadMessageInfo() == nil {
950 ms.StoreMessageInfo(mi)
951 }
952 return ms
953 }
954 return mi.MessageOf(x)
955 }
956
957
958 func (*ObserveRequest_Match_Tcp_PortRange) Descriptor() ([]byte, []int) {
959 return file_tap_proto_rawDescGZIP(), []int{0, 0, 2, 1}
960 }
961
962 func (x *ObserveRequest_Match_Tcp_PortRange) GetMin() uint32 {
963 if x != nil {
964 return x.Min
965 }
966 return 0
967 }
968
969 func (x *ObserveRequest_Match_Tcp_PortRange) GetMax() uint32 {
970 if x != nil {
971 return x.Max
972 }
973 return 0
974 }
975
976 type ObserveRequest_Match_Http_StringMatch struct {
977 state protoimpl.MessageState
978 sizeCache protoimpl.SizeCache
979 unknownFields protoimpl.UnknownFields
980
981
982
983
984
985 Match isObserveRequest_Match_Http_StringMatch_Match `protobuf_oneof:"match"`
986 }
987
988 func (x *ObserveRequest_Match_Http_StringMatch) Reset() {
989 *x = ObserveRequest_Match_Http_StringMatch{}
990 if protoimpl.UnsafeEnabled {
991 mi := &file_tap_proto_msgTypes[11]
992 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
993 ms.StoreMessageInfo(mi)
994 }
995 }
996
997 func (x *ObserveRequest_Match_Http_StringMatch) String() string {
998 return protoimpl.X.MessageStringOf(x)
999 }
1000
1001 func (*ObserveRequest_Match_Http_StringMatch) ProtoMessage() {}
1002
1003 func (x *ObserveRequest_Match_Http_StringMatch) ProtoReflect() protoreflect.Message {
1004 mi := &file_tap_proto_msgTypes[11]
1005 if protoimpl.UnsafeEnabled && x != nil {
1006 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1007 if ms.LoadMessageInfo() == nil {
1008 ms.StoreMessageInfo(mi)
1009 }
1010 return ms
1011 }
1012 return mi.MessageOf(x)
1013 }
1014
1015
1016 func (*ObserveRequest_Match_Http_StringMatch) Descriptor() ([]byte, []int) {
1017 return file_tap_proto_rawDescGZIP(), []int{0, 0, 3, 0}
1018 }
1019
1020 func (m *ObserveRequest_Match_Http_StringMatch) GetMatch() isObserveRequest_Match_Http_StringMatch_Match {
1021 if m != nil {
1022 return m.Match
1023 }
1024 return nil
1025 }
1026
1027 func (x *ObserveRequest_Match_Http_StringMatch) GetExact() string {
1028 if x, ok := x.GetMatch().(*ObserveRequest_Match_Http_StringMatch_Exact); ok {
1029 return x.Exact
1030 }
1031 return ""
1032 }
1033
1034 func (x *ObserveRequest_Match_Http_StringMatch) GetPrefix() string {
1035 if x, ok := x.GetMatch().(*ObserveRequest_Match_Http_StringMatch_Prefix); ok {
1036 return x.Prefix
1037 }
1038 return ""
1039 }
1040
1041 type isObserveRequest_Match_Http_StringMatch_Match interface {
1042 isObserveRequest_Match_Http_StringMatch_Match()
1043 }
1044
1045 type ObserveRequest_Match_Http_StringMatch_Exact struct {
1046 Exact string `protobuf:"bytes,1,opt,name=exact,proto3,oneof"`
1047 }
1048
1049 type ObserveRequest_Match_Http_StringMatch_Prefix struct {
1050 Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3,oneof"`
1051 }
1052
1053 func (*ObserveRequest_Match_Http_StringMatch_Exact) isObserveRequest_Match_Http_StringMatch_Match() {}
1054
1055 func (*ObserveRequest_Match_Http_StringMatch_Prefix) isObserveRequest_Match_Http_StringMatch_Match() {
1056 }
1057
1058 type ObserveRequest_Extract_Http struct {
1059 state protoimpl.MessageState
1060 sizeCache protoimpl.SizeCache
1061 unknownFields protoimpl.UnknownFields
1062
1063
1064
1065
1066 Extract isObserveRequest_Extract_Http_Extract `protobuf_oneof:"extract"`
1067 }
1068
1069 func (x *ObserveRequest_Extract_Http) Reset() {
1070 *x = ObserveRequest_Extract_Http{}
1071 if protoimpl.UnsafeEnabled {
1072 mi := &file_tap_proto_msgTypes[12]
1073 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1074 ms.StoreMessageInfo(mi)
1075 }
1076 }
1077
1078 func (x *ObserveRequest_Extract_Http) String() string {
1079 return protoimpl.X.MessageStringOf(x)
1080 }
1081
1082 func (*ObserveRequest_Extract_Http) ProtoMessage() {}
1083
1084 func (x *ObserveRequest_Extract_Http) ProtoReflect() protoreflect.Message {
1085 mi := &file_tap_proto_msgTypes[12]
1086 if protoimpl.UnsafeEnabled && x != nil {
1087 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1088 if ms.LoadMessageInfo() == nil {
1089 ms.StoreMessageInfo(mi)
1090 }
1091 return ms
1092 }
1093 return mi.MessageOf(x)
1094 }
1095
1096
1097 func (*ObserveRequest_Extract_Http) Descriptor() ([]byte, []int) {
1098 return file_tap_proto_rawDescGZIP(), []int{0, 1, 0}
1099 }
1100
1101 func (m *ObserveRequest_Extract_Http) GetExtract() isObserveRequest_Extract_Http_Extract {
1102 if m != nil {
1103 return m.Extract
1104 }
1105 return nil
1106 }
1107
1108 func (x *ObserveRequest_Extract_Http) GetHeaders() *ObserveRequest_Extract_Http_Headers {
1109 if x, ok := x.GetExtract().(*ObserveRequest_Extract_Http_Headers_); ok {
1110 return x.Headers
1111 }
1112 return nil
1113 }
1114
1115 type isObserveRequest_Extract_Http_Extract interface {
1116 isObserveRequest_Extract_Http_Extract()
1117 }
1118
1119 type ObserveRequest_Extract_Http_Headers_ struct {
1120 Headers *ObserveRequest_Extract_Http_Headers `protobuf:"bytes,1,opt,name=headers,proto3,oneof"`
1121 }
1122
1123 func (*ObserveRequest_Extract_Http_Headers_) isObserveRequest_Extract_Http_Extract() {}
1124
1125 type ObserveRequest_Extract_Http_Headers struct {
1126 state protoimpl.MessageState
1127 sizeCache protoimpl.SizeCache
1128 unknownFields protoimpl.UnknownFields
1129 }
1130
1131 func (x *ObserveRequest_Extract_Http_Headers) Reset() {
1132 *x = ObserveRequest_Extract_Http_Headers{}
1133 if protoimpl.UnsafeEnabled {
1134 mi := &file_tap_proto_msgTypes[13]
1135 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1136 ms.StoreMessageInfo(mi)
1137 }
1138 }
1139
1140 func (x *ObserveRequest_Extract_Http_Headers) String() string {
1141 return protoimpl.X.MessageStringOf(x)
1142 }
1143
1144 func (*ObserveRequest_Extract_Http_Headers) ProtoMessage() {}
1145
1146 func (x *ObserveRequest_Extract_Http_Headers) ProtoReflect() protoreflect.Message {
1147 mi := &file_tap_proto_msgTypes[13]
1148 if protoimpl.UnsafeEnabled && x != nil {
1149 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1150 if ms.LoadMessageInfo() == nil {
1151 ms.StoreMessageInfo(mi)
1152 }
1153 return ms
1154 }
1155 return mi.MessageOf(x)
1156 }
1157
1158
1159 func (*ObserveRequest_Extract_Http_Headers) Descriptor() ([]byte, []int) {
1160 return file_tap_proto_rawDescGZIP(), []int{0, 1, 0, 0}
1161 }
1162
1163 type TapEvent_EndpointMeta struct {
1164 state protoimpl.MessageState
1165 sizeCache protoimpl.SizeCache
1166 unknownFields protoimpl.UnknownFields
1167
1168 Labels map[string]string `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
1169 }
1170
1171 func (x *TapEvent_EndpointMeta) Reset() {
1172 *x = TapEvent_EndpointMeta{}
1173 if protoimpl.UnsafeEnabled {
1174 mi := &file_tap_proto_msgTypes[14]
1175 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1176 ms.StoreMessageInfo(mi)
1177 }
1178 }
1179
1180 func (x *TapEvent_EndpointMeta) String() string {
1181 return protoimpl.X.MessageStringOf(x)
1182 }
1183
1184 func (*TapEvent_EndpointMeta) ProtoMessage() {}
1185
1186 func (x *TapEvent_EndpointMeta) ProtoReflect() protoreflect.Message {
1187 mi := &file_tap_proto_msgTypes[14]
1188 if protoimpl.UnsafeEnabled && x != nil {
1189 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1190 if ms.LoadMessageInfo() == nil {
1191 ms.StoreMessageInfo(mi)
1192 }
1193 return ms
1194 }
1195 return mi.MessageOf(x)
1196 }
1197
1198
1199 func (*TapEvent_EndpointMeta) Descriptor() ([]byte, []int) {
1200 return file_tap_proto_rawDescGZIP(), []int{2, 0}
1201 }
1202
1203 func (x *TapEvent_EndpointMeta) GetLabels() map[string]string {
1204 if x != nil {
1205 return x.Labels
1206 }
1207 return nil
1208 }
1209
1210 type TapEvent_RouteMeta struct {
1211 state protoimpl.MessageState
1212 sizeCache protoimpl.SizeCache
1213 unknownFields protoimpl.UnknownFields
1214
1215 Labels map[string]string `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
1216 }
1217
1218 func (x *TapEvent_RouteMeta) Reset() {
1219 *x = TapEvent_RouteMeta{}
1220 if protoimpl.UnsafeEnabled {
1221 mi := &file_tap_proto_msgTypes[15]
1222 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1223 ms.StoreMessageInfo(mi)
1224 }
1225 }
1226
1227 func (x *TapEvent_RouteMeta) String() string {
1228 return protoimpl.X.MessageStringOf(x)
1229 }
1230
1231 func (*TapEvent_RouteMeta) ProtoMessage() {}
1232
1233 func (x *TapEvent_RouteMeta) ProtoReflect() protoreflect.Message {
1234 mi := &file_tap_proto_msgTypes[15]
1235 if protoimpl.UnsafeEnabled && x != nil {
1236 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1237 if ms.LoadMessageInfo() == nil {
1238 ms.StoreMessageInfo(mi)
1239 }
1240 return ms
1241 }
1242 return mi.MessageOf(x)
1243 }
1244
1245
1246 func (*TapEvent_RouteMeta) Descriptor() ([]byte, []int) {
1247 return file_tap_proto_rawDescGZIP(), []int{2, 1}
1248 }
1249
1250 func (x *TapEvent_RouteMeta) GetLabels() map[string]string {
1251 if x != nil {
1252 return x.Labels
1253 }
1254 return nil
1255 }
1256
1257 type TapEvent_Http struct {
1258 state protoimpl.MessageState
1259 sizeCache protoimpl.SizeCache
1260 unknownFields protoimpl.UnknownFields
1261
1262
1263
1264
1265
1266
1267 Event isTapEvent_Http_Event `protobuf_oneof:"event"`
1268 }
1269
1270 func (x *TapEvent_Http) Reset() {
1271 *x = TapEvent_Http{}
1272 if protoimpl.UnsafeEnabled {
1273 mi := &file_tap_proto_msgTypes[16]
1274 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1275 ms.StoreMessageInfo(mi)
1276 }
1277 }
1278
1279 func (x *TapEvent_Http) String() string {
1280 return protoimpl.X.MessageStringOf(x)
1281 }
1282
1283 func (*TapEvent_Http) ProtoMessage() {}
1284
1285 func (x *TapEvent_Http) ProtoReflect() protoreflect.Message {
1286 mi := &file_tap_proto_msgTypes[16]
1287 if protoimpl.UnsafeEnabled && x != nil {
1288 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1289 if ms.LoadMessageInfo() == nil {
1290 ms.StoreMessageInfo(mi)
1291 }
1292 return ms
1293 }
1294 return mi.MessageOf(x)
1295 }
1296
1297
1298 func (*TapEvent_Http) Descriptor() ([]byte, []int) {
1299 return file_tap_proto_rawDescGZIP(), []int{2, 2}
1300 }
1301
1302 func (m *TapEvent_Http) GetEvent() isTapEvent_Http_Event {
1303 if m != nil {
1304 return m.Event
1305 }
1306 return nil
1307 }
1308
1309 func (x *TapEvent_Http) GetRequestInit() *TapEvent_Http_RequestInit {
1310 if x, ok := x.GetEvent().(*TapEvent_Http_RequestInit_); ok {
1311 return x.RequestInit
1312 }
1313 return nil
1314 }
1315
1316 func (x *TapEvent_Http) GetResponseInit() *TapEvent_Http_ResponseInit {
1317 if x, ok := x.GetEvent().(*TapEvent_Http_ResponseInit_); ok {
1318 return x.ResponseInit
1319 }
1320 return nil
1321 }
1322
1323 func (x *TapEvent_Http) GetResponseEnd() *TapEvent_Http_ResponseEnd {
1324 if x, ok := x.GetEvent().(*TapEvent_Http_ResponseEnd_); ok {
1325 return x.ResponseEnd
1326 }
1327 return nil
1328 }
1329
1330 type isTapEvent_Http_Event interface {
1331 isTapEvent_Http_Event()
1332 }
1333
1334 type TapEvent_Http_RequestInit_ struct {
1335 RequestInit *TapEvent_Http_RequestInit `protobuf:"bytes,1,opt,name=request_init,json=requestInit,proto3,oneof"`
1336 }
1337
1338 type TapEvent_Http_ResponseInit_ struct {
1339 ResponseInit *TapEvent_Http_ResponseInit `protobuf:"bytes,2,opt,name=response_init,json=responseInit,proto3,oneof"`
1340 }
1341
1342 type TapEvent_Http_ResponseEnd_ struct {
1343 ResponseEnd *TapEvent_Http_ResponseEnd `protobuf:"bytes,3,opt,name=response_end,json=responseEnd,proto3,oneof"`
1344 }
1345
1346 func (*TapEvent_Http_RequestInit_) isTapEvent_Http_Event() {}
1347
1348 func (*TapEvent_Http_ResponseInit_) isTapEvent_Http_Event() {}
1349
1350 func (*TapEvent_Http_ResponseEnd_) isTapEvent_Http_Event() {}
1351
1352 type TapEvent_Http_StreamId struct {
1353 state protoimpl.MessageState
1354 sizeCache protoimpl.SizeCache
1355 unknownFields protoimpl.UnknownFields
1356
1357
1358 Base uint32 `protobuf:"varint,1,opt,name=base,proto3" json:"base,omitempty"`
1359
1360 Stream uint64 `protobuf:"varint,2,opt,name=stream,proto3" json:"stream,omitempty"`
1361 }
1362
1363 func (x *TapEvent_Http_StreamId) Reset() {
1364 *x = TapEvent_Http_StreamId{}
1365 if protoimpl.UnsafeEnabled {
1366 mi := &file_tap_proto_msgTypes[19]
1367 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1368 ms.StoreMessageInfo(mi)
1369 }
1370 }
1371
1372 func (x *TapEvent_Http_StreamId) String() string {
1373 return protoimpl.X.MessageStringOf(x)
1374 }
1375
1376 func (*TapEvent_Http_StreamId) ProtoMessage() {}
1377
1378 func (x *TapEvent_Http_StreamId) ProtoReflect() protoreflect.Message {
1379 mi := &file_tap_proto_msgTypes[19]
1380 if protoimpl.UnsafeEnabled && x != nil {
1381 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1382 if ms.LoadMessageInfo() == nil {
1383 ms.StoreMessageInfo(mi)
1384 }
1385 return ms
1386 }
1387 return mi.MessageOf(x)
1388 }
1389
1390
1391 func (*TapEvent_Http_StreamId) Descriptor() ([]byte, []int) {
1392 return file_tap_proto_rawDescGZIP(), []int{2, 2, 0}
1393 }
1394
1395 func (x *TapEvent_Http_StreamId) GetBase() uint32 {
1396 if x != nil {
1397 return x.Base
1398 }
1399 return 0
1400 }
1401
1402 func (x *TapEvent_Http_StreamId) GetStream() uint64 {
1403 if x != nil {
1404 return x.Stream
1405 }
1406 return 0
1407 }
1408
1409 type TapEvent_Http_RequestInit struct {
1410 state protoimpl.MessageState
1411 sizeCache protoimpl.SizeCache
1412 unknownFields protoimpl.UnknownFields
1413
1414 Id *TapEvent_Http_StreamId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
1415 Method *http_types.HttpMethod `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
1416 Scheme *http_types.Scheme `protobuf:"bytes,3,opt,name=scheme,proto3" json:"scheme,omitempty"`
1417 Authority string `protobuf:"bytes,4,opt,name=authority,proto3" json:"authority,omitempty"`
1418 Path string `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"`
1419 Headers *http_types.Headers `protobuf:"bytes,6,opt,name=headers,proto3" json:"headers,omitempty"`
1420 }
1421
1422 func (x *TapEvent_Http_RequestInit) Reset() {
1423 *x = TapEvent_Http_RequestInit{}
1424 if protoimpl.UnsafeEnabled {
1425 mi := &file_tap_proto_msgTypes[20]
1426 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1427 ms.StoreMessageInfo(mi)
1428 }
1429 }
1430
1431 func (x *TapEvent_Http_RequestInit) String() string {
1432 return protoimpl.X.MessageStringOf(x)
1433 }
1434
1435 func (*TapEvent_Http_RequestInit) ProtoMessage() {}
1436
1437 func (x *TapEvent_Http_RequestInit) ProtoReflect() protoreflect.Message {
1438 mi := &file_tap_proto_msgTypes[20]
1439 if protoimpl.UnsafeEnabled && x != nil {
1440 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1441 if ms.LoadMessageInfo() == nil {
1442 ms.StoreMessageInfo(mi)
1443 }
1444 return ms
1445 }
1446 return mi.MessageOf(x)
1447 }
1448
1449
1450 func (*TapEvent_Http_RequestInit) Descriptor() ([]byte, []int) {
1451 return file_tap_proto_rawDescGZIP(), []int{2, 2, 1}
1452 }
1453
1454 func (x *TapEvent_Http_RequestInit) GetId() *TapEvent_Http_StreamId {
1455 if x != nil {
1456 return x.Id
1457 }
1458 return nil
1459 }
1460
1461 func (x *TapEvent_Http_RequestInit) GetMethod() *http_types.HttpMethod {
1462 if x != nil {
1463 return x.Method
1464 }
1465 return nil
1466 }
1467
1468 func (x *TapEvent_Http_RequestInit) GetScheme() *http_types.Scheme {
1469 if x != nil {
1470 return x.Scheme
1471 }
1472 return nil
1473 }
1474
1475 func (x *TapEvent_Http_RequestInit) GetAuthority() string {
1476 if x != nil {
1477 return x.Authority
1478 }
1479 return ""
1480 }
1481
1482 func (x *TapEvent_Http_RequestInit) GetPath() string {
1483 if x != nil {
1484 return x.Path
1485 }
1486 return ""
1487 }
1488
1489 func (x *TapEvent_Http_RequestInit) GetHeaders() *http_types.Headers {
1490 if x != nil {
1491 return x.Headers
1492 }
1493 return nil
1494 }
1495
1496 type TapEvent_Http_ResponseInit struct {
1497 state protoimpl.MessageState
1498 sizeCache protoimpl.SizeCache
1499 unknownFields protoimpl.UnknownFields
1500
1501 Id *TapEvent_Http_StreamId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
1502 SinceRequestInit *duration.Duration `protobuf:"bytes,2,opt,name=since_request_init,json=sinceRequestInit,proto3" json:"since_request_init,omitempty"`
1503 HttpStatus uint32 `protobuf:"varint,3,opt,name=http_status,json=httpStatus,proto3" json:"http_status,omitempty"`
1504 Headers *http_types.Headers `protobuf:"bytes,4,opt,name=headers,proto3" json:"headers,omitempty"`
1505 }
1506
1507 func (x *TapEvent_Http_ResponseInit) Reset() {
1508 *x = TapEvent_Http_ResponseInit{}
1509 if protoimpl.UnsafeEnabled {
1510 mi := &file_tap_proto_msgTypes[21]
1511 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1512 ms.StoreMessageInfo(mi)
1513 }
1514 }
1515
1516 func (x *TapEvent_Http_ResponseInit) String() string {
1517 return protoimpl.X.MessageStringOf(x)
1518 }
1519
1520 func (*TapEvent_Http_ResponseInit) ProtoMessage() {}
1521
1522 func (x *TapEvent_Http_ResponseInit) ProtoReflect() protoreflect.Message {
1523 mi := &file_tap_proto_msgTypes[21]
1524 if protoimpl.UnsafeEnabled && x != nil {
1525 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1526 if ms.LoadMessageInfo() == nil {
1527 ms.StoreMessageInfo(mi)
1528 }
1529 return ms
1530 }
1531 return mi.MessageOf(x)
1532 }
1533
1534
1535 func (*TapEvent_Http_ResponseInit) Descriptor() ([]byte, []int) {
1536 return file_tap_proto_rawDescGZIP(), []int{2, 2, 2}
1537 }
1538
1539 func (x *TapEvent_Http_ResponseInit) GetId() *TapEvent_Http_StreamId {
1540 if x != nil {
1541 return x.Id
1542 }
1543 return nil
1544 }
1545
1546 func (x *TapEvent_Http_ResponseInit) GetSinceRequestInit() *duration.Duration {
1547 if x != nil {
1548 return x.SinceRequestInit
1549 }
1550 return nil
1551 }
1552
1553 func (x *TapEvent_Http_ResponseInit) GetHttpStatus() uint32 {
1554 if x != nil {
1555 return x.HttpStatus
1556 }
1557 return 0
1558 }
1559
1560 func (x *TapEvent_Http_ResponseInit) GetHeaders() *http_types.Headers {
1561 if x != nil {
1562 return x.Headers
1563 }
1564 return nil
1565 }
1566
1567 type TapEvent_Http_ResponseEnd struct {
1568 state protoimpl.MessageState
1569 sizeCache protoimpl.SizeCache
1570 unknownFields protoimpl.UnknownFields
1571
1572 Id *TapEvent_Http_StreamId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
1573 SinceRequestInit *duration.Duration `protobuf:"bytes,2,opt,name=since_request_init,json=sinceRequestInit,proto3" json:"since_request_init,omitempty"`
1574 SinceResponseInit *duration.Duration `protobuf:"bytes,3,opt,name=since_response_init,json=sinceResponseInit,proto3" json:"since_response_init,omitempty"`
1575 ResponseBytes uint64 `protobuf:"varint,4,opt,name=response_bytes,json=responseBytes,proto3" json:"response_bytes,omitempty"`
1576 Eos *Eos `protobuf:"bytes,5,opt,name=eos,proto3" json:"eos,omitempty"`
1577 Trailers *http_types.Headers `protobuf:"bytes,6,opt,name=trailers,proto3" json:"trailers,omitempty"`
1578 }
1579
1580 func (x *TapEvent_Http_ResponseEnd) Reset() {
1581 *x = TapEvent_Http_ResponseEnd{}
1582 if protoimpl.UnsafeEnabled {
1583 mi := &file_tap_proto_msgTypes[22]
1584 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1585 ms.StoreMessageInfo(mi)
1586 }
1587 }
1588
1589 func (x *TapEvent_Http_ResponseEnd) String() string {
1590 return protoimpl.X.MessageStringOf(x)
1591 }
1592
1593 func (*TapEvent_Http_ResponseEnd) ProtoMessage() {}
1594
1595 func (x *TapEvent_Http_ResponseEnd) ProtoReflect() protoreflect.Message {
1596 mi := &file_tap_proto_msgTypes[22]
1597 if protoimpl.UnsafeEnabled && x != nil {
1598 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1599 if ms.LoadMessageInfo() == nil {
1600 ms.StoreMessageInfo(mi)
1601 }
1602 return ms
1603 }
1604 return mi.MessageOf(x)
1605 }
1606
1607
1608 func (*TapEvent_Http_ResponseEnd) Descriptor() ([]byte, []int) {
1609 return file_tap_proto_rawDescGZIP(), []int{2, 2, 3}
1610 }
1611
1612 func (x *TapEvent_Http_ResponseEnd) GetId() *TapEvent_Http_StreamId {
1613 if x != nil {
1614 return x.Id
1615 }
1616 return nil
1617 }
1618
1619 func (x *TapEvent_Http_ResponseEnd) GetSinceRequestInit() *duration.Duration {
1620 if x != nil {
1621 return x.SinceRequestInit
1622 }
1623 return nil
1624 }
1625
1626 func (x *TapEvent_Http_ResponseEnd) GetSinceResponseInit() *duration.Duration {
1627 if x != nil {
1628 return x.SinceResponseInit
1629 }
1630 return nil
1631 }
1632
1633 func (x *TapEvent_Http_ResponseEnd) GetResponseBytes() uint64 {
1634 if x != nil {
1635 return x.ResponseBytes
1636 }
1637 return 0
1638 }
1639
1640 func (x *TapEvent_Http_ResponseEnd) GetEos() *Eos {
1641 if x != nil {
1642 return x.Eos
1643 }
1644 return nil
1645 }
1646
1647 func (x *TapEvent_Http_ResponseEnd) GetTrailers() *http_types.Headers {
1648 if x != nil {
1649 return x.Trailers
1650 }
1651 return nil
1652 }
1653
1654 var File_tap_proto protoreflect.FileDescriptor
1655
1656 var file_tap_proto_rawDesc = []byte{
1657 0x0a, 0x09, 0x74, 0x61, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x14, 0x69, 0x6f, 0x2e,
1658 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61,
1659 0x70, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
1660 0x75, 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74,
1661 0x6f, 0x1a, 0x10, 0x68, 0x74, 0x74, 0x70, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2e, 0x70, 0x72,
1662 0x6f, 0x74, 0x6f, 0x1a, 0x09, 0x6e, 0x65, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xbf,
1663 0x0e, 0x0a, 0x0e, 0x4f, 0x62, 0x73, 0x65, 0x72, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
1664 0x74, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d,
1665 0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x12, 0x40, 0x0a, 0x05, 0x6d, 0x61, 0x74, 0x63, 0x68,
1666 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b,
1667 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x4f, 0x62,
1668 0x73, 0x65, 0x72, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4d, 0x61, 0x74,
1669 0x63, 0x68, 0x52, 0x05, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x12, 0x46, 0x0a, 0x07, 0x65, 0x78, 0x74,
1670 0x72, 0x61, 0x63, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x69, 0x6f, 0x2e,
1671 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61,
1672 0x70, 0x2e, 0x4f, 0x62, 0x73, 0x65, 0x72, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
1673 0x2e, 0x45, 0x78, 0x74, 0x72, 0x61, 0x63, 0x74, 0x52, 0x07, 0x65, 0x78, 0x74, 0x72, 0x61, 0x63,
1674 0x74, 0x1a, 0xb7, 0x0b, 0x0a, 0x05, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x12, 0x42, 0x0a, 0x03, 0x61,
1675 0x6c, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2e, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69,
1676 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e,
1677 0x4f, 0x62, 0x73, 0x65, 0x72, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4d,
1678 0x61, 0x74, 0x63, 0x68, 0x2e, 0x53, 0x65, 0x71, 0x48, 0x00, 0x52, 0x03, 0x61, 0x6c, 0x6c, 0x12,
1679 0x42, 0x0a, 0x03, 0x61, 0x6e, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2e, 0x2e, 0x69,
1680 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e,
1681 0x74, 0x61, 0x70, 0x2e, 0x4f, 0x62, 0x73, 0x65, 0x72, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
1682 0x73, 0x74, 0x2e, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x53, 0x65, 0x71, 0x48, 0x00, 0x52, 0x03,
1683 0x61, 0x6e, 0x79, 0x12, 0x3e, 0x0a, 0x03, 0x6e, 0x6f, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b,
1684 0x32, 0x2a, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72,
1685 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x4f, 0x62, 0x73, 0x65, 0x72, 0x76, 0x65, 0x52,
1686 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x48, 0x00, 0x52, 0x03,
1687 0x6e, 0x6f, 0x74, 0x12, 0x48, 0x0a, 0x06, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x18, 0x04, 0x20,
1688 0x01, 0x28, 0x0b, 0x32, 0x2e, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64,
1689 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x4f, 0x62, 0x73, 0x65, 0x72,
1690 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x2e,
1691 0x54, 0x63, 0x70, 0x48, 0x00, 0x52, 0x06, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x12, 0x52, 0x0a,
1692 0x0b, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x05, 0x20, 0x01,
1693 0x28, 0x0b, 0x32, 0x2e, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e,
1694 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x4f, 0x62, 0x73, 0x65, 0x72, 0x76,
1695 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x54,
1696 0x63, 0x70, 0x48, 0x00, 0x52, 0x0b, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f,
1697 0x6e, 0x12, 0x45, 0x0a, 0x04, 0x68, 0x74, 0x74, 0x70, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32,
1698 0x2f, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f,
1699 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x4f, 0x62, 0x73, 0x65, 0x72, 0x76, 0x65, 0x52, 0x65,
1700 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x48, 0x74, 0x74, 0x70,
1701 0x48, 0x00, 0x52, 0x04, 0x68, 0x74, 0x74, 0x70, 0x12, 0x5f, 0x0a, 0x11, 0x64, 0x65, 0x73, 0x74,
1702 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x18, 0x07, 0x20,
1703 0x01, 0x28, 0x0b, 0x32, 0x30, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64,
1704 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x4f, 0x62, 0x73, 0x65, 0x72,
1705 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x2e,
1706 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x48, 0x00, 0x52, 0x10, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61,
1707 0x74, 0x69, 0x6f, 0x6e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x12, 0x53, 0x0a, 0x0b, 0x72, 0x6f, 0x75,
1708 0x74, 0x65, 0x5f, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x30,
1709 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78,
1710 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x4f, 0x62, 0x73, 0x65, 0x72, 0x76, 0x65, 0x52, 0x65, 0x71,
1711 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c,
1712 0x48, 0x00, 0x52, 0x0a, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x1a, 0x4b,
1713 0x0a, 0x03, 0x53, 0x65, 0x71, 0x12, 0x44, 0x0a, 0x07, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x73,
1714 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b,
1715 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x4f, 0x62,
1716 0x73, 0x65, 0x72, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4d, 0x61, 0x74,
1717 0x63, 0x68, 0x52, 0x07, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x73, 0x1a, 0x2f, 0x0a, 0x05, 0x4c,
1718 0x61, 0x62, 0x65, 0x6c, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28,
1719 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18,
1720 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x1a, 0xb5, 0x02, 0x0a,
1721 0x03, 0x54, 0x63, 0x70, 0x12, 0x52, 0x0a, 0x07, 0x6e, 0x65, 0x74, 0x6d, 0x61, 0x73, 0x6b, 0x18,
1722 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x36, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65,
1723 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x4f, 0x62, 0x73,
1724 0x65, 0x72, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4d, 0x61, 0x74, 0x63,
1725 0x68, 0x2e, 0x54, 0x63, 0x70, 0x2e, 0x4e, 0x65, 0x74, 0x6d, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52,
1726 0x07, 0x6e, 0x65, 0x74, 0x6d, 0x61, 0x73, 0x6b, 0x12, 0x50, 0x0a, 0x05, 0x70, 0x6f, 0x72, 0x74,
1727 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x38, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e,
1728 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x4f,
1729 0x62, 0x73, 0x65, 0x72, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4d, 0x61,
1730 0x74, 0x63, 0x68, 0x2e, 0x54, 0x63, 0x70, 0x2e, 0x50, 0x6f, 0x72, 0x74, 0x52, 0x61, 0x6e, 0x67,
1731 0x65, 0x48, 0x00, 0x52, 0x05, 0x70, 0x6f, 0x72, 0x74, 0x73, 0x1a, 0x4e, 0x0a, 0x07, 0x4e, 0x65,
1732 0x74, 0x6d, 0x61, 0x73, 0x6b, 0x12, 0x2f, 0x0a, 0x02, 0x69, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28,
1733 0x0b, 0x32, 0x1f, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70,
1734 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x6e, 0x65, 0x74, 0x2e, 0x49, 0x50, 0x41, 0x64, 0x64, 0x72, 0x65,
1735 0x73, 0x73, 0x52, 0x02, 0x69, 0x70, 0x12, 0x12, 0x0a, 0x04, 0x6d, 0x61, 0x73, 0x6b, 0x18, 0x02,
1736 0x20, 0x01, 0x28, 0x0d, 0x52, 0x04, 0x6d, 0x61, 0x73, 0x6b, 0x1a, 0x2f, 0x0a, 0x09, 0x50, 0x6f,
1737 0x72, 0x74, 0x52, 0x61, 0x6e, 0x67, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x6d, 0x69, 0x6e, 0x18, 0x01,
1738 0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x6d, 0x69, 0x6e, 0x12, 0x10, 0x0a, 0x03, 0x6d, 0x61, 0x78,
1739 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x03, 0x6d, 0x61, 0x78, 0x42, 0x07, 0x0a, 0x05, 0x6d,
1740 0x61, 0x74, 0x63, 0x68, 0x1a, 0x8b, 0x03, 0x0a, 0x04, 0x48, 0x74, 0x74, 0x70, 0x12, 0x3d, 0x0a,
1741 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 0x2e,
1742 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79,
1743 0x2e, 0x68, 0x74, 0x74, 0x70, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2e, 0x53, 0x63, 0x68, 0x65,
1744 0x6d, 0x65, 0x48, 0x00, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x65, 0x12, 0x41, 0x0a, 0x06,
1745 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x69,
1746 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e,
1747 0x68, 0x74, 0x74, 0x70, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2e, 0x48, 0x74, 0x74, 0x70, 0x4d,
1748 0x65, 0x74, 0x68, 0x6f, 0x64, 0x48, 0x00, 0x52, 0x06, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x12,
1749 0x5b, 0x0a, 0x09, 0x61, 0x75, 0x74, 0x68, 0x6f, 0x72, 0x69, 0x74, 0x79, 0x18, 0x02, 0x20, 0x01,
1750 0x28, 0x0b, 0x32, 0x3b, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e,
1751 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x4f, 0x62, 0x73, 0x65, 0x72, 0x76,
1752 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x48,
1753 0x74, 0x74, 0x70, 0x2e, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x48,
1754 0x00, 0x52, 0x09, 0x61, 0x75, 0x74, 0x68, 0x6f, 0x72, 0x69, 0x74, 0x79, 0x12, 0x51, 0x0a, 0x04,
1755 0x70, 0x61, 0x74, 0x68, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3b, 0x2e, 0x69, 0x6f, 0x2e,
1756 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61,
1757 0x70, 0x2e, 0x4f, 0x62, 0x73, 0x65, 0x72, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
1758 0x2e, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x2e, 0x48, 0x74, 0x74, 0x70, 0x2e, 0x53, 0x74, 0x72, 0x69,
1759 0x6e, 0x67, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x48, 0x00, 0x52, 0x04, 0x70, 0x61, 0x74, 0x68, 0x1a,
1760 0x48, 0x0a, 0x0b, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x12, 0x16,
1761 0x0a, 0x05, 0x65, 0x78, 0x61, 0x63, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52,
1762 0x05, 0x65, 0x78, 0x61, 0x63, 0x74, 0x12, 0x18, 0x0a, 0x06, 0x70, 0x72, 0x65, 0x66, 0x69, 0x78,
1763 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x06, 0x70, 0x72, 0x65, 0x66, 0x69, 0x78,
1764 0x42, 0x07, 0x0a, 0x05, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x42, 0x07, 0x0a, 0x05, 0x6d, 0x61, 0x74,
1765 0x63, 0x68, 0x42, 0x07, 0x0a, 0x05, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x1a, 0xd2, 0x01, 0x0a, 0x07,
1766 0x45, 0x78, 0x74, 0x72, 0x61, 0x63, 0x74, 0x12, 0x47, 0x0a, 0x04, 0x68, 0x74, 0x74, 0x70, 0x18,
1767 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65,
1768 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x4f, 0x62, 0x73,
1769 0x65, 0x72, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x45, 0x78, 0x74, 0x72,
1770 0x61, 0x63, 0x74, 0x2e, 0x48, 0x74, 0x74, 0x70, 0x48, 0x00, 0x52, 0x04, 0x68, 0x74, 0x74, 0x70,
1771 0x1a, 0x73, 0x0a, 0x04, 0x48, 0x74, 0x74, 0x70, 0x12, 0x55, 0x0a, 0x07, 0x68, 0x65, 0x61, 0x64,
1772 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x39, 0x2e, 0x69, 0x6f, 0x2e, 0x6c,
1773 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70,
1774 0x2e, 0x4f, 0x62, 0x73, 0x65, 0x72, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e,
1775 0x45, 0x78, 0x74, 0x72, 0x61, 0x63, 0x74, 0x2e, 0x48, 0x74, 0x74, 0x70, 0x2e, 0x48, 0x65, 0x61,
1776 0x64, 0x65, 0x72, 0x73, 0x48, 0x00, 0x52, 0x07, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x1a,
1777 0x09, 0x0a, 0x07, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x42, 0x09, 0x0a, 0x07, 0x65, 0x78,
1778 0x74, 0x72, 0x61, 0x63, 0x74, 0x42, 0x09, 0x0a, 0x07, 0x65, 0x78, 0x74, 0x72, 0x61, 0x63, 0x74,
1779 0x22, 0x64, 0x0a, 0x03, 0x45, 0x6f, 0x73, 0x12, 0x2a, 0x0a, 0x10, 0x67, 0x72, 0x70, 0x63, 0x5f,
1780 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
1781 0x0d, 0x48, 0x00, 0x52, 0x0e, 0x67, 0x72, 0x70, 0x63, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x43,
1782 0x6f, 0x64, 0x65, 0x12, 0x2a, 0x0a, 0x10, 0x72, 0x65, 0x73, 0x65, 0x74, 0x5f, 0x65, 0x72, 0x72,
1783 0x6f, 0x72, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x48, 0x00, 0x52,
1784 0x0e, 0x72, 0x65, 0x73, 0x65, 0x74, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x43, 0x6f, 0x64, 0x65, 0x42,
1785 0x05, 0x0a, 0x03, 0x65, 0x6e, 0x64, 0x22, 0xff, 0x10, 0x0a, 0x08, 0x54, 0x61, 0x70, 0x45, 0x76,
1786 0x65, 0x6e, 0x74, 0x12, 0x38, 0x0a, 0x06, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x18, 0x01, 0x20,
1787 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64,
1788 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x6e, 0x65, 0x74, 0x2e, 0x54, 0x63, 0x70, 0x41, 0x64,
1789 0x64, 0x72, 0x65, 0x73, 0x73, 0x52, 0x06, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x12, 0x4c, 0x0a,
1790 0x0b, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x5f, 0x6d, 0x65, 0x74, 0x61, 0x18, 0x05, 0x20, 0x01,
1791 0x28, 0x0b, 0x32, 0x2b, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e,
1792 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x54, 0x61, 0x70, 0x45, 0x76, 0x65,
1793 0x6e, 0x74, 0x2e, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x52,
1794 0x0a, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x12, 0x47, 0x0a, 0x0a, 0x72,
1795 0x6f, 0x75, 0x74, 0x65, 0x5f, 0x6d, 0x65, 0x74, 0x61, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32,
1796 0x28, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f,
1797 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x54, 0x61, 0x70, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e,
1798 0x52, 0x6f, 0x75, 0x74, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x52, 0x09, 0x72, 0x6f, 0x75, 0x74, 0x65,
1799 0x4d, 0x65, 0x74, 0x61, 0x12, 0x42, 0x0a, 0x0b, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61, 0x74,
1800 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x69, 0x6f, 0x2e, 0x6c,
1801 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x6e, 0x65, 0x74,
1802 0x2e, 0x54, 0x63, 0x70, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x52, 0x0b, 0x64, 0x65, 0x73,
1803 0x74, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x56, 0x0a, 0x10, 0x64, 0x65, 0x73, 0x74,
1804 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6d, 0x65, 0x74, 0x61, 0x18, 0x04, 0x20, 0x01,
1805 0x28, 0x0b, 0x32, 0x2b, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e,
1806 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x54, 0x61, 0x70, 0x45, 0x76, 0x65,
1807 0x6e, 0x74, 0x2e, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x52,
1808 0x0f, 0x64, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x65, 0x74, 0x61,
1809 0x12, 0x56, 0x0a, 0x0f, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x5f, 0x64, 0x69, 0x72, 0x65, 0x63, 0x74,
1810 0x69, 0x6f, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x2d, 0x2e, 0x69, 0x6f, 0x2e, 0x6c,
1811 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70,
1812 0x2e, 0x54, 0x61, 0x70, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x50, 0x72, 0x6f, 0x78, 0x79, 0x44,
1813 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x44,
1814 0x69, 0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x39, 0x0a, 0x04, 0x68, 0x74, 0x74, 0x70,
1815 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b,
1816 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x54, 0x61,
1817 0x70, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x48, 0x74, 0x74, 0x70, 0x48, 0x00, 0x52, 0x04, 0x68,
1818 0x74, 0x74, 0x70, 0x1a, 0x9a, 0x01, 0x0a, 0x0c, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74,
1819 0x4d, 0x65, 0x74, 0x61, 0x12, 0x4f, 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x01,
1820 0x20, 0x03, 0x28, 0x0b, 0x32, 0x37, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72,
1821 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x54, 0x61, 0x70, 0x45,
1822 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x4d, 0x65, 0x74,
1823 0x61, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x06, 0x6c,
1824 0x61, 0x62, 0x65, 0x6c, 0x73, 0x1a, 0x39, 0x0a, 0x0b, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45,
1825 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28,
1826 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18,
1827 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01,
1828 0x1a, 0x94, 0x01, 0x0a, 0x09, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x12, 0x4c,
1829 0x0a, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x34,
1830 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78,
1831 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x54, 0x61, 0x70, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x52,
1832 0x6f, 0x75, 0x74, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x2e, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45,
1833 0x6e, 0x74, 0x72, 0x79, 0x52, 0x06, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x1a, 0x39, 0x0a, 0x0b,
1834 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b,
1835 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a,
1836 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61,
1837 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x1a, 0xfb, 0x09, 0x0a, 0x04, 0x48, 0x74, 0x74, 0x70,
1838 0x12, 0x54, 0x0a, 0x0c, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x6e, 0x69, 0x74,
1839 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b,
1840 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x54, 0x61,
1841 0x70, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x48, 0x74, 0x74, 0x70, 0x2e, 0x52, 0x65, 0x71, 0x75,
1842 0x65, 0x73, 0x74, 0x49, 0x6e, 0x69, 0x74, 0x48, 0x00, 0x52, 0x0b, 0x72, 0x65, 0x71, 0x75, 0x65,
1843 0x73, 0x74, 0x49, 0x6e, 0x69, 0x74, 0x12, 0x57, 0x0a, 0x0d, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e,
1844 0x73, 0x65, 0x5f, 0x69, 0x6e, 0x69, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x30, 0x2e,
1845 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79,
1846 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x54, 0x61, 0x70, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x48, 0x74,
1847 0x74, 0x70, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x49, 0x6e, 0x69, 0x74, 0x48,
1848 0x00, 0x52, 0x0c, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x49, 0x6e, 0x69, 0x74, 0x12,
1849 0x54, 0x0a, 0x0c, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x65, 0x6e, 0x64, 0x18,
1850 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65,
1851 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x54, 0x61, 0x70,
1852 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x48, 0x74, 0x74, 0x70, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f,
1853 0x6e, 0x73, 0x65, 0x45, 0x6e, 0x64, 0x48, 0x00, 0x52, 0x0b, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e,
1854 0x73, 0x65, 0x45, 0x6e, 0x64, 0x1a, 0x36, 0x0a, 0x08, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x49,
1855 0x64, 0x12, 0x12, 0x0a, 0x04, 0x62, 0x61, 0x73, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52,
1856 0x04, 0x62, 0x61, 0x73, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18,
1857 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x1a, 0xbb, 0x02,
1858 0x0a, 0x0b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x49, 0x6e, 0x69, 0x74, 0x12, 0x3c, 0x0a,
1859 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x69, 0x6f, 0x2e, 0x6c,
1860 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70,
1861 0x2e, 0x54, 0x61, 0x70, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x48, 0x74, 0x74, 0x70, 0x2e, 0x53,
1862 0x74, 0x72, 0x65, 0x61, 0x6d, 0x49, 0x64, 0x52, 0x02, 0x69, 0x64, 0x12, 0x3f, 0x0a, 0x06, 0x6d,
1863 0x65, 0x74, 0x68, 0x6f, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x69, 0x6f,
1864 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x68,
1865 0x74, 0x74, 0x70, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2e, 0x48, 0x74, 0x74, 0x70, 0x4d, 0x65,
1866 0x74, 0x68, 0x6f, 0x64, 0x52, 0x06, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x12, 0x3b, 0x0a, 0x06,
1867 0x73, 0x63, 0x68, 0x65, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x69,
1868 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e,
1869 0x68, 0x74, 0x74, 0x70, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2e, 0x53, 0x63, 0x68, 0x65, 0x6d,
1870 0x65, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x61, 0x75, 0x74,
1871 0x68, 0x6f, 0x72, 0x69, 0x74, 0x79, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x61, 0x75,
1872 0x74, 0x68, 0x6f, 0x72, 0x69, 0x74, 0x79, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x61, 0x74, 0x68, 0x18,
1873 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x70, 0x61, 0x74, 0x68, 0x12, 0x3e, 0x0a, 0x07, 0x68,
1874 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x24, 0x2e, 0x69,
1875 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e,
1876 0x68, 0x74, 0x74, 0x70, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2e, 0x48, 0x65, 0x61, 0x64, 0x65,
1877 0x72, 0x73, 0x52, 0x07, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x1a, 0xf6, 0x01, 0x0a, 0x0c,
1878 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x49, 0x6e, 0x69, 0x74, 0x12, 0x3c, 0x0a, 0x02,
1879 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69,
1880 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e,
1881 0x54, 0x61, 0x70, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x48, 0x74, 0x74, 0x70, 0x2e, 0x53, 0x74,
1882 0x72, 0x65, 0x61, 0x6d, 0x49, 0x64, 0x52, 0x02, 0x69, 0x64, 0x12, 0x47, 0x0a, 0x12, 0x73, 0x69,
1883 0x6e, 0x63, 0x65, 0x5f, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x5f, 0x69, 0x6e, 0x69, 0x74,
1884 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
1885 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f,
1886 0x6e, 0x52, 0x10, 0x73, 0x69, 0x6e, 0x63, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x49,
1887 0x6e, 0x69, 0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x68, 0x74, 0x74, 0x70, 0x5f, 0x73, 0x74, 0x61, 0x74,
1888 0x75, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0a, 0x68, 0x74, 0x74, 0x70, 0x53, 0x74,
1889 0x61, 0x74, 0x75, 0x73, 0x12, 0x3e, 0x0a, 0x07, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x18,
1890 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x24, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65,
1891 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x68, 0x74, 0x74, 0x70, 0x5f, 0x74, 0x79,
1892 0x70, 0x65, 0x73, 0x2e, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x52, 0x07, 0x68, 0x65, 0x61,
1893 0x64, 0x65, 0x72, 0x73, 0x1a, 0xf5, 0x02, 0x0a, 0x0b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
1894 0x65, 0x45, 0x6e, 0x64, 0x12, 0x3c, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
1895 0x32, 0x2c, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72,
1896 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x54, 0x61, 0x70, 0x45, 0x76, 0x65, 0x6e, 0x74,
1897 0x2e, 0x48, 0x74, 0x74, 0x70, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x49, 0x64, 0x52, 0x02,
1898 0x69, 0x64, 0x12, 0x47, 0x0a, 0x12, 0x73, 0x69, 0x6e, 0x63, 0x65, 0x5f, 0x72, 0x65, 0x71, 0x75,
1899 0x65, 0x73, 0x74, 0x5f, 0x69, 0x6e, 0x69, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19,
1900 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66,
1901 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x10, 0x73, 0x69, 0x6e, 0x63, 0x65,
1902 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x49, 0x6e, 0x69, 0x74, 0x12, 0x49, 0x0a, 0x13, 0x73,
1903 0x69, 0x6e, 0x63, 0x65, 0x5f, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x69, 0x6e,
1904 0x69, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
1905 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74,
1906 0x69, 0x6f, 0x6e, 0x52, 0x11, 0x73, 0x69, 0x6e, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
1907 0x73, 0x65, 0x49, 0x6e, 0x69, 0x74, 0x12, 0x25, 0x0a, 0x0e, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e,
1908 0x73, 0x65, 0x5f, 0x62, 0x79, 0x74, 0x65, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0d,
1909 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x79, 0x74, 0x65, 0x73, 0x12, 0x2b, 0x0a,
1910 0x03, 0x65, 0x6f, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x69, 0x6f, 0x2e,
1911 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61,
1912 0x70, 0x2e, 0x45, 0x6f, 0x73, 0x52, 0x03, 0x65, 0x6f, 0x73, 0x12, 0x40, 0x0a, 0x08, 0x74, 0x72,
1913 0x61, 0x69, 0x6c, 0x65, 0x72, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x24, 0x2e, 0x69,
1914 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e,
1915 0x68, 0x74, 0x74, 0x70, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2e, 0x48, 0x65, 0x61, 0x64, 0x65,
1916 0x72, 0x73, 0x52, 0x08, 0x74, 0x72, 0x61, 0x69, 0x6c, 0x65, 0x72, 0x73, 0x42, 0x07, 0x0a, 0x05,
1917 0x65, 0x76, 0x65, 0x6e, 0x74, 0x22, 0x38, 0x0a, 0x0e, 0x50, 0x72, 0x6f, 0x78, 0x79, 0x44, 0x69,
1918 0x72, 0x65, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x0b, 0x0a, 0x07, 0x55, 0x4e, 0x4b, 0x4e, 0x4f,
1919 0x57, 0x4e, 0x10, 0x00, 0x12, 0x0b, 0x0a, 0x07, 0x49, 0x4e, 0x42, 0x4f, 0x55, 0x4e, 0x44, 0x10,
1920 0x01, 0x12, 0x0c, 0x0a, 0x08, 0x4f, 0x55, 0x54, 0x42, 0x4f, 0x55, 0x4e, 0x44, 0x10, 0x02, 0x42,
1921 0x07, 0x0a, 0x05, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x32, 0x5a, 0x0a, 0x03, 0x54, 0x61, 0x70, 0x12,
1922 0x53, 0x0a, 0x07, 0x4f, 0x62, 0x73, 0x65, 0x72, 0x76, 0x65, 0x12, 0x24, 0x2e, 0x69, 0x6f, 0x2e,
1923 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61,
1924 0x70, 0x2e, 0x4f, 0x62, 0x73, 0x65, 0x72, 0x76, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
1925 0x1a, 0x1e, 0x2e, 0x69, 0x6f, 0x2e, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2e, 0x70, 0x72,
1926 0x6f, 0x78, 0x79, 0x2e, 0x74, 0x61, 0x70, 0x2e, 0x54, 0x61, 0x70, 0x45, 0x76, 0x65, 0x6e, 0x74,
1927 0x22, 0x00, 0x30, 0x01, 0x42, 0x2e, 0x5a, 0x2c, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63,
1928 0x6f, 0x6d, 0x2f, 0x6c, 0x69, 0x6e, 0x6b, 0x65, 0x72, 0x64, 0x2f, 0x6c, 0x69, 0x6e, 0x6b, 0x65,
1929 0x72, 0x64, 0x32, 0x2d, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2d, 0x61, 0x70, 0x69, 0x2f, 0x67, 0x6f,
1930 0x2f, 0x74, 0x61, 0x70, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
1931 }
1932
1933 var (
1934 file_tap_proto_rawDescOnce sync.Once
1935 file_tap_proto_rawDescData = file_tap_proto_rawDesc
1936 )
1937
1938 func file_tap_proto_rawDescGZIP() []byte {
1939 file_tap_proto_rawDescOnce.Do(func() {
1940 file_tap_proto_rawDescData = protoimpl.X.CompressGZIP(file_tap_proto_rawDescData)
1941 })
1942 return file_tap_proto_rawDescData
1943 }
1944
1945 var file_tap_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
1946 var file_tap_proto_msgTypes = make([]protoimpl.MessageInfo, 23)
1947 var file_tap_proto_goTypes = []interface{}{
1948 (TapEvent_ProxyDirection)(0),
1949 (*ObserveRequest)(nil),
1950 (*Eos)(nil),
1951 (*TapEvent)(nil),
1952 (*ObserveRequest_Match)(nil),
1953 (*ObserveRequest_Extract)(nil),
1954 (*ObserveRequest_Match_Seq)(nil),
1955 (*ObserveRequest_Match_Label)(nil),
1956 (*ObserveRequest_Match_Tcp)(nil),
1957 (*ObserveRequest_Match_Http)(nil),
1958 (*ObserveRequest_Match_Tcp_Netmask)(nil),
1959 (*ObserveRequest_Match_Tcp_PortRange)(nil),
1960 (*ObserveRequest_Match_Http_StringMatch)(nil),
1961 (*ObserveRequest_Extract_Http)(nil),
1962 (*ObserveRequest_Extract_Http_Headers)(nil),
1963 (*TapEvent_EndpointMeta)(nil),
1964 (*TapEvent_RouteMeta)(nil),
1965 (*TapEvent_Http)(nil),
1966 nil,
1967 nil,
1968 (*TapEvent_Http_StreamId)(nil),
1969 (*TapEvent_Http_RequestInit)(nil),
1970 (*TapEvent_Http_ResponseInit)(nil),
1971 (*TapEvent_Http_ResponseEnd)(nil),
1972 (*net.TcpAddress)(nil),
1973 (*http_types.Scheme)(nil),
1974 (*http_types.HttpMethod)(nil),
1975 (*net.IPAddress)(nil),
1976 (*http_types.Headers)(nil),
1977 (*duration.Duration)(nil),
1978 }
1979 var file_tap_proto_depIdxs = []int32{
1980 4,
1981 5,
1982 24,
1983 15,
1984 16,
1985 24,
1986 15,
1987 0,
1988 17,
1989 6,
1990 6,
1991 4,
1992 8,
1993 8,
1994 9,
1995 7,
1996 7,
1997 13,
1998 4,
1999 10,
2000 11,
2001 25,
2002 26,
2003 12,
2004 12,
2005 27,
2006 14,
2007 18,
2008 19,
2009 21,
2010 22,
2011 23,
2012 20,
2013 26,
2014 25,
2015 28,
2016 20,
2017 29,
2018 28,
2019 20,
2020 29,
2021 29,
2022 2,
2023 28,
2024 1,
2025 3,
2026 45,
2027 44,
2028 44,
2029 44,
2030 0,
2031 }
2032
2033 func init() { file_tap_proto_init() }
2034 func file_tap_proto_init() {
2035 if File_tap_proto != nil {
2036 return
2037 }
2038 if !protoimpl.UnsafeEnabled {
2039 file_tap_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
2040 switch v := v.(*ObserveRequest); i {
2041 case 0:
2042 return &v.state
2043 case 1:
2044 return &v.sizeCache
2045 case 2:
2046 return &v.unknownFields
2047 default:
2048 return nil
2049 }
2050 }
2051 file_tap_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
2052 switch v := v.(*Eos); i {
2053 case 0:
2054 return &v.state
2055 case 1:
2056 return &v.sizeCache
2057 case 2:
2058 return &v.unknownFields
2059 default:
2060 return nil
2061 }
2062 }
2063 file_tap_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
2064 switch v := v.(*TapEvent); i {
2065 case 0:
2066 return &v.state
2067 case 1:
2068 return &v.sizeCache
2069 case 2:
2070 return &v.unknownFields
2071 default:
2072 return nil
2073 }
2074 }
2075 file_tap_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
2076 switch v := v.(*ObserveRequest_Match); i {
2077 case 0:
2078 return &v.state
2079 case 1:
2080 return &v.sizeCache
2081 case 2:
2082 return &v.unknownFields
2083 default:
2084 return nil
2085 }
2086 }
2087 file_tap_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
2088 switch v := v.(*ObserveRequest_Extract); i {
2089 case 0:
2090 return &v.state
2091 case 1:
2092 return &v.sizeCache
2093 case 2:
2094 return &v.unknownFields
2095 default:
2096 return nil
2097 }
2098 }
2099 file_tap_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
2100 switch v := v.(*ObserveRequest_Match_Seq); i {
2101 case 0:
2102 return &v.state
2103 case 1:
2104 return &v.sizeCache
2105 case 2:
2106 return &v.unknownFields
2107 default:
2108 return nil
2109 }
2110 }
2111 file_tap_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
2112 switch v := v.(*ObserveRequest_Match_Label); i {
2113 case 0:
2114 return &v.state
2115 case 1:
2116 return &v.sizeCache
2117 case 2:
2118 return &v.unknownFields
2119 default:
2120 return nil
2121 }
2122 }
2123 file_tap_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
2124 switch v := v.(*ObserveRequest_Match_Tcp); i {
2125 case 0:
2126 return &v.state
2127 case 1:
2128 return &v.sizeCache
2129 case 2:
2130 return &v.unknownFields
2131 default:
2132 return nil
2133 }
2134 }
2135 file_tap_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
2136 switch v := v.(*ObserveRequest_Match_Http); i {
2137 case 0:
2138 return &v.state
2139 case 1:
2140 return &v.sizeCache
2141 case 2:
2142 return &v.unknownFields
2143 default:
2144 return nil
2145 }
2146 }
2147 file_tap_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
2148 switch v := v.(*ObserveRequest_Match_Tcp_Netmask); i {
2149 case 0:
2150 return &v.state
2151 case 1:
2152 return &v.sizeCache
2153 case 2:
2154 return &v.unknownFields
2155 default:
2156 return nil
2157 }
2158 }
2159 file_tap_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
2160 switch v := v.(*ObserveRequest_Match_Tcp_PortRange); i {
2161 case 0:
2162 return &v.state
2163 case 1:
2164 return &v.sizeCache
2165 case 2:
2166 return &v.unknownFields
2167 default:
2168 return nil
2169 }
2170 }
2171 file_tap_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
2172 switch v := v.(*ObserveRequest_Match_Http_StringMatch); i {
2173 case 0:
2174 return &v.state
2175 case 1:
2176 return &v.sizeCache
2177 case 2:
2178 return &v.unknownFields
2179 default:
2180 return nil
2181 }
2182 }
2183 file_tap_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
2184 switch v := v.(*ObserveRequest_Extract_Http); i {
2185 case 0:
2186 return &v.state
2187 case 1:
2188 return &v.sizeCache
2189 case 2:
2190 return &v.unknownFields
2191 default:
2192 return nil
2193 }
2194 }
2195 file_tap_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
2196 switch v := v.(*ObserveRequest_Extract_Http_Headers); i {
2197 case 0:
2198 return &v.state
2199 case 1:
2200 return &v.sizeCache
2201 case 2:
2202 return &v.unknownFields
2203 default:
2204 return nil
2205 }
2206 }
2207 file_tap_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
2208 switch v := v.(*TapEvent_EndpointMeta); i {
2209 case 0:
2210 return &v.state
2211 case 1:
2212 return &v.sizeCache
2213 case 2:
2214 return &v.unknownFields
2215 default:
2216 return nil
2217 }
2218 }
2219 file_tap_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
2220 switch v := v.(*TapEvent_RouteMeta); i {
2221 case 0:
2222 return &v.state
2223 case 1:
2224 return &v.sizeCache
2225 case 2:
2226 return &v.unknownFields
2227 default:
2228 return nil
2229 }
2230 }
2231 file_tap_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
2232 switch v := v.(*TapEvent_Http); i {
2233 case 0:
2234 return &v.state
2235 case 1:
2236 return &v.sizeCache
2237 case 2:
2238 return &v.unknownFields
2239 default:
2240 return nil
2241 }
2242 }
2243 file_tap_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
2244 switch v := v.(*TapEvent_Http_StreamId); i {
2245 case 0:
2246 return &v.state
2247 case 1:
2248 return &v.sizeCache
2249 case 2:
2250 return &v.unknownFields
2251 default:
2252 return nil
2253 }
2254 }
2255 file_tap_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
2256 switch v := v.(*TapEvent_Http_RequestInit); i {
2257 case 0:
2258 return &v.state
2259 case 1:
2260 return &v.sizeCache
2261 case 2:
2262 return &v.unknownFields
2263 default:
2264 return nil
2265 }
2266 }
2267 file_tap_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
2268 switch v := v.(*TapEvent_Http_ResponseInit); i {
2269 case 0:
2270 return &v.state
2271 case 1:
2272 return &v.sizeCache
2273 case 2:
2274 return &v.unknownFields
2275 default:
2276 return nil
2277 }
2278 }
2279 file_tap_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} {
2280 switch v := v.(*TapEvent_Http_ResponseEnd); i {
2281 case 0:
2282 return &v.state
2283 case 1:
2284 return &v.sizeCache
2285 case 2:
2286 return &v.unknownFields
2287 default:
2288 return nil
2289 }
2290 }
2291 }
2292 file_tap_proto_msgTypes[1].OneofWrappers = []interface{}{
2293 (*Eos_GrpcStatusCode)(nil),
2294 (*Eos_ResetErrorCode)(nil),
2295 }
2296 file_tap_proto_msgTypes[2].OneofWrappers = []interface{}{
2297 (*TapEvent_Http_)(nil),
2298 }
2299 file_tap_proto_msgTypes[3].OneofWrappers = []interface{}{
2300 (*ObserveRequest_Match_All)(nil),
2301 (*ObserveRequest_Match_Any)(nil),
2302 (*ObserveRequest_Match_Not)(nil),
2303 (*ObserveRequest_Match_Source)(nil),
2304 (*ObserveRequest_Match_Destination)(nil),
2305 (*ObserveRequest_Match_Http_)(nil),
2306 (*ObserveRequest_Match_DestinationLabel)(nil),
2307 (*ObserveRequest_Match_RouteLabel)(nil),
2308 }
2309 file_tap_proto_msgTypes[4].OneofWrappers = []interface{}{
2310 (*ObserveRequest_Extract_Http_)(nil),
2311 }
2312 file_tap_proto_msgTypes[7].OneofWrappers = []interface{}{
2313 (*ObserveRequest_Match_Tcp_Netmask_)(nil),
2314 (*ObserveRequest_Match_Tcp_Ports)(nil),
2315 }
2316 file_tap_proto_msgTypes[8].OneofWrappers = []interface{}{
2317 (*ObserveRequest_Match_Http_Scheme)(nil),
2318 (*ObserveRequest_Match_Http_Method)(nil),
2319 (*ObserveRequest_Match_Http_Authority)(nil),
2320 (*ObserveRequest_Match_Http_Path)(nil),
2321 }
2322 file_tap_proto_msgTypes[11].OneofWrappers = []interface{}{
2323 (*ObserveRequest_Match_Http_StringMatch_Exact)(nil),
2324 (*ObserveRequest_Match_Http_StringMatch_Prefix)(nil),
2325 }
2326 file_tap_proto_msgTypes[12].OneofWrappers = []interface{}{
2327 (*ObserveRequest_Extract_Http_Headers_)(nil),
2328 }
2329 file_tap_proto_msgTypes[16].OneofWrappers = []interface{}{
2330 (*TapEvent_Http_RequestInit_)(nil),
2331 (*TapEvent_Http_ResponseInit_)(nil),
2332 (*TapEvent_Http_ResponseEnd_)(nil),
2333 }
2334 type x struct{}
2335 out := protoimpl.TypeBuilder{
2336 File: protoimpl.DescBuilder{
2337 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
2338 RawDescriptor: file_tap_proto_rawDesc,
2339 NumEnums: 1,
2340 NumMessages: 23,
2341 NumExtensions: 0,
2342 NumServices: 1,
2343 },
2344 GoTypes: file_tap_proto_goTypes,
2345 DependencyIndexes: file_tap_proto_depIdxs,
2346 EnumInfos: file_tap_proto_enumTypes,
2347 MessageInfos: file_tap_proto_msgTypes,
2348 }.Build()
2349 File_tap_proto = out.File
2350 file_tap_proto_rawDesc = nil
2351 file_tap_proto_goTypes = nil
2352 file_tap_proto_depIdxs = nil
2353 }
2354
View as plain text