20636e76a9
Presently, protoc 3.3.0 (released in 2017) is still being used. This commit updates the vet.sh script as well as existing generated files to use protoc 3.14.0 instead. The only concrete change this brings is updated import paths of Timestamp and Duration types. However, in practice this is a no-op, since the types themselves are already aliased to the new import path: - https://pkg.go.dev/github.com/golang/protobuf@v1.4.3/ptypes/duration#Duration - https://pkg.go.dev/github.com/golang/protobuf@v1.4.3/ptypes/timestamp#Timestamp
1188 lines
44 KiB
Go
1188 lines
44 KiB
Go
// Copyright 2018 The gRPC Authors
|
|
// All rights reserved.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
// The canonical version of this proto can be found at
|
|
// https://github.com/grpc/grpc-proto/blob/master/grpc/binlog/v1/binarylog.proto
|
|
|
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// versions:
|
|
// protoc-gen-go v1.25.0
|
|
// protoc v3.14.0
|
|
// source: grpc/binlog/v1/binarylog.proto
|
|
|
|
package grpc_binarylog_v1
|
|
|
|
import (
|
|
proto "github.com/golang/protobuf/proto"
|
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
|
durationpb "google.golang.org/protobuf/types/known/durationpb"
|
|
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
|
|
reflect "reflect"
|
|
sync "sync"
|
|
)
|
|
|
|
const (
|
|
// Verify that this generated code is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
|
|
// Verify that runtime/protoimpl is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
|
|
)
|
|
|
|
// This is a compile-time assertion that a sufficiently up-to-date version
|
|
// of the legacy proto package is being used.
|
|
const _ = proto.ProtoPackageIsVersion4
|
|
|
|
// Enumerates the type of event
|
|
// Note the terminology is different from the RPC semantics
|
|
// definition, but the same meaning is expressed here.
|
|
type GrpcLogEntry_EventType int32
|
|
|
|
const (
|
|
GrpcLogEntry_EVENT_TYPE_UNKNOWN GrpcLogEntry_EventType = 0
|
|
// Header sent from client to server
|
|
GrpcLogEntry_EVENT_TYPE_CLIENT_HEADER GrpcLogEntry_EventType = 1
|
|
// Header sent from server to client
|
|
GrpcLogEntry_EVENT_TYPE_SERVER_HEADER GrpcLogEntry_EventType = 2
|
|
// Message sent from client to server
|
|
GrpcLogEntry_EVENT_TYPE_CLIENT_MESSAGE GrpcLogEntry_EventType = 3
|
|
// Message sent from server to client
|
|
GrpcLogEntry_EVENT_TYPE_SERVER_MESSAGE GrpcLogEntry_EventType = 4
|
|
// A signal that client is done sending
|
|
GrpcLogEntry_EVENT_TYPE_CLIENT_HALF_CLOSE GrpcLogEntry_EventType = 5
|
|
// Trailer indicates the end of the RPC.
|
|
// On client side, this event means a trailer was either received
|
|
// from the network or the gRPC library locally generated a status
|
|
// to inform the application about a failure.
|
|
// On server side, this event means the server application requested
|
|
// to send a trailer. Note: EVENT_TYPE_CANCEL may still arrive after
|
|
// this due to races on server side.
|
|
GrpcLogEntry_EVENT_TYPE_SERVER_TRAILER GrpcLogEntry_EventType = 6
|
|
// A signal that the RPC is cancelled. On client side, this
|
|
// indicates the client application requests a cancellation.
|
|
// On server side, this indicates that cancellation was detected.
|
|
// Note: This marks the end of the RPC. Events may arrive after
|
|
// this due to races. For example, on client side a trailer
|
|
// may arrive even though the application requested to cancel the RPC.
|
|
GrpcLogEntry_EVENT_TYPE_CANCEL GrpcLogEntry_EventType = 7
|
|
)
|
|
|
|
// Enum value maps for GrpcLogEntry_EventType.
|
|
var (
|
|
GrpcLogEntry_EventType_name = map[int32]string{
|
|
0: "EVENT_TYPE_UNKNOWN",
|
|
1: "EVENT_TYPE_CLIENT_HEADER",
|
|
2: "EVENT_TYPE_SERVER_HEADER",
|
|
3: "EVENT_TYPE_CLIENT_MESSAGE",
|
|
4: "EVENT_TYPE_SERVER_MESSAGE",
|
|
5: "EVENT_TYPE_CLIENT_HALF_CLOSE",
|
|
6: "EVENT_TYPE_SERVER_TRAILER",
|
|
7: "EVENT_TYPE_CANCEL",
|
|
}
|
|
GrpcLogEntry_EventType_value = map[string]int32{
|
|
"EVENT_TYPE_UNKNOWN": 0,
|
|
"EVENT_TYPE_CLIENT_HEADER": 1,
|
|
"EVENT_TYPE_SERVER_HEADER": 2,
|
|
"EVENT_TYPE_CLIENT_MESSAGE": 3,
|
|
"EVENT_TYPE_SERVER_MESSAGE": 4,
|
|
"EVENT_TYPE_CLIENT_HALF_CLOSE": 5,
|
|
"EVENT_TYPE_SERVER_TRAILER": 6,
|
|
"EVENT_TYPE_CANCEL": 7,
|
|
}
|
|
)
|
|
|
|
func (x GrpcLogEntry_EventType) Enum() *GrpcLogEntry_EventType {
|
|
p := new(GrpcLogEntry_EventType)
|
|
*p = x
|
|
return p
|
|
}
|
|
|
|
func (x GrpcLogEntry_EventType) String() string {
|
|
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
|
|
}
|
|
|
|
func (GrpcLogEntry_EventType) Descriptor() protoreflect.EnumDescriptor {
|
|
return file_grpc_binlog_v1_binarylog_proto_enumTypes[0].Descriptor()
|
|
}
|
|
|
|
func (GrpcLogEntry_EventType) Type() protoreflect.EnumType {
|
|
return &file_grpc_binlog_v1_binarylog_proto_enumTypes[0]
|
|
}
|
|
|
|
func (x GrpcLogEntry_EventType) Number() protoreflect.EnumNumber {
|
|
return protoreflect.EnumNumber(x)
|
|
}
|
|
|
|
// Deprecated: Use GrpcLogEntry_EventType.Descriptor instead.
|
|
func (GrpcLogEntry_EventType) EnumDescriptor() ([]byte, []int) {
|
|
return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{0, 0}
|
|
}
|
|
|
|
// Enumerates the entity that generates the log entry
|
|
type GrpcLogEntry_Logger int32
|
|
|
|
const (
|
|
GrpcLogEntry_LOGGER_UNKNOWN GrpcLogEntry_Logger = 0
|
|
GrpcLogEntry_LOGGER_CLIENT GrpcLogEntry_Logger = 1
|
|
GrpcLogEntry_LOGGER_SERVER GrpcLogEntry_Logger = 2
|
|
)
|
|
|
|
// Enum value maps for GrpcLogEntry_Logger.
|
|
var (
|
|
GrpcLogEntry_Logger_name = map[int32]string{
|
|
0: "LOGGER_UNKNOWN",
|
|
1: "LOGGER_CLIENT",
|
|
2: "LOGGER_SERVER",
|
|
}
|
|
GrpcLogEntry_Logger_value = map[string]int32{
|
|
"LOGGER_UNKNOWN": 0,
|
|
"LOGGER_CLIENT": 1,
|
|
"LOGGER_SERVER": 2,
|
|
}
|
|
)
|
|
|
|
func (x GrpcLogEntry_Logger) Enum() *GrpcLogEntry_Logger {
|
|
p := new(GrpcLogEntry_Logger)
|
|
*p = x
|
|
return p
|
|
}
|
|
|
|
func (x GrpcLogEntry_Logger) String() string {
|
|
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
|
|
}
|
|
|
|
func (GrpcLogEntry_Logger) Descriptor() protoreflect.EnumDescriptor {
|
|
return file_grpc_binlog_v1_binarylog_proto_enumTypes[1].Descriptor()
|
|
}
|
|
|
|
func (GrpcLogEntry_Logger) Type() protoreflect.EnumType {
|
|
return &file_grpc_binlog_v1_binarylog_proto_enumTypes[1]
|
|
}
|
|
|
|
func (x GrpcLogEntry_Logger) Number() protoreflect.EnumNumber {
|
|
return protoreflect.EnumNumber(x)
|
|
}
|
|
|
|
// Deprecated: Use GrpcLogEntry_Logger.Descriptor instead.
|
|
func (GrpcLogEntry_Logger) EnumDescriptor() ([]byte, []int) {
|
|
return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{0, 1}
|
|
}
|
|
|
|
type Address_Type int32
|
|
|
|
const (
|
|
Address_TYPE_UNKNOWN Address_Type = 0
|
|
// address is in 1.2.3.4 form
|
|
Address_TYPE_IPV4 Address_Type = 1
|
|
// address is in IPv6 canonical form (RFC5952 section 4)
|
|
// The scope is NOT included in the address string.
|
|
Address_TYPE_IPV6 Address_Type = 2
|
|
// address is UDS string
|
|
Address_TYPE_UNIX Address_Type = 3
|
|
)
|
|
|
|
// Enum value maps for Address_Type.
|
|
var (
|
|
Address_Type_name = map[int32]string{
|
|
0: "TYPE_UNKNOWN",
|
|
1: "TYPE_IPV4",
|
|
2: "TYPE_IPV6",
|
|
3: "TYPE_UNIX",
|
|
}
|
|
Address_Type_value = map[string]int32{
|
|
"TYPE_UNKNOWN": 0,
|
|
"TYPE_IPV4": 1,
|
|
"TYPE_IPV6": 2,
|
|
"TYPE_UNIX": 3,
|
|
}
|
|
)
|
|
|
|
func (x Address_Type) Enum() *Address_Type {
|
|
p := new(Address_Type)
|
|
*p = x
|
|
return p
|
|
}
|
|
|
|
func (x Address_Type) String() string {
|
|
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
|
|
}
|
|
|
|
func (Address_Type) Descriptor() protoreflect.EnumDescriptor {
|
|
return file_grpc_binlog_v1_binarylog_proto_enumTypes[2].Descriptor()
|
|
}
|
|
|
|
func (Address_Type) Type() protoreflect.EnumType {
|
|
return &file_grpc_binlog_v1_binarylog_proto_enumTypes[2]
|
|
}
|
|
|
|
func (x Address_Type) Number() protoreflect.EnumNumber {
|
|
return protoreflect.EnumNumber(x)
|
|
}
|
|
|
|
// Deprecated: Use Address_Type.Descriptor instead.
|
|
func (Address_Type) EnumDescriptor() ([]byte, []int) {
|
|
return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{7, 0}
|
|
}
|
|
|
|
// Log entry we store in binary logs
|
|
type GrpcLogEntry struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// The timestamp of the binary log message
|
|
Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
|
|
// Uniquely identifies a call. The value must not be 0 in order to disambiguate
|
|
// from an unset value.
|
|
// Each call may have several log entries, they will all have the same call_id.
|
|
// Nothing is guaranteed about their value other than they are unique across
|
|
// different RPCs in the same gRPC process.
|
|
CallId uint64 `protobuf:"varint,2,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
|
|
// The entry sequence id for this call. The first GrpcLogEntry has a
|
|
// value of 1, to disambiguate from an unset value. The purpose of
|
|
// this field is to detect missing entries in environments where
|
|
// durability or ordering is not guaranteed.
|
|
SequenceIdWithinCall uint64 `protobuf:"varint,3,opt,name=sequence_id_within_call,json=sequenceIdWithinCall,proto3" json:"sequence_id_within_call,omitempty"`
|
|
Type GrpcLogEntry_EventType `protobuf:"varint,4,opt,name=type,proto3,enum=grpc.binarylog.v1.GrpcLogEntry_EventType" json:"type,omitempty"`
|
|
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
|
|
// The logger uses one of the following fields to record the payload,
|
|
// according to the type of the log entry.
|
|
//
|
|
// Types that are assignable to Payload:
|
|
// *GrpcLogEntry_ClientHeader
|
|
// *GrpcLogEntry_ServerHeader
|
|
// *GrpcLogEntry_Message
|
|
// *GrpcLogEntry_Trailer
|
|
Payload isGrpcLogEntry_Payload `protobuf_oneof:"payload"`
|
|
// true if payload does not represent the full message or metadata.
|
|
PayloadTruncated bool `protobuf:"varint,10,opt,name=payload_truncated,json=payloadTruncated,proto3" json:"payload_truncated,omitempty"`
|
|
// Peer address information, will only be recorded on the first
|
|
// incoming event. On client side, peer is logged on
|
|
// EVENT_TYPE_SERVER_HEADER normally or EVENT_TYPE_SERVER_TRAILER in
|
|
// the case of trailers-only. On server side, peer is always
|
|
// logged on EVENT_TYPE_CLIENT_HEADER.
|
|
Peer *Address `protobuf:"bytes,11,opt,name=peer,proto3" json:"peer,omitempty"`
|
|
}
|
|
|
|
func (x *GrpcLogEntry) Reset() {
|
|
*x = GrpcLogEntry{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[0]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *GrpcLogEntry) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*GrpcLogEntry) ProtoMessage() {}
|
|
|
|
func (x *GrpcLogEntry) ProtoReflect() protoreflect.Message {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[0]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use GrpcLogEntry.ProtoReflect.Descriptor instead.
|
|
func (*GrpcLogEntry) Descriptor() ([]byte, []int) {
|
|
return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
func (x *GrpcLogEntry) GetTimestamp() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.Timestamp
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *GrpcLogEntry) GetCallId() uint64 {
|
|
if x != nil {
|
|
return x.CallId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *GrpcLogEntry) GetSequenceIdWithinCall() uint64 {
|
|
if x != nil {
|
|
return x.SequenceIdWithinCall
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *GrpcLogEntry) GetType() GrpcLogEntry_EventType {
|
|
if x != nil {
|
|
return x.Type
|
|
}
|
|
return GrpcLogEntry_EVENT_TYPE_UNKNOWN
|
|
}
|
|
|
|
func (x *GrpcLogEntry) GetLogger() GrpcLogEntry_Logger {
|
|
if x != nil {
|
|
return x.Logger
|
|
}
|
|
return GrpcLogEntry_LOGGER_UNKNOWN
|
|
}
|
|
|
|
func (m *GrpcLogEntry) GetPayload() isGrpcLogEntry_Payload {
|
|
if m != nil {
|
|
return m.Payload
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *GrpcLogEntry) GetClientHeader() *ClientHeader {
|
|
if x, ok := x.GetPayload().(*GrpcLogEntry_ClientHeader); ok {
|
|
return x.ClientHeader
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *GrpcLogEntry) GetServerHeader() *ServerHeader {
|
|
if x, ok := x.GetPayload().(*GrpcLogEntry_ServerHeader); ok {
|
|
return x.ServerHeader
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *GrpcLogEntry) GetMessage() *Message {
|
|
if x, ok := x.GetPayload().(*GrpcLogEntry_Message); ok {
|
|
return x.Message
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *GrpcLogEntry) GetTrailer() *Trailer {
|
|
if x, ok := x.GetPayload().(*GrpcLogEntry_Trailer); ok {
|
|
return x.Trailer
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *GrpcLogEntry) GetPayloadTruncated() bool {
|
|
if x != nil {
|
|
return x.PayloadTruncated
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *GrpcLogEntry) GetPeer() *Address {
|
|
if x != nil {
|
|
return x.Peer
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type isGrpcLogEntry_Payload interface {
|
|
isGrpcLogEntry_Payload()
|
|
}
|
|
|
|
type GrpcLogEntry_ClientHeader struct {
|
|
ClientHeader *ClientHeader `protobuf:"bytes,6,opt,name=client_header,json=clientHeader,proto3,oneof"`
|
|
}
|
|
|
|
type GrpcLogEntry_ServerHeader struct {
|
|
ServerHeader *ServerHeader `protobuf:"bytes,7,opt,name=server_header,json=serverHeader,proto3,oneof"`
|
|
}
|
|
|
|
type GrpcLogEntry_Message struct {
|
|
// Used by EVENT_TYPE_CLIENT_MESSAGE, EVENT_TYPE_SERVER_MESSAGE
|
|
Message *Message `protobuf:"bytes,8,opt,name=message,proto3,oneof"`
|
|
}
|
|
|
|
type GrpcLogEntry_Trailer struct {
|
|
Trailer *Trailer `protobuf:"bytes,9,opt,name=trailer,proto3,oneof"`
|
|
}
|
|
|
|
func (*GrpcLogEntry_ClientHeader) isGrpcLogEntry_Payload() {}
|
|
|
|
func (*GrpcLogEntry_ServerHeader) isGrpcLogEntry_Payload() {}
|
|
|
|
func (*GrpcLogEntry_Message) isGrpcLogEntry_Payload() {}
|
|
|
|
func (*GrpcLogEntry_Trailer) isGrpcLogEntry_Payload() {}
|
|
|
|
type ClientHeader struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// This contains only the metadata from the application.
|
|
Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
|
|
// The name of the RPC method, which looks something like:
|
|
// /<service>/<method>
|
|
// Note the leading "/" character.
|
|
MethodName string `protobuf:"bytes,2,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
|
|
// A single process may be used to run multiple virtual
|
|
// servers with different identities.
|
|
// The authority is the name of such a server identitiy.
|
|
// It is typically a portion of the URI in the form of
|
|
// <host> or <host>:<port> .
|
|
Authority string `protobuf:"bytes,3,opt,name=authority,proto3" json:"authority,omitempty"`
|
|
// the RPC timeout
|
|
Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
|
|
}
|
|
|
|
func (x *ClientHeader) Reset() {
|
|
*x = ClientHeader{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[1]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *ClientHeader) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ClientHeader) ProtoMessage() {}
|
|
|
|
func (x *ClientHeader) ProtoReflect() protoreflect.Message {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[1]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ClientHeader.ProtoReflect.Descriptor instead.
|
|
func (*ClientHeader) Descriptor() ([]byte, []int) {
|
|
return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
func (x *ClientHeader) GetMetadata() *Metadata {
|
|
if x != nil {
|
|
return x.Metadata
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *ClientHeader) GetMethodName() string {
|
|
if x != nil {
|
|
return x.MethodName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *ClientHeader) GetAuthority() string {
|
|
if x != nil {
|
|
return x.Authority
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *ClientHeader) GetTimeout() *durationpb.Duration {
|
|
if x != nil {
|
|
return x.Timeout
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type ServerHeader struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// This contains only the metadata from the application.
|
|
Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
|
|
}
|
|
|
|
func (x *ServerHeader) Reset() {
|
|
*x = ServerHeader{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[2]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *ServerHeader) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ServerHeader) ProtoMessage() {}
|
|
|
|
func (x *ServerHeader) ProtoReflect() protoreflect.Message {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[2]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ServerHeader.ProtoReflect.Descriptor instead.
|
|
func (*ServerHeader) Descriptor() ([]byte, []int) {
|
|
return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{2}
|
|
}
|
|
|
|
func (x *ServerHeader) GetMetadata() *Metadata {
|
|
if x != nil {
|
|
return x.Metadata
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type Trailer struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// This contains only the metadata from the application.
|
|
Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
|
|
// The gRPC status code.
|
|
StatusCode uint32 `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
|
|
// An original status message before any transport specific
|
|
// encoding.
|
|
StatusMessage string `protobuf:"bytes,3,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
|
|
// The value of the 'grpc-status-details-bin' metadata key. If
|
|
// present, this is always an encoded 'google.rpc.Status' message.
|
|
StatusDetails []byte `protobuf:"bytes,4,opt,name=status_details,json=statusDetails,proto3" json:"status_details,omitempty"`
|
|
}
|
|
|
|
func (x *Trailer) Reset() {
|
|
*x = Trailer{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[3]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *Trailer) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Trailer) ProtoMessage() {}
|
|
|
|
func (x *Trailer) ProtoReflect() protoreflect.Message {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[3]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Trailer.ProtoReflect.Descriptor instead.
|
|
func (*Trailer) Descriptor() ([]byte, []int) {
|
|
return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{3}
|
|
}
|
|
|
|
func (x *Trailer) GetMetadata() *Metadata {
|
|
if x != nil {
|
|
return x.Metadata
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *Trailer) GetStatusCode() uint32 {
|
|
if x != nil {
|
|
return x.StatusCode
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *Trailer) GetStatusMessage() string {
|
|
if x != nil {
|
|
return x.StatusMessage
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Trailer) GetStatusDetails() []byte {
|
|
if x != nil {
|
|
return x.StatusDetails
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Message payload, used by CLIENT_MESSAGE and SERVER_MESSAGE
|
|
type Message struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
// Length of the message. It may not be the same as the length of the
|
|
// data field, as the logging payload can be truncated or omitted.
|
|
Length uint32 `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"`
|
|
// May be truncated or omitted.
|
|
Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
|
|
}
|
|
|
|
func (x *Message) Reset() {
|
|
*x = Message{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[4]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *Message) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Message) ProtoMessage() {}
|
|
|
|
func (x *Message) ProtoReflect() protoreflect.Message {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[4]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Message.ProtoReflect.Descriptor instead.
|
|
func (*Message) Descriptor() ([]byte, []int) {
|
|
return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{4}
|
|
}
|
|
|
|
func (x *Message) GetLength() uint32 {
|
|
if x != nil {
|
|
return x.Length
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *Message) GetData() []byte {
|
|
if x != nil {
|
|
return x.Data
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// A list of metadata pairs, used in the payload of client header,
|
|
// server header, and server trailer.
|
|
// Implementations may omit some entries to honor the header limits
|
|
// of GRPC_BINARY_LOG_CONFIG.
|
|
//
|
|
// Header keys added by gRPC are omitted. To be more specific,
|
|
// implementations will not log the following entries, and this is
|
|
// not to be treated as a truncation:
|
|
// - entries handled by grpc that are not user visible, such as those
|
|
// that begin with 'grpc-' (with exception of grpc-trace-bin)
|
|
// or keys like 'lb-token'
|
|
// - transport specific entries, including but not limited to:
|
|
// ':path', ':authority', 'content-encoding', 'user-agent', 'te', etc
|
|
// - entries added for call credentials
|
|
//
|
|
// Implementations must always log grpc-trace-bin if it is present.
|
|
// Practically speaking it will only be visible on server side because
|
|
// grpc-trace-bin is managed by low level client side mechanisms
|
|
// inaccessible from the application level. On server side, the
|
|
// header is just a normal metadata key.
|
|
// The pair will not count towards the size limit.
|
|
type Metadata struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
Entry []*MetadataEntry `protobuf:"bytes,1,rep,name=entry,proto3" json:"entry,omitempty"`
|
|
}
|
|
|
|
func (x *Metadata) Reset() {
|
|
*x = Metadata{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[5]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *Metadata) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Metadata) ProtoMessage() {}
|
|
|
|
func (x *Metadata) ProtoReflect() protoreflect.Message {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[5]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Metadata.ProtoReflect.Descriptor instead.
|
|
func (*Metadata) Descriptor() ([]byte, []int) {
|
|
return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{5}
|
|
}
|
|
|
|
func (x *Metadata) GetEntry() []*MetadataEntry {
|
|
if x != nil {
|
|
return x.Entry
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// A metadata key value pair
|
|
type MetadataEntry struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
|
|
Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
|
|
}
|
|
|
|
func (x *MetadataEntry) Reset() {
|
|
*x = MetadataEntry{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[6]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *MetadataEntry) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*MetadataEntry) ProtoMessage() {}
|
|
|
|
func (x *MetadataEntry) ProtoReflect() protoreflect.Message {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[6]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use MetadataEntry.ProtoReflect.Descriptor instead.
|
|
func (*MetadataEntry) Descriptor() ([]byte, []int) {
|
|
return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{6}
|
|
}
|
|
|
|
func (x *MetadataEntry) GetKey() string {
|
|
if x != nil {
|
|
return x.Key
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *MetadataEntry) GetValue() []byte {
|
|
if x != nil {
|
|
return x.Value
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Address information
|
|
type Address struct {
|
|
state protoimpl.MessageState
|
|
sizeCache protoimpl.SizeCache
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
Type Address_Type `protobuf:"varint,1,opt,name=type,proto3,enum=grpc.binarylog.v1.Address_Type" json:"type,omitempty"`
|
|
Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
|
|
// only for TYPE_IPV4 and TYPE_IPV6
|
|
IpPort uint32 `protobuf:"varint,3,opt,name=ip_port,json=ipPort,proto3" json:"ip_port,omitempty"`
|
|
}
|
|
|
|
func (x *Address) Reset() {
|
|
*x = Address{}
|
|
if protoimpl.UnsafeEnabled {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[7]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
}
|
|
|
|
func (x *Address) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*Address) ProtoMessage() {}
|
|
|
|
func (x *Address) ProtoReflect() protoreflect.Message {
|
|
mi := &file_grpc_binlog_v1_binarylog_proto_msgTypes[7]
|
|
if protoimpl.UnsafeEnabled && x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use Address.ProtoReflect.Descriptor instead.
|
|
func (*Address) Descriptor() ([]byte, []int) {
|
|
return file_grpc_binlog_v1_binarylog_proto_rawDescGZIP(), []int{7}
|
|
}
|
|
|
|
func (x *Address) GetType() Address_Type {
|
|
if x != nil {
|
|
return x.Type
|
|
}
|
|
return Address_TYPE_UNKNOWN
|
|
}
|
|
|
|
func (x *Address) GetAddress() string {
|
|
if x != nil {
|
|
return x.Address
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *Address) GetIpPort() uint32 {
|
|
if x != nil {
|
|
return x.IpPort
|
|
}
|
|
return 0
|
|
}
|
|
|
|
var File_grpc_binlog_v1_binarylog_proto protoreflect.FileDescriptor
|
|
|
|
var file_grpc_binlog_v1_binarylog_proto_rawDesc = []byte{
|
|
0x0a, 0x1e, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x62, 0x69, 0x6e, 0x6c, 0x6f, 0x67, 0x2f, 0x76, 0x31,
|
|
0x2f, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
|
|
0x12, 0x11, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67,
|
|
0x2e, 0x76, 0x31, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74,
|
|
0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72,
|
|
0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74,
|
|
0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70,
|
|
0x72, 0x6f, 0x74, 0x6f, 0x22, 0xbb, 0x07, 0x0a, 0x0c, 0x47, 0x72, 0x70, 0x63, 0x4c, 0x6f, 0x67,
|
|
0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x38, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61,
|
|
0x6d, 0x70, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
|
|
0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73,
|
|
0x74, 0x61, 0x6d, 0x70, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12,
|
|
0x17, 0x0a, 0x07, 0x63, 0x61, 0x6c, 0x6c, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04,
|
|
0x52, 0x06, 0x63, 0x61, 0x6c, 0x6c, 0x49, 0x64, 0x12, 0x35, 0x0a, 0x17, 0x73, 0x65, 0x71, 0x75,
|
|
0x65, 0x6e, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x5f, 0x77, 0x69, 0x74, 0x68, 0x69, 0x6e, 0x5f, 0x63,
|
|
0x61, 0x6c, 0x6c, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x52, 0x14, 0x73, 0x65, 0x71, 0x75, 0x65,
|
|
0x6e, 0x63, 0x65, 0x49, 0x64, 0x57, 0x69, 0x74, 0x68, 0x69, 0x6e, 0x43, 0x61, 0x6c, 0x6c, 0x12,
|
|
0x3d, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x29, 0x2e,
|
|
0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76,
|
|
0x31, 0x2e, 0x47, 0x72, 0x70, 0x63, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x2e, 0x45,
|
|
0x76, 0x65, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x3e,
|
|
0x0a, 0x06, 0x6c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x26,
|
|
0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e,
|
|
0x76, 0x31, 0x2e, 0x47, 0x72, 0x70, 0x63, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x2e,
|
|
0x4c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x52, 0x06, 0x6c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x12, 0x46,
|
|
0x0a, 0x0d, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18,
|
|
0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e,
|
|
0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74,
|
|
0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x48, 0x00, 0x52, 0x0c, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74,
|
|
0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x46, 0x0a, 0x0d, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72,
|
|
0x5f, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e,
|
|
0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76,
|
|
0x31, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x48, 0x00,
|
|
0x52, 0x0c, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x36,
|
|
0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32,
|
|
0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67,
|
|
0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x48, 0x00, 0x52, 0x07, 0x6d,
|
|
0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x36, 0x0a, 0x07, 0x74, 0x72, 0x61, 0x69, 0x6c, 0x65,
|
|
0x72, 0x18, 0x09, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62,
|
|
0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x72, 0x61, 0x69,
|
|
0x6c, 0x65, 0x72, 0x48, 0x00, 0x52, 0x07, 0x74, 0x72, 0x61, 0x69, 0x6c, 0x65, 0x72, 0x12, 0x2b,
|
|
0x0a, 0x11, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x5f, 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61,
|
|
0x74, 0x65, 0x64, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x08, 0x52, 0x10, 0x70, 0x61, 0x79, 0x6c, 0x6f,
|
|
0x61, 0x64, 0x54, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x64, 0x12, 0x2e, 0x0a, 0x04, 0x70,
|
|
0x65, 0x65, 0x72, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x72, 0x70, 0x63,
|
|
0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x64,
|
|
0x64, 0x72, 0x65, 0x73, 0x73, 0x52, 0x04, 0x70, 0x65, 0x65, 0x72, 0x22, 0xf5, 0x01, 0x0a, 0x09,
|
|
0x45, 0x76, 0x65, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x16, 0x0a, 0x12, 0x45, 0x56, 0x45,
|
|
0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10,
|
|
0x00, 0x12, 0x1c, 0x0a, 0x18, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f,
|
|
0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54, 0x5f, 0x48, 0x45, 0x41, 0x44, 0x45, 0x52, 0x10, 0x01, 0x12,
|
|
0x1c, 0x0a, 0x18, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x53, 0x45,
|
|
0x52, 0x56, 0x45, 0x52, 0x5f, 0x48, 0x45, 0x41, 0x44, 0x45, 0x52, 0x10, 0x02, 0x12, 0x1d, 0x0a,
|
|
0x19, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x43, 0x4c, 0x49, 0x45,
|
|
0x4e, 0x54, 0x5f, 0x4d, 0x45, 0x53, 0x53, 0x41, 0x47, 0x45, 0x10, 0x03, 0x12, 0x1d, 0x0a, 0x19,
|
|
0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x53, 0x45, 0x52, 0x56, 0x45,
|
|
0x52, 0x5f, 0x4d, 0x45, 0x53, 0x53, 0x41, 0x47, 0x45, 0x10, 0x04, 0x12, 0x20, 0x0a, 0x1c, 0x45,
|
|
0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54,
|
|
0x5f, 0x48, 0x41, 0x4c, 0x46, 0x5f, 0x43, 0x4c, 0x4f, 0x53, 0x45, 0x10, 0x05, 0x12, 0x1d, 0x0a,
|
|
0x19, 0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x53, 0x45, 0x52, 0x56,
|
|
0x45, 0x52, 0x5f, 0x54, 0x52, 0x41, 0x49, 0x4c, 0x45, 0x52, 0x10, 0x06, 0x12, 0x15, 0x0a, 0x11,
|
|
0x45, 0x56, 0x45, 0x4e, 0x54, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x43, 0x41, 0x4e, 0x43, 0x45,
|
|
0x4c, 0x10, 0x07, 0x22, 0x42, 0x0a, 0x06, 0x4c, 0x6f, 0x67, 0x67, 0x65, 0x72, 0x12, 0x12, 0x0a,
|
|
0x0e, 0x4c, 0x4f, 0x47, 0x47, 0x45, 0x52, 0x5f, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10,
|
|
0x00, 0x12, 0x11, 0x0a, 0x0d, 0x4c, 0x4f, 0x47, 0x47, 0x45, 0x52, 0x5f, 0x43, 0x4c, 0x49, 0x45,
|
|
0x4e, 0x54, 0x10, 0x01, 0x12, 0x11, 0x0a, 0x0d, 0x4c, 0x4f, 0x47, 0x47, 0x45, 0x52, 0x5f, 0x53,
|
|
0x45, 0x52, 0x56, 0x45, 0x52, 0x10, 0x02, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f,
|
|
0x61, 0x64, 0x22, 0xbb, 0x01, 0x0a, 0x0c, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x48, 0x65, 0x61,
|
|
0x64, 0x65, 0x72, 0x12, 0x37, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18,
|
|
0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e,
|
|
0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61,
|
|
0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x1f, 0x0a, 0x0b,
|
|
0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28,
|
|
0x09, 0x52, 0x0a, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1c, 0x0a,
|
|
0x09, 0x61, 0x75, 0x74, 0x68, 0x6f, 0x72, 0x69, 0x74, 0x79, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
|
|
0x52, 0x09, 0x61, 0x75, 0x74, 0x68, 0x6f, 0x72, 0x69, 0x74, 0x79, 0x12, 0x33, 0x0a, 0x07, 0x74,
|
|
0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67,
|
|
0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44,
|
|
0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74,
|
|
0x22, 0x47, 0x0a, 0x0c, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72,
|
|
0x12, 0x37, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01,
|
|
0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79,
|
|
0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52,
|
|
0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x22, 0xb1, 0x01, 0x0a, 0x07, 0x54, 0x72,
|
|
0x61, 0x69, 0x6c, 0x65, 0x72, 0x12, 0x37, 0x0a, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74,
|
|
0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62,
|
|
0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x74, 0x61,
|
|
0x64, 0x61, 0x74, 0x61, 0x52, 0x08, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x1f,
|
|
0x0a, 0x0b, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x02, 0x20,
|
|
0x01, 0x28, 0x0d, 0x52, 0x0a, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x43, 0x6f, 0x64, 0x65, 0x12,
|
|
0x25, 0x0a, 0x0e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67,
|
|
0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x4d,
|
|
0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
|
|
0x5f, 0x64, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0d,
|
|
0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x73, 0x22, 0x35, 0x0a,
|
|
0x07, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6c, 0x65, 0x6e, 0x67,
|
|
0x74, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x06, 0x6c, 0x65, 0x6e, 0x67, 0x74, 0x68,
|
|
0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04,
|
|
0x64, 0x61, 0x74, 0x61, 0x22, 0x42, 0x0a, 0x08, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61,
|
|
0x12, 0x36, 0x0a, 0x05, 0x65, 0x6e, 0x74, 0x72, 0x79, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32,
|
|
0x20, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67,
|
|
0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x45, 0x6e, 0x74, 0x72,
|
|
0x79, 0x52, 0x05, 0x65, 0x6e, 0x74, 0x72, 0x79, 0x22, 0x37, 0x0a, 0x0d, 0x4d, 0x65, 0x74, 0x61,
|
|
0x64, 0x61, 0x74, 0x61, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79,
|
|
0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76,
|
|
0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75,
|
|
0x65, 0x22, 0xb8, 0x01, 0x0a, 0x07, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x12, 0x33, 0x0a,
|
|
0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1f, 0x2e, 0x67, 0x72,
|
|
0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x31, 0x2e,
|
|
0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x2e, 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79,
|
|
0x70, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x02, 0x20,
|
|
0x01, 0x28, 0x09, 0x52, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x12, 0x17, 0x0a, 0x07,
|
|
0x69, 0x70, 0x5f, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x06, 0x69,
|
|
0x70, 0x50, 0x6f, 0x72, 0x74, 0x22, 0x45, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x12, 0x10, 0x0a,
|
|
0x0c, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 0x12,
|
|
0x0d, 0x0a, 0x09, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x49, 0x50, 0x56, 0x34, 0x10, 0x01, 0x12, 0x0d,
|
|
0x0a, 0x09, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x49, 0x50, 0x56, 0x36, 0x10, 0x02, 0x12, 0x0d, 0x0a,
|
|
0x09, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x49, 0x58, 0x10, 0x03, 0x42, 0x5c, 0x0a, 0x14,
|
|
0x69, 0x6f, 0x2e, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f,
|
|
0x67, 0x2e, 0x76, 0x31, 0x42, 0x0e, 0x42, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x4c, 0x6f, 0x67, 0x50,
|
|
0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x32, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67,
|
|
0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x62,
|
|
0x69, 0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x2f, 0x67, 0x72, 0x70, 0x63, 0x5f, 0x62, 0x69,
|
|
0x6e, 0x61, 0x72, 0x79, 0x6c, 0x6f, 0x67, 0x5f, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
|
|
0x6f, 0x33,
|
|
}
|
|
|
|
var (
|
|
file_grpc_binlog_v1_binarylog_proto_rawDescOnce sync.Once
|
|
file_grpc_binlog_v1_binarylog_proto_rawDescData = file_grpc_binlog_v1_binarylog_proto_rawDesc
|
|
)
|
|
|
|
func file_grpc_binlog_v1_binarylog_proto_rawDescGZIP() []byte {
|
|
file_grpc_binlog_v1_binarylog_proto_rawDescOnce.Do(func() {
|
|
file_grpc_binlog_v1_binarylog_proto_rawDescData = protoimpl.X.CompressGZIP(file_grpc_binlog_v1_binarylog_proto_rawDescData)
|
|
})
|
|
return file_grpc_binlog_v1_binarylog_proto_rawDescData
|
|
}
|
|
|
|
var file_grpc_binlog_v1_binarylog_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
|
|
var file_grpc_binlog_v1_binarylog_proto_msgTypes = make([]protoimpl.MessageInfo, 8)
|
|
var file_grpc_binlog_v1_binarylog_proto_goTypes = []interface{}{
|
|
(GrpcLogEntry_EventType)(0), // 0: grpc.binarylog.v1.GrpcLogEntry.EventType
|
|
(GrpcLogEntry_Logger)(0), // 1: grpc.binarylog.v1.GrpcLogEntry.Logger
|
|
(Address_Type)(0), // 2: grpc.binarylog.v1.Address.Type
|
|
(*GrpcLogEntry)(nil), // 3: grpc.binarylog.v1.GrpcLogEntry
|
|
(*ClientHeader)(nil), // 4: grpc.binarylog.v1.ClientHeader
|
|
(*ServerHeader)(nil), // 5: grpc.binarylog.v1.ServerHeader
|
|
(*Trailer)(nil), // 6: grpc.binarylog.v1.Trailer
|
|
(*Message)(nil), // 7: grpc.binarylog.v1.Message
|
|
(*Metadata)(nil), // 8: grpc.binarylog.v1.Metadata
|
|
(*MetadataEntry)(nil), // 9: grpc.binarylog.v1.MetadataEntry
|
|
(*Address)(nil), // 10: grpc.binarylog.v1.Address
|
|
(*timestamppb.Timestamp)(nil), // 11: google.protobuf.Timestamp
|
|
(*durationpb.Duration)(nil), // 12: google.protobuf.Duration
|
|
}
|
|
var file_grpc_binlog_v1_binarylog_proto_depIdxs = []int32{
|
|
11, // 0: grpc.binarylog.v1.GrpcLogEntry.timestamp:type_name -> google.protobuf.Timestamp
|
|
0, // 1: grpc.binarylog.v1.GrpcLogEntry.type:type_name -> grpc.binarylog.v1.GrpcLogEntry.EventType
|
|
1, // 2: grpc.binarylog.v1.GrpcLogEntry.logger:type_name -> grpc.binarylog.v1.GrpcLogEntry.Logger
|
|
4, // 3: grpc.binarylog.v1.GrpcLogEntry.client_header:type_name -> grpc.binarylog.v1.ClientHeader
|
|
5, // 4: grpc.binarylog.v1.GrpcLogEntry.server_header:type_name -> grpc.binarylog.v1.ServerHeader
|
|
7, // 5: grpc.binarylog.v1.GrpcLogEntry.message:type_name -> grpc.binarylog.v1.Message
|
|
6, // 6: grpc.binarylog.v1.GrpcLogEntry.trailer:type_name -> grpc.binarylog.v1.Trailer
|
|
10, // 7: grpc.binarylog.v1.GrpcLogEntry.peer:type_name -> grpc.binarylog.v1.Address
|
|
8, // 8: grpc.binarylog.v1.ClientHeader.metadata:type_name -> grpc.binarylog.v1.Metadata
|
|
12, // 9: grpc.binarylog.v1.ClientHeader.timeout:type_name -> google.protobuf.Duration
|
|
8, // 10: grpc.binarylog.v1.ServerHeader.metadata:type_name -> grpc.binarylog.v1.Metadata
|
|
8, // 11: grpc.binarylog.v1.Trailer.metadata:type_name -> grpc.binarylog.v1.Metadata
|
|
9, // 12: grpc.binarylog.v1.Metadata.entry:type_name -> grpc.binarylog.v1.MetadataEntry
|
|
2, // 13: grpc.binarylog.v1.Address.type:type_name -> grpc.binarylog.v1.Address.Type
|
|
14, // [14:14] is the sub-list for method output_type
|
|
14, // [14:14] is the sub-list for method input_type
|
|
14, // [14:14] is the sub-list for extension type_name
|
|
14, // [14:14] is the sub-list for extension extendee
|
|
0, // [0:14] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_grpc_binlog_v1_binarylog_proto_init() }
|
|
func file_grpc_binlog_v1_binarylog_proto_init() {
|
|
if File_grpc_binlog_v1_binarylog_proto != nil {
|
|
return
|
|
}
|
|
if !protoimpl.UnsafeEnabled {
|
|
file_grpc_binlog_v1_binarylog_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*GrpcLogEntry); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_grpc_binlog_v1_binarylog_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*ClientHeader); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_grpc_binlog_v1_binarylog_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*ServerHeader); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_grpc_binlog_v1_binarylog_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*Trailer); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_grpc_binlog_v1_binarylog_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*Message); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_grpc_binlog_v1_binarylog_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*Metadata); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_grpc_binlog_v1_binarylog_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*MetadataEntry); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
file_grpc_binlog_v1_binarylog_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
|
|
switch v := v.(*Address); i {
|
|
case 0:
|
|
return &v.state
|
|
case 1:
|
|
return &v.sizeCache
|
|
case 2:
|
|
return &v.unknownFields
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
}
|
|
file_grpc_binlog_v1_binarylog_proto_msgTypes[0].OneofWrappers = []interface{}{
|
|
(*GrpcLogEntry_ClientHeader)(nil),
|
|
(*GrpcLogEntry_ServerHeader)(nil),
|
|
(*GrpcLogEntry_Message)(nil),
|
|
(*GrpcLogEntry_Trailer)(nil),
|
|
}
|
|
type x struct{}
|
|
out := protoimpl.TypeBuilder{
|
|
File: protoimpl.DescBuilder{
|
|
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
|
RawDescriptor: file_grpc_binlog_v1_binarylog_proto_rawDesc,
|
|
NumEnums: 3,
|
|
NumMessages: 8,
|
|
NumExtensions: 0,
|
|
NumServices: 0,
|
|
},
|
|
GoTypes: file_grpc_binlog_v1_binarylog_proto_goTypes,
|
|
DependencyIndexes: file_grpc_binlog_v1_binarylog_proto_depIdxs,
|
|
EnumInfos: file_grpc_binlog_v1_binarylog_proto_enumTypes,
|
|
MessageInfos: file_grpc_binlog_v1_binarylog_proto_msgTypes,
|
|
}.Build()
|
|
File_grpc_binlog_v1_binarylog_proto = out.File
|
|
file_grpc_binlog_v1_binarylog_proto_rawDesc = nil
|
|
file_grpc_binlog_v1_binarylog_proto_goTypes = nil
|
|
file_grpc_binlog_v1_binarylog_proto_depIdxs = nil
|
|
}
|