1// Copyright 2018 The gRPC Authors
2// All rights reserved.
3//
4// Licensed under the Apache License, Version 2.0 (the "License");
5// you may not use this file except in compliance with the License.
6// You may obtain a copy of the License at
7//
8// http://www.apache.org/licenses/LICENSE-2.0
9//
10// Unless required by applicable law or agreed to in writing, software
11// distributed under the License is distributed on an "AS IS" BASIS,
12// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13// See the License for the specific language governing permissions and
14// limitations under the License.
15
16// The canonical version of this proto can be found at
17// https://github.com/grpc/grpc-proto/blob/master/grpc/binlog/v1/binarylog.proto
18
19// Code generated by protoc-gen-go. DO NOT EDIT.
20// versions:
21// protoc-gen-go v1.36.4
22// protoc v5.27.1
23// source: grpc/binlog/v1/binarylog.proto
24
25package grpc_binarylog_v1
26
27import (
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 unsafe "unsafe"
35)
36
37const (
38 // Verify that this generated code is sufficiently up-to-date.
39 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
40 // Verify that runtime/protoimpl is sufficiently up-to-date.
41 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
42)
43
44// Enumerates the type of event
45// Note the terminology is different from the RPC semantics
46// definition, but the same meaning is expressed here.
47type GrpcLogEntry_EventType int32
48
49const (
50 GrpcLogEntry_EVENT_TYPE_UNKNOWN GrpcLogEntry_EventType = 0
51 // Header sent from client to server
52 GrpcLogEntry_EVENT_TYPE_CLIENT_HEADER GrpcLogEntry_EventType = 1
53 // Header sent from server to client
54 GrpcLogEntry_EVENT_TYPE_SERVER_HEADER GrpcLogEntry_EventType = 2
55 // Message sent from client to server
56 GrpcLogEntry_EVENT_TYPE_CLIENT_MESSAGE GrpcLogEntry_EventType = 3
57 // Message sent from server to client
58 GrpcLogEntry_EVENT_TYPE_SERVER_MESSAGE GrpcLogEntry_EventType = 4
59 // A signal that client is done sending
60 GrpcLogEntry_EVENT_TYPE_CLIENT_HALF_CLOSE GrpcLogEntry_EventType = 5
61 // Trailer indicates the end of the RPC.
62 // On client side, this event means a trailer was either received
63 // from the network or the gRPC library locally generated a status
64 // to inform the application about a failure.
65 // On server side, this event means the server application requested
66 // to send a trailer. Note: EVENT_TYPE_CANCEL may still arrive after
67 // this due to races on server side.
68 GrpcLogEntry_EVENT_TYPE_SERVER_TRAILER GrpcLogEntry_EventType = 6
69 // A signal that the RPC is cancelled. On client side, this
70 // indicates the client application requests a cancellation.
71 // On server side, this indicates that cancellation was detected.
72 // Note: This marks the end of the RPC. Events may arrive after
73 // this due to races. For example, on client side a trailer
74 // may arrive even though the application requested to cancel the RPC.
75 GrpcLogEntry_EVENT_TYPE_CANCEL GrpcLogEntry_EventType = 7
76)
77
78// Enum value maps for GrpcLogEntry_EventType.
79var (
80 GrpcLogEntry_EventType_name = map[int32]string{
81 0: "EVENT_TYPE_UNKNOWN",
82 1: "EVENT_TYPE_CLIENT_HEADER",
83 2: "EVENT_TYPE_SERVER_HEADER",
84 3: "EVENT_TYPE_CLIENT_MESSAGE",
85 4: "EVENT_TYPE_SERVER_MESSAGE",
86 5: "EVENT_TYPE_CLIENT_HALF_CLOSE",
87 6: "EVENT_TYPE_SERVER_TRAILER",
88 7: "EVENT_TYPE_CANCEL",
89 }
90 GrpcLogEntry_EventType_value = map[string]int32{
91 "EVENT_TYPE_UNKNOWN": 0,
92 "EVENT_TYPE_CLIENT_HEADER": 1,
93 "EVENT_TYPE_SERVER_HEADER": 2,
94 "EVENT_TYPE_CLIENT_MESSAGE": 3,
95 "EVENT_TYPE_SERVER_MESSAGE": 4,
96 "EVENT_TYPE_CLIENT_HALF_CLOSE": 5,
97 "EVENT_TYPE_SERVER_TRAILER": 6,
98 "EVENT_TYPE_CANCEL": 7,
99 }
100)
101
102func (x GrpcLogEntry_EventType) Enum() *GrpcLogEntry_EventType {
103 p := new(GrpcLogEntry_EventType)
104 *p = x
105 return p
106}
107
108func (x GrpcLogEntry_EventType) String() string {
109 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
110}
111
112func (GrpcLogEntry_EventType) Descriptor() protoreflect.EnumDescriptor {
113 return file_grpc_binlog_v1_binarylog_proto_enumTypes[0].Descriptor()
114}
115
116func (GrpcLogEntry_EventType) Type() protoreflect.EnumType {
117 return &file_grpc_binlog_v1_binarylog_proto_enumTypes[0]
118}
119
120func (x GrpcLogEntry_EventType) Number() protoreflect.EnumNumber {
121 return protoreflect.EnumNumber(x)
122}
123
124// Deprecated: Use GrpcLogEntry_EventType.Descriptor instead.
125func (GrpcLogEntry_EventType) EnumDescriptor() ([]byte, []int) {
126 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{0, 0}
127}
128
129// Enumerates the entity that generates the log entry
130type GrpcLogEntry_Logger int32
131
132const (
133 GrpcLogEntry_LOGGER_UNKNOWN GrpcLogEntry_Logger = 0
134 GrpcLogEntry_LOGGER_CLIENT GrpcLogEntry_Logger = 1
135 GrpcLogEntry_LOGGER_SERVER GrpcLogEntry_Logger = 2
136)
137
138// Enum value maps for GrpcLogEntry_Logger.
139var (
140 GrpcLogEntry_Logger_name = map[int32]string{
141 0: "LOGGER_UNKNOWN",
142 1: "LOGGER_CLIENT",
143 2: "LOGGER_SERVER",
144 }
145 GrpcLogEntry_Logger_value = map[string]int32{
146 "LOGGER_UNKNOWN": 0,
147 "LOGGER_CLIENT": 1,
148 "LOGGER_SERVER": 2,
149 }
150)
151
152func (x GrpcLogEntry_Logger) Enum() *GrpcLogEntry_Logger {
153 p := new(GrpcLogEntry_Logger)
154 *p = x
155 return p
156}
157
158func (x GrpcLogEntry_Logger) String() string {
159 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
160}
161
162func (GrpcLogEntry_Logger) Descriptor() protoreflect.EnumDescriptor {
163 return file_grpc_binlog_v1_binarylog_proto_enumTypes[1].Descriptor()
164}
165
166func (GrpcLogEntry_Logger) Type() protoreflect.EnumType {
167 return &file_grpc_binlog_v1_binarylog_proto_enumTypes[1]
168}
169
170func (x GrpcLogEntry_Logger) Number() protoreflect.EnumNumber {
171 return protoreflect.EnumNumber(x)
172}
173
174// Deprecated: Use GrpcLogEntry_Logger.Descriptor instead.
175func (GrpcLogEntry_Logger) EnumDescriptor() ([]byte, []int) {
176 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{0, 1}
177}
178
179type Address_Type int32
180
181const (
182 Address_TYPE_UNKNOWN Address_Type = 0
183 // address is in 1.2.3.4 form
184 Address_TYPE_IPV4 Address_Type = 1
185 // address is in IPv6 canonical form (RFC5952 section 4)
186 // The scope is NOT included in the address string.
187 Address_TYPE_IPV6 Address_Type = 2
188 // address is UDS string
189 Address_TYPE_UNIX Address_Type = 3
190)
191
192// Enum value maps for Address_Type.
193var (
194 Address_Type_name = map[int32]string{
195 0: "TYPE_UNKNOWN",
196 1: "TYPE_IPV4",
197 2: "TYPE_IPV6",
198 3: "TYPE_UNIX",
199 }
200 Address_Type_value = map[string]int32{
201 "TYPE_UNKNOWN": 0,
202 "TYPE_IPV4": 1,
203 "TYPE_IPV6": 2,
204 "TYPE_UNIX": 3,
205 }
206)
207
208func (x Address_Type) Enum() *Address_Type {
209 p := new(Address_Type)
210 *p = x
211 return p
212}
213
214func (x Address_Type) String() string {
215 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
216}
217
218func (Address_Type) Descriptor() protoreflect.EnumDescriptor {
219 return file_grpc_binlog_v1_binarylog_proto_enumTypes[2].Descriptor()
220}
221
222func (Address_Type) Type() protoreflect.EnumType {
223 return &file_grpc_binlog_v1_binarylog_proto_enumTypes[2]
224}
225
226func (x Address_Type) Number() protoreflect.EnumNumber {
227 return protoreflect.EnumNumber(x)
228}
229
230// Deprecated: Use Address_Type.Descriptor instead.
231func (Address_Type) EnumDescriptor() ([]byte, []int) {
232 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{7, 0}
233}
234
235// Log entry we store in binary logs
236type GrpcLogEntry struct {
237 state protoimpl.MessageState `protogen:"open.v1"`
238 // The timestamp of the binary log message
239 Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
240 // Uniquely identifies a call. The value must not be 0 in order to disambiguate
241 // from an unset value.
242 // Each call may have several log entries, they will all have the same call_id.
243 // Nothing is guaranteed about their value other than they are unique across
244 // different RPCs in the same gRPC process.
245 CallId uint64 `protobuf:"varint,2,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
246 // The entry sequence id for this call. The first GrpcLogEntry has a
247 // value of 1, to disambiguate from an unset value. The purpose of
248 // this field is to detect missing entries in environments where
249 // durability or ordering is not guaranteed.
250 SequenceIdWithinCall uint64 `protobuf:"varint,3,opt,name=sequence_id_within_call,json=sequenceIdWithinCall,proto3" json:"sequence_id_within_call,omitempty"`
251 Type GrpcLogEntry_EventType `protobuf:"varint,4,opt,name=type,proto3,enum=grpc.binarylog.v1.GrpcLogEntry_EventType" json:"type,omitempty"`
252 Logger GrpcLogEntry_Logger `protobuf:"varint,5,opt,name=logger,proto3,enum=grpc.binarylog.v1.GrpcLogEntry_Logger" json:"logger,omitempty"` // One of the above Logger enum
253 // The logger uses one of the following fields to record the payload,
254 // according to the type of the log entry.
255 //
256 // Types that are valid to be assigned to Payload:
257 //
258 // *GrpcLogEntry_ClientHeader
259 // *GrpcLogEntry_ServerHeader
260 // *GrpcLogEntry_Message
261 // *GrpcLogEntry_Trailer
262 Payload isGrpcLogEntry_Payload `protobuf_oneof:"payload"`
263 // true if payload does not represent the full message or metadata.
264 PayloadTruncated bool `protobuf:"varint,10,opt,name=payload_truncated,json=payloadTruncated,proto3" json:"payload_truncated,omitempty"`
265 // Peer address information, will only be recorded on the first
266 // incoming event. On client side, peer is logged on
267 // EVENT_TYPE_SERVER_HEADER normally or EVENT_TYPE_SERVER_TRAILER in
268 // the case of trailers-only. On server side, peer is always
269 // logged on EVENT_TYPE_CLIENT_HEADER.
270 Peer *Address `protobuf:"bytes,11,opt,name=peer,proto3" json:"peer,omitempty"`
271 unknownFields protoimpl.UnknownFields
272 sizeCache protoimpl.SizeCache
273}
274
275func (x *GrpcLogEntry) Reset() {
276 *x = GrpcLogEntry{}
277 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[0]
278 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
279 ms.StoreMessageInfo(mi)
280}
281
282func (x *GrpcLogEntry) String() string {
283 return protoimpl.X.MessageStringOf(x)
284}
285
286func (*GrpcLogEntry) ProtoMessage() {}
287
288func (x *GrpcLogEntry) ProtoReflect() protoreflect.Message {
289 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[0]
290 if x != nil {
291 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
292 if ms.LoadMessageInfo() == nil {
293 ms.StoreMessageInfo(mi)
294 }
295 return ms
296 }
297 return mi.MessageOf(x)
298}
299
300// Deprecated: Use GrpcLogEntry.ProtoReflect.Descriptor instead.
301func (*GrpcLogEntry) Descriptor() ([]byte, []int) {
302 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{0}
303}
304
305func (x *GrpcLogEntry) GetTimestamp() *timestamppb.Timestamp {
306 if x != nil {
307 return x.Timestamp
308 }
309 return nil
310}
311
312func (x *GrpcLogEntry) GetCallId() uint64 {
313 if x != nil {
314 return x.CallId
315 }
316 return 0
317}
318
319func (x *GrpcLogEntry) GetSequenceIdWithinCall() uint64 {
320 if x != nil {
321 return x.SequenceIdWithinCall
322 }
323 return 0
324}
325
326func (x *GrpcLogEntry) GetType() GrpcLogEntry_EventType {
327 if x != nil {
328 return x.Type
329 }
330 return GrpcLogEntry_EVENT_TYPE_UNKNOWN
331}
332
333func (x *GrpcLogEntry) GetLogger() GrpcLogEntry_Logger {
334 if x != nil {
335 return x.Logger
336 }
337 return GrpcLogEntry_LOGGER_UNKNOWN
338}
339
340func (x *GrpcLogEntry) GetPayload() isGrpcLogEntry_Payload {
341 if x != nil {
342 return x.Payload
343 }
344 return nil
345}
346
347func (x *GrpcLogEntry) GetClientHeader() *ClientHeader {
348 if x != nil {
349 if x, ok := x.Payload.(*GrpcLogEntry_ClientHeader); ok {
350 return x.ClientHeader
351 }
352 }
353 return nil
354}
355
356func (x *GrpcLogEntry) GetServerHeader() *ServerHeader {
357 if x != nil {
358 if x, ok := x.Payload.(*GrpcLogEntry_ServerHeader); ok {
359 return x.ServerHeader
360 }
361 }
362 return nil
363}
364
365func (x *GrpcLogEntry) GetMessage() *Message {
366 if x != nil {
367 if x, ok := x.Payload.(*GrpcLogEntry_Message); ok {
368 return x.Message
369 }
370 }
371 return nil
372}
373
374func (x *GrpcLogEntry) GetTrailer() *Trailer {
375 if x != nil {
376 if x, ok := x.Payload.(*GrpcLogEntry_Trailer); ok {
377 return x.Trailer
378 }
379 }
380 return nil
381}
382
383func (x *GrpcLogEntry) GetPayloadTruncated() bool {
384 if x != nil {
385 return x.PayloadTruncated
386 }
387 return false
388}
389
390func (x *GrpcLogEntry) GetPeer() *Address {
391 if x != nil {
392 return x.Peer
393 }
394 return nil
395}
396
397type isGrpcLogEntry_Payload interface {
398 isGrpcLogEntry_Payload()
399}
400
401type GrpcLogEntry_ClientHeader struct {
402 ClientHeader *ClientHeader `protobuf:"bytes,6,opt,name=client_header,json=clientHeader,proto3,oneof"`
403}
404
405type GrpcLogEntry_ServerHeader struct {
406 ServerHeader *ServerHeader `protobuf:"bytes,7,opt,name=server_header,json=serverHeader,proto3,oneof"`
407}
408
409type GrpcLogEntry_Message struct {
410 // Used by EVENT_TYPE_CLIENT_MESSAGE, EVENT_TYPE_SERVER_MESSAGE
411 Message *Message `protobuf:"bytes,8,opt,name=message,proto3,oneof"`
412}
413
414type GrpcLogEntry_Trailer struct {
415 Trailer *Trailer `protobuf:"bytes,9,opt,name=trailer,proto3,oneof"`
416}
417
418func (*GrpcLogEntry_ClientHeader) isGrpcLogEntry_Payload() {}
419
420func (*GrpcLogEntry_ServerHeader) isGrpcLogEntry_Payload() {}
421
422func (*GrpcLogEntry_Message) isGrpcLogEntry_Payload() {}
423
424func (*GrpcLogEntry_Trailer) isGrpcLogEntry_Payload() {}
425
426type ClientHeader struct {
427 state protoimpl.MessageState `protogen:"open.v1"`
428 // This contains only the metadata from the application.
429 Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
430 // The name of the RPC method, which looks something like:
431 // /<service>/<method>
432 // Note the leading "/" character.
433 MethodName string `protobuf:"bytes,2,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
434 // A single process may be used to run multiple virtual
435 // servers with different identities.
436 // The authority is the name of such a server identity.
437 // It is typically a portion of the URI in the form of
438 // <host> or <host>:<port> .
439 Authority string `protobuf:"bytes,3,opt,name=authority,proto3" json:"authority,omitempty"`
440 // the RPC timeout
441 Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
442 unknownFields protoimpl.UnknownFields
443 sizeCache protoimpl.SizeCache
444}
445
446func (x *ClientHeader) Reset() {
447 *x = ClientHeader{}
448 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[1]
449 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
450 ms.StoreMessageInfo(mi)
451}
452
453func (x *ClientHeader) String() string {
454 return protoimpl.X.MessageStringOf(x)
455}
456
457func (*ClientHeader) ProtoMessage() {}
458
459func (x *ClientHeader) ProtoReflect() protoreflect.Message {
460 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[1]
461 if x != nil {
462 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
463 if ms.LoadMessageInfo() == nil {
464 ms.StoreMessageInfo(mi)
465 }
466 return ms
467 }
468 return mi.MessageOf(x)
469}
470
471// Deprecated: Use ClientHeader.ProtoReflect.Descriptor instead.
472func (*ClientHeader) Descriptor() ([]byte, []int) {
473 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{1}
474}
475
476func (x *ClientHeader) GetMetadata() *Metadata {
477 if x != nil {
478 return x.Metadata
479 }
480 return nil
481}
482
483func (x *ClientHeader) GetMethodName() string {
484 if x != nil {
485 return x.MethodName
486 }
487 return ""
488}
489
490func (x *ClientHeader) GetAuthority() string {
491 if x != nil {
492 return x.Authority
493 }
494 return ""
495}
496
497func (x *ClientHeader) GetTimeout() *durationpb.Duration {
498 if x != nil {
499 return x.Timeout
500 }
501 return nil
502}
503
504type ServerHeader struct {
505 state protoimpl.MessageState `protogen:"open.v1"`
506 // This contains only the metadata from the application.
507 Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
508 unknownFields protoimpl.UnknownFields
509 sizeCache protoimpl.SizeCache
510}
511
512func (x *ServerHeader) Reset() {
513 *x = ServerHeader{}
514 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[2]
515 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
516 ms.StoreMessageInfo(mi)
517}
518
519func (x *ServerHeader) String() string {
520 return protoimpl.X.MessageStringOf(x)
521}
522
523func (*ServerHeader) ProtoMessage() {}
524
525func (x *ServerHeader) ProtoReflect() protoreflect.Message {
526 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[2]
527 if 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// Deprecated: Use ServerHeader.ProtoReflect.Descriptor instead.
538func (*ServerHeader) Descriptor() ([]byte, []int) {
539 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{2}
540}
541
542func (x *ServerHeader) GetMetadata() *Metadata {
543 if x != nil {
544 return x.Metadata
545 }
546 return nil
547}
548
549type Trailer struct {
550 state protoimpl.MessageState `protogen:"open.v1"`
551 // This contains only the metadata from the application.
552 Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
553 // The gRPC status code.
554 StatusCode uint32 `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
555 // An original status message before any transport specific
556 // encoding.
557 StatusMessage string `protobuf:"bytes,3,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
558 // The value of the 'grpc-status-details-bin' metadata key. If
559 // present, this is always an encoded 'google.rpc.Status' message.
560 StatusDetails []byte `protobuf:"bytes,4,opt,name=status_details,json=statusDetails,proto3" json:"status_details,omitempty"`
561 unknownFields protoimpl.UnknownFields
562 sizeCache protoimpl.SizeCache
563}
564
565func (x *Trailer) Reset() {
566 *x = Trailer{}
567 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[3]
568 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
569 ms.StoreMessageInfo(mi)
570}
571
572func (x *Trailer) String() string {
573 return protoimpl.X.MessageStringOf(x)
574}
575
576func (*Trailer) ProtoMessage() {}
577
578func (x *Trailer) ProtoReflect() protoreflect.Message {
579 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[3]
580 if x != nil {
581 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
582 if ms.LoadMessageInfo() == nil {
583 ms.StoreMessageInfo(mi)
584 }
585 return ms
586 }
587 return mi.MessageOf(x)
588}
589
590// Deprecated: Use Trailer.ProtoReflect.Descriptor instead.
591func (*Trailer) Descriptor() ([]byte, []int) {
592 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{3}
593}
594
595func (x *Trailer) GetMetadata() *Metadata {
596 if x != nil {
597 return x.Metadata
598 }
599 return nil
600}
601
602func (x *Trailer) GetStatusCode() uint32 {
603 if x != nil {
604 return x.StatusCode
605 }
606 return 0
607}
608
609func (x *Trailer) GetStatusMessage() string {
610 if x != nil {
611 return x.StatusMessage
612 }
613 return ""
614}
615
616func (x *Trailer) GetStatusDetails() []byte {
617 if x != nil {
618 return x.StatusDetails
619 }
620 return nil
621}
622
623// Message payload, used by CLIENT_MESSAGE and SERVER_MESSAGE
624type Message struct {
625 state protoimpl.MessageState `protogen:"open.v1"`
626 // Length of the message. It may not be the same as the length of the
627 // data field, as the logging payload can be truncated or omitted.
628 Length uint32 `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"`
629 // May be truncated or omitted.
630 Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
631 unknownFields protoimpl.UnknownFields
632 sizeCache protoimpl.SizeCache
633}
634
635func (x *Message) Reset() {
636 *x = Message{}
637 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[4]
638 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
639 ms.StoreMessageInfo(mi)
640}
641
642func (x *Message) String() string {
643 return protoimpl.X.MessageStringOf(x)
644}
645
646func (*Message) ProtoMessage() {}
647
648func (x *Message) ProtoReflect() protoreflect.Message {
649 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[4]
650 if x != nil {
651 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
652 if ms.LoadMessageInfo() == nil {
653 ms.StoreMessageInfo(mi)
654 }
655 return ms
656 }
657 return mi.MessageOf(x)
658}
659
660// Deprecated: Use Message.ProtoReflect.Descriptor instead.
661func (*Message) Descriptor() ([]byte, []int) {
662 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{4}
663}
664
665func (x *Message) GetLength() uint32 {
666 if x != nil {
667 return x.Length
668 }
669 return 0
670}
671
672func (x *Message) GetData() []byte {
673 if x != nil {
674 return x.Data
675 }
676 return nil
677}
678
679// A list of metadata pairs, used in the payload of client header,
680// server header, and server trailer.
681// Implementations may omit some entries to honor the header limits
682// of GRPC_BINARY_LOG_CONFIG.
683//
684// Header keys added by gRPC are omitted. To be more specific,
685// implementations will not log the following entries, and this is
686// not to be treated as a truncation:
687// - entries handled by grpc that are not user visible, such as those
688// that begin with 'grpc-' (with exception of grpc-trace-bin)
689// or keys like 'lb-token'
690// - transport specific entries, including but not limited to:
691// ':path', ':authority', 'content-encoding', 'user-agent', 'te', etc
692// - entries added for call credentials
693//
694// Implementations must always log grpc-trace-bin if it is present.
695// Practically speaking it will only be visible on server side because
696// grpc-trace-bin is managed by low level client side mechanisms
697// inaccessible from the application level. On server side, the
698// header is just a normal metadata key.
699// The pair will not count towards the size limit.
700type Metadata struct {
701 state protoimpl.MessageState `protogen:"open.v1"`
702 Entry []*MetadataEntry `protobuf:"bytes,1,rep,name=entry,proto3" json:"entry,omitempty"`
703 unknownFields protoimpl.UnknownFields
704 sizeCache protoimpl.SizeCache
705}
706
707func (x *Metadata) Reset() {
708 *x = Metadata{}
709 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[5]
710 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
711 ms.StoreMessageInfo(mi)
712}
713
714func (x *Metadata) String() string {
715 return protoimpl.X.MessageStringOf(x)
716}
717
718func (*Metadata) ProtoMessage() {}
719
720func (x *Metadata) ProtoReflect() protoreflect.Message {
721 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[5]
722 if x != nil {
723 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
724 if ms.LoadMessageInfo() == nil {
725 ms.StoreMessageInfo(mi)
726 }
727 return ms
728 }
729 return mi.MessageOf(x)
730}
731
732// Deprecated: Use Metadata.ProtoReflect.Descriptor instead.
733func (*Metadata) Descriptor() ([]byte, []int) {
734 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{5}
735}
736
737func (x *Metadata) GetEntry() []*MetadataEntry {
738 if x != nil {
739 return x.Entry
740 }
741 return nil
742}
743
744// A metadata key value pair
745type MetadataEntry struct {
746 state protoimpl.MessageState `protogen:"open.v1"`
747 Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
748 Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
749 unknownFields protoimpl.UnknownFields
750 sizeCache protoimpl.SizeCache
751}
752
753func (x *MetadataEntry) Reset() {
754 *x = MetadataEntry{}
755 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[6]
756 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
757 ms.StoreMessageInfo(mi)
758}
759
760func (x *MetadataEntry) String() string {
761 return protoimpl.X.MessageStringOf(x)
762}
763
764func (*MetadataEntry) ProtoMessage() {}
765
766func (x *MetadataEntry) ProtoReflect() protoreflect.Message {
767 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[6]
768 if x != nil {
769 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
770 if ms.LoadMessageInfo() == nil {
771 ms.StoreMessageInfo(mi)
772 }
773 return ms
774 }
775 return mi.MessageOf(x)
776}
777
778// Deprecated: Use MetadataEntry.ProtoReflect.Descriptor instead.
779func (*MetadataEntry) Descriptor() ([]byte, []int) {
780 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{6}
781}
782
783func (x *MetadataEntry) GetKey() string {
784 if x != nil {
785 return x.Key
786 }
787 return ""
788}
789
790func (x *MetadataEntry) GetValue() []byte {
791 if x != nil {
792 return x.Value
793 }
794 return nil
795}
796
797// Address information
798type Address struct {
799 state protoimpl.MessageState `protogen:"open.v1"`
800 Type Address_Type `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.binarylog.v1.Address_Type" json:"type,omitempty"`
801 Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
802 // only for TYPE_IPV4 and TYPE_IPV6
803 IpPort uint32 `protobuf:"varint,3,opt,name=ip_port,json=ipPort,proto3" json:"ip_port,omitempty"`
804 unknownFields protoimpl.UnknownFields
805 sizeCache protoimpl.SizeCache
806}
807
808func (x *Address) Reset() {
809 *x = Address{}
810 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[7]
811 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
812 ms.StoreMessageInfo(mi)
813}
814
815func (x *Address) String() string {
816 return protoimpl.X.MessageStringOf(x)
817}
818
819func (*Address) ProtoMessage() {}
820
821func (x *Address) ProtoReflect() protoreflect.Message {
822 mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[7]
823 if x != nil {
824 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
825 if ms.LoadMessageInfo() == nil {
826 ms.StoreMessageInfo(mi)
827 }
828 return ms
829 }
830 return mi.MessageOf(x)
831}
832
833// Deprecated: Use Address.ProtoReflect.Descriptor instead.
834func (*Address) Descriptor() ([]byte, []int) {
835 return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{7}
836}
837
838func (x *Address) GetType() Address_Type {
839 if x != nil {
840 return x.Type
841 }
842 return Address_TYPE_UNKNOWN
843}
844
845func (x *Address) GetAddress() string {
846 if x != nil {
847 return x.Address
848 }
849 return ""
850}
851
852func (x *Address) GetIpPort() uint32 {
853 if x != nil {
854 return x.IpPort
855 }
856 return 0
857}
858
859var File_grpc_binlog_v1_binarylog_proto protoreflect.FileDescriptor
860
861var file_grpc_binlog_v1_binarylog_proto_rawDesc = string([]byte{
862 0x0a, 0x1e, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x62, 0x69, 0x6e, 0x6c, 0x6f, 0x67, 0x2f, 0x76, 0x31,
863 0x2f, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
864 0x12, 0x11, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67,
865 0x2e, 0x76, 0x31, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74,
866 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72,
867 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74,
868 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70,
869 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xbb, 0x07, 0x0a, 0x0c, 0x47, 0x72, 0x70, 0x63, 0x4c, 0x6f, 0x67,
870 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x38, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61,
871 0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
872 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73,
873 0x74, 0x61, 0x6d, 0x70, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12,
874 0x17, 0x0a, 0x07, 0x63, 0x61, 0x6c, 0x6c, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04,
875 0x52, 0x06, 0x63, 0x61, 0x6c, 0x6c, 0x49, 0x64, 0x12, 0x35, 0x0a, 0x17, 0x73, 0x65, 0x71, 0x75,
876 0x65, 0x6e, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x5f, 0x77, 0x69, 0x74, 0x68, 0x69, 0x6e, 0x5f, 0x63,
877 0x61, 0x6c, 0x6c, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x52, 0x14, 0x73, 0x65, 0x71, 0x75, 0x65,
878 0x6e, 0x63, 0x65, 0x49, 0x64, 0x57, 0x69, 0x74, 0x68, 0x69, 0x6e, 0x43, 0x61, 0x6c, 0x6c, 0x12,
879 0x3d, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x29, 0x2e,
880 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76,
881 0x31, 0x2e, 0x47, 0x72, 0x70, 0x63, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x2e, 0x45,
882 0x76, 0x65, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x3e,
883 0x0a, 0x06, 0x6c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x26,
884 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e,
885 0x76, 0x31, 0x2e, 0x47, 0x72, 0x70, 0x63, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x2e,
886 0x4c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x52, 0x06, 0x6c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x12, 0x46,
887 0x0a, 0x0d, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18,
888 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e,
889 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74,
890 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x48, 0x00, 0x52, 0x0c, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74,
891 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x46, 0x0a, 0x0d, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72,
892 0x5f, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e,
893 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76,
894 0x31, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x48, 0x00,
895 0x52, 0x0c, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x36,
896 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32,
897 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67,
898 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x48, 0x00, 0x52, 0x07, 0x6d,
899 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x36, 0x0a, 0x07, 0x74, 0x72, 0x61, 0x69, 0x6c, 0x65,
900 0x72, 0x18, 0x09, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62,
901 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x72, 0x61, 0x69,
902 0x6c, 0x65, 0x72, 0x48, 0x00, 0x52, 0x07, 0x74, 0x72, 0x61, 0x69, 0x6c, 0x65, 0x72, 0x12, 0x2b,
903 0x0a, 0x11, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x5f, 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61,
904 0x74, 0x65, 0x64, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x08, 0x52, 0x10, 0x70, 0x61, 0x79, 0x6c, 0x6f,
905 0x61, 0x64, 0x54, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x64, 0x12, 0x2e, 0x0a, 0x04, 0x70,
906 0x65, 0x65, 0x72, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63,
907 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x64,
908 0x64, 0x72, 0x65, 0x73, 0x73, 0x52, 0x04, 0x70, 0x65, 0x65, 0x72, 0x22, 0xf5, 0x01, 0x0a, 0x09,
909 0x45, 0x76, 0x65, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x16, 0x0a, 0x12, 0x45, 0x56, 0x45,
910 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10,
911 0x00, 0x12, 0x1c, 0x0a, 0x18, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f,
912 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54, 0x5f, 0x48, 0x45, 0x41, 0x44, 0x45, 0x52, 0x10, 0x01, 0x12,
913 0x1c, 0x0a, 0x18, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x53, 0x45,
914 0x52, 0x56, 0x45, 0x52, 0x5f, 0x48, 0x45, 0x41, 0x44, 0x45, 0x52, 0x10, 0x02, 0x12, 0x1d, 0x0a,
915 0x19, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x43, 0x4c, 0x49, 0x45,
916 0x4e, 0x54, 0x5f, 0x4d, 0x45, 0x53, 0x53, 0x41, 0x47, 0x45, 0x10, 0x03, 0x12, 0x1d, 0x0a, 0x19,
917 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x53, 0x45, 0x52, 0x56, 0x45,
918 0x52, 0x5f, 0x4d, 0x45, 0x53, 0x53, 0x41, 0x47, 0x45, 0x10, 0x04, 0x12, 0x20, 0x0a, 0x1c, 0x45,
919 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54,
920 0x5f, 0x48, 0x41, 0x4c, 0x46, 0x5f, 0x43, 0x4c, 0x4f, 0x53, 0x45, 0x10, 0x05, 0x12, 0x1d, 0x0a,
921 0x19, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x53, 0x45, 0x52, 0x56,
922 0x45, 0x52, 0x5f, 0x54, 0x52, 0x41, 0x49, 0x4c, 0x45, 0x52, 0x10, 0x06, 0x12, 0x15, 0x0a, 0x11,
923 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x43, 0x41, 0x4e, 0x43, 0x45,
924 0x4c, 0x10, 0x07, 0x22, 0x42, 0x0a, 0x06, 0x4c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x12, 0x12, 0x0a,
925 0x0e, 0x4c, 0x4f, 0x47, 0x47, 0x45, 0x52, 0x5f, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10,
926 0x00, 0x12, 0x11, 0x0a, 0x0d, 0x4c, 0x4f, 0x47, 0x47, 0x45, 0x52, 0x5f, 0x43, 0x4c, 0x49, 0x45,
927 0x4e, 0x54, 0x10, 0x01, 0x12, 0x11, 0x0a, 0x0d, 0x4c, 0x4f, 0x47, 0x47, 0x45, 0x52, 0x5f, 0x53,
928 0x45, 0x52, 0x56, 0x45, 0x52, 0x10, 0x02, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f,
929 0x61, 0x64, 0x22, 0xbb, 0x01, 0x0a, 0x0c, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x48, 0x65, 0x61,
930 0x64, 0x65, 0x72, 0x12, 0x37, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18,
931 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e,
932 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61,
933 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x1f, 0x0a, 0x0b,
934 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28,
935 0x09, 0x52, 0x0a, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1c, 0x0a,
936 0x09, 0x61, 0x75, 0x74, 0x68, 0x6f, 0x72, 0x69, 0x74, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
937 0x52, 0x09, 0x61, 0x75, 0x74, 0x68, 0x6f, 0x72, 0x69, 0x74, 0x79, 0x12, 0x33, 0x0a, 0x07, 0x74,
938 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67,
939 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44,
940 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74,
941 0x22, 0x47, 0x0a, 0x0c, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72,
942 0x12, 0x37, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01,
943 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79,
944 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52,
945 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0xb1, 0x01, 0x0a, 0x07, 0x54, 0x72,
946 0x61, 0x69, 0x6c, 0x65, 0x72, 0x12, 0x37, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74,
947 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62,
948 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x74, 0x61,
949 0x64, 0x61, 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x1f,
950 0x0a, 0x0b, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x02, 0x20,
951 0x01, 0x28, 0x0d, 0x52, 0x0a, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x43, 0x6f, 0x64, 0x65, 0x12,
952 0x25, 0x0a, 0x0e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67,
953 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x4d,
954 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
955 0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0d,
956 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 0x22, 0x35, 0x0a,
957 0x07, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6c, 0x65, 0x6e, 0x67,
958 0x74, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x06, 0x6c, 0x65, 0x6e, 0x67, 0x74, 0x68,
959 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04,
960 0x64, 0x61, 0x74, 0x61, 0x22, 0x42, 0x0a, 0x08, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61,
961 0x12, 0x36, 0x0a, 0x05, 0x65, 0x6e, 0x74, 0x72, 0x79, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32,
962 0x20, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67,
963 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x45, 0x6e, 0x74, 0x72,
964 0x79, 0x52, 0x05, 0x65, 0x6e, 0x74, 0x72, 0x79, 0x22, 0x37, 0x0a, 0x0d, 0x4d, 0x65, 0x74, 0x61,
965 0x64, 0x61, 0x74, 0x61, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79,
966 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76,
967 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75,
968 0x65, 0x22, 0xb8, 0x01, 0x0a, 0x07, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x12, 0x33, 0x0a,
969 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1f, 0x2e, 0x67, 0x72,
970 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e,
971 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79,
972 0x70, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x02, 0x20,
973 0x01, 0x28, 0x09, 0x52, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x12, 0x17, 0x0a, 0x07,
974 0x69, 0x70, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x06, 0x69,
975 0x70, 0x50, 0x6f, 0x72, 0x74, 0x22, 0x45, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x12, 0x10, 0x0a,
976 0x0c, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 0x12,
977 0x0d, 0x0a, 0x09, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x49, 0x50, 0x56, 0x34, 0x10, 0x01, 0x12, 0x0d,
978 0x0a, 0x09, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x49, 0x50, 0x56, 0x36, 0x10, 0x02, 0x12, 0x0d, 0x0a,
979 0x09, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x49, 0x58, 0x10, 0x03, 0x42, 0x5c, 0x0a, 0x14,
980 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f,
981 0x67, 0x2e, 0x76, 0x31, 0x42, 0x0e, 0x42, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x4c, 0x6f, 0x67, 0x50,
982 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x32, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67,
983 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x62,
984 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2f, 0x67, 0x72, 0x70, 0x63, 0x5f, 0x62, 0x69,
985 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x5f, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
986 0x6f, 0x33,
987})
988
989var (
990 file_grpc_binlog_v1_binarylog_proto_rawDescOnce sync.Once
991 file_grpc_binlog_v1_binarylog_proto_rawDescData []byte
992)
993
994func file_grpc_binlog_v1_binarylog_proto_rawDescGZIP() []byte {
995 file_grpc_binlog_v1_binarylog_proto_rawDescOnce.Do(func() {
996 file_grpc_binlog_v1_binarylog_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_grpc_binlog_v1_binarylog_proto_rawDesc), len(file_grpc_binlog_v1_binarylog_proto_rawDesc)))
997 })
998 return file_grpc_binlog_v1_binarylog_proto_rawDescData
999}
1000
1001var file_grpc_binlog_v1_binarylog_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
1002var file_grpc_binlog_v1_binarylog_proto_msgTypes = make([]protoimpl.MessageInfo, 8)
1003var file_grpc_binlog_v1_binarylog_proto_goTypes = []any{
1004 (GrpcLogEntry_EventType)(0), // 0: grpc.binarylog.v1.GrpcLogEntry.EventType
1005 (GrpcLogEntry_Logger)(0), // 1: grpc.binarylog.v1.GrpcLogEntry.Logger
1006 (Address_Type)(0), // 2: grpc.binarylog.v1.Address.Type
1007 (*GrpcLogEntry)(nil), // 3: grpc.binarylog.v1.GrpcLogEntry
1008 (*ClientHeader)(nil), // 4: grpc.binarylog.v1.ClientHeader
1009 (*ServerHeader)(nil), // 5: grpc.binarylog.v1.ServerHeader
1010 (*Trailer)(nil), // 6: grpc.binarylog.v1.Trailer
1011 (*Message)(nil), // 7: grpc.binarylog.v1.Message
1012 (*Metadata)(nil), // 8: grpc.binarylog.v1.Metadata
1013 (*MetadataEntry)(nil), // 9: grpc.binarylog.v1.MetadataEntry
1014 (*Address)(nil), // 10: grpc.binarylog.v1.Address
1015 (*timestamppb.Timestamp)(nil), // 11: google.protobuf.Timestamp
1016 (*durationpb.Duration)(nil), // 12: google.protobuf.Duration
1017}
1018var file_grpc_binlog_v1_binarylog_proto_depIdxs = []int32{
1019 11, // 0: grpc.binarylog.v1.GrpcLogEntry.timestamp:type_name -> google.protobuf.Timestamp
1020 0, // 1: grpc.binarylog.v1.GrpcLogEntry.type:type_name -> grpc.binarylog.v1.GrpcLogEntry.EventType
1021 1, // 2: grpc.binarylog.v1.GrpcLogEntry.logger:type_name -> grpc.binarylog.v1.GrpcLogEntry.Logger
1022 4, // 3: grpc.binarylog.v1.GrpcLogEntry.client_header:type_name -> grpc.binarylog.v1.ClientHeader
1023 5, // 4: grpc.binarylog.v1.GrpcLogEntry.server_header:type_name -> grpc.binarylog.v1.ServerHeader
1024 7, // 5: grpc.binarylog.v1.GrpcLogEntry.message:type_name -> grpc.binarylog.v1.Message
1025 6, // 6: grpc.binarylog.v1.GrpcLogEntry.trailer:type_name -> grpc.binarylog.v1.Trailer
1026 10, // 7: grpc.binarylog.v1.GrpcLogEntry.peer:type_name -> grpc.binarylog.v1.Address
1027 8, // 8: grpc.binarylog.v1.ClientHeader.metadata:type_name -> grpc.binarylog.v1.Metadata
1028 12, // 9: grpc.binarylog.v1.ClientHeader.timeout:type_name -> google.protobuf.Duration
1029 8, // 10: grpc.binarylog.v1.ServerHeader.metadata:type_name -> grpc.binarylog.v1.Metadata
1030 8, // 11: grpc.binarylog.v1.Trailer.metadata:type_name -> grpc.binarylog.v1.Metadata
1031 9, // 12: grpc.binarylog.v1.Metadata.entry:type_name -> grpc.binarylog.v1.MetadataEntry
1032 2, // 13: grpc.binarylog.v1.Address.type:type_name -> grpc.binarylog.v1.Address.Type
1033 14, // [14:14] is the sub-list for method output_type
1034 14, // [14:14] is the sub-list for method input_type
1035 14, // [14:14] is the sub-list for extension type_name
1036 14, // [14:14] is the sub-list for extension extendee
1037 0, // [0:14] is the sub-list for field type_name
1038}
1039
1040func init() { file_grpc_binlog_v1_binarylog_proto_init() }
1041func file_grpc_binlog_v1_binarylog_proto_init() {
1042 if File_grpc_binlog_v1_binarylog_proto != nil {
1043 return
1044 }
1045 file_grpc_binlog_v1_binarylog_proto_msgTypes[0].OneofWrappers = []any{
1046 (*GrpcLogEntry_ClientHeader)(nil),
1047 (*GrpcLogEntry_ServerHeader)(nil),
1048 (*GrpcLogEntry_Message)(nil),
1049 (*GrpcLogEntry_Trailer)(nil),
1050 }
1051 type x struct{}
1052 out := protoimpl.TypeBuilder{
1053 File: protoimpl.DescBuilder{
1054 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
1055 RawDescriptor: unsafe.Slice(unsafe.StringData(file_grpc_binlog_v1_binarylog_proto_rawDesc), len(file_grpc_binlog_v1_binarylog_proto_rawDesc)),
1056 NumEnums: 3,
1057 NumMessages: 8,
1058 NumExtensions: 0,
1059 NumServices: 0,
1060 },
1061 GoTypes: file_grpc_binlog_v1_binarylog_proto_goTypes,
1062 DependencyIndexes: file_grpc_binlog_v1_binarylog_proto_depIdxs,
1063 EnumInfos: file_grpc_binlog_v1_binarylog_proto_enumTypes,
1064 MessageInfos: file_grpc_binlog_v1_binarylog_proto_msgTypes,
1065 }.Build()
1066 File_grpc_binlog_v1_binarylog_proto = out.File
1067 file_grpc_binlog_v1_binarylog_proto_goTypes = nil
1068 file_grpc_binlog_v1_binarylog_proto_depIdxs = nil
1069}