Skip to content

Instantly share code, notes, and snippets.

@ajm188

ajm188/vtgate.pb.go.diff

Created August 10, 2020 03:05
Show Gist options
  • Save ajm188/a92a3f406401d04129f09e08fc9c36cd to your computer and use it in GitHub Desktop.
Save ajm188/a92a3f406401d04129f09e08fc9c36cd to your computer and use it in GitHub Desktop.
Download ZIP
proto diff
Raw
vtgate.pb.go.diff
diff --git a/go/vt/proto/vtgate/vtgate.pb.go b/go/vt/proto/vtgate/vtgate.pb.go
index 420d6e33c..8e4c6ab7a 100644
--- a/go/vt/proto/vtgate/vtgate.pb.go
+++ b/go/vt/proto/vtgate/vtgate.pb.go
@@ -1,29 +1,51 @@
+//
+//Copyright 2019 The Vitess Authors.
+//
+//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.
+
+// Data definitions for service vtgateservice.
+
// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// protoc-gen-go v1.25.0-devel
+// protoc v3.12.4
// source: vtgate.proto
package vtgate
import (
- fmt "fmt"
- math "math"
+ reflect "reflect"
+ sync "sync"
proto "github.com/golang/protobuf/proto"
+ protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+ protoimpl "google.golang.org/protobuf/runtime/protoimpl"
binlogdata "vitess.io/vitess/go/vt/proto/binlogdata"
query "vitess.io/vitess/go/vt/proto/query"
topodata "vitess.io/vitess/go/vt/proto/topodata"
vtrpc "vitess.io/vitess/go/vt/proto/vtrpc"
)
-// Reference imports to suppress errors if they are not otherwise used.
-var _ = proto.Marshal
-var _ = fmt.Errorf
-var _ = math.Inf
+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 to ensure that this generated file
-// is compatible with the proto package it is being compiled against.
-// A compilation error at this line likely means your copy of the
-// proto package needs to be updated.
-const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
+// This is a compile-time assertion that a sufficiently up-to-date version
+// of the legacy proto package is being used.
+const _ = proto.ProtoPackageIsVersion4
// TransactionMode controls the execution of distributed transaction
// across multiple shards.
@@ -40,26 +62,47 @@ const (
TransactionMode_TWOPC TransactionMode = 3
)
-var TransactionMode_name = map[int32]string{
- 0: "UNSPECIFIED",
- 1: "SINGLE",
- 2: "MULTI",
- 3: "TWOPC",
-}
+// Enum value maps for TransactionMode.
+var (
+ TransactionMode_name = map[int32]string{
+ 0: "UNSPECIFIED",
+ 1: "SINGLE",
+ 2: "MULTI",
+ 3: "TWOPC",
+ }
+ TransactionMode_value = map[string]int32{
+ "UNSPECIFIED": 0,
+ "SINGLE": 1,
+ "MULTI": 2,
+ "TWOPC": 3,
+ }
+)
-var TransactionMode_value = map[string]int32{
- "UNSPECIFIED": 0,
- "SINGLE": 1,
- "MULTI": 2,
- "TWOPC": 3,
+func (x TransactionMode) Enum() *TransactionMode {
+ p := new(TransactionMode)
+ *p = x
+ return p
}
func (x TransactionMode) String() string {
- return proto.EnumName(TransactionMode_name, int32(x))
+ return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
+}
+
+func (TransactionMode) Descriptor() protoreflect.EnumDescriptor {
+ return file_vtgate_proto_enumTypes[0].Descriptor()
+}
+
+func (TransactionMode) Type() protoreflect.EnumType {
+ return &file_vtgate_proto_enumTypes[0]
+}
+
+func (x TransactionMode) Number() protoreflect.EnumNumber {
+ return protoreflect.EnumNumber(x)
}
+// Deprecated: Use TransactionMode.Descriptor instead.
func (TransactionMode) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{0}
+ return file_vtgate_proto_rawDescGZIP(), []int{0}
}
// CommitOrder is used to designate which of the ShardSessions
@@ -77,26 +120,47 @@ const (
CommitOrder_AUTOCOMMIT CommitOrder = 3
)
-var CommitOrder_name = map[int32]string{
- 0: "NORMAL",
- 1: "PRE",
- 2: "POST",
- 3: "AUTOCOMMIT",
-}
+// Enum value maps for CommitOrder.
+var (
+ CommitOrder_name = map[int32]string{
+ 0: "NORMAL",
+ 1: "PRE",
+ 2: "POST",
+ 3: "AUTOCOMMIT",
+ }
+ CommitOrder_value = map[string]int32{
+ "NORMAL": 0,
+ "PRE": 1,
+ "POST": 2,
+ "AUTOCOMMIT": 3,
+ }
+)
-var CommitOrder_value = map[string]int32{
- "NORMAL": 0,
- "PRE": 1,
- "POST": 2,
- "AUTOCOMMIT": 3,
+func (x CommitOrder) Enum() *CommitOrder {
+ p := new(CommitOrder)
+ *p = x
+ return p
}
func (x CommitOrder) String() string {
- return proto.EnumName(CommitOrder_name, int32(x))
+ return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
+func (CommitOrder) Descriptor() protoreflect.EnumDescriptor {
+ return file_vtgate_proto_enumTypes[1].Descriptor()
+}
+
+func (CommitOrder) Type() protoreflect.EnumType {
+ return &file_vtgate_proto_enumTypes[1]
+}
+
+func (x CommitOrder) Number() protoreflect.EnumNumber {
+ return protoreflect.EnumNumber(x)
+}
+
+// Deprecated: Use CommitOrder.Descriptor instead.
func (CommitOrder) EnumDescriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{1}
+ return file_vtgate_proto_rawDescGZIP(), []int{1}
}
// Session objects are exchanged like cookies through various
@@ -110,6 +174,10 @@ func (CommitOrder) EnumDescriptor() ([]byte, []int) {
// discarded. If you're not in a transaction, Session is
// an optional parameter for the V2 APIs.
type Session struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
// in_transaction is set to true if the session is in a transaction.
InTransaction bool `protobuf:"varint,1,opt,name=in_transaction,json=inTransaction,proto3" json:"in_transaction,omitempty"`
// shard_sessions keep track of per-shard transaction info.
@@ -146,215 +214,159 @@ type Session struct {
// and is reset once transaction is committed or rolled back.
Savepoints []string `protobuf:"bytes,16,rep,name=savepoints,proto3" json:"savepoints,omitempty"`
// in_reserved_conn is set to true if the session should be using reserved connections.
- InReservedConn bool `protobuf:"varint,17,opt,name=in_reserved_conn,json=inReservedConn,proto3" json:"in_reserved_conn,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ InReservedConn bool `protobuf:"varint,17,opt,name=in_reserved_conn,json=inReservedConn,proto3" json:"in_reserved_conn,omitempty"`
}
-func (m *Session) Reset() { *m = Session{} }
-func (m *Session) String() string { return proto.CompactTextString(m) }
-func (*Session) ProtoMessage() {}
-func (*Session) Descriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{0}
+func (x *Session) Reset() {
+ *x = Session{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_vtgate_proto_msgTypes[0]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *Session) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Session.Unmarshal(m, b)
+func (x *Session) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *Session) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Session.Marshal(b, m, deterministic)
-}
-func (m *Session) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Session.Merge(m, src)
-}
-func (m *Session) XXX_Size() int {
- return xxx_messageInfo_Session.Size(m)
-}
-func (m *Session) XXX_DiscardUnknown() {
- xxx_messageInfo_Session.DiscardUnknown(m)
+
+func (*Session) ProtoMessage() {}
+
+func (x *Session) ProtoReflect() protoreflect.Message {
+ mi := &file_vtgate_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)
}
-var xxx_messageInfo_Session proto.InternalMessageInfo
+// Deprecated: Use Session.ProtoReflect.Descriptor instead.
+func (*Session) Descriptor() ([]byte, []int) {
+ return file_vtgate_proto_rawDescGZIP(), []int{0}
+}
-func (m *Session) GetInTransaction() bool {
- if m != nil {
- return m.InTransaction
+func (x *Session) GetInTransaction() bool {
+ if x != nil {
+ return x.InTransaction
}
return false
}
-func (m *Session) GetShardSessions() []*Session_ShardSession {
- if m != nil {
- return m.ShardSessions
+func (x *Session) GetShardSessions() []*Session_ShardSession {
+ if x != nil {
+ return x.ShardSessions
}
return nil
}
-func (m *Session) GetAutocommit() bool {
- if m != nil {
- return m.Autocommit
+func (x *Session) GetAutocommit() bool {
+ if x != nil {
+ return x.Autocommit
}
return false
}
-func (m *Session) GetTargetString() string {
- if m != nil {
- return m.TargetString
+func (x *Session) GetTargetString() string {
+ if x != nil {
+ return x.TargetString
}
return ""
}
-func (m *Session) GetOptions() *query.ExecuteOptions {
- if m != nil {
- return m.Options
+func (x *Session) GetOptions() *query.ExecuteOptions {
+ if x != nil {
+ return x.Options
}
return nil
}
-func (m *Session) GetTransactionMode() TransactionMode {
- if m != nil {
- return m.TransactionMode
+func (x *Session) GetTransactionMode() TransactionMode {
+ if x != nil {
+ return x.TransactionMode
}
return TransactionMode_UNSPECIFIED
}
-func (m *Session) GetWarnings() []*query.QueryWarning {
- if m != nil {
- return m.Warnings
+func (x *Session) GetWarnings() []*query.QueryWarning {
+ if x != nil {
+ return x.Warnings
}
return nil
}
-func (m *Session) GetPreSessions() []*Session_ShardSession {
- if m != nil {
- return m.PreSessions
+func (x *Session) GetPreSessions() []*Session_ShardSession {
+ if x != nil {
+ return x.PreSessions
}
return nil
}
-func (m *Session) GetPostSessions() []*Session_ShardSession {
- if m != nil {
- return m.PostSessions
+func (x *Session) GetPostSessions() []*Session_ShardSession {
+ if x != nil {
+ return x.PostSessions
}
return nil
}
-func (m *Session) GetLastInsertId() uint64 {
- if m != nil {
- return m.LastInsertId
+func (x *Session) GetLastInsertId() uint64 {
+ if x != nil {
+ return x.LastInsertId
}
return 0
}
-func (m *Session) GetFoundRows() uint64 {
- if m != nil {
- return m.FoundRows
+func (x *Session) GetFoundRows() uint64 {
+ if x != nil {
+ return x.FoundRows
}
return 0
}
-func (m *Session) GetUserDefinedVariables() map[string]*query.BindVariable {
- if m != nil {
- return m.UserDefinedVariables
+func (x *Session) GetUserDefinedVariables() map[string]*query.BindVariable {
+ if x != nil {
+ return x.UserDefinedVariables
}
return nil
}
-func (m *Session) GetSystemVariables() map[string]string {
- if m != nil {
- return m.SystemVariables
+func (x *Session) GetSystemVariables() map[string]string {
+ if x != nil {
+ return x.SystemVariables
}
return nil
}
-func (m *Session) GetRowCount() int64 {
- if m != nil {
- return m.RowCount
+func (x *Session) GetRowCount() int64 {
+ if x != nil {
+ return x.RowCount
}
return 0
}
-func (m *Session) GetSavepoints() []string {
- if m != nil {
- return m.Savepoints
+func (x *Session) GetSavepoints() []string {
+ if x != nil {
+ return x.Savepoints
}
return nil
}
-func (m *Session) GetInReservedConn() bool {
- if m != nil {
- return m.InReservedConn
+func (x *Session) GetInReservedConn() bool {
+ if x != nil {
+ return x.InReservedConn
}
return false
}
-type Session_ShardSession struct {
- Target *query.Target `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
- TransactionId int64 `protobuf:"varint,2,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
- TabletAlias *topodata.TabletAlias `protobuf:"bytes,3,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
- // reserved connection if a dedicated connection is needed
- ReservedId int64 `protobuf:"varint,4,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *Session_ShardSession) Reset() { *m = Session_ShardSession{} }
-func (m *Session_ShardSession) String() string { return proto.CompactTextString(m) }
-func (*Session_ShardSession) ProtoMessage() {}
-func (*Session_ShardSession) Descriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{0, 0}
-}
-
-func (m *Session_ShardSession) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_Session_ShardSession.Unmarshal(m, b)
-}
-func (m *Session_ShardSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_Session_ShardSession.Marshal(b, m, deterministic)
-}
-func (m *Session_ShardSession) XXX_Merge(src proto.Message) {
- xxx_messageInfo_Session_ShardSession.Merge(m, src)
-}
-func (m *Session_ShardSession) XXX_Size() int {
- return xxx_messageInfo_Session_ShardSession.Size(m)
-}
-func (m *Session_ShardSession) XXX_DiscardUnknown() {
- xxx_messageInfo_Session_ShardSession.DiscardUnknown(m)
-}
-
-var xxx_messageInfo_Session_ShardSession proto.InternalMessageInfo
-
-func (m *Session_ShardSession) GetTarget() *query.Target {
- if m != nil {
- return m.Target
- }
- return nil
-}
-
-func (m *Session_ShardSession) GetTransactionId() int64 {
- if m != nil {
- return m.TransactionId
- }
- return 0
-}
-
-func (m *Session_ShardSession) GetTabletAlias() *topodata.TabletAlias {
- if m != nil {
- return m.TabletAlias
- }
- return nil
-}
-
-func (m *Session_ShardSession) GetReservedId() int64 {
- if m != nil {
- return m.ReservedId
- }
- return 0
-}
-
// ExecuteRequest is the payload to Execute.
type ExecuteRequest struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
// caller_id identifies the caller. This is the effective caller ID,
// set by the application to further identify the caller.
CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
@@ -364,83 +376,91 @@ type ExecuteRequest struct {
Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
// These values are deprecated. Use session instead.
// TODO(sougou): remove in 3.1
- TabletType topodata.TabletType `protobuf:"varint,4,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
- KeyspaceShard string `protobuf:"bytes,6,opt,name=keyspace_shard,json=keyspaceShard,proto3" json:"keyspace_shard,omitempty"`
- Options *query.ExecuteOptions `protobuf:"bytes,7,opt,name=options,proto3" json:"options,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ TabletType topodata.TabletType `protobuf:"varint,4,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
+ KeyspaceShard string `protobuf:"bytes,6,opt,name=keyspace_shard,json=keyspaceShard,proto3" json:"keyspace_shard,omitempty"`
+ Options *query.ExecuteOptions `protobuf:"bytes,7,opt,name=options,proto3" json:"options,omitempty"`
}
-func (m *ExecuteRequest) Reset() { *m = ExecuteRequest{} }
-func (m *ExecuteRequest) String() string { return proto.CompactTextString(m) }
-func (*ExecuteRequest) ProtoMessage() {}
-func (*ExecuteRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{1}
+func (x *ExecuteRequest) Reset() {
+ *x = ExecuteRequest{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_vtgate_proto_msgTypes[1]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *ExecuteRequest) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_ExecuteRequest.Unmarshal(m, b)
-}
-func (m *ExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_ExecuteRequest.Marshal(b, m, deterministic)
-}
-func (m *ExecuteRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ExecuteRequest.Merge(m, src)
+func (x *ExecuteRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *ExecuteRequest) XXX_Size() int {
- return xxx_messageInfo_ExecuteRequest.Size(m)
-}
-func (m *ExecuteRequest) XXX_DiscardUnknown() {
- xxx_messageInfo_ExecuteRequest.DiscardUnknown(m)
+
+func (*ExecuteRequest) ProtoMessage() {}
+
+func (x *ExecuteRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_vtgate_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)
}
-var xxx_messageInfo_ExecuteRequest proto.InternalMessageInfo
+// Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.
+func (*ExecuteRequest) Descriptor() ([]byte, []int) {
+ return file_vtgate_proto_rawDescGZIP(), []int{1}
+}
-func (m *ExecuteRequest) GetCallerId() *vtrpc.CallerID {
- if m != nil {
- return m.CallerId
+func (x *ExecuteRequest) GetCallerId() *vtrpc.CallerID {
+ if x != nil {
+ return x.CallerId
}
return nil
}
-func (m *ExecuteRequest) GetSession() *Session {
- if m != nil {
- return m.Session
+func (x *ExecuteRequest) GetSession() *Session {
+ if x != nil {
+ return x.Session
}
return nil
}
-func (m *ExecuteRequest) GetQuery() *query.BoundQuery {
- if m != nil {
- return m.Query
+func (x *ExecuteRequest) GetQuery() *query.BoundQuery {
+ if x != nil {
+ return x.Query
}
return nil
}
-func (m *ExecuteRequest) GetTabletType() topodata.TabletType {
- if m != nil {
- return m.TabletType
+func (x *ExecuteRequest) GetTabletType() topodata.TabletType {
+ if x != nil {
+ return x.TabletType
}
return topodata.TabletType_UNKNOWN
}
-func (m *ExecuteRequest) GetKeyspaceShard() string {
- if m != nil {
- return m.KeyspaceShard
+func (x *ExecuteRequest) GetKeyspaceShard() string {
+ if x != nil {
+ return x.KeyspaceShard
}
return ""
}
-func (m *ExecuteRequest) GetOptions() *query.ExecuteOptions {
- if m != nil {
- return m.Options
+func (x *ExecuteRequest) GetOptions() *query.ExecuteOptions {
+ if x != nil {
+ return x.Options
}
return nil
}
// ExecuteResponse is the returned value from Execute.
type ExecuteResponse struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
// error contains an application level error if necessary. Note the
// session may have changed, even when an error is returned (for
// instance if a database integrity error happened).
@@ -448,60 +468,68 @@ type ExecuteResponse struct {
// session is the updated session information.
Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
// result contains the query result, only set if error is unset.
- Result *query.QueryResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ Result *query.QueryResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
}
-func (m *ExecuteResponse) Reset() { *m = ExecuteResponse{} }
-func (m *ExecuteResponse) String() string { return proto.CompactTextString(m) }
-func (*ExecuteResponse) ProtoMessage() {}
-func (*ExecuteResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{2}
+func (x *ExecuteResponse) Reset() {
+ *x = ExecuteResponse{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_vtgate_proto_msgTypes[2]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *ExecuteResponse) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_ExecuteResponse.Unmarshal(m, b)
-}
-func (m *ExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_ExecuteResponse.Marshal(b, m, deterministic)
+func (x *ExecuteResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *ExecuteResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ExecuteResponse.Merge(m, src)
-}
-func (m *ExecuteResponse) XXX_Size() int {
- return xxx_messageInfo_ExecuteResponse.Size(m)
-}
-func (m *ExecuteResponse) XXX_DiscardUnknown() {
- xxx_messageInfo_ExecuteResponse.DiscardUnknown(m)
+
+func (*ExecuteResponse) ProtoMessage() {}
+
+func (x *ExecuteResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_vtgate_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)
}
-var xxx_messageInfo_ExecuteResponse proto.InternalMessageInfo
+// Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.
+func (*ExecuteResponse) Descriptor() ([]byte, []int) {
+ return file_vtgate_proto_rawDescGZIP(), []int{2}
+}
-func (m *ExecuteResponse) GetError() *vtrpc.RPCError {
- if m != nil {
- return m.Error
+func (x *ExecuteResponse) GetError() *vtrpc.RPCError {
+ if x != nil {
+ return x.Error
}
return nil
}
-func (m *ExecuteResponse) GetSession() *Session {
- if m != nil {
- return m.Session
+func (x *ExecuteResponse) GetSession() *Session {
+ if x != nil {
+ return x.Session
}
return nil
}
-func (m *ExecuteResponse) GetResult() *query.QueryResult {
- if m != nil {
- return m.Result
+func (x *ExecuteResponse) GetResult() *query.QueryResult {
+ if x != nil {
+ return x.Result
}
return nil
}
// ExecuteBatchRequest is the payload to ExecuteBatch.
type ExecuteBatchRequest struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
// caller_id identifies the caller. This is the effective caller ID,
// set by the application to further identify the caller.
CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
@@ -511,91 +539,99 @@ type ExecuteBatchRequest struct {
Queries []*query.BoundQuery `protobuf:"bytes,3,rep,name=queries,proto3" json:"queries,omitempty"`
// These values are deprecated. Use session instead.
// TODO(sougou): remove in 3.1
- TabletType topodata.TabletType `protobuf:"varint,4,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
- AsTransaction bool `protobuf:"varint,5,opt,name=as_transaction,json=asTransaction,proto3" json:"as_transaction,omitempty"`
- KeyspaceShard string `protobuf:"bytes,6,opt,name=keyspace_shard,json=keyspaceShard,proto3" json:"keyspace_shard,omitempty"`
- Options *query.ExecuteOptions `protobuf:"bytes,7,opt,name=options,proto3" json:"options,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
-}
-
-func (m *ExecuteBatchRequest) Reset() { *m = ExecuteBatchRequest{} }
-func (m *ExecuteBatchRequest) String() string { return proto.CompactTextString(m) }
-func (*ExecuteBatchRequest) ProtoMessage() {}
-func (*ExecuteBatchRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{3}
+ TabletType topodata.TabletType `protobuf:"varint,4,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
+ AsTransaction bool `protobuf:"varint,5,opt,name=as_transaction,json=asTransaction,proto3" json:"as_transaction,omitempty"`
+ KeyspaceShard string `protobuf:"bytes,6,opt,name=keyspace_shard,json=keyspaceShard,proto3" json:"keyspace_shard,omitempty"`
+ Options *query.ExecuteOptions `protobuf:"bytes,7,opt,name=options,proto3" json:"options,omitempty"`
+}
+
+func (x *ExecuteBatchRequest) Reset() {
+ *x = ExecuteBatchRequest{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_vtgate_proto_msgTypes[3]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *ExecuteBatchRequest) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_ExecuteBatchRequest.Unmarshal(m, b)
-}
-func (m *ExecuteBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_ExecuteBatchRequest.Marshal(b, m, deterministic)
-}
-func (m *ExecuteBatchRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ExecuteBatchRequest.Merge(m, src)
-}
-func (m *ExecuteBatchRequest) XXX_Size() int {
- return xxx_messageInfo_ExecuteBatchRequest.Size(m)
+func (x *ExecuteBatchRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *ExecuteBatchRequest) XXX_DiscardUnknown() {
- xxx_messageInfo_ExecuteBatchRequest.DiscardUnknown(m)
+
+func (*ExecuteBatchRequest) ProtoMessage() {}
+
+func (x *ExecuteBatchRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_vtgate_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)
}
-var xxx_messageInfo_ExecuteBatchRequest proto.InternalMessageInfo
+// Deprecated: Use ExecuteBatchRequest.ProtoReflect.Descriptor instead.
+func (*ExecuteBatchRequest) Descriptor() ([]byte, []int) {
+ return file_vtgate_proto_rawDescGZIP(), []int{3}
+}
-func (m *ExecuteBatchRequest) GetCallerId() *vtrpc.CallerID {
- if m != nil {
- return m.CallerId
+func (x *ExecuteBatchRequest) GetCallerId() *vtrpc.CallerID {
+ if x != nil {
+ return x.CallerId
}
return nil
}
-func (m *ExecuteBatchRequest) GetSession() *Session {
- if m != nil {
- return m.Session
+func (x *ExecuteBatchRequest) GetSession() *Session {
+ if x != nil {
+ return x.Session
}
return nil
}
-func (m *ExecuteBatchRequest) GetQueries() []*query.BoundQuery {
- if m != nil {
- return m.Queries
+func (x *ExecuteBatchRequest) GetQueries() []*query.BoundQuery {
+ if x != nil {
+ return x.Queries
}
return nil
}
-func (m *ExecuteBatchRequest) GetTabletType() topodata.TabletType {
- if m != nil {
- return m.TabletType
+func (x *ExecuteBatchRequest) GetTabletType() topodata.TabletType {
+ if x != nil {
+ return x.TabletType
}
return topodata.TabletType_UNKNOWN
}
-func (m *ExecuteBatchRequest) GetAsTransaction() bool {
- if m != nil {
- return m.AsTransaction
+func (x *ExecuteBatchRequest) GetAsTransaction() bool {
+ if x != nil {
+ return x.AsTransaction
}
return false
}
-func (m *ExecuteBatchRequest) GetKeyspaceShard() string {
- if m != nil {
- return m.KeyspaceShard
+func (x *ExecuteBatchRequest) GetKeyspaceShard() string {
+ if x != nil {
+ return x.KeyspaceShard
}
return ""
}
-func (m *ExecuteBatchRequest) GetOptions() *query.ExecuteOptions {
- if m != nil {
- return m.Options
+func (x *ExecuteBatchRequest) GetOptions() *query.ExecuteOptions {
+ if x != nil {
+ return x.Options
}
return nil
}
// ExecuteBatchResponse is the returned value from ExecuteBatch.
type ExecuteBatchResponse struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
// error contains an application level error if necessary. Note the
// session may have changed, even when an error is returned (for
// instance if a database integrity error happened).
@@ -603,60 +639,68 @@ type ExecuteBatchResponse struct {
// session is the updated session information.
Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
// results contains the query results, only set if application level error is unset.
- Results []*query.ResultWithError `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ Results []*query.ResultWithError `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
}
-func (m *ExecuteBatchResponse) Reset() { *m = ExecuteBatchResponse{} }
-func (m *ExecuteBatchResponse) String() string { return proto.CompactTextString(m) }
-func (*ExecuteBatchResponse) ProtoMessage() {}
-func (*ExecuteBatchResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{4}
+func (x *ExecuteBatchResponse) Reset() {
+ *x = ExecuteBatchResponse{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_vtgate_proto_msgTypes[4]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *ExecuteBatchResponse) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_ExecuteBatchResponse.Unmarshal(m, b)
-}
-func (m *ExecuteBatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_ExecuteBatchResponse.Marshal(b, m, deterministic)
+func (x *ExecuteBatchResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *ExecuteBatchResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ExecuteBatchResponse.Merge(m, src)
-}
-func (m *ExecuteBatchResponse) XXX_Size() int {
- return xxx_messageInfo_ExecuteBatchResponse.Size(m)
-}
-func (m *ExecuteBatchResponse) XXX_DiscardUnknown() {
- xxx_messageInfo_ExecuteBatchResponse.DiscardUnknown(m)
+
+func (*ExecuteBatchResponse) ProtoMessage() {}
+
+func (x *ExecuteBatchResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_vtgate_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)
}
-var xxx_messageInfo_ExecuteBatchResponse proto.InternalMessageInfo
+// Deprecated: Use ExecuteBatchResponse.ProtoReflect.Descriptor instead.
+func (*ExecuteBatchResponse) Descriptor() ([]byte, []int) {
+ return file_vtgate_proto_rawDescGZIP(), []int{4}
+}
-func (m *ExecuteBatchResponse) GetError() *vtrpc.RPCError {
- if m != nil {
- return m.Error
+func (x *ExecuteBatchResponse) GetError() *vtrpc.RPCError {
+ if x != nil {
+ return x.Error
}
return nil
}
-func (m *ExecuteBatchResponse) GetSession() *Session {
- if m != nil {
- return m.Session
+func (x *ExecuteBatchResponse) GetSession() *Session {
+ if x != nil {
+ return x.Session
}
return nil
}
-func (m *ExecuteBatchResponse) GetResults() []*query.ResultWithError {
- if m != nil {
- return m.Results
+func (x *ExecuteBatchResponse) GetResults() []*query.ResultWithError {
+ if x != nil {
+ return x.Results
}
return nil
}
// StreamExecuteRequest is the payload to StreamExecute.
type StreamExecuteRequest struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
// caller_id identifies the caller. This is the effective caller ID,
// set by the application to further identify the caller.
CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
@@ -668,75 +712,79 @@ type StreamExecuteRequest struct {
KeyspaceShard string `protobuf:"bytes,4,opt,name=keyspace_shard,json=keyspaceShard,proto3" json:"keyspace_shard,omitempty"`
Options *query.ExecuteOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
// session carries the session state.
- Session *Session `protobuf:"bytes,6,opt,name=session,proto3" json:"session,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ Session *Session `protobuf:"bytes,6,opt,name=session,proto3" json:"session,omitempty"`
}
-func (m *StreamExecuteRequest) Reset() { *m = StreamExecuteRequest{} }
-func (m *StreamExecuteRequest) String() string { return proto.CompactTextString(m) }
-func (*StreamExecuteRequest) ProtoMessage() {}
-func (*StreamExecuteRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{5}
+func (x *StreamExecuteRequest) Reset() {
+ *x = StreamExecuteRequest{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_vtgate_proto_msgTypes[5]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *StreamExecuteRequest) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_StreamExecuteRequest.Unmarshal(m, b)
-}
-func (m *StreamExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_StreamExecuteRequest.Marshal(b, m, deterministic)
-}
-func (m *StreamExecuteRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_StreamExecuteRequest.Merge(m, src)
-}
-func (m *StreamExecuteRequest) XXX_Size() int {
- return xxx_messageInfo_StreamExecuteRequest.Size(m)
+func (x *StreamExecuteRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *StreamExecuteRequest) XXX_DiscardUnknown() {
- xxx_messageInfo_StreamExecuteRequest.DiscardUnknown(m)
+
+func (*StreamExecuteRequest) ProtoMessage() {}
+
+func (x *StreamExecuteRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_vtgate_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)
}
-var xxx_messageInfo_StreamExecuteRequest proto.InternalMessageInfo
+// Deprecated: Use StreamExecuteRequest.ProtoReflect.Descriptor instead.
+func (*StreamExecuteRequest) Descriptor() ([]byte, []int) {
+ return file_vtgate_proto_rawDescGZIP(), []int{5}
+}
-func (m *StreamExecuteRequest) GetCallerId() *vtrpc.CallerID {
- if m != nil {
- return m.CallerId
+func (x *StreamExecuteRequest) GetCallerId() *vtrpc.CallerID {
+ if x != nil {
+ return x.CallerId
}
return nil
}
-func (m *StreamExecuteRequest) GetQuery() *query.BoundQuery {
- if m != nil {
- return m.Query
+func (x *StreamExecuteRequest) GetQuery() *query.BoundQuery {
+ if x != nil {
+ return x.Query
}
return nil
}
-func (m *StreamExecuteRequest) GetTabletType() topodata.TabletType {
- if m != nil {
- return m.TabletType
+func (x *StreamExecuteRequest) GetTabletType() topodata.TabletType {
+ if x != nil {
+ return x.TabletType
}
return topodata.TabletType_UNKNOWN
}
-func (m *StreamExecuteRequest) GetKeyspaceShard() string {
- if m != nil {
- return m.KeyspaceShard
+func (x *StreamExecuteRequest) GetKeyspaceShard() string {
+ if x != nil {
+ return x.KeyspaceShard
}
return ""
}
-func (m *StreamExecuteRequest) GetOptions() *query.ExecuteOptions {
- if m != nil {
- return m.Options
+func (x *StreamExecuteRequest) GetOptions() *query.ExecuteOptions {
+ if x != nil {
+ return x.Options
}
return nil
}
-func (m *StreamExecuteRequest) GetSession() *Session {
- if m != nil {
- return m.Session
+func (x *StreamExecuteRequest) GetSession() *Session {
+ if x != nil {
+ return x.Session
}
return nil
}
@@ -745,332 +793,813 @@ func (m *StreamExecuteRequest) GetSession() *Session {
// The session is currently not returned because StreamExecute is
// not expected to modify it.
type StreamExecuteResponse struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
// result contains the result data.
// The first value contains only Fields information.
// The next values contain the actual rows, a few values per result.
- Result *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ Result *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}
-func (m *StreamExecuteResponse) Reset() { *m = StreamExecuteResponse{} }
-func (m *StreamExecuteResponse) String() string { return proto.CompactTextString(m) }
-func (*StreamExecuteResponse) ProtoMessage() {}
-func (*StreamExecuteResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{6}
+func (x *StreamExecuteResponse) Reset() {
+ *x = StreamExecuteResponse{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_vtgate_proto_msgTypes[6]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *StreamExecuteResponse) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_StreamExecuteResponse.Unmarshal(m, b)
-}
-func (m *StreamExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_StreamExecuteResponse.Marshal(b, m, deterministic)
-}
-func (m *StreamExecuteResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_StreamExecuteResponse.Merge(m, src)
+func (x *StreamExecuteResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *StreamExecuteResponse) XXX_Size() int {
- return xxx_messageInfo_StreamExecuteResponse.Size(m)
-}
-func (m *StreamExecuteResponse) XXX_DiscardUnknown() {
- xxx_messageInfo_StreamExecuteResponse.DiscardUnknown(m)
+
+func (*StreamExecuteResponse) ProtoMessage() {}
+
+func (x *StreamExecuteResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_vtgate_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)
}
-var xxx_messageInfo_StreamExecuteResponse proto.InternalMessageInfo
+// Deprecated: Use StreamExecuteResponse.ProtoReflect.Descriptor instead.
+func (*StreamExecuteResponse) Descriptor() ([]byte, []int) {
+ return file_vtgate_proto_rawDescGZIP(), []int{6}
+}
-func (m *StreamExecuteResponse) GetResult() *query.QueryResult {
- if m != nil {
- return m.Result
+func (x *StreamExecuteResponse) GetResult() *query.QueryResult {
+ if x != nil {
+ return x.Result
}
return nil
}
// ResolveTransactionRequest is the payload to ResolveTransaction.
type ResolveTransactionRequest struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
// caller_id identifies the caller. This is the effective caller ID,
// set by the application to further identify the caller.
CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
// dtid is the dtid of the transaction to be resolved.
- Dtid string `protobuf:"bytes,2,opt,name=dtid,proto3" json:"dtid,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ Dtid string `protobuf:"bytes,2,opt,name=dtid,proto3" json:"dtid,omitempty"`
}
-func (m *ResolveTransactionRequest) Reset() { *m = ResolveTransactionRequest{} }
-func (m *ResolveTransactionRequest) String() string { return proto.CompactTextString(m) }
-func (*ResolveTransactionRequest) ProtoMessage() {}
-func (*ResolveTransactionRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{7}
+func (x *ResolveTransactionRequest) Reset() {
+ *x = ResolveTransactionRequest{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_vtgate_proto_msgTypes[7]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *ResolveTransactionRequest) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_ResolveTransactionRequest.Unmarshal(m, b)
-}
-func (m *ResolveTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_ResolveTransactionRequest.Marshal(b, m, deterministic)
+func (x *ResolveTransactionRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *ResolveTransactionRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ResolveTransactionRequest.Merge(m, src)
-}
-func (m *ResolveTransactionRequest) XXX_Size() int {
- return xxx_messageInfo_ResolveTransactionRequest.Size(m)
-}
-func (m *ResolveTransactionRequest) XXX_DiscardUnknown() {
- xxx_messageInfo_ResolveTransactionRequest.DiscardUnknown(m)
+
+func (*ResolveTransactionRequest) ProtoMessage() {}
+
+func (x *ResolveTransactionRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_vtgate_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)
}
-var xxx_messageInfo_ResolveTransactionRequest proto.InternalMessageInfo
+// Deprecated: Use ResolveTransactionRequest.ProtoReflect.Descriptor instead.
+func (*ResolveTransactionRequest) Descriptor() ([]byte, []int) {
+ return file_vtgate_proto_rawDescGZIP(), []int{7}
+}
-func (m *ResolveTransactionRequest) GetCallerId() *vtrpc.CallerID {
- if m != nil {
- return m.CallerId
+func (x *ResolveTransactionRequest) GetCallerId() *vtrpc.CallerID {
+ if x != nil {
+ return x.CallerId
}
return nil
}
-func (m *ResolveTransactionRequest) GetDtid() string {
- if m != nil {
- return m.Dtid
+func (x *ResolveTransactionRequest) GetDtid() string {
+ if x != nil {
+ return x.Dtid
}
return ""
}
// ResolveTransactionResponse is the returned value from Rollback.
type ResolveTransactionResponse struct {
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
}
-func (m *ResolveTransactionResponse) Reset() { *m = ResolveTransactionResponse{} }
-func (m *ResolveTransactionResponse) String() string { return proto.CompactTextString(m) }
-func (*ResolveTransactionResponse) ProtoMessage() {}
-func (*ResolveTransactionResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{8}
+func (x *ResolveTransactionResponse) Reset() {
+ *x = ResolveTransactionResponse{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_vtgate_proto_msgTypes[8]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *ResolveTransactionResponse) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_ResolveTransactionResponse.Unmarshal(m, b)
-}
-func (m *ResolveTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_ResolveTransactionResponse.Marshal(b, m, deterministic)
+func (x *ResolveTransactionResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *ResolveTransactionResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_ResolveTransactionResponse.Merge(m, src)
-}
-func (m *ResolveTransactionResponse) XXX_Size() int {
- return xxx_messageInfo_ResolveTransactionResponse.Size(m)
-}
-func (m *ResolveTransactionResponse) XXX_DiscardUnknown() {
- xxx_messageInfo_ResolveTransactionResponse.DiscardUnknown(m)
+
+func (*ResolveTransactionResponse) ProtoMessage() {}
+
+func (x *ResolveTransactionResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_vtgate_proto_msgTypes[8]
+ 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)
}
-var xxx_messageInfo_ResolveTransactionResponse proto.InternalMessageInfo
+// Deprecated: Use ResolveTransactionResponse.ProtoReflect.Descriptor instead.
+func (*ResolveTransactionResponse) Descriptor() ([]byte, []int) {
+ return file_vtgate_proto_rawDescGZIP(), []int{8}
+}
// VStreamRequest is the payload for VStream.
type VStreamRequest struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
TabletType topodata.TabletType `protobuf:"varint,2,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
// position specifies the starting point of the bin log positions
// as well as the keyspace-shards to pull events from.
// position is of the form 'ks1:0@MySQL56/<mysql_pos>|ks2:-80@MySQL56/<mysql_pos>'.
- Vgtid *binlogdata.VGtid `protobuf:"bytes,3,opt,name=vgtid,proto3" json:"vgtid,omitempty"`
- Filter *binlogdata.Filter `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ Vgtid *binlogdata.VGtid `protobuf:"bytes,3,opt,name=vgtid,proto3" json:"vgtid,omitempty"`
+ Filter *binlogdata.Filter `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
}
-func (m *VStreamRequest) Reset() { *m = VStreamRequest{} }
-func (m *VStreamRequest) String() string { return proto.CompactTextString(m) }
-func (*VStreamRequest) ProtoMessage() {}
-func (*VStreamRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{9}
+func (x *VStreamRequest) Reset() {
+ *x = VStreamRequest{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_vtgate_proto_msgTypes[9]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *VStreamRequest) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_VStreamRequest.Unmarshal(m, b)
-}
-func (m *VStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_VStreamRequest.Marshal(b, m, deterministic)
-}
-func (m *VStreamRequest) XXX_Merge(src proto.Message) {
- xxx_messageInfo_VStreamRequest.Merge(m, src)
-}
-func (m *VStreamRequest) XXX_Size() int {
- return xxx_messageInfo_VStreamRequest.Size(m)
+func (x *VStreamRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *VStreamRequest) XXX_DiscardUnknown() {
- xxx_messageInfo_VStreamRequest.DiscardUnknown(m)
+
+func (*VStreamRequest) ProtoMessage() {}
+
+func (x *VStreamRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_vtgate_proto_msgTypes[9]
+ 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)
}
-var xxx_messageInfo_VStreamRequest proto.InternalMessageInfo
+// Deprecated: Use VStreamRequest.ProtoReflect.Descriptor instead.
+func (*VStreamRequest) Descriptor() ([]byte, []int) {
+ return file_vtgate_proto_rawDescGZIP(), []int{9}
+}
-func (m *VStreamRequest) GetCallerId() *vtrpc.CallerID {
- if m != nil {
- return m.CallerId
+func (x *VStreamRequest) GetCallerId() *vtrpc.CallerID {
+ if x != nil {
+ return x.CallerId
}
return nil
}
-func (m *VStreamRequest) GetTabletType() topodata.TabletType {
- if m != nil {
- return m.TabletType
+func (x *VStreamRequest) GetTabletType() topodata.TabletType {
+ if x != nil {
+ return x.TabletType
}
return topodata.TabletType_UNKNOWN
}
-func (m *VStreamRequest) GetVgtid() *binlogdata.VGtid {
- if m != nil {
- return m.Vgtid
+func (x *VStreamRequest) GetVgtid() *binlogdata.VGtid {
+ if x != nil {
+ return x.Vgtid
}
return nil
}
-func (m *VStreamRequest) GetFilter() *binlogdata.Filter {
- if m != nil {
- return m.Filter
+func (x *VStreamRequest) GetFilter() *binlogdata.Filter {
+ if x != nil {
+ return x.Filter
}
return nil
}
// VStreamResponse is streamed by VStream.
type VStreamResponse struct {
- Events []*binlogdata.VEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
+ Events []*binlogdata.VEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
+}
+
+func (x *VStreamResponse) Reset() {
+ *x = VStreamResponse{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_vtgate_proto_msgTypes[10]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *VStreamResponse) Reset() { *m = VStreamResponse{} }
-func (m *VStreamResponse) String() string { return proto.CompactTextString(m) }
-func (*VStreamResponse) ProtoMessage() {}
+func (x *VStreamResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*VStreamResponse) ProtoMessage() {}
+
+func (x *VStreamResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_vtgate_proto_msgTypes[10]
+ 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 VStreamResponse.ProtoReflect.Descriptor instead.
func (*VStreamResponse) Descriptor() ([]byte, []int) {
- return fileDescriptor_aab96496ceaf1ebb, []int{10}
+ return file_vtgate_proto_rawDescGZIP(), []int{10}
+}
+
+func (x *VStreamResponse) GetEvents() []*binlogdata.VEvent {
+ if x != nil {
+ return x.Events
+ }
+ return nil
+}
+
+type Session_ShardSession struct {
+ state protoimpl.MessageState
+ sizeCache protoimpl.SizeCache
+ unknownFields protoimpl.UnknownFields
+
+ Target *query.Target `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
+ TransactionId int64 `protobuf:"varint,2,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
+ TabletAlias *topodata.TabletAlias `protobuf:"bytes,3,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
+ // reserved connection if a dedicated connection is needed
+ ReservedId int64 `protobuf:"varint,4,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"`
}
-func (m *VStreamResponse) XXX_Unmarshal(b []byte) error {
- return xxx_messageInfo_VStreamResponse.Unmarshal(m, b)
+func (x *Session_ShardSession) Reset() {
+ *x = Session_ShardSession{}
+ if protoimpl.UnsafeEnabled {
+ mi := &file_vtgate_proto_msgTypes[11]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+ }
}
-func (m *VStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
- return xxx_messageInfo_VStreamResponse.Marshal(b, m, deterministic)
+
+func (x *Session_ShardSession) String() string {
+ return protoimpl.X.MessageStringOf(x)
}
-func (m *VStreamResponse) XXX_Merge(src proto.Message) {
- xxx_messageInfo_VStreamResponse.Merge(m, src)
+
+func (*Session_ShardSession) ProtoMessage() {}
+
+func (x *Session_ShardSession) ProtoReflect() protoreflect.Message {
+ mi := &file_vtgate_proto_msgTypes[11]
+ 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)
}
-func (m *VStreamResponse) XXX_Size() int {
- return xxx_messageInfo_VStreamResponse.Size(m)
+
+// Deprecated: Use Session_ShardSession.ProtoReflect.Descriptor instead.
+func (*Session_ShardSession) Descriptor() ([]byte, []int) {
+ return file_vtgate_proto_rawDescGZIP(), []int{0, 0}
}
-func (m *VStreamResponse) XXX_DiscardUnknown() {
- xxx_messageInfo_VStreamResponse.DiscardUnknown(m)
+
+func (x *Session_ShardSession) GetTarget() *query.Target {
+ if x != nil {
+ return x.Target
+ }
+ return nil
}
-var xxx_messageInfo_VStreamResponse proto.InternalMessageInfo
+func (x *Session_ShardSession) GetTransactionId() int64 {
+ if x != nil {
+ return x.TransactionId
+ }
+ return 0
+}
-func (m *VStreamResponse) GetEvents() []*binlogdata.VEvent {
- if m != nil {
- return m.Events
+func (x *Session_ShardSession) GetTabletAlias() *topodata.TabletAlias {
+ if x != nil {
+ return x.TabletAlias
}
return nil
}
-func init() {
- proto.RegisterEnum("vtgate.TransactionMode", TransactionMode_name, TransactionMode_value)
- proto.RegisterEnum("vtgate.CommitOrder", CommitOrder_name, CommitOrder_value)
- proto.RegisterType((*Session)(nil), "vtgate.Session")
- proto.RegisterMapType((map[string]string)(nil), "vtgate.Session.SystemVariablesEntry")
- proto.RegisterMapType((map[string]*query.BindVariable)(nil), "vtgate.Session.UserDefinedVariablesEntry")
- proto.RegisterType((*Session_ShardSession)(nil), "vtgate.Session.ShardSession")
- proto.RegisterType((*ExecuteRequest)(nil), "vtgate.ExecuteRequest")
- proto.RegisterType((*ExecuteResponse)(nil), "vtgate.ExecuteResponse")
- proto.RegisterType((*ExecuteBatchRequest)(nil), "vtgate.ExecuteBatchRequest")
- proto.RegisterType((*ExecuteBatchResponse)(nil), "vtgate.ExecuteBatchResponse")
- proto.RegisterType((*StreamExecuteRequest)(nil), "vtgate.StreamExecuteRequest")
- proto.RegisterType((*StreamExecuteResponse)(nil), "vtgate.StreamExecuteResponse")
- proto.RegisterType((*ResolveTransactionRequest)(nil), "vtgate.ResolveTransactionRequest")
- proto.RegisterType((*ResolveTransactionResponse)(nil), "vtgate.ResolveTransactionResponse")
- proto.RegisterType((*VStreamRequest)(nil), "vtgate.VStreamRequest")
- proto.RegisterType((*VStreamResponse)(nil), "vtgate.VStreamResponse")
-}
-
-func init() { proto.RegisterFile("vtgate.proto", fileDescriptor_aab96496ceaf1ebb) }
-
-var fileDescriptor_aab96496ceaf1ebb = []byte{
- // 1181 bytes of a gzipped FileDescriptorProto
- 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x56, 0xdd, 0x8e, 0x1b, 0xb5,
- 0x17, 0xef, 0x64, 0xf2, 0x35, 0x27, 0x5f, 0x53, 0x37, 0xed, 0x7f, 0x9a, 0x7f, 0x81, 0x28, 0x6d,
- 0xd5, 0xb4, 0xa0, 0x04, 0x2d, 0x02, 0x55, 0x08, 0x84, 0x76, 0xb3, 0x69, 0x95, 0xaa, 0xdb, 0x2c,
- 0x4e, 0x76, 0x2b, 0x21, 0xd0, 0x68, 0x9a, 0x71, 0x53, 0xab, 0xd9, 0xf1, 0xd4, 0x76, 0xb2, 0xe4,
- 0x29, 0xb8, 0xe7, 0x1a, 0x89, 0x47, 0xe0, 0x1d, 0xb8, 0xe3, 0x8d, 0x90, 0xed, 0x49, 0x32, 0x1b,
- 0x16, 0xba, 0x6d, 0xb5, 0x37, 0x23, 0x9f, 0x0f, 0x9f, 0x39, 0xe7, 0xf7, 0x3b, 0xc7, 0x36, 0x94,
- 0x17, 0x72, 0x1a, 0x48, 0xd2, 0x89, 0x39, 0x93, 0x0c, 0xe5, 0x8d, 0xd4, 0x70, 0x5f, 0xd0, 0x68,
- 0xc6, 0xa6, 0x61, 0x20, 0x03, 0x63, 0x69, 0x94, 0xde, 0xcc, 0x09, 0x5f, 0x26, 0x42, 0x55, 0xb2,
- 0x98, 0xa5, 0x8d, 0x0b, 0xc9, 0xe3, 0x89, 0x11, 0x5a, 0xbf, 0x39, 0x50, 0x18, 0x11, 0x21, 0x28,
- 0x8b, 0xd0, 0x5d, 0xa8, 0xd2, 0xc8, 0x97, 0x3c, 0x88, 0x44, 0x30, 0x91, 0x94, 0x45, 0x9e, 0xd5,
- 0xb4, 0xda, 0x45, 0x5c, 0xa1, 0xd1, 0x78, 0xa3, 0x44, 0x3d, 0xa8, 0x8a, 0x57, 0x01, 0x0f, 0x7d,
- 0x61, 0xf6, 0x09, 0x2f, 0xd3, 0xb4, 0xdb, 0xa5, 0x9d, 0x5b, 0x9d, 0x24, 0xbb, 0x24, 0x5e, 0x67,
- 0xa4, 0xbc, 0x12, 0x01, 0x57, 0x44, 0x4a, 0x12, 0xe8, 0x63, 0x80, 0x60, 0x2e, 0xd9, 0x84, 0x9d,
- 0x9c, 0x50, 0xe9, 0x65, 0xf5, 0x7f, 0x52, 0x1a, 0x74, 0x1b, 0x2a, 0x32, 0xe0, 0x53, 0x22, 0x7d,
- 0x21, 0x39, 0x8d, 0xa6, 0x5e, 0xae, 0x69, 0xb5, 0x1d, 0x5c, 0x36, 0xca, 0x91, 0xd6, 0xa1, 0x2e,
- 0x14, 0x58, 0x2c, 0x75, 0x0a, 0xf9, 0xa6, 0xd5, 0x2e, 0xed, 0x5c, 0xef, 0x98, 0xc2, 0xfb, 0x3f,
- 0x93, 0xc9, 0x5c, 0x92, 0xa1, 0x31, 0xe2, 0x95, 0x17, 0xda, 0x03, 0x37, 0x55, 0x9e, 0x7f, 0xc2,
- 0x42, 0xe2, 0x15, 0x9a, 0x56, 0xbb, 0xba, 0xf3, 0xbf, 0x55, 0xf2, 0xa9, 0x4a, 0x0f, 0x58, 0x48,
- 0x70, 0x4d, 0x9e, 0x55, 0xa0, 0x2e, 0x14, 0x4f, 0x03, 0x1e, 0xd1, 0x68, 0x2a, 0xbc, 0xa2, 0x2e,
- 0xfc, 0x5a, 0xf2, 0xd7, 0xef, 0xd5, 0xf7, 0xb9, 0xb1, 0xe1, 0xb5, 0x13, 0xfa, 0x0e, 0xca, 0x31,
- 0x27, 0x1b, 0xb4, 0x9c, 0x0b, 0xa0, 0x55, 0x8a, 0x39, 0x59, 0x63, 0xb5, 0x0b, 0x95, 0x98, 0x09,
- 0xb9, 0x89, 0x00, 0x17, 0x88, 0x50, 0x56, 0x5b, 0xd6, 0x21, 0xee, 0x40, 0x75, 0x16, 0x08, 0xe9,
- 0xd3, 0x48, 0x10, 0x2e, 0x7d, 0x1a, 0x7a, 0xa5, 0xa6, 0xd5, 0xce, 0xe2, 0xb2, 0xd2, 0x0e, 0xb4,
- 0x72, 0x10, 0xa2, 0x8f, 0x00, 0x5e, 0xb2, 0x79, 0x14, 0xfa, 0x9c, 0x9d, 0x0a, 0xaf, 0xac, 0x3d,
- 0x1c, 0xad, 0xc1, 0xec, 0x54, 0x20, 0x1f, 0x6e, 0xcc, 0x05, 0xe1, 0x7e, 0x48, 0x5e, 0xd2, 0x88,
- 0x84, 0xfe, 0x22, 0xe0, 0x34, 0x78, 0x31, 0x23, 0xc2, 0xab, 0xe8, 0x84, 0xee, 0x6f, 0x27, 0x74,
- 0x24, 0x08, 0xdf, 0x37, 0xce, 0xc7, 0x2b, 0xdf, 0x7e, 0x24, 0xf9, 0x12, 0xd7, 0xe7, 0xe7, 0x98,
- 0xd0, 0x10, 0x5c, 0xb1, 0x14, 0x92, 0x9c, 0xa4, 0x42, 0x57, 0x75, 0xe8, 0x3b, 0xff, 0xa8, 0x55,
- 0xfb, 0x6d, 0x45, 0xad, 0x89, 0xb3, 0x5a, 0xf4, 0x7f, 0x70, 0x38, 0x3b, 0xf5, 0x27, 0x6c, 0x1e,
- 0x49, 0xaf, 0xd6, 0xb4, 0xda, 0x36, 0x2e, 0x72, 0x76, 0xda, 0x53, 0xb2, 0x6a, 0x41, 0x11, 0x2c,
- 0x48, 0xcc, 0x68, 0x24, 0x85, 0xe7, 0x36, 0xed, 0xb6, 0x83, 0x53, 0x1a, 0xd4, 0x06, 0x97, 0x46,
- 0x3e, 0x27, 0x82, 0xf0, 0x05, 0x09, 0xfd, 0x09, 0x8b, 0x22, 0xef, 0xaa, 0x6e, 0xd4, 0x2a, 0x8d,
- 0x70, 0xa2, 0xee, 0xb1, 0x28, 0x6a, 0xfc, 0x61, 0x41, 0x39, 0x0d, 0x3e, 0xba, 0x0b, 0x79, 0xd3,
- 0xa8, 0x7a, 0x82, 0x4a, 0x3b, 0x95, 0xa4, 0x43, 0xc6, 0x5a, 0x89, 0x13, 0xa3, 0x1a, 0xb8, 0x74,
- 0x3b, 0xd2, 0xd0, 0xcb, 0xe8, 0x1c, 0x2b, 0x29, 0xed, 0x20, 0x44, 0x0f, 0xa1, 0x2c, 0x55, 0x3d,
- 0xd2, 0x0f, 0x66, 0x34, 0x10, 0x9e, 0x9d, 0xf4, 0xfa, 0x7a, 0xae, 0xc7, 0xda, 0xba, 0xab, 0x8c,
- 0xb8, 0x24, 0x37, 0x02, 0xfa, 0x04, 0x4a, 0xeb, 0xfc, 0x69, 0xa8, 0xc7, 0xcc, 0xc6, 0xb0, 0x52,
- 0x0d, 0xc2, 0xc6, 0x8f, 0x70, 0xf3, 0x5f, 0x49, 0x42, 0x2e, 0xd8, 0xaf, 0xc9, 0x52, 0x97, 0xe0,
- 0x60, 0xb5, 0x44, 0xf7, 0x21, 0xb7, 0x08, 0x66, 0x73, 0xa2, 0xf3, 0xdc, 0x34, 0xfe, 0x1e, 0x8d,
- 0xd6, 0x7b, 0xb1, 0xf1, 0xf8, 0x3a, 0xf3, 0xd0, 0x6a, 0xec, 0x41, 0xfd, 0x3c, 0x9e, 0xce, 0x09,
- 0x5c, 0x4f, 0x07, 0x76, 0x52, 0x31, 0x9e, 0x64, 0x8b, 0xb6, 0x9b, 0x6d, 0xfd, 0x9e, 0x81, 0x6a,
- 0x32, 0xd4, 0x98, 0xbc, 0x99, 0x13, 0x21, 0xd1, 0x67, 0xe0, 0x4c, 0x82, 0xd9, 0x8c, 0x70, 0x55,
- 0x99, 0x81, 0xb9, 0xd6, 0x31, 0x47, 0x5b, 0x4f, 0xeb, 0x07, 0xfb, 0xb8, 0x68, 0x3c, 0x06, 0x21,
- 0xba, 0x0f, 0x85, 0x64, 0x7c, 0x92, 0xdc, 0x6b, 0x5b, 0x1d, 0x85, 0x57, 0x76, 0x74, 0x0f, 0x72,
- 0xba, 0xac, 0x04, 0xe7, 0xab, 0xab, 0x22, 0xd5, 0x1c, 0xe8, 0x11, 0xc7, 0xc6, 0x8e, 0xbe, 0x84,
- 0x04, 0x6c, 0x5f, 0x2e, 0x63, 0xa2, 0xd1, 0xad, 0xee, 0xd4, 0xb7, 0x69, 0x19, 0x2f, 0x63, 0x82,
- 0x41, 0xae, 0xd7, 0x8a, 0xf5, 0xd7, 0x64, 0x29, 0xe2, 0x60, 0x42, 0x7c, 0x7d, 0x28, 0xea, 0xc3,
- 0xcb, 0xc1, 0x95, 0x95, 0x56, 0xb7, 0x52, 0xfa, 0x70, 0x2b, 0x5c, 0xe4, 0x70, 0x7b, 0x92, 0x2d,
- 0xe6, 0xdc, 0x7c, 0xeb, 0x17, 0x0b, 0x6a, 0x6b, 0xa4, 0x44, 0xcc, 0x22, 0xa1, 0xfe, 0x98, 0x23,
- 0x9c, 0x33, 0xbe, 0x05, 0x13, 0x3e, 0xec, 0xf5, 0x95, 0x1a, 0x1b, 0xeb, 0xbb, 0x60, 0xf4, 0x00,
- 0xf2, 0x9c, 0x88, 0xf9, 0x4c, 0x26, 0x20, 0xa1, 0xf4, 0x11, 0x88, 0xb5, 0x05, 0x27, 0x1e, 0xad,
- 0xbf, 0x32, 0x70, 0x2d, 0xc9, 0x68, 0x2f, 0x90, 0x93, 0x57, 0x97, 0x4e, 0xe0, 0xa7, 0x50, 0x50,
- 0xd9, 0x50, 0xa2, 0x46, 0xc5, 0x3e, 0x9f, 0xc2, 0x95, 0xc7, 0x07, 0x90, 0x18, 0x88, 0x33, 0x77,
- 0x65, 0xce, 0xdc, 0x95, 0x81, 0x48, 0xdf, 0x95, 0x97, 0xc4, 0x75, 0xeb, 0x57, 0x0b, 0xea, 0x67,
- 0x31, 0xbd, 0x34, 0xaa, 0x3f, 0x87, 0x82, 0x21, 0x72, 0x85, 0xe6, 0x8d, 0x24, 0x37, 0x43, 0xf3,
- 0x73, 0x2a, 0x5f, 0x99, 0xd0, 0x2b, 0x37, 0x35, 0xac, 0xf5, 0x91, 0xe4, 0x24, 0x38, 0xf9, 0xa0,
- 0x91, 0x5d, 0xcf, 0x61, 0xe6, 0xdd, 0xe6, 0xd0, 0x7e, 0xef, 0x39, 0xcc, 0xbe, 0x85, 0x9b, 0xdc,
- 0x85, 0x1e, 0x19, 0x29, 0x6c, 0xf3, 0xff, 0x8d, 0x6d, 0xab, 0x07, 0xd7, 0xb7, 0x80, 0x4a, 0x68,
- 0xdc, 0xcc, 0x97, 0xf5, 0xd6, 0xf9, 0xfa, 0x09, 0x6e, 0x62, 0x22, 0xd8, 0x6c, 0x41, 0x52, 0x9d,
- 0xf7, 0x7e, 0x90, 0x23, 0xc8, 0x86, 0x32, 0xb9, 0x86, 0x1c, 0xac, 0xd7, 0xad, 0x5b, 0xd0, 0x38,
- 0x2f, 0xbc, 0x49, 0xb4, 0xf5, 0xa7, 0x05, 0xd5, 0x63, 0x53, 0xc3, 0xfb, 0xfd, 0x72, 0x8b, 0xbc,
- 0xcc, 0x05, 0xc9, 0xbb, 0x07, 0xb9, 0xc5, 0x54, 0xa5, 0xba, 0x3a, 0xa4, 0x53, 0x6f, 0xe0, 0xe3,
- 0xc7, 0x92, 0x86, 0xd8, 0xd8, 0x15, 0x92, 0x2f, 0xe9, 0x4c, 0x12, 0xae, 0xd9, 0x55, 0x48, 0xa6,
- 0x3c, 0x1f, 0x69, 0x0b, 0x4e, 0x3c, 0x5a, 0xdf, 0x42, 0x6d, 0x5d, 0xcb, 0x86, 0x08, 0xb2, 0x20,
- 0xea, 0x81, 0x60, 0xe9, 0xe6, 0x3f, 0xb3, 0xfd, 0xb8, 0xaf, 0x4c, 0x38, 0xf1, 0x78, 0xb0, 0x0f,
- 0xb5, 0xad, 0xd7, 0x23, 0xaa, 0x41, 0xe9, 0xe8, 0xd9, 0xe8, 0xb0, 0xdf, 0x1b, 0x3c, 0x1a, 0xf4,
- 0xf7, 0xdd, 0x2b, 0x08, 0x20, 0x3f, 0x1a, 0x3c, 0x7b, 0xfc, 0xb4, 0xef, 0x5a, 0xc8, 0x81, 0xdc,
- 0xc1, 0xd1, 0xd3, 0xf1, 0xc0, 0xcd, 0xa8, 0xe5, 0xf8, 0xf9, 0xf0, 0xb0, 0xe7, 0xda, 0x0f, 0xbe,
- 0x81, 0x52, 0x4f, 0xbf, 0x81, 0x87, 0x3c, 0x24, 0x5c, 0x6d, 0x78, 0x36, 0xc4, 0x07, 0xbb, 0x4f,
- 0xdd, 0x2b, 0xa8, 0x00, 0xf6, 0x21, 0x56, 0x3b, 0x8b, 0x90, 0x3d, 0x1c, 0x8e, 0xc6, 0x6e, 0x06,
- 0x55, 0x01, 0x76, 0x8f, 0xc6, 0xc3, 0xde, 0xf0, 0xe0, 0x60, 0x30, 0x76, 0xed, 0xbd, 0xaf, 0xa0,
- 0x46, 0x59, 0x67, 0x41, 0x25, 0x11, 0xc2, 0x3c, 0xf1, 0x7f, 0xb8, 0x9d, 0x48, 0x94, 0x75, 0xcd,
- 0xaa, 0x3b, 0x65, 0xdd, 0x85, 0xec, 0x6a, 0x6b, 0xd7, 0xb4, 0xe6, 0x8b, 0xbc, 0x96, 0xbe, 0xf8,
- 0x3b, 0x00, 0x00, 0xff, 0xff, 0x0a, 0x94, 0x91, 0x45, 0x62, 0x0c, 0x00, 0x00,
+func (x *Session_ShardSession) GetReservedId() int64 {
+ if x != nil {
+ return x.ReservedId
+ }
+ return 0
+}
+
+var File_vtgate_proto protoreflect.FileDescriptor
+
+var file_vtgate_proto_rawDesc = []byte{
+ 0x0a, 0x0c, 0x76, 0x74, 0x67, 0x61, 0x74, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x06,
+ 0x76, 0x74, 0x67, 0x61, 0x74, 0x65, 0x1a, 0x10, 0x62, 0x69, 0x6e, 0x6c, 0x6f, 0x67, 0x64, 0x61,
+ 0x74, 0x61, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x0b, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
+ 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x0e, 0x74, 0x6f, 0x70, 0x6f, 0x64, 0x61, 0x74, 0x61, 0x2e,
+ 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x0b, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x70, 0x72, 0x6f,
+ 0x74, 0x6f, 0x22, 0xa4, 0x09, 0x0a, 0x07, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x25,
+ 0x0a, 0x0e, 0x69, 0x6e, 0x5f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e,
+ 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0d, 0x69, 0x6e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61,
+ 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x43, 0x0a, 0x0e, 0x73, 0x68, 0x61, 0x72, 0x64, 0x5f, 0x73,
+ 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1c, 0x2e,
+ 0x76, 0x74, 0x67, 0x61, 0x74, 0x65, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x53,
+ 0x68, 0x61, 0x72, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x0d, 0x73, 0x68, 0x61,
+ 0x72, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x1e, 0x0a, 0x0a, 0x61, 0x75,
+ 0x74, 0x6f, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0a,
+ 0x61, 0x75, 0x74, 0x6f, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x12, 0x23, 0x0a, 0x0d, 0x74, 0x61,
+ 0x72, 0x67, 0x65, 0x74, 0x5f, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x18, 0x05, 0x20, 0x01, 0x28,
+ 0x09, 0x52, 0x0c, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x12,
+ 0x2f, 0x0a, 0x07, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b,
+ 0x32, 0x15, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x65,
+ 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x07, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73,
+ 0x12, 0x42, 0x0a, 0x10, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f,
+ 0x6d, 0x6f, 0x64, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x17, 0x2e, 0x76, 0x74, 0x67,
+ 0x61, 0x74, 0x65, 0x2e, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4d,
+ 0x6f, 0x64, 0x65, 0x52, 0x0f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e,
+ 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x2f, 0x0a, 0x08, 0x77, 0x61, 0x72, 0x6e, 0x69, 0x6e, 0x67, 0x73,
+ 0x18, 0x08, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x13, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x51,
+ 0x75, 0x65, 0x72, 0x79, 0x57, 0x61, 0x72, 0x6e, 0x69, 0x6e, 0x67, 0x52, 0x08, 0x77, 0x61, 0x72,
+ 0x6e, 0x69, 0x6e, 0x67, 0x73, 0x12, 0x3f, 0x0a, 0x0c, 0x70, 0x72, 0x65, 0x5f, 0x73, 0x65, 0x73,
+ 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x09, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x76, 0x74,
+ 0x67, 0x61, 0x74, 0x65, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x53, 0x68, 0x61,
+ 0x72, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x0b, 0x70, 0x72, 0x65, 0x53, 0x65,
+ 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x41, 0x0a, 0x0d, 0x70, 0x6f, 0x73, 0x74, 0x5f, 0x73,
+ 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x0a, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1c, 0x2e,
+ 0x76, 0x74, 0x67, 0x61, 0x74, 0x65, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x53,
+ 0x68, 0x61, 0x72, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x0c, 0x70, 0x6f, 0x73,
+ 0x74, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x24, 0x0a, 0x0e, 0x6c, 0x61, 0x73,
+ 0x74, 0x5f, 0x69, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x0b, 0x20, 0x01, 0x28,
+ 0x04, 0x52, 0x0c, 0x6c, 0x61, 0x73, 0x74, 0x49, 0x6e, 0x73, 0x65, 0x72, 0x74, 0x49, 0x64, 0x12,
+ 0x1d, 0x0a, 0x0a, 0x66, 0x6f, 0x75, 0x6e, 0x64, 0x5f, 0x72, 0x6f, 0x77, 0x73, 0x18, 0x0c, 0x20,
+ 0x01, 0x28, 0x04, 0x52, 0x09, 0x66, 0x6f, 0x75, 0x6e, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x12, 0x5f,
+ 0x0a, 0x16, 0x75, 0x73, 0x65, 0x72, 0x5f, 0x64, 0x65, 0x66, 0x69, 0x6e, 0x65, 0x64, 0x5f, 0x76,
+ 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x18, 0x0d, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x29,
+ 0x2e, 0x76, 0x74, 0x67, 0x61, 0x74, 0x65, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e,
+ 0x55, 0x73, 0x65, 0x72, 0x44, 0x65, 0x66, 0x69, 0x6e, 0x65, 0x64, 0x56, 0x61, 0x72, 0x69, 0x61,
+ 0x62, 0x6c, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x14, 0x75, 0x73, 0x65, 0x72, 0x44,
+ 0x65, 0x66, 0x69, 0x6e, 0x65, 0x64, 0x56, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x12,
+ 0x4f, 0x0a, 0x10, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x5f, 0x76, 0x61, 0x72, 0x69, 0x61, 0x62,
+ 0x6c, 0x65, 0x73, 0x18, 0x0e, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x24, 0x2e, 0x76, 0x74, 0x67, 0x61,
+ 0x74, 0x65, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x53, 0x79, 0x73, 0x74, 0x65,
+ 0x6d, 0x56, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52,
+ 0x0f, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x56, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73,
+ 0x12, 0x1b, 0x0a, 0x09, 0x72, 0x6f, 0x77, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x0f, 0x20,
+ 0x01, 0x28, 0x03, 0x52, 0x08, 0x72, 0x6f, 0x77, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x1e, 0x0a,
+ 0x0a, 0x73, 0x61, 0x76, 0x65, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x73, 0x18, 0x10, 0x20, 0x03, 0x28,
+ 0x09, 0x52, 0x0a, 0x73, 0x61, 0x76, 0x65, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x73, 0x12, 0x28, 0x0a,
+ 0x10, 0x69, 0x6e, 0x5f, 0x72, 0x65, 0x73, 0x65, 0x72, 0x76, 0x65, 0x64, 0x5f, 0x63, 0x6f, 0x6e,
+ 0x6e, 0x18, 0x11, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0e, 0x69, 0x6e, 0x52, 0x65, 0x73, 0x65, 0x72,
+ 0x76, 0x65, 0x64, 0x43, 0x6f, 0x6e, 0x6e, 0x1a, 0xb7, 0x01, 0x0a, 0x0c, 0x53, 0x68, 0x61, 0x72,
+ 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x25, 0x0a, 0x06, 0x74, 0x61, 0x72, 0x67,
+ 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0d, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79,
+ 0x2e, 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x52, 0x06, 0x74, 0x61, 0x72, 0x67, 0x65, 0x74, 0x12,
+ 0x25, 0x0a, 0x0e, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69,
+ 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0d, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63,
+ 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x38, 0x0a, 0x0c, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x74,
+ 0x5f, 0x61, 0x6c, 0x69, 0x61, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x15, 0x2e, 0x74,
+ 0x6f, 0x70, 0x6f, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x74, 0x41, 0x6c,
+ 0x69, 0x61, 0x73, 0x52, 0x0b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x74, 0x41, 0x6c, 0x69, 0x61, 0x73,
+ 0x12, 0x1f, 0x0a, 0x0b, 0x72, 0x65, 0x73, 0x65, 0x72, 0x76, 0x65, 0x64, 0x5f, 0x69, 0x64, 0x18,
+ 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0a, 0x72, 0x65, 0x73, 0x65, 0x72, 0x76, 0x65, 0x64, 0x49,
+ 0x64, 0x1a, 0x5c, 0x0a, 0x19, 0x55, 0x73, 0x65, 0x72, 0x44, 0x65, 0x66, 0x69, 0x6e, 0x65, 0x64,
+ 0x56, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10,
+ 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79,
+ 0x12, 0x29, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32,
+ 0x13, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x42, 0x69, 0x6e, 0x64, 0x56, 0x61, 0x72, 0x69,
+ 0x61, 0x62, 0x6c, 0x65, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x1a,
+ 0x42, 0x0a, 0x14, 0x53, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x56, 0x61, 0x72, 0x69, 0x61, 0x62, 0x6c,
+ 0x65, 0x73, 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, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a,
+ 0x02, 0x38, 0x01, 0x4a, 0x04, 0x08, 0x03, 0x10, 0x04, 0x22, 0xa7, 0x02, 0x0a, 0x0e, 0x45, 0x78,
+ 0x65, 0x63, 0x75, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x2c, 0x0a, 0x09,
+ 0x63, 0x61, 0x6c, 0x6c, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
+ 0x0f, 0x2e, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x43, 0x61, 0x6c, 0x6c, 0x65, 0x72, 0x49, 0x44,
+ 0x52, 0x08, 0x63, 0x61, 0x6c, 0x6c, 0x65, 0x72, 0x49, 0x64, 0x12, 0x29, 0x0a, 0x07, 0x73, 0x65,
+ 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x76, 0x74,
+ 0x67, 0x61, 0x74, 0x65, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x73, 0x65,
+ 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x27, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x03,
+ 0x20, 0x01, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x42, 0x6f, 0x75,
+ 0x6e, 0x64, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x12, 0x35,
+ 0x0a, 0x0b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x74, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x04, 0x20,
+ 0x01, 0x28, 0x0e, 0x32, 0x14, 0x2e, 0x74, 0x6f, 0x70, 0x6f, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x54,
+ 0x61, 0x62, 0x6c, 0x65, 0x74, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0a, 0x74, 0x61, 0x62, 0x6c, 0x65,
+ 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x6b, 0x65, 0x79, 0x73, 0x70, 0x61, 0x63,
+ 0x65, 0x5f, 0x73, 0x68, 0x61, 0x72, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6b,
+ 0x65, 0x79, 0x73, 0x70, 0x61, 0x63, 0x65, 0x53, 0x68, 0x61, 0x72, 0x64, 0x12, 0x2f, 0x0a, 0x07,
+ 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x15, 0x2e,
+ 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x65, 0x4f, 0x70, 0x74,
+ 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x07, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x4a, 0x04, 0x08,
+ 0x05, 0x10, 0x06, 0x22, 0x8f, 0x01, 0x0a, 0x0f, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x65, 0x52,
+ 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x25, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72,
+ 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x52,
+ 0x50, 0x43, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x29,
+ 0x0a, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32,
+ 0x0f, 0x2e, 0x76, 0x74, 0x67, 0x61, 0x74, 0x65, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
+ 0x52, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x2a, 0x0a, 0x06, 0x72, 0x65, 0x73,
+ 0x75, 0x6c, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x71, 0x75, 0x65, 0x72,
+ 0x79, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x06, 0x72,
+ 0x65, 0x73, 0x75, 0x6c, 0x74, 0x22, 0xd1, 0x02, 0x0a, 0x13, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74,
+ 0x65, 0x42, 0x61, 0x74, 0x63, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x2c, 0x0a,
+ 0x09, 0x63, 0x61, 0x6c, 0x6c, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
+ 0x32, 0x0f, 0x2e, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x43, 0x61, 0x6c, 0x6c, 0x65, 0x72, 0x49,
+ 0x44, 0x52, 0x08, 0x63, 0x61, 0x6c, 0x6c, 0x65, 0x72, 0x49, 0x64, 0x12, 0x29, 0x0a, 0x07, 0x73,
+ 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x76,
+ 0x74, 0x67, 0x61, 0x74, 0x65, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x73,
+ 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x2b, 0x0a, 0x07, 0x71, 0x75, 0x65, 0x72, 0x69, 0x65,
+ 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
+ 0x42, 0x6f, 0x75, 0x6e, 0x64, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x07, 0x71, 0x75, 0x65, 0x72,
+ 0x69, 0x65, 0x73, 0x12, 0x35, 0x0a, 0x0b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x74, 0x5f, 0x74, 0x79,
+ 0x70, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x14, 0x2e, 0x74, 0x6f, 0x70, 0x6f, 0x64,
+ 0x61, 0x74, 0x61, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x74, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0a,
+ 0x74, 0x61, 0x62, 0x6c, 0x65, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x61, 0x73,
+ 0x5f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x05, 0x20, 0x01,
+ 0x28, 0x08, 0x52, 0x0d, 0x61, 0x73, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f,
+ 0x6e, 0x12, 0x25, 0x0a, 0x0e, 0x6b, 0x65, 0x79, 0x73, 0x70, 0x61, 0x63, 0x65, 0x5f, 0x73, 0x68,
+ 0x61, 0x72, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6b, 0x65, 0x79, 0x73, 0x70,
+ 0x61, 0x63, 0x65, 0x53, 0x68, 0x61, 0x72, 0x64, 0x12, 0x2f, 0x0a, 0x07, 0x6f, 0x70, 0x74, 0x69,
+ 0x6f, 0x6e, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x15, 0x2e, 0x71, 0x75, 0x65, 0x72,
+ 0x79, 0x2e, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73,
+ 0x52, 0x07, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x22, 0x9a, 0x01, 0x0a, 0x14, 0x45, 0x78,
+ 0x65, 0x63, 0x75, 0x74, 0x65, 0x42, 0x61, 0x74, 0x63, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
+ 0x73, 0x65, 0x12, 0x25, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28,
+ 0x0b, 0x32, 0x0f, 0x2e, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x52, 0x50, 0x43, 0x45, 0x72, 0x72,
+ 0x6f, 0x72, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x29, 0x0a, 0x07, 0x73, 0x65, 0x73,
+ 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x76, 0x74, 0x67,
+ 0x61, 0x74, 0x65, 0x2e, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x73, 0x65, 0x73,
+ 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x30, 0x0a, 0x07, 0x72, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x18,
+ 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x52, 0x65,
+ 0x73, 0x75, 0x6c, 0x74, 0x57, 0x69, 0x74, 0x68, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x07, 0x72,
+ 0x65, 0x73, 0x75, 0x6c, 0x74, 0x73, 0x22, 0xa7, 0x02, 0x0a, 0x14, 0x53, 0x74, 0x72, 0x65, 0x61,
+ 0x6d, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
+ 0x2c, 0x0a, 0x09, 0x63, 0x61, 0x6c, 0x6c, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01,
+ 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x43, 0x61, 0x6c, 0x6c, 0x65,
+ 0x72, 0x49, 0x44, 0x52, 0x08, 0x63, 0x61, 0x6c, 0x6c, 0x65, 0x72, 0x49, 0x64, 0x12, 0x27, 0x0a,
+ 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x71,
+ 0x75, 0x65, 0x72, 0x79, 0x2e, 0x42, 0x6f, 0x75, 0x6e, 0x64, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52,
+ 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x12, 0x35, 0x0a, 0x0b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x74,
+ 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x14, 0x2e, 0x74, 0x6f,
+ 0x70, 0x6f, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x74, 0x54, 0x79, 0x70,
+ 0x65, 0x52, 0x0a, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x25, 0x0a,
+ 0x0e, 0x6b, 0x65, 0x79, 0x73, 0x70, 0x61, 0x63, 0x65, 0x5f, 0x73, 0x68, 0x61, 0x72, 0x64, 0x18,
+ 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6b, 0x65, 0x79, 0x73, 0x70, 0x61, 0x63, 0x65, 0x53,
+ 0x68, 0x61, 0x72, 0x64, 0x12, 0x2f, 0x0a, 0x07, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18,
+ 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x15, 0x2e, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x45, 0x78,
+ 0x65, 0x63, 0x75, 0x74, 0x65, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x07, 0x6f, 0x70,
+ 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x29, 0x0a, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
+ 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x76, 0x74, 0x67, 0x61, 0x74, 0x65, 0x2e,
+ 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
+ 0x22, 0x43, 0x0a, 0x15, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x45, 0x78, 0x65, 0x63, 0x75, 0x74,
+ 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2a, 0x0a, 0x06, 0x72, 0x65, 0x73,
+ 0x75, 0x6c, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x71, 0x75, 0x65, 0x72,
+ 0x79, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x52, 0x06, 0x72,
+ 0x65, 0x73, 0x75, 0x6c, 0x74, 0x22, 0x5d, 0x0a, 0x19, 0x52, 0x65, 0x73, 0x6f, 0x6c, 0x76, 0x65,
+ 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65,
+ 0x73, 0x74, 0x12, 0x2c, 0x0a, 0x09, 0x63, 0x61, 0x6c, 0x6c, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18,
+ 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x76, 0x74, 0x72, 0x70, 0x63, 0x2e, 0x43, 0x61,
+ 0x6c, 0x6c, 0x65, 0x72, 0x49, 0x44, 0x52, 0x08, 0x63, 0x61, 0x6c, 0x6c, 0x65, 0x72, 0x49, 0x64,
+ 0x12, 0x12, 0x0a, 0x04, 0x64, 0x74, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04,
+ 0x64, 0x74, 0x69, 0x64, 0x22, 0x1c, 0x0a, 0x1a, 0x52, 0x65, 0x73, 0x6f, 0x6c, 0x76, 0x65, 0x54,
+ 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
+ 0x73, 0x65, 0x22, 0xca, 0x01, 0x0a, 0x0e, 0x56, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65,
+ 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x2c, 0x0a, 0x09, 0x63, 0x61, 0x6c, 0x6c, 0x65, 0x72, 0x5f,
+ 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x76, 0x74, 0x72, 0x70, 0x63,
+ 0x2e, 0x43, 0x61, 0x6c, 0x6c, 0x65, 0x72, 0x49, 0x44, 0x52, 0x08, 0x63, 0x61, 0x6c, 0x6c, 0x65,
+ 0x72, 0x49, 0x64, 0x12, 0x35, 0x0a, 0x0b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x74, 0x5f, 0x74, 0x79,
+ 0x70, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x14, 0x2e, 0x74, 0x6f, 0x70, 0x6f, 0x64,
+ 0x61, 0x74, 0x61, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x74, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0a,
+ 0x74, 0x61, 0x62, 0x6c, 0x65, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x27, 0x0a, 0x05, 0x76, 0x67,
+ 0x74, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x62, 0x69, 0x6e, 0x6c,
+ 0x6f, 0x67, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x56, 0x47, 0x74, 0x69, 0x64, 0x52, 0x05, 0x76, 0x67,
+ 0x74, 0x69, 0x64, 0x12, 0x2a, 0x0a, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x18, 0x04, 0x20,
+ 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x62, 0x69, 0x6e, 0x6c, 0x6f, 0x67, 0x64, 0x61, 0x74, 0x61,
+ 0x2e, 0x46, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x52, 0x06, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x22,
+ 0x3d, 0x0a, 0x0f, 0x56, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
+ 0x73, 0x65, 0x12, 0x2a, 0x0a, 0x06, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x18, 0x01, 0x20, 0x03,
+ 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x62, 0x69, 0x6e, 0x6c, 0x6f, 0x67, 0x64, 0x61, 0x74, 0x61, 0x2e,
+ 0x56, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x52, 0x06, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x2a, 0x44,
+ 0x0a, 0x0f, 0x54, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4d, 0x6f, 0x64,
+ 0x65, 0x12, 0x0f, 0x0a, 0x0b, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44,
+ 0x10, 0x00, 0x12, 0x0a, 0x0a, 0x06, 0x53, 0x49, 0x4e, 0x47, 0x4c, 0x45, 0x10, 0x01, 0x12, 0x09,
+ 0x0a, 0x05, 0x4d, 0x55, 0x4c, 0x54, 0x49, 0x10, 0x02, 0x12, 0x09, 0x0a, 0x05, 0x54, 0x57, 0x4f,
+ 0x50, 0x43, 0x10, 0x03, 0x2a, 0x3c, 0x0a, 0x0b, 0x43, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x4f, 0x72,
+ 0x64, 0x65, 0x72, 0x12, 0x0a, 0x0a, 0x06, 0x4e, 0x4f, 0x52, 0x4d, 0x41, 0x4c, 0x10, 0x00, 0x12,
+ 0x07, 0x0a, 0x03, 0x50, 0x52, 0x45, 0x10, 0x01, 0x12, 0x08, 0x0a, 0x04, 0x50, 0x4f, 0x53, 0x54,
+ 0x10, 0x02, 0x12, 0x0e, 0x0a, 0x0a, 0x41, 0x55, 0x54, 0x4f, 0x43, 0x4f, 0x4d, 0x4d, 0x49, 0x54,
+ 0x10, 0x03, 0x42, 0x36, 0x0a, 0x0f, 0x69, 0x6f, 0x2e, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e,
+ 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x5a, 0x23, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2e, 0x69, 0x6f,
+ 0x2f, 0x76, 0x69, 0x74, 0x65, 0x73, 0x73, 0x2f, 0x67, 0x6f, 0x2f, 0x76, 0x74, 0x2f, 0x70, 0x72,
+ 0x6f, 0x74, 0x6f, 0x2f, 0x76, 0x74, 0x67, 0x61, 0x74, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
+ 0x6f, 0x33,
+}
+
+var (
+ file_vtgate_proto_rawDescOnce sync.Once
+ file_vtgate_proto_rawDescData = file_vtgate_proto_rawDesc
+)
+
+func file_vtgate_proto_rawDescGZIP() []byte {
+ file_vtgate_proto_rawDescOnce.Do(func() {
+ file_vtgate_proto_rawDescData = protoimpl.X.CompressGZIP(file_vtgate_proto_rawDescData)
+ })
+ return file_vtgate_proto_rawDescData
+}
+
+var file_vtgate_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
+var file_vtgate_proto_msgTypes = make([]protoimpl.MessageInfo, 14)
+var file_vtgate_proto_goTypes = []interface{}{
+ (TransactionMode)(0), // 0: vtgate.TransactionMode
+ (CommitOrder)(0), // 1: vtgate.CommitOrder
+ (*Session)(nil), // 2: vtgate.Session
+ (*ExecuteRequest)(nil), // 3: vtgate.ExecuteRequest
+ (*ExecuteResponse)(nil), // 4: vtgate.ExecuteResponse
+ (*ExecuteBatchRequest)(nil), // 5: vtgate.ExecuteBatchRequest
+ (*ExecuteBatchResponse)(nil), // 6: vtgate.ExecuteBatchResponse
+ (*StreamExecuteRequest)(nil), // 7: vtgate.StreamExecuteRequest
+ (*StreamExecuteResponse)(nil), // 8: vtgate.StreamExecuteResponse
+ (*ResolveTransactionRequest)(nil), // 9: vtgate.ResolveTransactionRequest
+ (*ResolveTransactionResponse)(nil), // 10: vtgate.ResolveTransactionResponse
+ (*VStreamRequest)(nil), // 11: vtgate.VStreamRequest
+ (*VStreamResponse)(nil), // 12: vtgate.VStreamResponse
+ (*Session_ShardSession)(nil), // 13: vtgate.Session.ShardSession
+ nil, // 14: vtgate.Session.UserDefinedVariablesEntry
+ nil, // 15: vtgate.Session.SystemVariablesEntry
+ (*query.ExecuteOptions)(nil), // 16: query.ExecuteOptions
+ (*query.QueryWarning)(nil), // 17: query.QueryWarning
+ (*vtrpc.CallerID)(nil), // 18: vtrpc.CallerID
+ (*query.BoundQuery)(nil), // 19: query.BoundQuery
+ (topodata.TabletType)(0), // 20: topodata.TabletType
+ (*vtrpc.RPCError)(nil), // 21: vtrpc.RPCError
+ (*query.QueryResult)(nil), // 22: query.QueryResult
+ (*query.ResultWithError)(nil), // 23: query.ResultWithError
+ (*binlogdata.VGtid)(nil), // 24: binlogdata.VGtid
+ (*binlogdata.Filter)(nil), // 25: binlogdata.Filter
+ (*binlogdata.VEvent)(nil), // 26: binlogdata.VEvent
+ (*query.Target)(nil), // 27: query.Target
+ (*topodata.TabletAlias)(nil), // 28: topodata.TabletAlias
+ (*query.BindVariable)(nil), // 29: query.BindVariable
+}
+var file_vtgate_proto_depIdxs = []int32{
+ 13, // 0: vtgate.Session.shard_sessions:type_name -> vtgate.Session.ShardSession
+ 16, // 1: vtgate.Session.options:type_name -> query.ExecuteOptions
+ 0, // 2: vtgate.Session.transaction_mode:type_name -> vtgate.TransactionMode
+ 17, // 3: vtgate.Session.warnings:type_name -> query.QueryWarning
+ 13, // 4: vtgate.Session.pre_sessions:type_name -> vtgate.Session.ShardSession
+ 13, // 5: vtgate.Session.post_sessions:type_name -> vtgate.Session.ShardSession
+ 14, // 6: vtgate.Session.user_defined_variables:type_name -> vtgate.Session.UserDefinedVariablesEntry
+ 15, // 7: vtgate.Session.system_variables:type_name -> vtgate.Session.SystemVariablesEntry
+ 18, // 8: vtgate.ExecuteRequest.caller_id:type_name -> vtrpc.CallerID
+ 2, // 9: vtgate.ExecuteRequest.session:type_name -> vtgate.Session
+ 19, // 10: vtgate.ExecuteRequest.query:type_name -> query.BoundQuery
+ 20, // 11: vtgate.ExecuteRequest.tablet_type:type_name -> topodata.TabletType
+ 16, // 12: vtgate.ExecuteRequest.options:type_name -> query.ExecuteOptions
+ 21, // 13: vtgate.ExecuteResponse.error:type_name -> vtrpc.RPCError
+ 2, // 14: vtgate.ExecuteResponse.session:type_name -> vtgate.Session
+ 22, // 15: vtgate.ExecuteResponse.result:type_name -> query.QueryResult
+ 18, // 16: vtgate.ExecuteBatchRequest.caller_id:type_name -> vtrpc.CallerID
+ 2, // 17: vtgate.ExecuteBatchRequest.session:type_name -> vtgate.Session
+ 19, // 18: vtgate.ExecuteBatchRequest.queries:type_name -> query.BoundQuery
+ 20, // 19: vtgate.ExecuteBatchRequest.tablet_type:type_name -> topodata.TabletType
+ 16, // 20: vtgate.ExecuteBatchRequest.options:type_name -> query.ExecuteOptions
+ 21, // 21: vtgate.ExecuteBatchResponse.error:type_name -> vtrpc.RPCError
+ 2, // 22: vtgate.ExecuteBatchResponse.session:type_name -> vtgate.Session
+ 23, // 23: vtgate.ExecuteBatchResponse.results:type_name -> query.ResultWithError
+ 18, // 24: vtgate.StreamExecuteRequest.caller_id:type_name -> vtrpc.CallerID
+ 19, // 25: vtgate.StreamExecuteRequest.query:type_name -> query.BoundQuery
+ 20, // 26: vtgate.StreamExecuteRequest.tablet_type:type_name -> topodata.TabletType
+ 16, // 27: vtgate.StreamExecuteRequest.options:type_name -> query.ExecuteOptions
+ 2, // 28: vtgate.StreamExecuteRequest.session:type_name -> vtgate.Session
+ 22, // 29: vtgate.StreamExecuteResponse.result:type_name -> query.QueryResult
+ 18, // 30: vtgate.ResolveTransactionRequest.caller_id:type_name -> vtrpc.CallerID
+ 18, // 31: vtgate.VStreamRequest.caller_id:type_name -> vtrpc.CallerID
+ 20, // 32: vtgate.VStreamRequest.tablet_type:type_name -> topodata.TabletType
+ 24, // 33: vtgate.VStreamRequest.vgtid:type_name -> binlogdata.VGtid
+ 25, // 34: vtgate.VStreamRequest.filter:type_name -> binlogdata.Filter
+ 26, // 35: vtgate.VStreamResponse.events:type_name -> binlogdata.VEvent
+ 27, // 36: vtgate.Session.ShardSession.target:type_name -> query.Target
+ 28, // 37: vtgate.Session.ShardSession.tablet_alias:type_name -> topodata.TabletAlias
+ 29, // 38: vtgate.Session.UserDefinedVariablesEntry.value:type_name -> query.BindVariable
+ 39, // [39:39] is the sub-list for method output_type
+ 39, // [39:39] is the sub-list for method input_type
+ 39, // [39:39] is the sub-list for extension type_name
+ 39, // [39:39] is the sub-list for extension extendee
+ 0, // [0:39] is the sub-list for field type_name
+}
+
+func init() { file_vtgate_proto_init() }
+func file_vtgate_proto_init() {
+ if File_vtgate_proto != nil {
+ return
+ }
+ if !protoimpl.UnsafeEnabled {
+ file_vtgate_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*Session); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_vtgate_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*ExecuteRequest); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_vtgate_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*ExecuteResponse); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_vtgate_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*ExecuteBatchRequest); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_vtgate_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*ExecuteBatchResponse); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_vtgate_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*StreamExecuteRequest); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_vtgate_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*StreamExecuteResponse); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_vtgate_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*ResolveTransactionRequest); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_vtgate_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*ResolveTransactionResponse); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_vtgate_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*VStreamRequest); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_vtgate_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*VStreamResponse); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ file_vtgate_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
+ switch v := v.(*Session_ShardSession); i {
+ case 0:
+ return &v.state
+ case 1:
+ return &v.sizeCache
+ case 2:
+ return &v.unknownFields
+ default:
+ return nil
+ }
+ }
+ }
+ type x struct{}
+ out := protoimpl.TypeBuilder{
+ File: protoimpl.DescBuilder{
+ GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+ RawDescriptor: file_vtgate_proto_rawDesc,
+ NumEnums: 2,
+ NumMessages: 14,
+ NumExtensions: 0,
+ NumServices: 0,
+ },
+ GoTypes: file_vtgate_proto_goTypes,
+ DependencyIndexes: file_vtgate_proto_depIdxs,
+ EnumInfos: file_vtgate_proto_enumTypes,
+ MessageInfos: file_vtgate_proto_msgTypes,
+ }.Build()
+ File_vtgate_proto = out.File
+ file_vtgate_proto_rawDesc = nil
+ file_vtgate_proto_goTypes = nil
+ file_vtgate_proto_depIdxs = nil
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment