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