1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25 package grpc_binarylog_v1
26
27 import (
28 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
29 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
30 durationpb "google.golang.org/protobuf/types/known/durationpb"
31 timestamppb "google.golang.org/protobuf/types/known/timestamppb"
32 reflect "reflect"
33 sync "sync"
34 )
35
36 const (
37
38 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
39
40 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
41 )
42
43
44
45
46 type GrpcLogEntry_EventType int32
47
48 const (
49 GrpcLogEntry_EVENT_TYPE_UNKNOWN GrpcLogEntry_EventType = 0
50
51 GrpcLogEntry_EVENT_TYPE_CLIENT_HEADER GrpcLogEntry_EventType = 1
52
53 GrpcLogEntry_EVENT_TYPE_SERVER_HEADER GrpcLogEntry_EventType = 2
54
55 GrpcLogEntry_EVENT_TYPE_CLIENT_MESSAGE GrpcLogEntry_EventType = 3
56
57 GrpcLogEntry_EVENT_TYPE_SERVER_MESSAGE GrpcLogEntry_EventType = 4
58
59 GrpcLogEntry_EVENT_TYPE_CLIENT_HALF_CLOSE GrpcLogEntry_EventType = 5
60
61
62
63
64
65
66
67 GrpcLogEntry_EVENT_TYPE_SERVER_TRAILER GrpcLogEntry_EventType = 6
68
69
70
71
72
73
74 GrpcLogEntry_EVENT_TYPE_CANCEL GrpcLogEntry_EventType = 7
75 )
76
77
78 var (
79 GrpcLogEntry_EventType_name = map[int32]string{
80 0: "EVENT_TYPE_UNKNOWN",
81 1: "EVENT_TYPE_CLIENT_HEADER",
82 2: "EVENT_TYPE_SERVER_HEADER",
83 3: "EVENT_TYPE_CLIENT_MESSAGE",
84 4: "EVENT_TYPE_SERVER_MESSAGE",
85 5: "EVENT_TYPE_CLIENT_HALF_CLOSE",
86 6: "EVENT_TYPE_SERVER_TRAILER",
87 7: "EVENT_TYPE_CANCEL",
88 }
89 GrpcLogEntry_EventType_value = map[string]int32{
90 "EVENT_TYPE_UNKNOWN": 0,
91 "EVENT_TYPE_CLIENT_HEADER": 1,
92 "EVENT_TYPE_SERVER_HEADER": 2,
93 "EVENT_TYPE_CLIENT_MESSAGE": 3,
94 "EVENT_TYPE_SERVER_MESSAGE": 4,
95 "EVENT_TYPE_CLIENT_HALF_CLOSE": 5,
96 "EVENT_TYPE_SERVER_TRAILER": 6,
97 "EVENT_TYPE_CANCEL": 7,
98 }
99 )
100
101 func (x GrpcLogEntry_EventType) Enum() *GrpcLogEntry_EventType {
102 p := new(GrpcLogEntry_EventType)
103 *p = x
104 return p
105 }
106
107 func (x GrpcLogEntry_EventType) String() string {
108 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
109 }
110
111 func (GrpcLogEntry_EventType) Descriptor() protoreflect.EnumDescriptor {
112 return file_grpc_binlog_v1_binarylog_proto_enumTypes[0].Descriptor()
113 }
114
115 func (GrpcLogEntry_EventType) Type() protoreflect.EnumType {
116 return &file_grpc_binlog_v1_binarylog_proto_enumTypes[0]
117 }
118
119 func (x GrpcLogEntry_EventType) Number() protoreflect.EnumNumber {
120 return protoreflect.EnumNumber(x)
121 }
122
123
124 func (GrpcLogEntry_EventType) EnumDescriptor() ([]byte, []int) {
125 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{0, 0}
126 }
127
128
129 type GrpcLogEntry_Logger int32
130
131 const (
132 GrpcLogEntry_LOGGER_UNKNOWN GrpcLogEntry_Logger = 0
133 GrpcLogEntry_LOGGER_CLIENT GrpcLogEntry_Logger = 1
134 GrpcLogEntry_LOGGER_SERVER GrpcLogEntry_Logger = 2
135 )
136
137
138 var (
139 GrpcLogEntry_Logger_name = map[int32]string{
140 0: "LOGGER_UNKNOWN",
141 1: "LOGGER_CLIENT",
142 2: "LOGGER_SERVER",
143 }
144 GrpcLogEntry_Logger_value = map[string]int32{
145 "LOGGER_UNKNOWN": 0,
146 "LOGGER_CLIENT": 1,
147 "LOGGER_SERVER": 2,
148 }
149 )
150
151 func (x GrpcLogEntry_Logger) Enum() *GrpcLogEntry_Logger {
152 p := new(GrpcLogEntry_Logger)
153 *p = x
154 return p
155 }
156
157 func (x GrpcLogEntry_Logger) String() string {
158 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
159 }
160
161 func (GrpcLogEntry_Logger) Descriptor() protoreflect.EnumDescriptor {
162 return file_grpc_binlog_v1_binarylog_proto_enumTypes[1].Descriptor()
163 }
164
165 func (GrpcLogEntry_Logger) Type() protoreflect.EnumType {
166 return &file_grpc_binlog_v1_binarylog_proto_enumTypes[1]
167 }
168
169 func (x GrpcLogEntry_Logger) Number() protoreflect.EnumNumber {
170 return protoreflect.EnumNumber(x)
171 }
172
173
174 func (GrpcLogEntry_Logger) EnumDescriptor() ([]byte, []int) {
175 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{0, 1}
176 }
177
178 type Address_Type int32
179
180 const (
181 Address_TYPE_UNKNOWN Address_Type = 0
182
183 Address_TYPE_IPV4 Address_Type = 1
184
185
186 Address_TYPE_IPV6 Address_Type = 2
187
188 Address_TYPE_UNIX Address_Type = 3
189 )
190
191
192 var (
193 Address_Type_name = map[int32]string{
194 0: "TYPE_UNKNOWN",
195 1: "TYPE_IPV4",
196 2: "TYPE_IPV6",
197 3: "TYPE_UNIX",
198 }
199 Address_Type_value = map[string]int32{
200 "TYPE_UNKNOWN": 0,
201 "TYPE_IPV4": 1,
202 "TYPE_IPV6": 2,
203 "TYPE_UNIX": 3,
204 }
205 )
206
207 func (x Address_Type) Enum() *Address_Type {
208 p := new(Address_Type)
209 *p = x
210 return p
211 }
212
213 func (x Address_Type) String() string {
214 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
215 }
216
217 func (Address_Type) Descriptor() protoreflect.EnumDescriptor {
218 return file_grpc_binlog_v1_binarylog_proto_enumTypes[2].Descriptor()
219 }
220
221 func (Address_Type) Type() protoreflect.EnumType {
222 return &file_grpc_binlog_v1_binarylog_proto_enumTypes[2]
223 }
224
225 func (x Address_Type) Number() protoreflect.EnumNumber {
226 return protoreflect.EnumNumber(x)
227 }
228
229
230 func (Address_Type) EnumDescriptor() ([]byte, []int) {
231 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{7, 0}
232 }
233
234
235 type GrpcLogEntry struct {
236 state protoimpl.MessageState
237 sizeCache protoimpl.SizeCache
238 unknownFields protoimpl.UnknownFields
239
240
241 Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
242
243
244
245
246
247 CallId uint64 `protobuf:"varint,2,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
248
249
250
251
252 SequenceIdWithinCall uint64 `protobuf:"varint,3,opt,name=sequence_id_within_call,json=sequenceIdWithinCall,proto3" json:"sequence_id_within_call,omitempty"`
253 Type GrpcLogEntry_EventType `protobuf:"varint,4,opt,name=type,proto3,enum=grpc.binarylog.v1.GrpcLogEntry_EventType" json:"type,omitempty"`
254 Logger GrpcLogEntry_Logger `protobuf:"varint,5,opt,name=logger,proto3,enum=grpc.binarylog.v1.GrpcLogEntry_Logger" json:"logger,omitempty"`
255
256
257
258
259
260
261
262
263
264 Payload isGrpcLogEntry_Payload `protobuf_oneof:"payload"`
265
266 PayloadTruncated bool `protobuf:"varint,10,opt,name=payload_truncated,json=payloadTruncated,proto3" json:"payload_truncated,omitempty"`
267
268
269
270
271
272 Peer *Address `protobuf:"bytes,11,opt,name=peer,proto3" json:"peer,omitempty"`
273 }
274
275 func (x *GrpcLogEntry) Reset() {
276 *x = GrpcLogEntry{}
277 if protoimpl.UnsafeEnabled {
278 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[0]
279 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
280 ms.StoreMessageInfo(mi)
281 }
282 }
283
284 func (x *GrpcLogEntry) String() string {
285 return protoimpl.X.MessageStringOf(x)
286 }
287
288 func (*GrpcLogEntry) ProtoMessage() {}
289
290 func (x *GrpcLogEntry) ProtoReflect() protoreflect.Message {
291 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[0]
292 if protoimpl.UnsafeEnabled && x != nil {
293 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
294 if ms.LoadMessageInfo() == nil {
295 ms.StoreMessageInfo(mi)
296 }
297 return ms
298 }
299 return mi.MessageOf(x)
300 }
301
302
303 func (*GrpcLogEntry) Descriptor() ([]byte, []int) {
304 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{0}
305 }
306
307 func (x *GrpcLogEntry) GetTimestamp() *timestamppb.Timestamp {
308 if x != nil {
309 return x.Timestamp
310 }
311 return nil
312 }
313
314 func (x *GrpcLogEntry) GetCallId() uint64 {
315 if x != nil {
316 return x.CallId
317 }
318 return 0
319 }
320
321 func (x *GrpcLogEntry) GetSequenceIdWithinCall() uint64 {
322 if x != nil {
323 return x.SequenceIdWithinCall
324 }
325 return 0
326 }
327
328 func (x *GrpcLogEntry) GetType() GrpcLogEntry_EventType {
329 if x != nil {
330 return x.Type
331 }
332 return GrpcLogEntry_EVENT_TYPE_UNKNOWN
333 }
334
335 func (x *GrpcLogEntry) GetLogger() GrpcLogEntry_Logger {
336 if x != nil {
337 return x.Logger
338 }
339 return GrpcLogEntry_LOGGER_UNKNOWN
340 }
341
342 func (m *GrpcLogEntry) GetPayload() isGrpcLogEntry_Payload {
343 if m != nil {
344 return m.Payload
345 }
346 return nil
347 }
348
349 func (x *GrpcLogEntry) GetClientHeader() *ClientHeader {
350 if x, ok := x.GetPayload().(*GrpcLogEntry_ClientHeader); ok {
351 return x.ClientHeader
352 }
353 return nil
354 }
355
356 func (x *GrpcLogEntry) GetServerHeader() *ServerHeader {
357 if x, ok := x.GetPayload().(*GrpcLogEntry_ServerHeader); ok {
358 return x.ServerHeader
359 }
360 return nil
361 }
362
363 func (x *GrpcLogEntry) GetMessage() *Message {
364 if x, ok := x.GetPayload().(*GrpcLogEntry_Message); ok {
365 return x.Message
366 }
367 return nil
368 }
369
370 func (x *GrpcLogEntry) GetTrailer() *Trailer {
371 if x, ok := x.GetPayload().(*GrpcLogEntry_Trailer); ok {
372 return x.Trailer
373 }
374 return nil
375 }
376
377 func (x *GrpcLogEntry) GetPayloadTruncated() bool {
378 if x != nil {
379 return x.PayloadTruncated
380 }
381 return false
382 }
383
384 func (x *GrpcLogEntry) GetPeer() *Address {
385 if x != nil {
386 return x.Peer
387 }
388 return nil
389 }
390
391 type isGrpcLogEntry_Payload interface {
392 isGrpcLogEntry_Payload()
393 }
394
395 type GrpcLogEntry_ClientHeader struct {
396 ClientHeader *ClientHeader `protobuf:"bytes,6,opt,name=client_header,json=clientHeader,proto3,oneof"`
397 }
398
399 type GrpcLogEntry_ServerHeader struct {
400 ServerHeader *ServerHeader `protobuf:"bytes,7,opt,name=server_header,json=serverHeader,proto3,oneof"`
401 }
402
403 type GrpcLogEntry_Message struct {
404
405 Message *Message `protobuf:"bytes,8,opt,name=message,proto3,oneof"`
406 }
407
408 type GrpcLogEntry_Trailer struct {
409 Trailer *Trailer `protobuf:"bytes,9,opt,name=trailer,proto3,oneof"`
410 }
411
412 func (*GrpcLogEntry_ClientHeader) isGrpcLogEntry_Payload() {}
413
414 func (*GrpcLogEntry_ServerHeader) isGrpcLogEntry_Payload() {}
415
416 func (*GrpcLogEntry_Message) isGrpcLogEntry_Payload() {}
417
418 func (*GrpcLogEntry_Trailer) isGrpcLogEntry_Payload() {}
419
420 type ClientHeader struct {
421 state protoimpl.MessageState
422 sizeCache protoimpl.SizeCache
423 unknownFields protoimpl.UnknownFields
424
425
426 Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
427
428
429
430 MethodName string `protobuf:"bytes,2,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
431
432
433
434
435
436 Authority string `protobuf:"bytes,3,opt,name=authority,proto3" json:"authority,omitempty"`
437
438 Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
439 }
440
441 func (x *ClientHeader) Reset() {
442 *x = ClientHeader{}
443 if protoimpl.UnsafeEnabled {
444 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[1]
445 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
446 ms.StoreMessageInfo(mi)
447 }
448 }
449
450 func (x *ClientHeader) String() string {
451 return protoimpl.X.MessageStringOf(x)
452 }
453
454 func (*ClientHeader) ProtoMessage() {}
455
456 func (x *ClientHeader) ProtoReflect() protoreflect.Message {
457 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[1]
458 if protoimpl.UnsafeEnabled && x != nil {
459 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
460 if ms.LoadMessageInfo() == nil {
461 ms.StoreMessageInfo(mi)
462 }
463 return ms
464 }
465 return mi.MessageOf(x)
466 }
467
468
469 func (*ClientHeader) Descriptor() ([]byte, []int) {
470 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{1}
471 }
472
473 func (x *ClientHeader) GetMetadata() *Metadata {
474 if x != nil {
475 return x.Metadata
476 }
477 return nil
478 }
479
480 func (x *ClientHeader) GetMethodName() string {
481 if x != nil {
482 return x.MethodName
483 }
484 return ""
485 }
486
487 func (x *ClientHeader) GetAuthority() string {
488 if x != nil {
489 return x.Authority
490 }
491 return ""
492 }
493
494 func (x *ClientHeader) GetTimeout() *durationpb.Duration {
495 if x != nil {
496 return x.Timeout
497 }
498 return nil
499 }
500
501 type ServerHeader struct {
502 state protoimpl.MessageState
503 sizeCache protoimpl.SizeCache
504 unknownFields protoimpl.UnknownFields
505
506
507 Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
508 }
509
510 func (x *ServerHeader) Reset() {
511 *x = ServerHeader{}
512 if protoimpl.UnsafeEnabled {
513 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[2]
514 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
515 ms.StoreMessageInfo(mi)
516 }
517 }
518
519 func (x *ServerHeader) String() string {
520 return protoimpl.X.MessageStringOf(x)
521 }
522
523 func (*ServerHeader) ProtoMessage() {}
524
525 func (x *ServerHeader) ProtoReflect() protoreflect.Message {
526 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[2]
527 if protoimpl.UnsafeEnabled && x != nil {
528 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
529 if ms.LoadMessageInfo() == nil {
530 ms.StoreMessageInfo(mi)
531 }
532 return ms
533 }
534 return mi.MessageOf(x)
535 }
536
537
538 func (*ServerHeader) Descriptor() ([]byte, []int) {
539 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{2}
540 }
541
542 func (x *ServerHeader) GetMetadata() *Metadata {
543 if x != nil {
544 return x.Metadata
545 }
546 return nil
547 }
548
549 type Trailer struct {
550 state protoimpl.MessageState
551 sizeCache protoimpl.SizeCache
552 unknownFields protoimpl.UnknownFields
553
554
555 Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
556
557 StatusCode uint32 `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
558
559
560 StatusMessage string `protobuf:"bytes,3,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
561
562
563 StatusDetails []byte `protobuf:"bytes,4,opt,name=status_details,json=statusDetails,proto3" json:"status_details,omitempty"`
564 }
565
566 func (x *Trailer) Reset() {
567 *x = Trailer{}
568 if protoimpl.UnsafeEnabled {
569 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[3]
570 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
571 ms.StoreMessageInfo(mi)
572 }
573 }
574
575 func (x *Trailer) String() string {
576 return protoimpl.X.MessageStringOf(x)
577 }
578
579 func (*Trailer) ProtoMessage() {}
580
581 func (x *Trailer) ProtoReflect() protoreflect.Message {
582 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[3]
583 if protoimpl.UnsafeEnabled && x != nil {
584 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
585 if ms.LoadMessageInfo() == nil {
586 ms.StoreMessageInfo(mi)
587 }
588 return ms
589 }
590 return mi.MessageOf(x)
591 }
592
593
594 func (*Trailer) Descriptor() ([]byte, []int) {
595 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{3}
596 }
597
598 func (x *Trailer) GetMetadata() *Metadata {
599 if x != nil {
600 return x.Metadata
601 }
602 return nil
603 }
604
605 func (x *Trailer) GetStatusCode() uint32 {
606 if x != nil {
607 return x.StatusCode
608 }
609 return 0
610 }
611
612 func (x *Trailer) GetStatusMessage() string {
613 if x != nil {
614 return x.StatusMessage
615 }
616 return ""
617 }
618
619 func (x *Trailer) GetStatusDetails() []byte {
620 if x != nil {
621 return x.StatusDetails
622 }
623 return nil
624 }
625
626
627 type Message struct {
628 state protoimpl.MessageState
629 sizeCache protoimpl.SizeCache
630 unknownFields protoimpl.UnknownFields
631
632
633
634 Length uint32 `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"`
635
636 Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
637 }
638
639 func (x *Message) Reset() {
640 *x = Message{}
641 if protoimpl.UnsafeEnabled {
642 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[4]
643 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
644 ms.StoreMessageInfo(mi)
645 }
646 }
647
648 func (x *Message) String() string {
649 return protoimpl.X.MessageStringOf(x)
650 }
651
652 func (*Message) ProtoMessage() {}
653
654 func (x *Message) ProtoReflect() protoreflect.Message {
655 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[4]
656 if protoimpl.UnsafeEnabled && x != nil {
657 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
658 if ms.LoadMessageInfo() == nil {
659 ms.StoreMessageInfo(mi)
660 }
661 return ms
662 }
663 return mi.MessageOf(x)
664 }
665
666
667 func (*Message) Descriptor() ([]byte, []int) {
668 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{4}
669 }
670
671 func (x *Message) GetLength() uint32 {
672 if x != nil {
673 return x.Length
674 }
675 return 0
676 }
677
678 func (x *Message) GetData() []byte {
679 if x != nil {
680 return x.Data
681 }
682 return nil
683 }
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706 type Metadata struct {
707 state protoimpl.MessageState
708 sizeCache protoimpl.SizeCache
709 unknownFields protoimpl.UnknownFields
710
711 Entry []*MetadataEntry `protobuf:"bytes,1,rep,name=entry,proto3" json:"entry,omitempty"`
712 }
713
714 func (x *Metadata) Reset() {
715 *x = Metadata{}
716 if protoimpl.UnsafeEnabled {
717 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[5]
718 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
719 ms.StoreMessageInfo(mi)
720 }
721 }
722
723 func (x *Metadata) String() string {
724 return protoimpl.X.MessageStringOf(x)
725 }
726
727 func (*Metadata) ProtoMessage() {}
728
729 func (x *Metadata) ProtoReflect() protoreflect.Message {
730 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[5]
731 if protoimpl.UnsafeEnabled && x != nil {
732 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
733 if ms.LoadMessageInfo() == nil {
734 ms.StoreMessageInfo(mi)
735 }
736 return ms
737 }
738 return mi.MessageOf(x)
739 }
740
741
742 func (*Metadata) Descriptor() ([]byte, []int) {
743 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{5}
744 }
745
746 func (x *Metadata) GetEntry() []*MetadataEntry {
747 if x != nil {
748 return x.Entry
749 }
750 return nil
751 }
752
753
754 type MetadataEntry struct {
755 state protoimpl.MessageState
756 sizeCache protoimpl.SizeCache
757 unknownFields protoimpl.UnknownFields
758
759 Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
760 Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
761 }
762
763 func (x *MetadataEntry) Reset() {
764 *x = MetadataEntry{}
765 if protoimpl.UnsafeEnabled {
766 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[6]
767 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
768 ms.StoreMessageInfo(mi)
769 }
770 }
771
772 func (x *MetadataEntry) String() string {
773 return protoimpl.X.MessageStringOf(x)
774 }
775
776 func (*MetadataEntry) ProtoMessage() {}
777
778 func (x *MetadataEntry) ProtoReflect() protoreflect.Message {
779 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[6]
780 if protoimpl.UnsafeEnabled && x != nil {
781 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
782 if ms.LoadMessageInfo() == nil {
783 ms.StoreMessageInfo(mi)
784 }
785 return ms
786 }
787 return mi.MessageOf(x)
788 }
789
790
791 func (*MetadataEntry) Descriptor() ([]byte, []int) {
792 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{6}
793 }
794
795 func (x *MetadataEntry) GetKey() string {
796 if x != nil {
797 return x.Key
798 }
799 return ""
800 }
801
802 func (x *MetadataEntry) GetValue() []byte {
803 if x != nil {
804 return x.Value
805 }
806 return nil
807 }
808
809
810 type Address struct {
811 state protoimpl.MessageState
812 sizeCache protoimpl.SizeCache
813 unknownFields protoimpl.UnknownFields
814
815 Type Address_Type `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.binarylog.v1.Address_Type" json:"type,omitempty"`
816 Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
817
818 IpPort uint32 `protobuf:"varint,3,opt,name=ip_port,json=ipPort,proto3" json:"ip_port,omitempty"`
819 }
820
821 func (x *Address) Reset() {
822 *x = Address{}
823 if protoimpl.UnsafeEnabled {
824 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[7]
825 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
826 ms.StoreMessageInfo(mi)
827 }
828 }
829
830 func (x *Address) String() string {
831 return protoimpl.X.MessageStringOf(x)
832 }
833
834 func (*Address) ProtoMessage() {}
835
836 func (x *Address) ProtoReflect() protoreflect.Message {
837 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[7]
838 if protoimpl.UnsafeEnabled && x != nil {
839 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
840 if ms.LoadMessageInfo() == nil {
841 ms.StoreMessageInfo(mi)
842 }
843 return ms
844 }
845 return mi.MessageOf(x)
846 }
847
848
849 func (*Address) Descriptor() ([]byte, []int) {
850 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{7}
851 }
852
853 func (x *Address) GetType() Address_Type {
854 if x != nil {
855 return x.Type
856 }
857 return Address_TYPE_UNKNOWN
858 }
859
860 func (x *Address) GetAddress() string {
861 if x != nil {
862 return x.Address
863 }
864 return ""
865 }
866
867 func (x *Address) GetIpPort() uint32 {
868 if x != nil {
869 return x.IpPort
870 }
871 return 0
872 }
873
874 var File_grpc_binlog_v1_binarylog_proto protoreflect.FileDescriptor
875
876 var file_grpc_binlog_v1_binarylog_proto_rawDesc = []byte{
877 0x0a, 0x1e, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x62, 0x69, 0x6e, 0x6c, 0x6f, 0x67, 0x2f, 0x76, 0x31,
878 0x2f, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
879 0x12, 0x11, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67,
880 0x2e, 0x76, 0x31, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74,
881 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72,
882 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74,
883 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70,
884 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xbb, 0x07, 0x0a, 0x0c, 0x47, 0x72, 0x70, 0x63, 0x4c, 0x6f, 0x67,
885 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x38, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61,
886 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
887 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73,
888 0x74, 0x61, 0x6d, 0x70, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12,
889 0x17, 0x0a, 0x07, 0x63, 0x61, 0x6c, 0x6c, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04,
890 0x52, 0x06, 0x63, 0x61, 0x6c, 0x6c, 0x49, 0x64, 0x12, 0x35, 0x0a, 0x17, 0x73, 0x65, 0x71, 0x75,
891 0x65, 0x6e, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x5f, 0x77, 0x69, 0x74, 0x68, 0x69, 0x6e, 0x5f, 0x63,
892 0x61, 0x6c, 0x6c, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x52, 0x14, 0x73, 0x65, 0x71, 0x75, 0x65,
893 0x6e, 0x63, 0x65, 0x49, 0x64, 0x57, 0x69, 0x74, 0x68, 0x69, 0x6e, 0x43, 0x61, 0x6c, 0x6c, 0x12,
894 0x3d, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x29, 0x2e,
895 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76,
896 0x31, 0x2e, 0x47, 0x72, 0x70, 0x63, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x2e, 0x45,
897 0x76, 0x65, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x3e,
898 0x0a, 0x06, 0x6c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x26,
899 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e,
900 0x76, 0x31, 0x2e, 0x47, 0x72, 0x70, 0x63, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x2e,
901 0x4c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x52, 0x06, 0x6c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x12, 0x46,
902 0x0a, 0x0d, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18,
903 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e,
904 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74,
905 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x48, 0x00, 0x52, 0x0c, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74,
906 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x46, 0x0a, 0x0d, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72,
907 0x5f, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e,
908 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76,
909 0x31, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x48, 0x00,
910 0x52, 0x0c, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x36,
911 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32,
912 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67,
913 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x48, 0x00, 0x52, 0x07, 0x6d,
914 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x36, 0x0a, 0x07, 0x74, 0x72, 0x61, 0x69, 0x6c, 0x65,
915 0x72, 0x18, 0x09, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62,
916 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x72, 0x61, 0x69,
917 0x6c, 0x65, 0x72, 0x48, 0x00, 0x52, 0x07, 0x74, 0x72, 0x61, 0x69, 0x6c, 0x65, 0x72, 0x12, 0x2b,
918 0x0a, 0x11, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x5f, 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61,
919 0x74, 0x65, 0x64, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x08, 0x52, 0x10, 0x70, 0x61, 0x79, 0x6c, 0x6f,
920 0x61, 0x64, 0x54, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x64, 0x12, 0x2e, 0x0a, 0x04, 0x70,
921 0x65, 0x65, 0x72, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63,
922 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x64,
923 0x64, 0x72, 0x65, 0x73, 0x73, 0x52, 0x04, 0x70, 0x65, 0x65, 0x72, 0x22, 0xf5, 0x01, 0x0a, 0x09,
924 0x45, 0x76, 0x65, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x16, 0x0a, 0x12, 0x45, 0x56, 0x45,
925 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10,
926 0x00, 0x12, 0x1c, 0x0a, 0x18, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f,
927 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54, 0x5f, 0x48, 0x45, 0x41, 0x44, 0x45, 0x52, 0x10, 0x01, 0x12,
928 0x1c, 0x0a, 0x18, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x53, 0x45,
929 0x52, 0x56, 0x45, 0x52, 0x5f, 0x48, 0x45, 0x41, 0x44, 0x45, 0x52, 0x10, 0x02, 0x12, 0x1d, 0x0a,
930 0x19, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x43, 0x4c, 0x49, 0x45,
931 0x4e, 0x54, 0x5f, 0x4d, 0x45, 0x53, 0x53, 0x41, 0x47, 0x45, 0x10, 0x03, 0x12, 0x1d, 0x0a, 0x19,
932 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x53, 0x45, 0x52, 0x56, 0x45,
933 0x52, 0x5f, 0x4d, 0x45, 0x53, 0x53, 0x41, 0x47, 0x45, 0x10, 0x04, 0x12, 0x20, 0x0a, 0x1c, 0x45,
934 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54,
935 0x5f, 0x48, 0x41, 0x4c, 0x46, 0x5f, 0x43, 0x4c, 0x4f, 0x53, 0x45, 0x10, 0x05, 0x12, 0x1d, 0x0a,
936 0x19, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x53, 0x45, 0x52, 0x56,
937 0x45, 0x52, 0x5f, 0x54, 0x52, 0x41, 0x49, 0x4c, 0x45, 0x52, 0x10, 0x06, 0x12, 0x15, 0x0a, 0x11,
938 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x43, 0x41, 0x4e, 0x43, 0x45,
939 0x4c, 0x10, 0x07, 0x22, 0x42, 0x0a, 0x06, 0x4c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x12, 0x12, 0x0a,
940 0x0e, 0x4c, 0x4f, 0x47, 0x47, 0x45, 0x52, 0x5f, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10,
941 0x00, 0x12, 0x11, 0x0a, 0x0d, 0x4c, 0x4f, 0x47, 0x47, 0x45, 0x52, 0x5f, 0x43, 0x4c, 0x49, 0x45,
942 0x4e, 0x54, 0x10, 0x01, 0x12, 0x11, 0x0a, 0x0d, 0x4c, 0x4f, 0x47, 0x47, 0x45, 0x52, 0x5f, 0x53,
943 0x45, 0x52, 0x56, 0x45, 0x52, 0x10, 0x02, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f,
944 0x61, 0x64, 0x22, 0xbb, 0x01, 0x0a, 0x0c, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x48, 0x65, 0x61,
945 0x64, 0x65, 0x72, 0x12, 0x37, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18,
946 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e,
947 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61,
948 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x1f, 0x0a, 0x0b,
949 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28,
950 0x09, 0x52, 0x0a, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1c, 0x0a,
951 0x09, 0x61, 0x75, 0x74, 0x68, 0x6f, 0x72, 0x69, 0x74, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
952 0x52, 0x09, 0x61, 0x75, 0x74, 0x68, 0x6f, 0x72, 0x69, 0x74, 0x79, 0x12, 0x33, 0x0a, 0x07, 0x74,
953 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67,
954 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44,
955 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74,
956 0x22, 0x47, 0x0a, 0x0c, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72,
957 0x12, 0x37, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01,
958 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79,
959 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52,
960 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0xb1, 0x01, 0x0a, 0x07, 0x54, 0x72,
961 0x61, 0x69, 0x6c, 0x65, 0x72, 0x12, 0x37, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74,
962 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62,
963 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x74, 0x61,
964 0x64, 0x61, 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x1f,
965 0x0a, 0x0b, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x02, 0x20,
966 0x01, 0x28, 0x0d, 0x52, 0x0a, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x43, 0x6f, 0x64, 0x65, 0x12,
967 0x25, 0x0a, 0x0e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67,
968 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x4d,
969 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
970 0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0d,
971 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 0x22, 0x35, 0x0a,
972 0x07, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6c, 0x65, 0x6e, 0x67,
973 0x74, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x06, 0x6c, 0x65, 0x6e, 0x67, 0x74, 0x68,
974 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04,
975 0x64, 0x61, 0x74, 0x61, 0x22, 0x42, 0x0a, 0x08, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61,
976 0x12, 0x36, 0x0a, 0x05, 0x65, 0x6e, 0x74, 0x72, 0x79, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32,
977 0x20, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67,
978 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x45, 0x6e, 0x74, 0x72,
979 0x79, 0x52, 0x05, 0x65, 0x6e, 0x74, 0x72, 0x79, 0x22, 0x37, 0x0a, 0x0d, 0x4d, 0x65, 0x74, 0x61,
980 0x64, 0x61, 0x74, 0x61, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79,
981 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76,
982 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75,
983 0x65, 0x22, 0xb8, 0x01, 0x0a, 0x07, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x12, 0x33, 0x0a,
984 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1f, 0x2e, 0x67, 0x72,
985 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e,
986 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79,
987 0x70, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x02, 0x20,
988 0x01, 0x28, 0x09, 0x52, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x12, 0x17, 0x0a, 0x07,
989 0x69, 0x70, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x06, 0x69,
990 0x70, 0x50, 0x6f, 0x72, 0x74, 0x22, 0x45, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x12, 0x10, 0x0a,
991 0x0c, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 0x12,
992 0x0d, 0x0a, 0x09, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x49, 0x50, 0x56, 0x34, 0x10, 0x01, 0x12, 0x0d,
993 0x0a, 0x09, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x49, 0x50, 0x56, 0x36, 0x10, 0x02, 0x12, 0x0d, 0x0a,
994 0x09, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x49, 0x58, 0x10, 0x03, 0x42, 0x5c, 0x0a, 0x14,
995 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f,
996 0x67, 0x2e, 0x76, 0x31, 0x42, 0x0e, 0x42, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x4c, 0x6f, 0x67, 0x50,
997 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x32, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67,
998 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x62,
999 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2f, 0x67, 0x72, 0x70, 0x63, 0x5f, 0x62, 0x69,
1000 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x5f, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
1001 0x6f, 0x33,
1002 }
1003
1004 var (
1005 file_grpc_binlog_v1_binarylog_proto_rawDescOnce sync.Once
1006 file_grpc_binlog_v1_binarylog_proto_rawDescData = file_grpc_binlog_v1_binarylog_proto_rawDesc
1007 )
1008
1009 func file_grpc_binlog_v1_binarylog_proto_rawDescGZIP() []byte {
1010 file_grpc_binlog_v1_binarylog_proto_rawDescOnce.Do(func() {
1011 file_grpc_binlog_v1_binarylog_proto_rawDescData = protoimpl.X.CompressGZIP(file_grpc_binlog_v1_binarylog_proto_rawDescData)
1012 })
1013 return file_grpc_binlog_v1_binarylog_proto_rawDescData
1014 }
1015
1016 var file_grpc_binlog_v1_binarylog_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
1017 var file_grpc_binlog_v1_binarylog_proto_msgTypes = make([]protoimpl.MessageInfo, 8)
1018 var file_grpc_binlog_v1_binarylog_proto_goTypes = []interface{}{
1019 (GrpcLogEntry_EventType)(0),
1020 (GrpcLogEntry_Logger)(0),
1021 (Address_Type)(0),
1022 (*GrpcLogEntry)(nil),
1023 (*ClientHeader)(nil),
1024 (*ServerHeader)(nil),
1025 (*Trailer)(nil),
1026 (*Message)(nil),
1027 (*Metadata)(nil),
1028 (*MetadataEntry)(nil),
1029 (*Address)(nil),
1030 (*timestamppb.Timestamp)(nil),
1031 (*durationpb.Duration)(nil),
1032 }
1033 var file_grpc_binlog_v1_binarylog_proto_depIdxs = []int32{
1034 11,
1035 0,
1036 1,
1037 4,
1038 5,
1039 7,
1040 6,
1041 10,
1042 8,
1043 12,
1044 8,
1045 8,
1046 9,
1047 2,
1048 14,
1049 14,
1050 14,
1051 14,
1052 0,
1053 }
1054
1055 func init() { file_grpc_binlog_v1_binarylog_proto_init() }
1056 func file_grpc_binlog_v1_binarylog_proto_init() {
1057 if File_grpc_binlog_v1_binarylog_proto != nil {
1058 return
1059 }
1060 if !protoimpl.UnsafeEnabled {
1061 file_grpc_binlog_v1_binarylog_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
1062 switch v := v.(*GrpcLogEntry); i {
1063 case 0:
1064 return &v.state
1065 case 1:
1066 return &v.sizeCache
1067 case 2:
1068 return &v.unknownFields
1069 default:
1070 return nil
1071 }
1072 }
1073 file_grpc_binlog_v1_binarylog_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
1074 switch v := v.(*ClientHeader); i {
1075 case 0:
1076 return &v.state
1077 case 1:
1078 return &v.sizeCache
1079 case 2:
1080 return &v.unknownFields
1081 default:
1082 return nil
1083 }
1084 }
1085 file_grpc_binlog_v1_binarylog_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
1086 switch v := v.(*ServerHeader); i {
1087 case 0:
1088 return &v.state
1089 case 1:
1090 return &v.sizeCache
1091 case 2:
1092 return &v.unknownFields
1093 default:
1094 return nil
1095 }
1096 }
1097 file_grpc_binlog_v1_binarylog_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
1098 switch v := v.(*Trailer); i {
1099 case 0:
1100 return &v.state
1101 case 1:
1102 return &v.sizeCache
1103 case 2:
1104 return &v.unknownFields
1105 default:
1106 return nil
1107 }
1108 }
1109 file_grpc_binlog_v1_binarylog_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
1110 switch v := v.(*Message); i {
1111 case 0:
1112 return &v.state
1113 case 1:
1114 return &v.sizeCache
1115 case 2:
1116 return &v.unknownFields
1117 default:
1118 return nil
1119 }
1120 }
1121 file_grpc_binlog_v1_binarylog_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
1122 switch v := v.(*Metadata); i {
1123 case 0:
1124 return &v.state
1125 case 1:
1126 return &v.sizeCache
1127 case 2:
1128 return &v.unknownFields
1129 default:
1130 return nil
1131 }
1132 }
1133 file_grpc_binlog_v1_binarylog_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
1134 switch v := v.(*MetadataEntry); i {
1135 case 0:
1136 return &v.state
1137 case 1:
1138 return &v.sizeCache
1139 case 2:
1140 return &v.unknownFields
1141 default:
1142 return nil
1143 }
1144 }
1145 file_grpc_binlog_v1_binarylog_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
1146 switch v := v.(*Address); i {
1147 case 0:
1148 return &v.state
1149 case 1:
1150 return &v.sizeCache
1151 case 2:
1152 return &v.unknownFields
1153 default:
1154 return nil
1155 }
1156 }
1157 }
1158 file_grpc_binlog_v1_binarylog_proto_msgTypes[0].OneofWrappers = []interface{}{
1159 (*GrpcLogEntry_ClientHeader)(nil),
1160 (*GrpcLogEntry_ServerHeader)(nil),
1161 (*GrpcLogEntry_Message)(nil),
1162 (*GrpcLogEntry_Trailer)(nil),
1163 }
1164 type x struct{}
1165 out := protoimpl.TypeBuilder{
1166 File: protoimpl.DescBuilder{
1167 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
1168 RawDescriptor: file_grpc_binlog_v1_binarylog_proto_rawDesc,
1169 NumEnums: 3,
1170 NumMessages: 8,
1171 NumExtensions: 0,
1172 NumServices: 0,
1173 },
1174 GoTypes: file_grpc_binlog_v1_binarylog_proto_goTypes,
1175 DependencyIndexes: file_grpc_binlog_v1_binarylog_proto_depIdxs,
1176 EnumInfos: file_grpc_binlog_v1_binarylog_proto_enumTypes,
1177 MessageInfos: file_grpc_binlog_v1_binarylog_proto_msgTypes,
1178 }.Build()
1179 File_grpc_binlog_v1_binarylog_proto = out.File
1180 file_grpc_binlog_v1_binarylog_proto_rawDesc = nil
1181 file_grpc_binlog_v1_binarylog_proto_goTypes = nil
1182 file_grpc_binlog_v1_binarylog_proto_depIdxs = nil
1183 }
1184
View as plain text