Documentation

Index

Constants

This section is empty.

Variables

View Source
var ExecuteOptions_IncludedFields_name = map[int32]string{
	0: "TYPE_AND_NAME",
	1: "TYPE_ONLY",
	2: "ALL",
}
View Source
var ExecuteOptions_IncludedFields_value = map[string]int32{
	"TYPE_AND_NAME": 0,
	"TYPE_ONLY":     1,
	"ALL":           2,
}
View Source
var ExecuteOptions_TransactionIsolation_name = map[int32]string{
	0: "DEFAULT",
	1: "REPEATABLE_READ",
	2: "READ_COMMITTED",
	3: "READ_UNCOMMITTED",
	4: "SERIALIZABLE",
	5: "CONSISTENT_SNAPSHOT_READ_ONLY",
}
View Source
var ExecuteOptions_TransactionIsolation_value = map[string]int32{
	"DEFAULT":                       0,
	"REPEATABLE_READ":               1,
	"READ_COMMITTED":                2,
	"READ_UNCOMMITTED":              3,
	"SERIALIZABLE":                  4,
	"CONSISTENT_SNAPSHOT_READ_ONLY": 5,
}
View Source
var ExecuteOptions_Workload_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "OLTP",
	2: "OLAP",
	3: "DBA",
}
View Source
var ExecuteOptions_Workload_value = map[string]int32{
	"UNSPECIFIED": 0,
	"OLTP":        1,
	"OLAP":        2,
	"DBA":         3,
}
View Source
var Flag_name = map[int32]string{
	0:    "NONE",
	256:  "ISINTEGRAL",
	512:  "ISUNSIGNED",
	1024: "ISFLOAT",
	2048: "ISQUOTED",
	4096: "ISTEXT",
	8192: "ISBINARY",
}
View Source
var Flag_value = map[string]int32{
	"NONE":       0,
	"ISINTEGRAL": 256,
	"ISUNSIGNED": 512,
	"ISFLOAT":    1024,
	"ISQUOTED":   2048,
	"ISTEXT":     4096,
	"ISBINARY":   8192,
}
View Source
var MySqlFlag_name = map[int32]string{
	0:     "EMPTY",
	1:     "NOT_NULL_FLAG",
	2:     "PRI_KEY_FLAG",
	4:     "UNIQUE_KEY_FLAG",
	8:     "MULTIPLE_KEY_FLAG",
	16:    "BLOB_FLAG",
	32:    "UNSIGNED_FLAG",
	64:    "ZEROFILL_FLAG",
	128:   "BINARY_FLAG",
	256:   "ENUM_FLAG",
	512:   "AUTO_INCREMENT_FLAG",
	1024:  "TIMESTAMP_FLAG",
	2048:  "SET_FLAG",
	4096:  "NO_DEFAULT_VALUE_FLAG",
	8192:  "ON_UPDATE_NOW_FLAG",
	32768: "NUM_FLAG",
	16384: "PART_KEY_FLAG",

	65536:  "UNIQUE_FLAG",
	131072: "BINCMP_FLAG",
}
View Source
var MySqlFlag_value = map[string]int32{
	"EMPTY":                 0,
	"NOT_NULL_FLAG":         1,
	"PRI_KEY_FLAG":          2,
	"UNIQUE_KEY_FLAG":       4,
	"MULTIPLE_KEY_FLAG":     8,
	"BLOB_FLAG":             16,
	"UNSIGNED_FLAG":         32,
	"ZEROFILL_FLAG":         64,
	"BINARY_FLAG":           128,
	"ENUM_FLAG":             256,
	"AUTO_INCREMENT_FLAG":   512,
	"TIMESTAMP_FLAG":        1024,
	"SET_FLAG":              2048,
	"NO_DEFAULT_VALUE_FLAG": 4096,
	"ON_UPDATE_NOW_FLAG":    8192,
	"NUM_FLAG":              32768,
	"PART_KEY_FLAG":         16384,
	"GROUP_FLAG":            32768,
	"UNIQUE_FLAG":           65536,
	"BINCMP_FLAG":           131072,
}
View Source
var SplitQueryRequest_Algorithm_name = map[int32]string{
	0: "EQUAL_SPLITS",
	1: "FULL_SCAN",
}
View Source
var SplitQueryRequest_Algorithm_value = map[string]int32{
	"EQUAL_SPLITS": 0,
	"FULL_SCAN":    1,
}
View Source
var StreamEvent_Statement_Category_name = map[int32]string{
	0: "Error",
	1: "DML",
	2: "DDL",
}
View Source
var StreamEvent_Statement_Category_value = map[string]int32{
	"Error": 0,
	"DML":   1,
	"DDL":   2,
}
View Source
var TransactionState_name = map[int32]string{
	0: "UNKNOWN",
	1: "PREPARE",
	2: "COMMIT",
	3: "ROLLBACK",
}
View Source
var TransactionState_value = map[string]int32{
	"UNKNOWN":  0,
	"PREPARE":  1,
	"COMMIT":   2,
	"ROLLBACK": 3,
}
View Source
var Type_name = map[int32]string{
	0:     "NULL_TYPE",
	257:   "INT8",
	770:   "UINT8",
	259:   "INT16",
	772:   "UINT16",
	261:   "INT24",
	774:   "UINT24",
	263:   "INT32",
	776:   "UINT32",
	265:   "INT64",
	778:   "UINT64",
	1035:  "FLOAT32",
	1036:  "FLOAT64",
	2061:  "TIMESTAMP",
	2062:  "DATE",
	2063:  "TIME",
	2064:  "DATETIME",
	785:   "YEAR",
	18:    "DECIMAL",
	6163:  "TEXT",
	10260: "BLOB",
	6165:  "VARCHAR",
	10262: "VARBINARY",
	6167:  "CHAR",
	10264: "BINARY",
	2073:  "BIT",
	2074:  "ENUM",
	2075:  "SET",
	28:    "TUPLE",
	2077:  "GEOMETRY",
	2078:  "JSON",
	31:    "EXPRESSION",
}
View Source
var Type_value = map[string]int32{
	"NULL_TYPE":  0,
	"INT8":       257,
	"UINT8":      770,
	"INT16":      259,
	"UINT16":     772,
	"INT24":      261,
	"UINT24":     774,
	"INT32":      263,
	"UINT32":     776,
	"INT64":      265,
	"UINT64":     778,
	"FLOAT32":    1035,
	"FLOAT64":    1036,
	"TIMESTAMP":  2061,
	"DATE":       2062,
	"TIME":       2063,
	"DATETIME":   2064,
	"YEAR":       785,
	"DECIMAL":    18,
	"TEXT":       6163,
	"BLOB":       10260,
	"VARCHAR":    6165,
	"VARBINARY":  10262,
	"CHAR":       6167,
	"BINARY":     10264,
	"BIT":        2073,
	"ENUM":       2074,
	"SET":        2075,
	"TUPLE":      28,
	"GEOMETRY":   2077,
	"JSON":       2078,
	"EXPRESSION": 31,
}

Functions

This section is empty.

Types

type AggregateStats

type AggregateStats struct {
	// healthy_tablet_count is the number of healthy tablets in the group.
	HealthyTabletCount int32 `protobuf:"varint,1,opt,name=healthy_tablet_count,json=healthyTabletCount,proto3" json:"healthy_tablet_count,omitempty"`
	// unhealthy_tablet_count is the number of unhealthy tablets in the group.
	UnhealthyTabletCount int32 `protobuf:"varint,2,opt,name=unhealthy_tablet_count,json=unhealthyTabletCount,proto3" json:"unhealthy_tablet_count,omitempty"`
	// seconds_behind_master_min is the minimum of the
	// seconds_behind_master values of the healthy tablets. It is unset
	// if the tablet type is master.
	SecondsBehindMasterMin uint32 `` /* 132-byte string literal not displayed */
	// seconds_behind_master_max is the maximum of the
	// seconds_behind_master values of the healthy tablets. It is unset
	// if the tablet type is master.
	SecondsBehindMasterMax uint32   `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

    AggregateStats contains information about the health of a group of tablets for a Target. It is used to propagate stats from a vtgate to another, or from the Gateway layer of a vtgate to the routing layer.

    func (*AggregateStats) Descriptor

    func (*AggregateStats) Descriptor() ([]byte, []int)

    func (*AggregateStats) GetHealthyTabletCount

    func (m *AggregateStats) GetHealthyTabletCount() int32

    func (*AggregateStats) GetSecondsBehindMasterMax

    func (m *AggregateStats) GetSecondsBehindMasterMax() uint32

    func (*AggregateStats) GetSecondsBehindMasterMin

    func (m *AggregateStats) GetSecondsBehindMasterMin() uint32

    func (*AggregateStats) GetUnhealthyTabletCount

    func (m *AggregateStats) GetUnhealthyTabletCount() int32

    func (*AggregateStats) ProtoMessage

    func (*AggregateStats) ProtoMessage()

    func (*AggregateStats) Reset

    func (m *AggregateStats) Reset()

    func (*AggregateStats) String

    func (m *AggregateStats) String() string

    func (*AggregateStats) XXX_DiscardUnknown

    func (m *AggregateStats) XXX_DiscardUnknown()

    func (*AggregateStats) XXX_Marshal

    func (m *AggregateStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

    func (*AggregateStats) XXX_Merge

    func (dst *AggregateStats) XXX_Merge(src proto.Message)

    func (*AggregateStats) XXX_Size

    func (m *AggregateStats) XXX_Size() int

    func (*AggregateStats) XXX_Unmarshal

    func (m *AggregateStats) XXX_Unmarshal(b []byte) error

    type BeginExecuteBatchRequest

    type BeginExecuteBatchRequest struct {
    	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
    	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
    	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
    	Queries              []*BoundQuery   `protobuf:"bytes,4,rep,name=queries,proto3" json:"queries,omitempty"`
    	AsTransaction        bool            `protobuf:"varint,5,opt,name=as_transaction,json=asTransaction,proto3" json:"as_transaction,omitempty"`
    	Options              *ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
    	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    	XXX_unrecognized     []byte          `json:"-"`
    	XXX_sizecache        int32           `json:"-"`
    }

      BeginExecuteBatchRequest is the payload to BeginExecuteBatch

      func (*BeginExecuteBatchRequest) Descriptor

      func (*BeginExecuteBatchRequest) Descriptor() ([]byte, []int)

      func (*BeginExecuteBatchRequest) GetAsTransaction

      func (m *BeginExecuteBatchRequest) GetAsTransaction() bool

      func (*BeginExecuteBatchRequest) GetEffectiveCallerId

      func (m *BeginExecuteBatchRequest) GetEffectiveCallerId() *vtrpc.CallerID

      func (*BeginExecuteBatchRequest) GetImmediateCallerId

      func (m *BeginExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID

      func (*BeginExecuteBatchRequest) GetOptions

      func (m *BeginExecuteBatchRequest) GetOptions() *ExecuteOptions

      func (*BeginExecuteBatchRequest) GetQueries

      func (m *BeginExecuteBatchRequest) GetQueries() []*BoundQuery

      func (*BeginExecuteBatchRequest) GetTarget

      func (m *BeginExecuteBatchRequest) GetTarget() *Target

      func (*BeginExecuteBatchRequest) ProtoMessage

      func (*BeginExecuteBatchRequest) ProtoMessage()

      func (*BeginExecuteBatchRequest) Reset

      func (m *BeginExecuteBatchRequest) Reset()

      func (*BeginExecuteBatchRequest) String

      func (m *BeginExecuteBatchRequest) String() string

      func (*BeginExecuteBatchRequest) XXX_DiscardUnknown

      func (m *BeginExecuteBatchRequest) XXX_DiscardUnknown()

      func (*BeginExecuteBatchRequest) XXX_Marshal

      func (m *BeginExecuteBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

      func (*BeginExecuteBatchRequest) XXX_Merge

      func (dst *BeginExecuteBatchRequest) XXX_Merge(src proto.Message)

      func (*BeginExecuteBatchRequest) XXX_Size

      func (m *BeginExecuteBatchRequest) XXX_Size() int

      func (*BeginExecuteBatchRequest) XXX_Unmarshal

      func (m *BeginExecuteBatchRequest) XXX_Unmarshal(b []byte) error

      type BeginExecuteBatchResponse

      type BeginExecuteBatchResponse struct {
      	// error contains an application level error if necessary. Note the
      	// transaction_id may be set, even when an error is returned, if the begin
      	// worked but the execute failed.
      	Error   *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
      	Results []*QueryResult  `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
      	// transaction_id might be non-zero even if an error is present.
      	TransactionId        int64    `protobuf:"varint,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

        BeginExecuteBatchResponse is the returned value from BeginExecuteBatch

        func (*BeginExecuteBatchResponse) Descriptor

        func (*BeginExecuteBatchResponse) Descriptor() ([]byte, []int)

        func (*BeginExecuteBatchResponse) GetError

        func (m *BeginExecuteBatchResponse) GetError() *vtrpc.RPCError

        func (*BeginExecuteBatchResponse) GetResults

        func (m *BeginExecuteBatchResponse) GetResults() []*QueryResult

        func (*BeginExecuteBatchResponse) GetTransactionId

        func (m *BeginExecuteBatchResponse) GetTransactionId() int64

        func (*BeginExecuteBatchResponse) ProtoMessage

        func (*BeginExecuteBatchResponse) ProtoMessage()

        func (*BeginExecuteBatchResponse) Reset

        func (m *BeginExecuteBatchResponse) Reset()

        func (*BeginExecuteBatchResponse) String

        func (m *BeginExecuteBatchResponse) String() string

        func (*BeginExecuteBatchResponse) XXX_DiscardUnknown

        func (m *BeginExecuteBatchResponse) XXX_DiscardUnknown()

        func (*BeginExecuteBatchResponse) XXX_Marshal

        func (m *BeginExecuteBatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

        func (*BeginExecuteBatchResponse) XXX_Merge

        func (dst *BeginExecuteBatchResponse) XXX_Merge(src proto.Message)

        func (*BeginExecuteBatchResponse) XXX_Size

        func (m *BeginExecuteBatchResponse) XXX_Size() int

        func (*BeginExecuteBatchResponse) XXX_Unmarshal

        func (m *BeginExecuteBatchResponse) XXX_Unmarshal(b []byte) error

        type BeginExecuteRequest

        type BeginExecuteRequest struct {
        	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
        	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
        	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
        	Query                *BoundQuery     `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
        	Options              *ExecuteOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
        	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
        	XXX_unrecognized     []byte          `json:"-"`
        	XXX_sizecache        int32           `json:"-"`
        }

          BeginExecuteRequest is the payload to BeginExecute

          func (*BeginExecuteRequest) Descriptor

          func (*BeginExecuteRequest) Descriptor() ([]byte, []int)

          func (*BeginExecuteRequest) GetEffectiveCallerId

          func (m *BeginExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

          func (*BeginExecuteRequest) GetImmediateCallerId

          func (m *BeginExecuteRequest) GetImmediateCallerId() *VTGateCallerID

          func (*BeginExecuteRequest) GetOptions

          func (m *BeginExecuteRequest) GetOptions() *ExecuteOptions

          func (*BeginExecuteRequest) GetQuery

          func (m *BeginExecuteRequest) GetQuery() *BoundQuery

          func (*BeginExecuteRequest) GetTarget

          func (m *BeginExecuteRequest) GetTarget() *Target

          func (*BeginExecuteRequest) ProtoMessage

          func (*BeginExecuteRequest) ProtoMessage()

          func (*BeginExecuteRequest) Reset

          func (m *BeginExecuteRequest) Reset()

          func (*BeginExecuteRequest) String

          func (m *BeginExecuteRequest) String() string

          func (*BeginExecuteRequest) XXX_DiscardUnknown

          func (m *BeginExecuteRequest) XXX_DiscardUnknown()

          func (*BeginExecuteRequest) XXX_Marshal

          func (m *BeginExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

          func (*BeginExecuteRequest) XXX_Merge

          func (dst *BeginExecuteRequest) XXX_Merge(src proto.Message)

          func (*BeginExecuteRequest) XXX_Size

          func (m *BeginExecuteRequest) XXX_Size() int

          func (*BeginExecuteRequest) XXX_Unmarshal

          func (m *BeginExecuteRequest) XXX_Unmarshal(b []byte) error

          type BeginExecuteResponse

          type BeginExecuteResponse struct {
          	// error contains an application level error if necessary. Note the
          	// transaction_id may be set, even when an error is returned, if the begin
          	// worked but the execute failed.
          	Error  *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
          	Result *QueryResult    `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
          	// transaction_id might be non-zero even if an error is present.
          	TransactionId        int64    `protobuf:"varint,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
          	XXX_NoUnkeyedLiteral struct{} `json:"-"`
          	XXX_unrecognized     []byte   `json:"-"`
          	XXX_sizecache        int32    `json:"-"`
          }

            BeginExecuteResponse is the returned value from BeginExecute

            func (*BeginExecuteResponse) Descriptor

            func (*BeginExecuteResponse) Descriptor() ([]byte, []int)

            func (*BeginExecuteResponse) GetError

            func (m *BeginExecuteResponse) GetError() *vtrpc.RPCError

            func (*BeginExecuteResponse) GetResult

            func (m *BeginExecuteResponse) GetResult() *QueryResult

            func (*BeginExecuteResponse) GetTransactionId

            func (m *BeginExecuteResponse) GetTransactionId() int64

            func (*BeginExecuteResponse) ProtoMessage

            func (*BeginExecuteResponse) ProtoMessage()

            func (*BeginExecuteResponse) Reset

            func (m *BeginExecuteResponse) Reset()

            func (*BeginExecuteResponse) String

            func (m *BeginExecuteResponse) String() string

            func (*BeginExecuteResponse) XXX_DiscardUnknown

            func (m *BeginExecuteResponse) XXX_DiscardUnknown()

            func (*BeginExecuteResponse) XXX_Marshal

            func (m *BeginExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

            func (*BeginExecuteResponse) XXX_Merge

            func (dst *BeginExecuteResponse) XXX_Merge(src proto.Message)

            func (*BeginExecuteResponse) XXX_Size

            func (m *BeginExecuteResponse) XXX_Size() int

            func (*BeginExecuteResponse) XXX_Unmarshal

            func (m *BeginExecuteResponse) XXX_Unmarshal(b []byte) error

            type BeginRequest

            type BeginRequest struct {
            	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
            	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
            	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
            	Options              *ExecuteOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
            	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
            	XXX_unrecognized     []byte          `json:"-"`
            	XXX_sizecache        int32           `json:"-"`
            }

              BeginRequest is the payload to Begin

              func (*BeginRequest) Descriptor

              func (*BeginRequest) Descriptor() ([]byte, []int)

              func (*BeginRequest) GetEffectiveCallerId

              func (m *BeginRequest) GetEffectiveCallerId() *vtrpc.CallerID

              func (*BeginRequest) GetImmediateCallerId

              func (m *BeginRequest) GetImmediateCallerId() *VTGateCallerID

              func (*BeginRequest) GetOptions

              func (m *BeginRequest) GetOptions() *ExecuteOptions

              func (*BeginRequest) GetTarget

              func (m *BeginRequest) GetTarget() *Target

              func (*BeginRequest) ProtoMessage

              func (*BeginRequest) ProtoMessage()

              func (*BeginRequest) Reset

              func (m *BeginRequest) Reset()

              func (*BeginRequest) String

              func (m *BeginRequest) String() string

              func (*BeginRequest) XXX_DiscardUnknown

              func (m *BeginRequest) XXX_DiscardUnknown()

              func (*BeginRequest) XXX_Marshal

              func (m *BeginRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

              func (*BeginRequest) XXX_Merge

              func (dst *BeginRequest) XXX_Merge(src proto.Message)

              func (*BeginRequest) XXX_Size

              func (m *BeginRequest) XXX_Size() int

              func (*BeginRequest) XXX_Unmarshal

              func (m *BeginRequest) XXX_Unmarshal(b []byte) error

              type BeginResponse

              type BeginResponse struct {
              	TransactionId        int64    `protobuf:"varint,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
              	XXX_NoUnkeyedLiteral struct{} `json:"-"`
              	XXX_unrecognized     []byte   `json:"-"`
              	XXX_sizecache        int32    `json:"-"`
              }

                BeginResponse is the returned value from Begin

                func (*BeginResponse) Descriptor

                func (*BeginResponse) Descriptor() ([]byte, []int)

                func (*BeginResponse) GetTransactionId

                func (m *BeginResponse) GetTransactionId() int64

                func (*BeginResponse) ProtoMessage

                func (*BeginResponse) ProtoMessage()

                func (*BeginResponse) Reset

                func (m *BeginResponse) Reset()

                func (*BeginResponse) String

                func (m *BeginResponse) String() string

                func (*BeginResponse) XXX_DiscardUnknown

                func (m *BeginResponse) XXX_DiscardUnknown()

                func (*BeginResponse) XXX_Marshal

                func (m *BeginResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                func (*BeginResponse) XXX_Merge

                func (dst *BeginResponse) XXX_Merge(src proto.Message)

                func (*BeginResponse) XXX_Size

                func (m *BeginResponse) XXX_Size() int

                func (*BeginResponse) XXX_Unmarshal

                func (m *BeginResponse) XXX_Unmarshal(b []byte) error

                type BindVariable

                type BindVariable struct {
                	Type  Type   `protobuf:"varint,1,opt,name=type,proto3,enum=query.Type" json:"type,omitempty"`
                	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
                	// values are set if type is TUPLE.
                	Values               []*Value `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
                	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                	XXX_unrecognized     []byte   `json:"-"`
                	XXX_sizecache        int32    `json:"-"`
                }

                  BindVariable represents a single bind variable in a Query.

                  func (*BindVariable) Descriptor

                  func (*BindVariable) Descriptor() ([]byte, []int)

                  func (*BindVariable) GetType

                  func (m *BindVariable) GetType() Type

                  func (*BindVariable) GetValue

                  func (m *BindVariable) GetValue() []byte

                  func (*BindVariable) GetValues

                  func (m *BindVariable) GetValues() []*Value

                  func (*BindVariable) ProtoMessage

                  func (*BindVariable) ProtoMessage()

                  func (*BindVariable) Reset

                  func (m *BindVariable) Reset()

                  func (*BindVariable) String

                  func (m *BindVariable) String() string

                  func (*BindVariable) XXX_DiscardUnknown

                  func (m *BindVariable) XXX_DiscardUnknown()

                  func (*BindVariable) XXX_Marshal

                  func (m *BindVariable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                  func (*BindVariable) XXX_Merge

                  func (dst *BindVariable) XXX_Merge(src proto.Message)

                  func (*BindVariable) XXX_Size

                  func (m *BindVariable) XXX_Size() int

                  func (*BindVariable) XXX_Unmarshal

                  func (m *BindVariable) XXX_Unmarshal(b []byte) error

                  type BoundQuery

                  type BoundQuery struct {
                  	// sql is the SQL query to execute
                  	Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
                  	// bind_variables is a map of all bind variables to expand in the query.
                  	// nil values are not allowed. Use NULL_TYPE to express a NULL value.
                  	BindVariables        map[string]*BindVariable `` /* 188-byte string literal not displayed */
                  	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
                  	XXX_unrecognized     []byte                   `json:"-"`
                  	XXX_sizecache        int32                    `json:"-"`
                  }

                    BoundQuery is a query with its bind variables

                    func (*BoundQuery) Descriptor

                    func (*BoundQuery) Descriptor() ([]byte, []int)

                    func (*BoundQuery) GetBindVariables

                    func (m *BoundQuery) GetBindVariables() map[string]*BindVariable

                    func (*BoundQuery) GetSql

                    func (m *BoundQuery) GetSql() string

                    func (*BoundQuery) ProtoMessage

                    func (*BoundQuery) ProtoMessage()

                    func (*BoundQuery) Reset

                    func (m *BoundQuery) Reset()

                    func (*BoundQuery) String

                    func (m *BoundQuery) String() string

                    func (*BoundQuery) XXX_DiscardUnknown

                    func (m *BoundQuery) XXX_DiscardUnknown()

                    func (*BoundQuery) XXX_Marshal

                    func (m *BoundQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                    func (*BoundQuery) XXX_Merge

                    func (dst *BoundQuery) XXX_Merge(src proto.Message)

                    func (*BoundQuery) XXX_Size

                    func (m *BoundQuery) XXX_Size() int

                    func (*BoundQuery) XXX_Unmarshal

                    func (m *BoundQuery) XXX_Unmarshal(b []byte) error

                    type CommitPreparedRequest

                    type CommitPreparedRequest struct {
                    	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                    	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                    	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                    	Dtid                 string          `protobuf:"bytes,4,opt,name=dtid,proto3" json:"dtid,omitempty"`
                    	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
                    	XXX_unrecognized     []byte          `json:"-"`
                    	XXX_sizecache        int32           `json:"-"`
                    }

                      CommitPreparedRequest is the payload to CommitPrepared

                      func (*CommitPreparedRequest) Descriptor

                      func (*CommitPreparedRequest) Descriptor() ([]byte, []int)

                      func (*CommitPreparedRequest) GetDtid

                      func (m *CommitPreparedRequest) GetDtid() string

                      func (*CommitPreparedRequest) GetEffectiveCallerId

                      func (m *CommitPreparedRequest) GetEffectiveCallerId() *vtrpc.CallerID

                      func (*CommitPreparedRequest) GetImmediateCallerId

                      func (m *CommitPreparedRequest) GetImmediateCallerId() *VTGateCallerID

                      func (*CommitPreparedRequest) GetTarget

                      func (m *CommitPreparedRequest) GetTarget() *Target

                      func (*CommitPreparedRequest) ProtoMessage

                      func (*CommitPreparedRequest) ProtoMessage()

                      func (*CommitPreparedRequest) Reset

                      func (m *CommitPreparedRequest) Reset()

                      func (*CommitPreparedRequest) String

                      func (m *CommitPreparedRequest) String() string

                      func (*CommitPreparedRequest) XXX_DiscardUnknown

                      func (m *CommitPreparedRequest) XXX_DiscardUnknown()

                      func (*CommitPreparedRequest) XXX_Marshal

                      func (m *CommitPreparedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                      func (*CommitPreparedRequest) XXX_Merge

                      func (dst *CommitPreparedRequest) XXX_Merge(src proto.Message)

                      func (*CommitPreparedRequest) XXX_Size

                      func (m *CommitPreparedRequest) XXX_Size() int

                      func (*CommitPreparedRequest) XXX_Unmarshal

                      func (m *CommitPreparedRequest) XXX_Unmarshal(b []byte) error

                      type CommitPreparedResponse

                      type CommitPreparedResponse struct {
                      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                      	XXX_unrecognized     []byte   `json:"-"`
                      	XXX_sizecache        int32    `json:"-"`
                      }

                        CommitPreparedResponse is the returned value from CommitPrepared

                        func (*CommitPreparedResponse) Descriptor

                        func (*CommitPreparedResponse) Descriptor() ([]byte, []int)

                        func (*CommitPreparedResponse) ProtoMessage

                        func (*CommitPreparedResponse) ProtoMessage()

                        func (*CommitPreparedResponse) Reset

                        func (m *CommitPreparedResponse) Reset()

                        func (*CommitPreparedResponse) String

                        func (m *CommitPreparedResponse) String() string

                        func (*CommitPreparedResponse) XXX_DiscardUnknown

                        func (m *CommitPreparedResponse) XXX_DiscardUnknown()

                        func (*CommitPreparedResponse) XXX_Marshal

                        func (m *CommitPreparedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                        func (*CommitPreparedResponse) XXX_Merge

                        func (dst *CommitPreparedResponse) XXX_Merge(src proto.Message)

                        func (*CommitPreparedResponse) XXX_Size

                        func (m *CommitPreparedResponse) XXX_Size() int

                        func (*CommitPreparedResponse) XXX_Unmarshal

                        func (m *CommitPreparedResponse) XXX_Unmarshal(b []byte) error

                        type CommitRequest

                        type CommitRequest struct {
                        	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                        	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                        	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                        	TransactionId        int64           `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
                        	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
                        	XXX_unrecognized     []byte          `json:"-"`
                        	XXX_sizecache        int32           `json:"-"`
                        }

                          CommitRequest is the payload to Commit

                          func (*CommitRequest) Descriptor

                          func (*CommitRequest) Descriptor() ([]byte, []int)

                          func (*CommitRequest) GetEffectiveCallerId

                          func (m *CommitRequest) GetEffectiveCallerId() *vtrpc.CallerID

                          func (*CommitRequest) GetImmediateCallerId

                          func (m *CommitRequest) GetImmediateCallerId() *VTGateCallerID

                          func (*CommitRequest) GetTarget

                          func (m *CommitRequest) GetTarget() *Target

                          func (*CommitRequest) GetTransactionId

                          func (m *CommitRequest) GetTransactionId() int64

                          func (*CommitRequest) ProtoMessage

                          func (*CommitRequest) ProtoMessage()

                          func (*CommitRequest) Reset

                          func (m *CommitRequest) Reset()

                          func (*CommitRequest) String

                          func (m *CommitRequest) String() string

                          func (*CommitRequest) XXX_DiscardUnknown

                          func (m *CommitRequest) XXX_DiscardUnknown()

                          func (*CommitRequest) XXX_Marshal

                          func (m *CommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                          func (*CommitRequest) XXX_Merge

                          func (dst *CommitRequest) XXX_Merge(src proto.Message)

                          func (*CommitRequest) XXX_Size

                          func (m *CommitRequest) XXX_Size() int

                          func (*CommitRequest) XXX_Unmarshal

                          func (m *CommitRequest) XXX_Unmarshal(b []byte) error

                          type CommitResponse

                          type CommitResponse struct {
                          	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                          	XXX_unrecognized     []byte   `json:"-"`
                          	XXX_sizecache        int32    `json:"-"`
                          }

                            CommitResponse is the returned value from Commit

                            func (*CommitResponse) Descriptor

                            func (*CommitResponse) Descriptor() ([]byte, []int)

                            func (*CommitResponse) ProtoMessage

                            func (*CommitResponse) ProtoMessage()

                            func (*CommitResponse) Reset

                            func (m *CommitResponse) Reset()

                            func (*CommitResponse) String

                            func (m *CommitResponse) String() string

                            func (*CommitResponse) XXX_DiscardUnknown

                            func (m *CommitResponse) XXX_DiscardUnknown()

                            func (*CommitResponse) XXX_Marshal

                            func (m *CommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                            func (*CommitResponse) XXX_Merge

                            func (dst *CommitResponse) XXX_Merge(src proto.Message)

                            func (*CommitResponse) XXX_Size

                            func (m *CommitResponse) XXX_Size() int

                            func (*CommitResponse) XXX_Unmarshal

                            func (m *CommitResponse) XXX_Unmarshal(b []byte) error

                            type ConcludeTransactionRequest

                            type ConcludeTransactionRequest struct {
                            	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                            	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                            	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                            	Dtid                 string          `protobuf:"bytes,4,opt,name=dtid,proto3" json:"dtid,omitempty"`
                            	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
                            	XXX_unrecognized     []byte          `json:"-"`
                            	XXX_sizecache        int32           `json:"-"`
                            }

                              ConcludeTransactionRequest is the payload to ConcludeTransaction

                              func (*ConcludeTransactionRequest) Descriptor

                              func (*ConcludeTransactionRequest) Descriptor() ([]byte, []int)

                              func (*ConcludeTransactionRequest) GetDtid

                              func (m *ConcludeTransactionRequest) GetDtid() string

                              func (*ConcludeTransactionRequest) GetEffectiveCallerId

                              func (m *ConcludeTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID

                              func (*ConcludeTransactionRequest) GetImmediateCallerId

                              func (m *ConcludeTransactionRequest) GetImmediateCallerId() *VTGateCallerID

                              func (*ConcludeTransactionRequest) GetTarget

                              func (m *ConcludeTransactionRequest) GetTarget() *Target

                              func (*ConcludeTransactionRequest) ProtoMessage

                              func (*ConcludeTransactionRequest) ProtoMessage()

                              func (*ConcludeTransactionRequest) Reset

                              func (m *ConcludeTransactionRequest) Reset()

                              func (*ConcludeTransactionRequest) String

                              func (m *ConcludeTransactionRequest) String() string

                              func (*ConcludeTransactionRequest) XXX_DiscardUnknown

                              func (m *ConcludeTransactionRequest) XXX_DiscardUnknown()

                              func (*ConcludeTransactionRequest) XXX_Marshal

                              func (m *ConcludeTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                              func (*ConcludeTransactionRequest) XXX_Merge

                              func (dst *ConcludeTransactionRequest) XXX_Merge(src proto.Message)

                              func (*ConcludeTransactionRequest) XXX_Size

                              func (m *ConcludeTransactionRequest) XXX_Size() int

                              func (*ConcludeTransactionRequest) XXX_Unmarshal

                              func (m *ConcludeTransactionRequest) XXX_Unmarshal(b []byte) error

                              type ConcludeTransactionResponse

                              type ConcludeTransactionResponse struct {
                              	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                              	XXX_unrecognized     []byte   `json:"-"`
                              	XXX_sizecache        int32    `json:"-"`
                              }

                                ConcludeTransactionResponse is the returned value from ConcludeTransaction

                                func (*ConcludeTransactionResponse) Descriptor

                                func (*ConcludeTransactionResponse) Descriptor() ([]byte, []int)

                                func (*ConcludeTransactionResponse) ProtoMessage

                                func (*ConcludeTransactionResponse) ProtoMessage()

                                func (*ConcludeTransactionResponse) Reset

                                func (m *ConcludeTransactionResponse) Reset()

                                func (*ConcludeTransactionResponse) String

                                func (m *ConcludeTransactionResponse) String() string

                                func (*ConcludeTransactionResponse) XXX_DiscardUnknown

                                func (m *ConcludeTransactionResponse) XXX_DiscardUnknown()

                                func (*ConcludeTransactionResponse) XXX_Marshal

                                func (m *ConcludeTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                func (*ConcludeTransactionResponse) XXX_Merge

                                func (dst *ConcludeTransactionResponse) XXX_Merge(src proto.Message)

                                func (*ConcludeTransactionResponse) XXX_Size

                                func (m *ConcludeTransactionResponse) XXX_Size() int

                                func (*ConcludeTransactionResponse) XXX_Unmarshal

                                func (m *ConcludeTransactionResponse) XXX_Unmarshal(b []byte) error

                                type CreateTransactionRequest

                                type CreateTransactionRequest struct {
                                	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                                	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                                	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                                	Dtid                 string          `protobuf:"bytes,4,opt,name=dtid,proto3" json:"dtid,omitempty"`
                                	Participants         []*Target       `protobuf:"bytes,5,rep,name=participants,proto3" json:"participants,omitempty"`
                                	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
                                	XXX_unrecognized     []byte          `json:"-"`
                                	XXX_sizecache        int32           `json:"-"`
                                }

                                  CreateTransactionRequest is the payload to CreateTransaction

                                  func (*CreateTransactionRequest) Descriptor

                                  func (*CreateTransactionRequest) Descriptor() ([]byte, []int)

                                  func (*CreateTransactionRequest) GetDtid

                                  func (m *CreateTransactionRequest) GetDtid() string

                                  func (*CreateTransactionRequest) GetEffectiveCallerId

                                  func (m *CreateTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID

                                  func (*CreateTransactionRequest) GetImmediateCallerId

                                  func (m *CreateTransactionRequest) GetImmediateCallerId() *VTGateCallerID

                                  func (*CreateTransactionRequest) GetParticipants

                                  func (m *CreateTransactionRequest) GetParticipants() []*Target

                                  func (*CreateTransactionRequest) GetTarget

                                  func (m *CreateTransactionRequest) GetTarget() *Target

                                  func (*CreateTransactionRequest) ProtoMessage

                                  func (*CreateTransactionRequest) ProtoMessage()

                                  func (*CreateTransactionRequest) Reset

                                  func (m *CreateTransactionRequest) Reset()

                                  func (*CreateTransactionRequest) String

                                  func (m *CreateTransactionRequest) String() string

                                  func (*CreateTransactionRequest) XXX_DiscardUnknown

                                  func (m *CreateTransactionRequest) XXX_DiscardUnknown()

                                  func (*CreateTransactionRequest) XXX_Marshal

                                  func (m *CreateTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                  func (*CreateTransactionRequest) XXX_Merge

                                  func (dst *CreateTransactionRequest) XXX_Merge(src proto.Message)

                                  func (*CreateTransactionRequest) XXX_Size

                                  func (m *CreateTransactionRequest) XXX_Size() int

                                  func (*CreateTransactionRequest) XXX_Unmarshal

                                  func (m *CreateTransactionRequest) XXX_Unmarshal(b []byte) error

                                  type CreateTransactionResponse

                                  type CreateTransactionResponse struct {
                                  	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                  	XXX_unrecognized     []byte   `json:"-"`
                                  	XXX_sizecache        int32    `json:"-"`
                                  }

                                    CreateTransactionResponse is the returned value from CreateTransaction

                                    func (*CreateTransactionResponse) Descriptor

                                    func (*CreateTransactionResponse) Descriptor() ([]byte, []int)

                                    func (*CreateTransactionResponse) ProtoMessage

                                    func (*CreateTransactionResponse) ProtoMessage()

                                    func (*CreateTransactionResponse) Reset

                                    func (m *CreateTransactionResponse) Reset()

                                    func (*CreateTransactionResponse) String

                                    func (m *CreateTransactionResponse) String() string

                                    func (*CreateTransactionResponse) XXX_DiscardUnknown

                                    func (m *CreateTransactionResponse) XXX_DiscardUnknown()

                                    func (*CreateTransactionResponse) XXX_Marshal

                                    func (m *CreateTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                    func (*CreateTransactionResponse) XXX_Merge

                                    func (dst *CreateTransactionResponse) XXX_Merge(src proto.Message)

                                    func (*CreateTransactionResponse) XXX_Size

                                    func (m *CreateTransactionResponse) XXX_Size() int

                                    func (*CreateTransactionResponse) XXX_Unmarshal

                                    func (m *CreateTransactionResponse) XXX_Unmarshal(b []byte) error

                                    type EventToken

                                    type EventToken struct {
                                    	// timestamp is the MySQL timestamp of the statements. Seconds since Epoch.
                                    	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
                                    	// The shard name that applied the statements. Note this is not set when
                                    	// streaming from a vttablet. It is only used on the client -> vtgate link.
                                    	Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
                                    	// The position on the replication stream after this statement was applied.
                                    	// It is not the transaction ID / GTID, but the position / GTIDSet.
                                    	Position             string   `protobuf:"bytes,3,opt,name=position,proto3" json:"position,omitempty"`
                                    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                    	XXX_unrecognized     []byte   `json:"-"`
                                    	XXX_sizecache        int32    `json:"-"`
                                    }

                                      EventToken is a structure that describes a point in time in a replication stream on one shard. The most recent known replication position can be retrieved from vttablet when executing a query. It is also sent with the replication streams from the binlog service.

                                      func (*EventToken) Descriptor

                                      func (*EventToken) Descriptor() ([]byte, []int)

                                      func (*EventToken) GetPosition

                                      func (m *EventToken) GetPosition() string

                                      func (*EventToken) GetShard

                                      func (m *EventToken) GetShard() string

                                      func (*EventToken) GetTimestamp

                                      func (m *EventToken) GetTimestamp() int64

                                      func (*EventToken) ProtoMessage

                                      func (*EventToken) ProtoMessage()

                                      func (*EventToken) Reset

                                      func (m *EventToken) Reset()

                                      func (*EventToken) String

                                      func (m *EventToken) String() string

                                      func (*EventToken) XXX_DiscardUnknown

                                      func (m *EventToken) XXX_DiscardUnknown()

                                      func (*EventToken) XXX_Marshal

                                      func (m *EventToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                      func (*EventToken) XXX_Merge

                                      func (dst *EventToken) XXX_Merge(src proto.Message)

                                      func (*EventToken) XXX_Size

                                      func (m *EventToken) XXX_Size() int

                                      func (*EventToken) XXX_Unmarshal

                                      func (m *EventToken) XXX_Unmarshal(b []byte) error

                                      type ExecuteBatchRequest

                                      type ExecuteBatchRequest struct {
                                      	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                                      	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                                      	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                                      	Queries              []*BoundQuery   `protobuf:"bytes,4,rep,name=queries,proto3" json:"queries,omitempty"`
                                      	AsTransaction        bool            `protobuf:"varint,5,opt,name=as_transaction,json=asTransaction,proto3" json:"as_transaction,omitempty"`
                                      	TransactionId        int64           `protobuf:"varint,6,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
                                      	Options              *ExecuteOptions `protobuf:"bytes,7,opt,name=options,proto3" json:"options,omitempty"`
                                      	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
                                      	XXX_unrecognized     []byte          `json:"-"`
                                      	XXX_sizecache        int32           `json:"-"`
                                      }

                                        ExecuteBatchRequest is the payload to ExecuteBatch

                                        func (*ExecuteBatchRequest) Descriptor

                                        func (*ExecuteBatchRequest) Descriptor() ([]byte, []int)

                                        func (*ExecuteBatchRequest) GetAsTransaction

                                        func (m *ExecuteBatchRequest) GetAsTransaction() bool

                                        func (*ExecuteBatchRequest) GetEffectiveCallerId

                                        func (m *ExecuteBatchRequest) GetEffectiveCallerId() *vtrpc.CallerID

                                        func (*ExecuteBatchRequest) GetImmediateCallerId

                                        func (m *ExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID

                                        func (*ExecuteBatchRequest) GetOptions

                                        func (m *ExecuteBatchRequest) GetOptions() *ExecuteOptions

                                        func (*ExecuteBatchRequest) GetQueries

                                        func (m *ExecuteBatchRequest) GetQueries() []*BoundQuery

                                        func (*ExecuteBatchRequest) GetTarget

                                        func (m *ExecuteBatchRequest) GetTarget() *Target

                                        func (*ExecuteBatchRequest) GetTransactionId

                                        func (m *ExecuteBatchRequest) GetTransactionId() int64

                                        func (*ExecuteBatchRequest) ProtoMessage

                                        func (*ExecuteBatchRequest) ProtoMessage()

                                        func (*ExecuteBatchRequest) Reset

                                        func (m *ExecuteBatchRequest) Reset()

                                        func (*ExecuteBatchRequest) String

                                        func (m *ExecuteBatchRequest) String() string

                                        func (*ExecuteBatchRequest) XXX_DiscardUnknown

                                        func (m *ExecuteBatchRequest) XXX_DiscardUnknown()

                                        func (*ExecuteBatchRequest) XXX_Marshal

                                        func (m *ExecuteBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                        func (*ExecuteBatchRequest) XXX_Merge

                                        func (dst *ExecuteBatchRequest) XXX_Merge(src proto.Message)

                                        func (*ExecuteBatchRequest) XXX_Size

                                        func (m *ExecuteBatchRequest) XXX_Size() int

                                        func (*ExecuteBatchRequest) XXX_Unmarshal

                                        func (m *ExecuteBatchRequest) XXX_Unmarshal(b []byte) error

                                        type ExecuteBatchResponse

                                        type ExecuteBatchResponse struct {
                                        	Results              []*QueryResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
                                        	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
                                        	XXX_unrecognized     []byte         `json:"-"`
                                        	XXX_sizecache        int32          `json:"-"`
                                        }

                                          ExecuteBatchResponse is the returned value from ExecuteBatch

                                          func (*ExecuteBatchResponse) Descriptor

                                          func (*ExecuteBatchResponse) Descriptor() ([]byte, []int)

                                          func (*ExecuteBatchResponse) GetResults

                                          func (m *ExecuteBatchResponse) GetResults() []*QueryResult

                                          func (*ExecuteBatchResponse) ProtoMessage

                                          func (*ExecuteBatchResponse) ProtoMessage()

                                          func (*ExecuteBatchResponse) Reset

                                          func (m *ExecuteBatchResponse) Reset()

                                          func (*ExecuteBatchResponse) String

                                          func (m *ExecuteBatchResponse) String() string

                                          func (*ExecuteBatchResponse) XXX_DiscardUnknown

                                          func (m *ExecuteBatchResponse) XXX_DiscardUnknown()

                                          func (*ExecuteBatchResponse) XXX_Marshal

                                          func (m *ExecuteBatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                          func (*ExecuteBatchResponse) XXX_Merge

                                          func (dst *ExecuteBatchResponse) XXX_Merge(src proto.Message)

                                          func (*ExecuteBatchResponse) XXX_Size

                                          func (m *ExecuteBatchResponse) XXX_Size() int

                                          func (*ExecuteBatchResponse) XXX_Unmarshal

                                          func (m *ExecuteBatchResponse) XXX_Unmarshal(b []byte) error

                                          type ExecuteOptions

                                          type ExecuteOptions struct {
                                          	// If set, we will try to include an EventToken with the responses.
                                          	IncludeEventToken bool `protobuf:"varint,2,opt,name=include_event_token,json=includeEventToken,proto3" json:"include_event_token,omitempty"`
                                          	// If set, the fresher field may be set as a result comparison to this token.
                                          	// This is a shortcut so the application doesn't need to care about
                                          	// comparing EventTokens.
                                          	CompareEventToken *EventToken `protobuf:"bytes,3,opt,name=compare_event_token,json=compareEventToken,proto3" json:"compare_event_token,omitempty"`
                                          	// Controls what fields are returned in Field message responses from mysql, i.e.
                                          	// field name, table name, etc. This is an optimization for high-QPS queries where
                                          	// the client knows what it's getting
                                          	IncludedFields ExecuteOptions_IncludedFields `` /* 145-byte string literal not displayed */
                                          	// client_rows_found specifies if rows_affected should return
                                          	// rows found instead of rows affected. Behavior is defined
                                          	// by MySQL's CLIENT_FOUND_ROWS flag.
                                          	ClientFoundRows bool `protobuf:"varint,5,opt,name=client_found_rows,json=clientFoundRows,proto3" json:"client_found_rows,omitempty"`
                                          	// workload specifies the type of workload:
                                          	// OLTP: DMLs allowed, results have row count limit, and
                                          	// query timeouts are shorter.
                                          	// OLAP: DMLS not allowed, no limit on row count, timeouts
                                          	// can be as high as desired.
                                          	// DBA: no limit on rowcount or timeout, all queries allowed
                                          	// but intended for long DMLs and DDLs.
                                          	Workload ExecuteOptions_Workload `protobuf:"varint,6,opt,name=workload,proto3,enum=query.ExecuteOptions_Workload" json:"workload,omitempty"`
                                          	// sql_select_limit sets an implicit limit on all select statements. Since
                                          	// vitess also sets a rowcount limit on queries, the smallest value wins.
                                          	SqlSelectLimit       int64                               `protobuf:"varint,8,opt,name=sql_select_limit,json=sqlSelectLimit,proto3" json:"sql_select_limit,omitempty"`
                                          	TransactionIsolation ExecuteOptions_TransactionIsolation `` /* 169-byte string literal not displayed */
                                          	// skip_query_plan_cache specifies if the query plan should be cached by vitess.
                                          	// By default all query plans are cached.
                                          	SkipQueryPlanCache   bool     `protobuf:"varint,10,opt,name=skip_query_plan_cache,json=skipQueryPlanCache,proto3" json:"skip_query_plan_cache,omitempty"`
                                          	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                          	XXX_unrecognized     []byte   `json:"-"`
                                          	XXX_sizecache        int32    `json:"-"`
                                          }

                                            ExecuteOptions is passed around for all Execute calls.

                                            func (*ExecuteOptions) Descriptor

                                            func (*ExecuteOptions) Descriptor() ([]byte, []int)

                                            func (*ExecuteOptions) GetClientFoundRows

                                            func (m *ExecuteOptions) GetClientFoundRows() bool

                                            func (*ExecuteOptions) GetCompareEventToken

                                            func (m *ExecuteOptions) GetCompareEventToken() *EventToken

                                            func (*ExecuteOptions) GetIncludeEventToken

                                            func (m *ExecuteOptions) GetIncludeEventToken() bool

                                            func (*ExecuteOptions) GetIncludedFields

                                            func (m *ExecuteOptions) GetIncludedFields() ExecuteOptions_IncludedFields

                                            func (*ExecuteOptions) GetSkipQueryPlanCache

                                            func (m *ExecuteOptions) GetSkipQueryPlanCache() bool

                                            func (*ExecuteOptions) GetSqlSelectLimit

                                            func (m *ExecuteOptions) GetSqlSelectLimit() int64

                                            func (*ExecuteOptions) GetTransactionIsolation

                                            func (m *ExecuteOptions) GetTransactionIsolation() ExecuteOptions_TransactionIsolation

                                            func (*ExecuteOptions) GetWorkload

                                            func (m *ExecuteOptions) GetWorkload() ExecuteOptions_Workload

                                            func (*ExecuteOptions) ProtoMessage

                                            func (*ExecuteOptions) ProtoMessage()

                                            func (*ExecuteOptions) Reset

                                            func (m *ExecuteOptions) Reset()

                                            func (*ExecuteOptions) String

                                            func (m *ExecuteOptions) String() string

                                            func (*ExecuteOptions) XXX_DiscardUnknown

                                            func (m *ExecuteOptions) XXX_DiscardUnknown()

                                            func (*ExecuteOptions) XXX_Marshal

                                            func (m *ExecuteOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                            func (*ExecuteOptions) XXX_Merge

                                            func (dst *ExecuteOptions) XXX_Merge(src proto.Message)

                                            func (*ExecuteOptions) XXX_Size

                                            func (m *ExecuteOptions) XXX_Size() int

                                            func (*ExecuteOptions) XXX_Unmarshal

                                            func (m *ExecuteOptions) XXX_Unmarshal(b []byte) error

                                            type ExecuteOptions_IncludedFields

                                            type ExecuteOptions_IncludedFields int32
                                            const (
                                            	ExecuteOptions_TYPE_AND_NAME ExecuteOptions_IncludedFields = 0
                                            	ExecuteOptions_TYPE_ONLY     ExecuteOptions_IncludedFields = 1
                                            	ExecuteOptions_ALL           ExecuteOptions_IncludedFields = 2
                                            )

                                            func (ExecuteOptions_IncludedFields) EnumDescriptor

                                            func (ExecuteOptions_IncludedFields) EnumDescriptor() ([]byte, []int)

                                            func (ExecuteOptions_IncludedFields) String

                                            type ExecuteOptions_TransactionIsolation

                                            type ExecuteOptions_TransactionIsolation int32
                                            const (
                                            	ExecuteOptions_DEFAULT          ExecuteOptions_TransactionIsolation = 0
                                            	ExecuteOptions_REPEATABLE_READ  ExecuteOptions_TransactionIsolation = 1
                                            	ExecuteOptions_READ_COMMITTED   ExecuteOptions_TransactionIsolation = 2
                                            	ExecuteOptions_READ_UNCOMMITTED ExecuteOptions_TransactionIsolation = 3
                                            	ExecuteOptions_SERIALIZABLE     ExecuteOptions_TransactionIsolation = 4
                                            	// This is not an "official" transaction level but it will do a
                                            	// START TRANSACTION WITH CONSISTENT SNAPSHOT, READ ONLY
                                            	ExecuteOptions_CONSISTENT_SNAPSHOT_READ_ONLY ExecuteOptions_TransactionIsolation = 5
                                            )

                                            func (ExecuteOptions_TransactionIsolation) EnumDescriptor

                                            func (ExecuteOptions_TransactionIsolation) EnumDescriptor() ([]byte, []int)

                                            func (ExecuteOptions_TransactionIsolation) String

                                            type ExecuteOptions_Workload

                                            type ExecuteOptions_Workload int32
                                            const (
                                            	ExecuteOptions_UNSPECIFIED ExecuteOptions_Workload = 0
                                            	ExecuteOptions_OLTP        ExecuteOptions_Workload = 1
                                            	ExecuteOptions_OLAP        ExecuteOptions_Workload = 2
                                            	ExecuteOptions_DBA         ExecuteOptions_Workload = 3
                                            )

                                            func (ExecuteOptions_Workload) EnumDescriptor

                                            func (ExecuteOptions_Workload) EnumDescriptor() ([]byte, []int)

                                            func (ExecuteOptions_Workload) String

                                            func (x ExecuteOptions_Workload) String() string

                                            type ExecuteRequest

                                            type ExecuteRequest struct {
                                            	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                                            	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                                            	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                                            	Query                *BoundQuery     `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
                                            	TransactionId        int64           `protobuf:"varint,5,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
                                            	Options              *ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
                                            	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
                                            	XXX_unrecognized     []byte          `json:"-"`
                                            	XXX_sizecache        int32           `json:"-"`
                                            }

                                              ExecuteRequest is the payload to Execute

                                              func (*ExecuteRequest) Descriptor

                                              func (*ExecuteRequest) Descriptor() ([]byte, []int)

                                              func (*ExecuteRequest) GetEffectiveCallerId

                                              func (m *ExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

                                              func (*ExecuteRequest) GetImmediateCallerId

                                              func (m *ExecuteRequest) GetImmediateCallerId() *VTGateCallerID

                                              func (*ExecuteRequest) GetOptions

                                              func (m *ExecuteRequest) GetOptions() *ExecuteOptions

                                              func (*ExecuteRequest) GetQuery

                                              func (m *ExecuteRequest) GetQuery() *BoundQuery

                                              func (*ExecuteRequest) GetTarget

                                              func (m *ExecuteRequest) GetTarget() *Target

                                              func (*ExecuteRequest) GetTransactionId

                                              func (m *ExecuteRequest) GetTransactionId() int64

                                              func (*ExecuteRequest) ProtoMessage

                                              func (*ExecuteRequest) ProtoMessage()

                                              func (*ExecuteRequest) Reset

                                              func (m *ExecuteRequest) Reset()

                                              func (*ExecuteRequest) String

                                              func (m *ExecuteRequest) String() string

                                              func (*ExecuteRequest) XXX_DiscardUnknown

                                              func (m *ExecuteRequest) XXX_DiscardUnknown()

                                              func (*ExecuteRequest) XXX_Marshal

                                              func (m *ExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                              func (*ExecuteRequest) XXX_Merge

                                              func (dst *ExecuteRequest) XXX_Merge(src proto.Message)

                                              func (*ExecuteRequest) XXX_Size

                                              func (m *ExecuteRequest) XXX_Size() int

                                              func (*ExecuteRequest) XXX_Unmarshal

                                              func (m *ExecuteRequest) XXX_Unmarshal(b []byte) error

                                              type ExecuteResponse

                                              type ExecuteResponse struct {
                                              	Result               *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
                                              	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
                                              	XXX_unrecognized     []byte       `json:"-"`
                                              	XXX_sizecache        int32        `json:"-"`
                                              }

                                                ExecuteResponse is the returned value from Execute

                                                func (*ExecuteResponse) Descriptor

                                                func (*ExecuteResponse) Descriptor() ([]byte, []int)

                                                func (*ExecuteResponse) GetResult

                                                func (m *ExecuteResponse) GetResult() *QueryResult

                                                func (*ExecuteResponse) ProtoMessage

                                                func (*ExecuteResponse) ProtoMessage()

                                                func (*ExecuteResponse) Reset

                                                func (m *ExecuteResponse) Reset()

                                                func (*ExecuteResponse) String

                                                func (m *ExecuteResponse) String() string

                                                func (*ExecuteResponse) XXX_DiscardUnknown

                                                func (m *ExecuteResponse) XXX_DiscardUnknown()

                                                func (*ExecuteResponse) XXX_Marshal

                                                func (m *ExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                func (*ExecuteResponse) XXX_Merge

                                                func (dst *ExecuteResponse) XXX_Merge(src proto.Message)

                                                func (*ExecuteResponse) XXX_Size

                                                func (m *ExecuteResponse) XXX_Size() int

                                                func (*ExecuteResponse) XXX_Unmarshal

                                                func (m *ExecuteResponse) XXX_Unmarshal(b []byte) error

                                                type Field

                                                type Field struct {
                                                	// name of the field as returned by mysql C API
                                                	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
                                                	// vitess-defined type. Conversion function is in sqltypes package.
                                                	Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=query.Type" json:"type,omitempty"`
                                                	// Remaining fields from mysql C API.
                                                	// These fields are only populated when ExecuteOptions.included_fields
                                                	// is set to IncludedFields.ALL.
                                                	Table    string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
                                                	OrgTable string `protobuf:"bytes,4,opt,name=org_table,json=orgTable,proto3" json:"org_table,omitempty"`
                                                	Database string `protobuf:"bytes,5,opt,name=database,proto3" json:"database,omitempty"`
                                                	OrgName  string `protobuf:"bytes,6,opt,name=org_name,json=orgName,proto3" json:"org_name,omitempty"`
                                                	// column_length is really a uint32. All 32 bits can be used.
                                                	ColumnLength uint32 `protobuf:"varint,7,opt,name=column_length,json=columnLength,proto3" json:"column_length,omitempty"`
                                                	// charset is actually a uint16. Only the lower 16 bits are used.
                                                	Charset uint32 `protobuf:"varint,8,opt,name=charset,proto3" json:"charset,omitempty"`
                                                	// decimals is actualy a uint8. Only the lower 8 bits are used.
                                                	Decimals uint32 `protobuf:"varint,9,opt,name=decimals,proto3" json:"decimals,omitempty"`
                                                	// flags is actually a uint16. Only the lower 16 bits are used.
                                                	Flags                uint32   `protobuf:"varint,10,opt,name=flags,proto3" json:"flags,omitempty"`
                                                	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                	XXX_unrecognized     []byte   `json:"-"`
                                                	XXX_sizecache        int32    `json:"-"`
                                                }

                                                  Field describes a single column returned by a query

                                                  func (*Field) Descriptor

                                                  func (*Field) Descriptor() ([]byte, []int)

                                                  func (*Field) GetCharset

                                                  func (m *Field) GetCharset() uint32

                                                  func (*Field) GetColumnLength

                                                  func (m *Field) GetColumnLength() uint32

                                                  func (*Field) GetDatabase

                                                  func (m *Field) GetDatabase() string

                                                  func (*Field) GetDecimals

                                                  func (m *Field) GetDecimals() uint32

                                                  func (*Field) GetFlags

                                                  func (m *Field) GetFlags() uint32

                                                  func (*Field) GetName

                                                  func (m *Field) GetName() string

                                                  func (*Field) GetOrgName

                                                  func (m *Field) GetOrgName() string

                                                  func (*Field) GetOrgTable

                                                  func (m *Field) GetOrgTable() string

                                                  func (*Field) GetTable

                                                  func (m *Field) GetTable() string

                                                  func (*Field) GetType

                                                  func (m *Field) GetType() Type

                                                  func (*Field) ProtoMessage

                                                  func (*Field) ProtoMessage()

                                                  func (*Field) Reset

                                                  func (m *Field) Reset()

                                                  func (*Field) String

                                                  func (m *Field) String() string

                                                  func (*Field) XXX_DiscardUnknown

                                                  func (m *Field) XXX_DiscardUnknown()

                                                  func (*Field) XXX_Marshal

                                                  func (m *Field) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                  func (*Field) XXX_Merge

                                                  func (dst *Field) XXX_Merge(src proto.Message)

                                                  func (*Field) XXX_Size

                                                  func (m *Field) XXX_Size() int

                                                  func (*Field) XXX_Unmarshal

                                                  func (m *Field) XXX_Unmarshal(b []byte) error

                                                  type Flag

                                                  type Flag int32

                                                    Flag allows us to qualify types by their common properties.

                                                    const (
                                                    	Flag_NONE       Flag = 0
                                                    	Flag_ISINTEGRAL Flag = 256
                                                    	Flag_ISUNSIGNED Flag = 512
                                                    	Flag_ISFLOAT    Flag = 1024
                                                    	Flag_ISQUOTED   Flag = 2048
                                                    	Flag_ISTEXT     Flag = 4096
                                                    	Flag_ISBINARY   Flag = 8192
                                                    )

                                                    func (Flag) EnumDescriptor

                                                    func (Flag) EnumDescriptor() ([]byte, []int)

                                                    func (Flag) String

                                                    func (x Flag) String() string

                                                    type MessageAckRequest

                                                    type MessageAckRequest struct {
                                                    	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                                                    	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                                                    	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                                                    	// name is the message table name.
                                                    	Name                 string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
                                                    	Ids                  []*Value `protobuf:"bytes,5,rep,name=ids,proto3" json:"ids,omitempty"`
                                                    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                    	XXX_unrecognized     []byte   `json:"-"`
                                                    	XXX_sizecache        int32    `json:"-"`
                                                    }

                                                      MessageAckRequest is the request payload for MessageAck.

                                                      func (*MessageAckRequest) Descriptor

                                                      func (*MessageAckRequest) Descriptor() ([]byte, []int)

                                                      func (*MessageAckRequest) GetEffectiveCallerId

                                                      func (m *MessageAckRequest) GetEffectiveCallerId() *vtrpc.CallerID

                                                      func (*MessageAckRequest) GetIds

                                                      func (m *MessageAckRequest) GetIds() []*Value

                                                      func (*MessageAckRequest) GetImmediateCallerId

                                                      func (m *MessageAckRequest) GetImmediateCallerId() *VTGateCallerID

                                                      func (*MessageAckRequest) GetName

                                                      func (m *MessageAckRequest) GetName() string

                                                      func (*MessageAckRequest) GetTarget

                                                      func (m *MessageAckRequest) GetTarget() *Target

                                                      func (*MessageAckRequest) ProtoMessage

                                                      func (*MessageAckRequest) ProtoMessage()

                                                      func (*MessageAckRequest) Reset

                                                      func (m *MessageAckRequest) Reset()

                                                      func (*MessageAckRequest) String

                                                      func (m *MessageAckRequest) String() string

                                                      func (*MessageAckRequest) XXX_DiscardUnknown

                                                      func (m *MessageAckRequest) XXX_DiscardUnknown()

                                                      func (*MessageAckRequest) XXX_Marshal

                                                      func (m *MessageAckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                      func (*MessageAckRequest) XXX_Merge

                                                      func (dst *MessageAckRequest) XXX_Merge(src proto.Message)

                                                      func (*MessageAckRequest) XXX_Size

                                                      func (m *MessageAckRequest) XXX_Size() int

                                                      func (*MessageAckRequest) XXX_Unmarshal

                                                      func (m *MessageAckRequest) XXX_Unmarshal(b []byte) error

                                                      type MessageAckResponse

                                                      type MessageAckResponse struct {
                                                      	// result contains the result of the ack operation.
                                                      	// Since this acts like a DML, only
                                                      	// RowsAffected is returned in the result.
                                                      	Result               *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
                                                      	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
                                                      	XXX_unrecognized     []byte       `json:"-"`
                                                      	XXX_sizecache        int32        `json:"-"`
                                                      }

                                                        MessageAckResponse is the response for MessageAck.

                                                        func (*MessageAckResponse) Descriptor

                                                        func (*MessageAckResponse) Descriptor() ([]byte, []int)

                                                        func (*MessageAckResponse) GetResult

                                                        func (m *MessageAckResponse) GetResult() *QueryResult

                                                        func (*MessageAckResponse) ProtoMessage

                                                        func (*MessageAckResponse) ProtoMessage()

                                                        func (*MessageAckResponse) Reset

                                                        func (m *MessageAckResponse) Reset()

                                                        func (*MessageAckResponse) String

                                                        func (m *MessageAckResponse) String() string

                                                        func (*MessageAckResponse) XXX_DiscardUnknown

                                                        func (m *MessageAckResponse) XXX_DiscardUnknown()

                                                        func (*MessageAckResponse) XXX_Marshal

                                                        func (m *MessageAckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                        func (*MessageAckResponse) XXX_Merge

                                                        func (dst *MessageAckResponse) XXX_Merge(src proto.Message)

                                                        func (*MessageAckResponse) XXX_Size

                                                        func (m *MessageAckResponse) XXX_Size() int

                                                        func (*MessageAckResponse) XXX_Unmarshal

                                                        func (m *MessageAckResponse) XXX_Unmarshal(b []byte) error

                                                        type MessageStreamRequest

                                                        type MessageStreamRequest struct {
                                                        	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                                                        	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                                                        	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                                                        	// name is the message table name.
                                                        	Name                 string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
                                                        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                        	XXX_unrecognized     []byte   `json:"-"`
                                                        	XXX_sizecache        int32    `json:"-"`
                                                        }

                                                          MessageStreamRequest is the request payload for MessageStream.

                                                          func (*MessageStreamRequest) Descriptor

                                                          func (*MessageStreamRequest) Descriptor() ([]byte, []int)

                                                          func (*MessageStreamRequest) GetEffectiveCallerId

                                                          func (m *MessageStreamRequest) GetEffectiveCallerId() *vtrpc.CallerID

                                                          func (*MessageStreamRequest) GetImmediateCallerId

                                                          func (m *MessageStreamRequest) GetImmediateCallerId() *VTGateCallerID

                                                          func (*MessageStreamRequest) GetName

                                                          func (m *MessageStreamRequest) GetName() string

                                                          func (*MessageStreamRequest) GetTarget

                                                          func (m *MessageStreamRequest) GetTarget() *Target

                                                          func (*MessageStreamRequest) ProtoMessage

                                                          func (*MessageStreamRequest) ProtoMessage()

                                                          func (*MessageStreamRequest) Reset

                                                          func (m *MessageStreamRequest) Reset()

                                                          func (*MessageStreamRequest) String

                                                          func (m *MessageStreamRequest) String() string

                                                          func (*MessageStreamRequest) XXX_DiscardUnknown

                                                          func (m *MessageStreamRequest) XXX_DiscardUnknown()

                                                          func (*MessageStreamRequest) XXX_Marshal

                                                          func (m *MessageStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                          func (*MessageStreamRequest) XXX_Merge

                                                          func (dst *MessageStreamRequest) XXX_Merge(src proto.Message)

                                                          func (*MessageStreamRequest) XXX_Size

                                                          func (m *MessageStreamRequest) XXX_Size() int

                                                          func (*MessageStreamRequest) XXX_Unmarshal

                                                          func (m *MessageStreamRequest) XXX_Unmarshal(b []byte) error

                                                          type MessageStreamResponse

                                                          type MessageStreamResponse struct {
                                                          	Result               *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
                                                          	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
                                                          	XXX_unrecognized     []byte       `json:"-"`
                                                          	XXX_sizecache        int32        `json:"-"`
                                                          }

                                                            MessageStreamResponse is a response for MessageStream.

                                                            func (*MessageStreamResponse) Descriptor

                                                            func (*MessageStreamResponse) Descriptor() ([]byte, []int)

                                                            func (*MessageStreamResponse) GetResult

                                                            func (m *MessageStreamResponse) GetResult() *QueryResult

                                                            func (*MessageStreamResponse) ProtoMessage

                                                            func (*MessageStreamResponse) ProtoMessage()

                                                            func (*MessageStreamResponse) Reset

                                                            func (m *MessageStreamResponse) Reset()

                                                            func (*MessageStreamResponse) String

                                                            func (m *MessageStreamResponse) String() string

                                                            func (*MessageStreamResponse) XXX_DiscardUnknown

                                                            func (m *MessageStreamResponse) XXX_DiscardUnknown()

                                                            func (*MessageStreamResponse) XXX_Marshal

                                                            func (m *MessageStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                            func (*MessageStreamResponse) XXX_Merge

                                                            func (dst *MessageStreamResponse) XXX_Merge(src proto.Message)

                                                            func (*MessageStreamResponse) XXX_Size

                                                            func (m *MessageStreamResponse) XXX_Size() int

                                                            func (*MessageStreamResponse) XXX_Unmarshal

                                                            func (m *MessageStreamResponse) XXX_Unmarshal(b []byte) error

                                                            type MySqlFlag

                                                            type MySqlFlag int32

                                                              Flags sent from the MySQL C API

                                                              const (
                                                              	MySqlFlag_EMPTY                 MySqlFlag = 0
                                                              	MySqlFlag_NOT_NULL_FLAG         MySqlFlag = 1
                                                              	MySqlFlag_PRI_KEY_FLAG          MySqlFlag = 2
                                                              	MySqlFlag_UNIQUE_KEY_FLAG       MySqlFlag = 4
                                                              	MySqlFlag_MULTIPLE_KEY_FLAG     MySqlFlag = 8
                                                              	MySqlFlag_BLOB_FLAG             MySqlFlag = 16
                                                              	MySqlFlag_UNSIGNED_FLAG         MySqlFlag = 32
                                                              	MySqlFlag_ZEROFILL_FLAG         MySqlFlag = 64
                                                              	MySqlFlag_BINARY_FLAG           MySqlFlag = 128
                                                              	MySqlFlag_ENUM_FLAG             MySqlFlag = 256
                                                              	MySqlFlag_AUTO_INCREMENT_FLAG   MySqlFlag = 512
                                                              	MySqlFlag_TIMESTAMP_FLAG        MySqlFlag = 1024
                                                              	MySqlFlag_SET_FLAG              MySqlFlag = 2048
                                                              	MySqlFlag_NO_DEFAULT_VALUE_FLAG MySqlFlag = 4096
                                                              	MySqlFlag_ON_UPDATE_NOW_FLAG    MySqlFlag = 8192
                                                              	MySqlFlag_NUM_FLAG              MySqlFlag = 32768
                                                              	MySqlFlag_PART_KEY_FLAG         MySqlFlag = 16384
                                                              	MySqlFlag_GROUP_FLAG            MySqlFlag = 32768
                                                              	MySqlFlag_UNIQUE_FLAG           MySqlFlag = 65536
                                                              	MySqlFlag_BINCMP_FLAG           MySqlFlag = 131072
                                                              )

                                                              func (MySqlFlag) EnumDescriptor

                                                              func (MySqlFlag) EnumDescriptor() ([]byte, []int)

                                                              func (MySqlFlag) String

                                                              func (x MySqlFlag) String() string

                                                              type PrepareRequest

                                                              type PrepareRequest struct {
                                                              	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                                                              	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                                                              	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                                                              	TransactionId        int64           `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
                                                              	Dtid                 string          `protobuf:"bytes,5,opt,name=dtid,proto3" json:"dtid,omitempty"`
                                                              	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
                                                              	XXX_unrecognized     []byte          `json:"-"`
                                                              	XXX_sizecache        int32           `json:"-"`
                                                              }

                                                                PrepareRequest is the payload to Prepare

                                                                func (*PrepareRequest) Descriptor

                                                                func (*PrepareRequest) Descriptor() ([]byte, []int)

                                                                func (*PrepareRequest) GetDtid

                                                                func (m *PrepareRequest) GetDtid() string

                                                                func (*PrepareRequest) GetEffectiveCallerId

                                                                func (m *PrepareRequest) GetEffectiveCallerId() *vtrpc.CallerID

                                                                func (*PrepareRequest) GetImmediateCallerId

                                                                func (m *PrepareRequest) GetImmediateCallerId() *VTGateCallerID

                                                                func (*PrepareRequest) GetTarget

                                                                func (m *PrepareRequest) GetTarget() *Target

                                                                func (*PrepareRequest) GetTransactionId

                                                                func (m *PrepareRequest) GetTransactionId() int64

                                                                func (*PrepareRequest) ProtoMessage

                                                                func (*PrepareRequest) ProtoMessage()

                                                                func (*PrepareRequest) Reset

                                                                func (m *PrepareRequest) Reset()

                                                                func (*PrepareRequest) String

                                                                func (m *PrepareRequest) String() string

                                                                func (*PrepareRequest) XXX_DiscardUnknown

                                                                func (m *PrepareRequest) XXX_DiscardUnknown()

                                                                func (*PrepareRequest) XXX_Marshal

                                                                func (m *PrepareRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                func (*PrepareRequest) XXX_Merge

                                                                func (dst *PrepareRequest) XXX_Merge(src proto.Message)

                                                                func (*PrepareRequest) XXX_Size

                                                                func (m *PrepareRequest) XXX_Size() int

                                                                func (*PrepareRequest) XXX_Unmarshal

                                                                func (m *PrepareRequest) XXX_Unmarshal(b []byte) error

                                                                type PrepareResponse

                                                                type PrepareResponse struct {
                                                                	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                	XXX_unrecognized     []byte   `json:"-"`
                                                                	XXX_sizecache        int32    `json:"-"`
                                                                }

                                                                  PrepareResponse is the returned value from Prepare

                                                                  func (*PrepareResponse) Descriptor

                                                                  func (*PrepareResponse) Descriptor() ([]byte, []int)

                                                                  func (*PrepareResponse) ProtoMessage

                                                                  func (*PrepareResponse) ProtoMessage()

                                                                  func (*PrepareResponse) Reset

                                                                  func (m *PrepareResponse) Reset()

                                                                  func (*PrepareResponse) String

                                                                  func (m *PrepareResponse) String() string

                                                                  func (*PrepareResponse) XXX_DiscardUnknown

                                                                  func (m *PrepareResponse) XXX_DiscardUnknown()

                                                                  func (*PrepareResponse) XXX_Marshal

                                                                  func (m *PrepareResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                  func (*PrepareResponse) XXX_Merge

                                                                  func (dst *PrepareResponse) XXX_Merge(src proto.Message)

                                                                  func (*PrepareResponse) XXX_Size

                                                                  func (m *PrepareResponse) XXX_Size() int

                                                                  func (*PrepareResponse) XXX_Unmarshal

                                                                  func (m *PrepareResponse) XXX_Unmarshal(b []byte) error

                                                                  type QueryResult

                                                                  type QueryResult struct {
                                                                  	Fields               []*Field      `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
                                                                  	RowsAffected         uint64        `protobuf:"varint,2,opt,name=rows_affected,json=rowsAffected,proto3" json:"rows_affected,omitempty"`
                                                                  	InsertId             uint64        `protobuf:"varint,3,opt,name=insert_id,json=insertId,proto3" json:"insert_id,omitempty"`
                                                                  	Rows                 []*Row        `protobuf:"bytes,4,rep,name=rows,proto3" json:"rows,omitempty"`
                                                                  	Extras               *ResultExtras `protobuf:"bytes,5,opt,name=extras,proto3" json:"extras,omitempty"`
                                                                  	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
                                                                  	XXX_unrecognized     []byte        `json:"-"`
                                                                  	XXX_sizecache        int32         `json:"-"`
                                                                  }

                                                                    QueryResult is returned by Execute and ExecuteStream.

                                                                    As returned by Execute, len(fields) is always equal to len(row) (for each row in rows).

                                                                    As returned by StreamExecute, the first QueryResult has the fields set, and subsequent QueryResult have rows set. And as Execute, len(QueryResult[0].fields) is always equal to len(row) (for each row in rows for each QueryResult in QueryResult[1:]).

                                                                    func (*QueryResult) Descriptor

                                                                    func (*QueryResult) Descriptor() ([]byte, []int)

                                                                    func (*QueryResult) GetExtras

                                                                    func (m *QueryResult) GetExtras() *ResultExtras

                                                                    func (*QueryResult) GetFields

                                                                    func (m *QueryResult) GetFields() []*Field

                                                                    func (*QueryResult) GetInsertId

                                                                    func (m *QueryResult) GetInsertId() uint64

                                                                    func (*QueryResult) GetRows

                                                                    func (m *QueryResult) GetRows() []*Row

                                                                    func (*QueryResult) GetRowsAffected

                                                                    func (m *QueryResult) GetRowsAffected() uint64

                                                                    func (*QueryResult) ProtoMessage

                                                                    func (*QueryResult) ProtoMessage()

                                                                    func (*QueryResult) Reset

                                                                    func (m *QueryResult) Reset()

                                                                    func (*QueryResult) String

                                                                    func (m *QueryResult) String() string

                                                                    func (*QueryResult) XXX_DiscardUnknown

                                                                    func (m *QueryResult) XXX_DiscardUnknown()

                                                                    func (*QueryResult) XXX_Marshal

                                                                    func (m *QueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                    func (*QueryResult) XXX_Merge

                                                                    func (dst *QueryResult) XXX_Merge(src proto.Message)

                                                                    func (*QueryResult) XXX_Size

                                                                    func (m *QueryResult) XXX_Size() int

                                                                    func (*QueryResult) XXX_Unmarshal

                                                                    func (m *QueryResult) XXX_Unmarshal(b []byte) error

                                                                    type QuerySplit

                                                                    type QuerySplit struct {
                                                                    	// query is the query to execute
                                                                    	Query *BoundQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
                                                                    	// row_count is the approximate row count the query will return
                                                                    	RowCount             int64    `protobuf:"varint,2,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
                                                                    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                    	XXX_unrecognized     []byte   `json:"-"`
                                                                    	XXX_sizecache        int32    `json:"-"`
                                                                    }

                                                                      QuerySplit represents one query to execute on the tablet

                                                                      func (*QuerySplit) Descriptor

                                                                      func (*QuerySplit) Descriptor() ([]byte, []int)

                                                                      func (*QuerySplit) GetQuery

                                                                      func (m *QuerySplit) GetQuery() *BoundQuery

                                                                      func (*QuerySplit) GetRowCount

                                                                      func (m *QuerySplit) GetRowCount() int64

                                                                      func (*QuerySplit) ProtoMessage

                                                                      func (*QuerySplit) ProtoMessage()

                                                                      func (*QuerySplit) Reset

                                                                      func (m *QuerySplit) Reset()

                                                                      func (*QuerySplit) String

                                                                      func (m *QuerySplit) String() string

                                                                      func (*QuerySplit) XXX_DiscardUnknown

                                                                      func (m *QuerySplit) XXX_DiscardUnknown()

                                                                      func (*QuerySplit) XXX_Marshal

                                                                      func (m *QuerySplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                      func (*QuerySplit) XXX_Merge

                                                                      func (dst *QuerySplit) XXX_Merge(src proto.Message)

                                                                      func (*QuerySplit) XXX_Size

                                                                      func (m *QuerySplit) XXX_Size() int

                                                                      func (*QuerySplit) XXX_Unmarshal

                                                                      func (m *QuerySplit) XXX_Unmarshal(b []byte) error

                                                                      type QueryWarning

                                                                      type QueryWarning struct {
                                                                      	Code                 uint32   `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
                                                                      	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
                                                                      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                      	XXX_unrecognized     []byte   `json:"-"`
                                                                      	XXX_sizecache        int32    `json:"-"`
                                                                      }

                                                                        QueryWarning is used to convey out of band query execution warnings by storing in the vtgate.Session

                                                                        func (*QueryWarning) Descriptor

                                                                        func (*QueryWarning) Descriptor() ([]byte, []int)

                                                                        func (*QueryWarning) GetCode

                                                                        func (m *QueryWarning) GetCode() uint32

                                                                        func (*QueryWarning) GetMessage

                                                                        func (m *QueryWarning) GetMessage() string

                                                                        func (*QueryWarning) ProtoMessage

                                                                        func (*QueryWarning) ProtoMessage()

                                                                        func (*QueryWarning) Reset

                                                                        func (m *QueryWarning) Reset()

                                                                        func (*QueryWarning) String

                                                                        func (m *QueryWarning) String() string

                                                                        func (*QueryWarning) XXX_DiscardUnknown

                                                                        func (m *QueryWarning) XXX_DiscardUnknown()

                                                                        func (*QueryWarning) XXX_Marshal

                                                                        func (m *QueryWarning) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                        func (*QueryWarning) XXX_Merge

                                                                        func (dst *QueryWarning) XXX_Merge(src proto.Message)

                                                                        func (*QueryWarning) XXX_Size

                                                                        func (m *QueryWarning) XXX_Size() int

                                                                        func (*QueryWarning) XXX_Unmarshal

                                                                        func (m *QueryWarning) XXX_Unmarshal(b []byte) error

                                                                        type ReadTransactionRequest

                                                                        type ReadTransactionRequest struct {
                                                                        	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                                                                        	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                                                                        	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                                                                        	Dtid                 string          `protobuf:"bytes,4,opt,name=dtid,proto3" json:"dtid,omitempty"`
                                                                        	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
                                                                        	XXX_unrecognized     []byte          `json:"-"`
                                                                        	XXX_sizecache        int32           `json:"-"`
                                                                        }

                                                                          ReadTransactionRequest is the payload to ReadTransaction

                                                                          func (*ReadTransactionRequest) Descriptor

                                                                          func (*ReadTransactionRequest) Descriptor() ([]byte, []int)

                                                                          func (*ReadTransactionRequest) GetDtid

                                                                          func (m *ReadTransactionRequest) GetDtid() string

                                                                          func (*ReadTransactionRequest) GetEffectiveCallerId

                                                                          func (m *ReadTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID

                                                                          func (*ReadTransactionRequest) GetImmediateCallerId

                                                                          func (m *ReadTransactionRequest) GetImmediateCallerId() *VTGateCallerID

                                                                          func (*ReadTransactionRequest) GetTarget

                                                                          func (m *ReadTransactionRequest) GetTarget() *Target

                                                                          func (*ReadTransactionRequest) ProtoMessage

                                                                          func (*ReadTransactionRequest) ProtoMessage()

                                                                          func (*ReadTransactionRequest) Reset

                                                                          func (m *ReadTransactionRequest) Reset()

                                                                          func (*ReadTransactionRequest) String

                                                                          func (m *ReadTransactionRequest) String() string

                                                                          func (*ReadTransactionRequest) XXX_DiscardUnknown

                                                                          func (m *ReadTransactionRequest) XXX_DiscardUnknown()

                                                                          func (*ReadTransactionRequest) XXX_Marshal

                                                                          func (m *ReadTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                          func (*ReadTransactionRequest) XXX_Merge

                                                                          func (dst *ReadTransactionRequest) XXX_Merge(src proto.Message)

                                                                          func (*ReadTransactionRequest) XXX_Size

                                                                          func (m *ReadTransactionRequest) XXX_Size() int

                                                                          func (*ReadTransactionRequest) XXX_Unmarshal

                                                                          func (m *ReadTransactionRequest) XXX_Unmarshal(b []byte) error

                                                                          type ReadTransactionResponse

                                                                          type ReadTransactionResponse struct {
                                                                          	Metadata             *TransactionMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
                                                                          	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
                                                                          	XXX_unrecognized     []byte               `json:"-"`
                                                                          	XXX_sizecache        int32                `json:"-"`
                                                                          }

                                                                            ReadTransactionResponse is the returned value from ReadTransaction

                                                                            func (*ReadTransactionResponse) Descriptor

                                                                            func (*ReadTransactionResponse) Descriptor() ([]byte, []int)

                                                                            func (*ReadTransactionResponse) GetMetadata

                                                                            func (m *ReadTransactionResponse) GetMetadata() *TransactionMetadata

                                                                            func (*ReadTransactionResponse) ProtoMessage

                                                                            func (*ReadTransactionResponse) ProtoMessage()

                                                                            func (*ReadTransactionResponse) Reset

                                                                            func (m *ReadTransactionResponse) Reset()

                                                                            func (*ReadTransactionResponse) String

                                                                            func (m *ReadTransactionResponse) String() string

                                                                            func (*ReadTransactionResponse) XXX_DiscardUnknown

                                                                            func (m *ReadTransactionResponse) XXX_DiscardUnknown()

                                                                            func (*ReadTransactionResponse) XXX_Marshal

                                                                            func (m *ReadTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                            func (*ReadTransactionResponse) XXX_Merge

                                                                            func (dst *ReadTransactionResponse) XXX_Merge(src proto.Message)

                                                                            func (*ReadTransactionResponse) XXX_Size

                                                                            func (m *ReadTransactionResponse) XXX_Size() int

                                                                            func (*ReadTransactionResponse) XXX_Unmarshal

                                                                            func (m *ReadTransactionResponse) XXX_Unmarshal(b []byte) error

                                                                            type RealtimeStats

                                                                            type RealtimeStats struct {
                                                                            	// health_error is the last error we got from health check,
                                                                            	// or empty is the server is healthy. This is used for subset selection,
                                                                            	// we do not send queries to servers that are not healthy.
                                                                            	HealthError string `protobuf:"bytes,1,opt,name=health_error,json=healthError,proto3" json:"health_error,omitempty"`
                                                                            	// seconds_behind_master is populated for slaves only. It indicates
                                                                            	// how far behind on (MySQL) replication a slave currently is.  It is used
                                                                            	// by clients for subset selection (so we don't try to send traffic
                                                                            	// to tablets that are too far behind).
                                                                            	// NOTE: This field must not be evaluated if "health_error" is not empty.
                                                                            	// TODO(mberlin): Let's switch it to int64 instead?
                                                                            	SecondsBehindMaster uint32 `protobuf:"varint,2,opt,name=seconds_behind_master,json=secondsBehindMaster,proto3" json:"seconds_behind_master,omitempty"`
                                                                            	// bin_log_players_count is the number of currently running binlog players.
                                                                            	// if the value is 0, it means that filtered replication is currently not
                                                                            	// running on the tablet. If >0, filtered replication is running.
                                                                            	// NOTE: This field must not be evaluated if "health_error" is not empty.
                                                                            	BinlogPlayersCount int32 `protobuf:"varint,3,opt,name=binlog_players_count,json=binlogPlayersCount,proto3" json:"binlog_players_count,omitempty"`
                                                                            	// seconds_behind_master_filtered_replication is populated for the receiving
                                                                            	// master of an ongoing filtered replication only.
                                                                            	// It specifies how far the receiving master lags behind the sending master.
                                                                            	// NOTE: This field must not be evaluated if "health_error" is not empty.
                                                                            	// NOTE: This field must not be evaluated if "bin_log_players_count" is 0.
                                                                            	SecondsBehindMasterFilteredReplication int64 `` /* 182-byte string literal not displayed */
                                                                            	// cpu_usage is used for load-based balancing
                                                                            	CpuUsage float64 `protobuf:"fixed64,5,opt,name=cpu_usage,json=cpuUsage,proto3" json:"cpu_usage,omitempty"`
                                                                            	// qps is the average QPS (queries per second) rate in the last XX seconds
                                                                            	// where XX is usually 60 (See query_service_stats.go).
                                                                            	Qps                  float64  `protobuf:"fixed64,6,opt,name=qps,proto3" json:"qps,omitempty"`
                                                                            	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                            	XXX_unrecognized     []byte   `json:"-"`
                                                                            	XXX_sizecache        int32    `json:"-"`
                                                                            }

                                                                              RealtimeStats contains information about the tablet status. It is only valid for a single tablet.

                                                                              func (*RealtimeStats) Descriptor

                                                                              func (*RealtimeStats) Descriptor() ([]byte, []int)

                                                                              func (*RealtimeStats) GetBinlogPlayersCount

                                                                              func (m *RealtimeStats) GetBinlogPlayersCount() int32

                                                                              func (*RealtimeStats) GetCpuUsage

                                                                              func (m *RealtimeStats) GetCpuUsage() float64

                                                                              func (*RealtimeStats) GetHealthError

                                                                              func (m *RealtimeStats) GetHealthError() string

                                                                              func (*RealtimeStats) GetQps

                                                                              func (m *RealtimeStats) GetQps() float64

                                                                              func (*RealtimeStats) GetSecondsBehindMaster

                                                                              func (m *RealtimeStats) GetSecondsBehindMaster() uint32

                                                                              func (*RealtimeStats) GetSecondsBehindMasterFilteredReplication

                                                                              func (m *RealtimeStats) GetSecondsBehindMasterFilteredReplication() int64

                                                                              func (*RealtimeStats) ProtoMessage

                                                                              func (*RealtimeStats) ProtoMessage()

                                                                              func (*RealtimeStats) Reset

                                                                              func (m *RealtimeStats) Reset()

                                                                              func (*RealtimeStats) String

                                                                              func (m *RealtimeStats) String() string

                                                                              func (*RealtimeStats) XXX_DiscardUnknown

                                                                              func (m *RealtimeStats) XXX_DiscardUnknown()

                                                                              func (*RealtimeStats) XXX_Marshal

                                                                              func (m *RealtimeStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                              func (*RealtimeStats) XXX_Merge

                                                                              func (dst *RealtimeStats) XXX_Merge(src proto.Message)

                                                                              func (*RealtimeStats) XXX_Size

                                                                              func (m *RealtimeStats) XXX_Size() int

                                                                              func (*RealtimeStats) XXX_Unmarshal

                                                                              func (m *RealtimeStats) XXX_Unmarshal(b []byte) error

                                                                              type ResultExtras

                                                                              type ResultExtras struct {
                                                                              	// event_token is populated if the include_event_token flag is set
                                                                              	// in ExecuteOptions.
                                                                              	EventToken *EventToken `protobuf:"bytes,1,opt,name=event_token,json=eventToken,proto3" json:"event_token,omitempty"`
                                                                              	// If set, it means the data returned with this result is fresher
                                                                              	// than the compare_token passed in the ExecuteOptions.
                                                                              	Fresher              bool     `protobuf:"varint,2,opt,name=fresher,proto3" json:"fresher,omitempty"`
                                                                              	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                              	XXX_unrecognized     []byte   `json:"-"`
                                                                              	XXX_sizecache        int32    `json:"-"`
                                                                              }

                                                                                ResultExtras contains optional out-of-band information. Usually the extras are requested by adding ExecuteOptions flags.

                                                                                func (*ResultExtras) Descriptor

                                                                                func (*ResultExtras) Descriptor() ([]byte, []int)

                                                                                func (*ResultExtras) GetEventToken

                                                                                func (m *ResultExtras) GetEventToken() *EventToken

                                                                                func (*ResultExtras) GetFresher

                                                                                func (m *ResultExtras) GetFresher() bool

                                                                                func (*ResultExtras) ProtoMessage

                                                                                func (*ResultExtras) ProtoMessage()

                                                                                func (*ResultExtras) Reset

                                                                                func (m *ResultExtras) Reset()

                                                                                func (*ResultExtras) String

                                                                                func (m *ResultExtras) String() string

                                                                                func (*ResultExtras) XXX_DiscardUnknown

                                                                                func (m *ResultExtras) XXX_DiscardUnknown()

                                                                                func (*ResultExtras) XXX_Marshal

                                                                                func (m *ResultExtras) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                func (*ResultExtras) XXX_Merge

                                                                                func (dst *ResultExtras) XXX_Merge(src proto.Message)

                                                                                func (*ResultExtras) XXX_Size

                                                                                func (m *ResultExtras) XXX_Size() int

                                                                                func (*ResultExtras) XXX_Unmarshal

                                                                                func (m *ResultExtras) XXX_Unmarshal(b []byte) error

                                                                                type ResultWithError

                                                                                type ResultWithError struct {
                                                                                	// error contains an query level error, only set if result is unset.
                                                                                	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
                                                                                	// result contains the query result, only set if error is unset.
                                                                                	Result               *QueryResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
                                                                                	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
                                                                                	XXX_unrecognized     []byte       `json:"-"`
                                                                                	XXX_sizecache        int32        `json:"-"`
                                                                                }

                                                                                  ResultWithError represents a query response in the form of result or error but not both. TODO: To be used in ExecuteBatchResponse and BeginExecuteBatchResponse.

                                                                                  func (*ResultWithError) Descriptor

                                                                                  func (*ResultWithError) Descriptor() ([]byte, []int)

                                                                                  func (*ResultWithError) GetError

                                                                                  func (m *ResultWithError) GetError() *vtrpc.RPCError

                                                                                  func (*ResultWithError) GetResult

                                                                                  func (m *ResultWithError) GetResult() *QueryResult

                                                                                  func (*ResultWithError) ProtoMessage

                                                                                  func (*ResultWithError) ProtoMessage()

                                                                                  func (*ResultWithError) Reset

                                                                                  func (m *ResultWithError) Reset()

                                                                                  func (*ResultWithError) String

                                                                                  func (m *ResultWithError) String() string

                                                                                  func (*ResultWithError) XXX_DiscardUnknown

                                                                                  func (m *ResultWithError) XXX_DiscardUnknown()

                                                                                  func (*ResultWithError) XXX_Marshal

                                                                                  func (m *ResultWithError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                  func (*ResultWithError) XXX_Merge

                                                                                  func (dst *ResultWithError) XXX_Merge(src proto.Message)

                                                                                  func (*ResultWithError) XXX_Size

                                                                                  func (m *ResultWithError) XXX_Size() int

                                                                                  func (*ResultWithError) XXX_Unmarshal

                                                                                  func (m *ResultWithError) XXX_Unmarshal(b []byte) error

                                                                                  type RollbackPreparedRequest

                                                                                  type RollbackPreparedRequest struct {
                                                                                  	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                                                                                  	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                                                                                  	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                                                                                  	TransactionId        int64           `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
                                                                                  	Dtid                 string          `protobuf:"bytes,5,opt,name=dtid,proto3" json:"dtid,omitempty"`
                                                                                  	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
                                                                                  	XXX_unrecognized     []byte          `json:"-"`
                                                                                  	XXX_sizecache        int32           `json:"-"`
                                                                                  }

                                                                                    RollbackPreparedRequest is the payload to RollbackPrepared

                                                                                    func (*RollbackPreparedRequest) Descriptor

                                                                                    func (*RollbackPreparedRequest) Descriptor() ([]byte, []int)

                                                                                    func (*RollbackPreparedRequest) GetDtid

                                                                                    func (m *RollbackPreparedRequest) GetDtid() string

                                                                                    func (*RollbackPreparedRequest) GetEffectiveCallerId

                                                                                    func (m *RollbackPreparedRequest) GetEffectiveCallerId() *vtrpc.CallerID

                                                                                    func (*RollbackPreparedRequest) GetImmediateCallerId

                                                                                    func (m *RollbackPreparedRequest) GetImmediateCallerId() *VTGateCallerID

                                                                                    func (*RollbackPreparedRequest) GetTarget

                                                                                    func (m *RollbackPreparedRequest) GetTarget() *Target

                                                                                    func (*RollbackPreparedRequest) GetTransactionId

                                                                                    func (m *RollbackPreparedRequest) GetTransactionId() int64

                                                                                    func (*RollbackPreparedRequest) ProtoMessage

                                                                                    func (*RollbackPreparedRequest) ProtoMessage()

                                                                                    func (*RollbackPreparedRequest) Reset

                                                                                    func (m *RollbackPreparedRequest) Reset()

                                                                                    func (*RollbackPreparedRequest) String

                                                                                    func (m *RollbackPreparedRequest) String() string

                                                                                    func (*RollbackPreparedRequest) XXX_DiscardUnknown

                                                                                    func (m *RollbackPreparedRequest) XXX_DiscardUnknown()

                                                                                    func (*RollbackPreparedRequest) XXX_Marshal

                                                                                    func (m *RollbackPreparedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                    func (*RollbackPreparedRequest) XXX_Merge

                                                                                    func (dst *RollbackPreparedRequest) XXX_Merge(src proto.Message)

                                                                                    func (*RollbackPreparedRequest) XXX_Size

                                                                                    func (m *RollbackPreparedRequest) XXX_Size() int

                                                                                    func (*RollbackPreparedRequest) XXX_Unmarshal

                                                                                    func (m *RollbackPreparedRequest) XXX_Unmarshal(b []byte) error

                                                                                    type RollbackPreparedResponse

                                                                                    type RollbackPreparedResponse struct {
                                                                                    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                    	XXX_unrecognized     []byte   `json:"-"`
                                                                                    	XXX_sizecache        int32    `json:"-"`
                                                                                    }

                                                                                      RollbackPreparedResponse is the returned value from RollbackPrepared

                                                                                      func (*RollbackPreparedResponse) Descriptor

                                                                                      func (*RollbackPreparedResponse) Descriptor() ([]byte, []int)

                                                                                      func (*RollbackPreparedResponse) ProtoMessage

                                                                                      func (*RollbackPreparedResponse) ProtoMessage()

                                                                                      func (*RollbackPreparedResponse) Reset

                                                                                      func (m *RollbackPreparedResponse) Reset()

                                                                                      func (*RollbackPreparedResponse) String

                                                                                      func (m *RollbackPreparedResponse) String() string

                                                                                      func (*RollbackPreparedResponse) XXX_DiscardUnknown

                                                                                      func (m *RollbackPreparedResponse) XXX_DiscardUnknown()

                                                                                      func (*RollbackPreparedResponse) XXX_Marshal

                                                                                      func (m *RollbackPreparedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                      func (*RollbackPreparedResponse) XXX_Merge

                                                                                      func (dst *RollbackPreparedResponse) XXX_Merge(src proto.Message)

                                                                                      func (*RollbackPreparedResponse) XXX_Size

                                                                                      func (m *RollbackPreparedResponse) XXX_Size() int

                                                                                      func (*RollbackPreparedResponse) XXX_Unmarshal

                                                                                      func (m *RollbackPreparedResponse) XXX_Unmarshal(b []byte) error

                                                                                      type RollbackRequest

                                                                                      type RollbackRequest struct {
                                                                                      	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                                                                                      	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                                                                                      	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                                                                                      	TransactionId        int64           `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
                                                                                      	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
                                                                                      	XXX_unrecognized     []byte          `json:"-"`
                                                                                      	XXX_sizecache        int32           `json:"-"`
                                                                                      }

                                                                                        RollbackRequest is the payload to Rollback

                                                                                        func (*RollbackRequest) Descriptor

                                                                                        func (*RollbackRequest) Descriptor() ([]byte, []int)

                                                                                        func (*RollbackRequest) GetEffectiveCallerId

                                                                                        func (m *RollbackRequest) GetEffectiveCallerId() *vtrpc.CallerID

                                                                                        func (*RollbackRequest) GetImmediateCallerId

                                                                                        func (m *RollbackRequest) GetImmediateCallerId() *VTGateCallerID

                                                                                        func (*RollbackRequest) GetTarget

                                                                                        func (m *RollbackRequest) GetTarget() *Target

                                                                                        func (*RollbackRequest) GetTransactionId

                                                                                        func (m *RollbackRequest) GetTransactionId() int64

                                                                                        func (*RollbackRequest) ProtoMessage

                                                                                        func (*RollbackRequest) ProtoMessage()

                                                                                        func (*RollbackRequest) Reset

                                                                                        func (m *RollbackRequest) Reset()

                                                                                        func (*RollbackRequest) String

                                                                                        func (m *RollbackRequest) String() string

                                                                                        func (*RollbackRequest) XXX_DiscardUnknown

                                                                                        func (m *RollbackRequest) XXX_DiscardUnknown()

                                                                                        func (*RollbackRequest) XXX_Marshal

                                                                                        func (m *RollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                        func (*RollbackRequest) XXX_Merge

                                                                                        func (dst *RollbackRequest) XXX_Merge(src proto.Message)

                                                                                        func (*RollbackRequest) XXX_Size

                                                                                        func (m *RollbackRequest) XXX_Size() int

                                                                                        func (*RollbackRequest) XXX_Unmarshal

                                                                                        func (m *RollbackRequest) XXX_Unmarshal(b []byte) error

                                                                                        type RollbackResponse

                                                                                        type RollbackResponse struct {
                                                                                        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                        	XXX_unrecognized     []byte   `json:"-"`
                                                                                        	XXX_sizecache        int32    `json:"-"`
                                                                                        }

                                                                                          RollbackResponse is the returned value from Rollback

                                                                                          func (*RollbackResponse) Descriptor

                                                                                          func (*RollbackResponse) Descriptor() ([]byte, []int)

                                                                                          func (*RollbackResponse) ProtoMessage

                                                                                          func (*RollbackResponse) ProtoMessage()

                                                                                          func (*RollbackResponse) Reset

                                                                                          func (m *RollbackResponse) Reset()

                                                                                          func (*RollbackResponse) String

                                                                                          func (m *RollbackResponse) String() string

                                                                                          func (*RollbackResponse) XXX_DiscardUnknown

                                                                                          func (m *RollbackResponse) XXX_DiscardUnknown()

                                                                                          func (*RollbackResponse) XXX_Marshal

                                                                                          func (m *RollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                          func (*RollbackResponse) XXX_Merge

                                                                                          func (dst *RollbackResponse) XXX_Merge(src proto.Message)

                                                                                          func (*RollbackResponse) XXX_Size

                                                                                          func (m *RollbackResponse) XXX_Size() int

                                                                                          func (*RollbackResponse) XXX_Unmarshal

                                                                                          func (m *RollbackResponse) XXX_Unmarshal(b []byte) error

                                                                                          type Row

                                                                                          type Row struct {
                                                                                          	// lengths contains the length of each value in values.
                                                                                          	// A length of -1 means that the field is NULL. While
                                                                                          	// reading values, you have to accummulate the length
                                                                                          	// to know the offset where the next value begins in values.
                                                                                          	Lengths []int64 `protobuf:"zigzag64,1,rep,packed,name=lengths,proto3" json:"lengths,omitempty"`
                                                                                          	// values contains a concatenation of all values in the row.
                                                                                          	Values               []byte   `protobuf:"bytes,2,opt,name=values,proto3" json:"values,omitempty"`
                                                                                          	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                          	XXX_unrecognized     []byte   `json:"-"`
                                                                                          	XXX_sizecache        int32    `json:"-"`
                                                                                          }

                                                                                            Row is a database row.

                                                                                            func (*Row) Descriptor

                                                                                            func (*Row) Descriptor() ([]byte, []int)

                                                                                            func (*Row) GetLengths

                                                                                            func (m *Row) GetLengths() []int64

                                                                                            func (*Row) GetValues

                                                                                            func (m *Row) GetValues() []byte

                                                                                            func (*Row) ProtoMessage

                                                                                            func (*Row) ProtoMessage()

                                                                                            func (*Row) Reset

                                                                                            func (m *Row) Reset()

                                                                                            func (*Row) String

                                                                                            func (m *Row) String() string

                                                                                            func (*Row) XXX_DiscardUnknown

                                                                                            func (m *Row) XXX_DiscardUnknown()

                                                                                            func (*Row) XXX_Marshal

                                                                                            func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                            func (*Row) XXX_Merge

                                                                                            func (dst *Row) XXX_Merge(src proto.Message)

                                                                                            func (*Row) XXX_Size

                                                                                            func (m *Row) XXX_Size() int

                                                                                            func (*Row) XXX_Unmarshal

                                                                                            func (m *Row) XXX_Unmarshal(b []byte) error

                                                                                            type SetRollbackRequest

                                                                                            type SetRollbackRequest struct {
                                                                                            	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                                                                                            	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                                                                                            	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                                                                                            	TransactionId        int64           `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
                                                                                            	Dtid                 string          `protobuf:"bytes,5,opt,name=dtid,proto3" json:"dtid,omitempty"`
                                                                                            	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
                                                                                            	XXX_unrecognized     []byte          `json:"-"`
                                                                                            	XXX_sizecache        int32           `json:"-"`
                                                                                            }

                                                                                              SetRollbackRequest is the payload to SetRollback

                                                                                              func (*SetRollbackRequest) Descriptor

                                                                                              func (*SetRollbackRequest) Descriptor() ([]byte, []int)

                                                                                              func (*SetRollbackRequest) GetDtid

                                                                                              func (m *SetRollbackRequest) GetDtid() string

                                                                                              func (*SetRollbackRequest) GetEffectiveCallerId

                                                                                              func (m *SetRollbackRequest) GetEffectiveCallerId() *vtrpc.CallerID

                                                                                              func (*SetRollbackRequest) GetImmediateCallerId

                                                                                              func (m *SetRollbackRequest) GetImmediateCallerId() *VTGateCallerID

                                                                                              func (*SetRollbackRequest) GetTarget

                                                                                              func (m *SetRollbackRequest) GetTarget() *Target

                                                                                              func (*SetRollbackRequest) GetTransactionId

                                                                                              func (m *SetRollbackRequest) GetTransactionId() int64

                                                                                              func (*SetRollbackRequest) ProtoMessage

                                                                                              func (*SetRollbackRequest) ProtoMessage()

                                                                                              func (*SetRollbackRequest) Reset

                                                                                              func (m *SetRollbackRequest) Reset()

                                                                                              func (*SetRollbackRequest) String

                                                                                              func (m *SetRollbackRequest) String() string

                                                                                              func (*SetRollbackRequest) XXX_DiscardUnknown

                                                                                              func (m *SetRollbackRequest) XXX_DiscardUnknown()

                                                                                              func (*SetRollbackRequest) XXX_Marshal

                                                                                              func (m *SetRollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                              func (*SetRollbackRequest) XXX_Merge

                                                                                              func (dst *SetRollbackRequest) XXX_Merge(src proto.Message)

                                                                                              func (*SetRollbackRequest) XXX_Size

                                                                                              func (m *SetRollbackRequest) XXX_Size() int

                                                                                              func (*SetRollbackRequest) XXX_Unmarshal

                                                                                              func (m *SetRollbackRequest) XXX_Unmarshal(b []byte) error

                                                                                              type SetRollbackResponse

                                                                                              type SetRollbackResponse struct {
                                                                                              	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                              	XXX_unrecognized     []byte   `json:"-"`
                                                                                              	XXX_sizecache        int32    `json:"-"`
                                                                                              }

                                                                                                SetRollbackResponse is the returned value from SetRollback

                                                                                                func (*SetRollbackResponse) Descriptor

                                                                                                func (*SetRollbackResponse) Descriptor() ([]byte, []int)

                                                                                                func (*SetRollbackResponse) ProtoMessage

                                                                                                func (*SetRollbackResponse) ProtoMessage()

                                                                                                func (*SetRollbackResponse) Reset

                                                                                                func (m *SetRollbackResponse) Reset()

                                                                                                func (*SetRollbackResponse) String

                                                                                                func (m *SetRollbackResponse) String() string

                                                                                                func (*SetRollbackResponse) XXX_DiscardUnknown

                                                                                                func (m *SetRollbackResponse) XXX_DiscardUnknown()

                                                                                                func (*SetRollbackResponse) XXX_Marshal

                                                                                                func (m *SetRollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                func (*SetRollbackResponse) XXX_Merge

                                                                                                func (dst *SetRollbackResponse) XXX_Merge(src proto.Message)

                                                                                                func (*SetRollbackResponse) XXX_Size

                                                                                                func (m *SetRollbackResponse) XXX_Size() int

                                                                                                func (*SetRollbackResponse) XXX_Unmarshal

                                                                                                func (m *SetRollbackResponse) XXX_Unmarshal(b []byte) error

                                                                                                type SplitQueryRequest

                                                                                                type SplitQueryRequest struct {
                                                                                                	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                                                                                                	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                                                                                                	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                                                                                                	Query             *BoundQuery     `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
                                                                                                	SplitColumn       []string        `protobuf:"bytes,5,rep,name=split_column,json=splitColumn,proto3" json:"split_column,omitempty"`
                                                                                                	// Exactly one of the following must be nonzero.
                                                                                                	SplitCount           int64                       `protobuf:"varint,6,opt,name=split_count,json=splitCount,proto3" json:"split_count,omitempty"`
                                                                                                	NumRowsPerQueryPart  int64                       `protobuf:"varint,8,opt,name=num_rows_per_query_part,json=numRowsPerQueryPart,proto3" json:"num_rows_per_query_part,omitempty"`
                                                                                                	Algorithm            SplitQueryRequest_Algorithm `protobuf:"varint,9,opt,name=algorithm,proto3,enum=query.SplitQueryRequest_Algorithm" json:"algorithm,omitempty"`
                                                                                                	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
                                                                                                	XXX_unrecognized     []byte                      `json:"-"`
                                                                                                	XXX_sizecache        int32                       `json:"-"`
                                                                                                }

                                                                                                  SplitQueryRequest is the payload for SplitQuery sent by VTGate to a VTTablet. See vtgate.SplitQueryRequest for more details.

                                                                                                  func (*SplitQueryRequest) Descriptor

                                                                                                  func (*SplitQueryRequest) Descriptor() ([]byte, []int)

                                                                                                  func (*SplitQueryRequest) GetAlgorithm

                                                                                                  func (*SplitQueryRequest) GetEffectiveCallerId

                                                                                                  func (m *SplitQueryRequest) GetEffectiveCallerId() *vtrpc.CallerID

                                                                                                  func (*SplitQueryRequest) GetImmediateCallerId

                                                                                                  func (m *SplitQueryRequest) GetImmediateCallerId() *VTGateCallerID

                                                                                                  func (*SplitQueryRequest) GetNumRowsPerQueryPart

                                                                                                  func (m *SplitQueryRequest) GetNumRowsPerQueryPart() int64

                                                                                                  func (*SplitQueryRequest) GetQuery

                                                                                                  func (m *SplitQueryRequest) GetQuery() *BoundQuery

                                                                                                  func (*SplitQueryRequest) GetSplitColumn

                                                                                                  func (m *SplitQueryRequest) GetSplitColumn() []string

                                                                                                  func (*SplitQueryRequest) GetSplitCount

                                                                                                  func (m *SplitQueryRequest) GetSplitCount() int64

                                                                                                  func (*SplitQueryRequest) GetTarget

                                                                                                  func (m *SplitQueryRequest) GetTarget() *Target

                                                                                                  func (*SplitQueryRequest) ProtoMessage

                                                                                                  func (*SplitQueryRequest) ProtoMessage()

                                                                                                  func (*SplitQueryRequest) Reset

                                                                                                  func (m *SplitQueryRequest) Reset()

                                                                                                  func (*SplitQueryRequest) String

                                                                                                  func (m *SplitQueryRequest) String() string

                                                                                                  func (*SplitQueryRequest) XXX_DiscardUnknown

                                                                                                  func (m *SplitQueryRequest) XXX_DiscardUnknown()

                                                                                                  func (*SplitQueryRequest) XXX_Marshal

                                                                                                  func (m *SplitQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                  func (*SplitQueryRequest) XXX_Merge

                                                                                                  func (dst *SplitQueryRequest) XXX_Merge(src proto.Message)

                                                                                                  func (*SplitQueryRequest) XXX_Size

                                                                                                  func (m *SplitQueryRequest) XXX_Size() int

                                                                                                  func (*SplitQueryRequest) XXX_Unmarshal

                                                                                                  func (m *SplitQueryRequest) XXX_Unmarshal(b []byte) error

                                                                                                  type SplitQueryRequest_Algorithm

                                                                                                  type SplitQueryRequest_Algorithm int32
                                                                                                  const (
                                                                                                  	SplitQueryRequest_EQUAL_SPLITS SplitQueryRequest_Algorithm = 0
                                                                                                  	SplitQueryRequest_FULL_SCAN    SplitQueryRequest_Algorithm = 1
                                                                                                  )

                                                                                                  func (SplitQueryRequest_Algorithm) EnumDescriptor

                                                                                                  func (SplitQueryRequest_Algorithm) EnumDescriptor() ([]byte, []int)

                                                                                                  func (SplitQueryRequest_Algorithm) String

                                                                                                  type SplitQueryResponse

                                                                                                  type SplitQueryResponse struct {
                                                                                                  	Queries              []*QuerySplit `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
                                                                                                  	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
                                                                                                  	XXX_unrecognized     []byte        `json:"-"`
                                                                                                  	XXX_sizecache        int32         `json:"-"`
                                                                                                  }

                                                                                                    SplitQueryResponse is returned by SplitQuery and represents all the queries to execute in order to get the entire data set.

                                                                                                    func (*SplitQueryResponse) Descriptor

                                                                                                    func (*SplitQueryResponse) Descriptor() ([]byte, []int)

                                                                                                    func (*SplitQueryResponse) GetQueries

                                                                                                    func (m *SplitQueryResponse) GetQueries() []*QuerySplit

                                                                                                    func (*SplitQueryResponse) ProtoMessage

                                                                                                    func (*SplitQueryResponse) ProtoMessage()

                                                                                                    func (*SplitQueryResponse) Reset

                                                                                                    func (m *SplitQueryResponse) Reset()

                                                                                                    func (*SplitQueryResponse) String

                                                                                                    func (m *SplitQueryResponse) String() string

                                                                                                    func (*SplitQueryResponse) XXX_DiscardUnknown

                                                                                                    func (m *SplitQueryResponse) XXX_DiscardUnknown()

                                                                                                    func (*SplitQueryResponse) XXX_Marshal

                                                                                                    func (m *SplitQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                    func (*SplitQueryResponse) XXX_Merge

                                                                                                    func (dst *SplitQueryResponse) XXX_Merge(src proto.Message)

                                                                                                    func (*SplitQueryResponse) XXX_Size

                                                                                                    func (m *SplitQueryResponse) XXX_Size() int

                                                                                                    func (*SplitQueryResponse) XXX_Unmarshal

                                                                                                    func (m *SplitQueryResponse) XXX_Unmarshal(b []byte) error

                                                                                                    type StartCommitRequest

                                                                                                    type StartCommitRequest struct {
                                                                                                    	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                                                                                                    	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                                                                                                    	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                                                                                                    	TransactionId        int64           `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
                                                                                                    	Dtid                 string          `protobuf:"bytes,5,opt,name=dtid,proto3" json:"dtid,omitempty"`
                                                                                                    	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
                                                                                                    	XXX_unrecognized     []byte          `json:"-"`
                                                                                                    	XXX_sizecache        int32           `json:"-"`
                                                                                                    }

                                                                                                      StartCommitRequest is the payload to StartCommit

                                                                                                      func (*StartCommitRequest) Descriptor

                                                                                                      func (*StartCommitRequest) Descriptor() ([]byte, []int)

                                                                                                      func (*StartCommitRequest) GetDtid

                                                                                                      func (m *StartCommitRequest) GetDtid() string

                                                                                                      func (*StartCommitRequest) GetEffectiveCallerId

                                                                                                      func (m *StartCommitRequest) GetEffectiveCallerId() *vtrpc.CallerID

                                                                                                      func (*StartCommitRequest) GetImmediateCallerId

                                                                                                      func (m *StartCommitRequest) GetImmediateCallerId() *VTGateCallerID

                                                                                                      func (*StartCommitRequest) GetTarget

                                                                                                      func (m *StartCommitRequest) GetTarget() *Target

                                                                                                      func (*StartCommitRequest) GetTransactionId

                                                                                                      func (m *StartCommitRequest) GetTransactionId() int64

                                                                                                      func (*StartCommitRequest) ProtoMessage

                                                                                                      func (*StartCommitRequest) ProtoMessage()

                                                                                                      func (*StartCommitRequest) Reset

                                                                                                      func (m *StartCommitRequest) Reset()

                                                                                                      func (*StartCommitRequest) String

                                                                                                      func (m *StartCommitRequest) String() string

                                                                                                      func (*StartCommitRequest) XXX_DiscardUnknown

                                                                                                      func (m *StartCommitRequest) XXX_DiscardUnknown()

                                                                                                      func (*StartCommitRequest) XXX_Marshal

                                                                                                      func (m *StartCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                      func (*StartCommitRequest) XXX_Merge

                                                                                                      func (dst *StartCommitRequest) XXX_Merge(src proto.Message)

                                                                                                      func (*StartCommitRequest) XXX_Size

                                                                                                      func (m *StartCommitRequest) XXX_Size() int

                                                                                                      func (*StartCommitRequest) XXX_Unmarshal

                                                                                                      func (m *StartCommitRequest) XXX_Unmarshal(b []byte) error

                                                                                                      type StartCommitResponse

                                                                                                      type StartCommitResponse struct {
                                                                                                      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                                      	XXX_unrecognized     []byte   `json:"-"`
                                                                                                      	XXX_sizecache        int32    `json:"-"`
                                                                                                      }

                                                                                                        StartCommitResponse is the returned value from StartCommit

                                                                                                        func (*StartCommitResponse) Descriptor

                                                                                                        func (*StartCommitResponse) Descriptor() ([]byte, []int)

                                                                                                        func (*StartCommitResponse) ProtoMessage

                                                                                                        func (*StartCommitResponse) ProtoMessage()

                                                                                                        func (*StartCommitResponse) Reset

                                                                                                        func (m *StartCommitResponse) Reset()

                                                                                                        func (*StartCommitResponse) String

                                                                                                        func (m *StartCommitResponse) String() string

                                                                                                        func (*StartCommitResponse) XXX_DiscardUnknown

                                                                                                        func (m *StartCommitResponse) XXX_DiscardUnknown()

                                                                                                        func (*StartCommitResponse) XXX_Marshal

                                                                                                        func (m *StartCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                        func (*StartCommitResponse) XXX_Merge

                                                                                                        func (dst *StartCommitResponse) XXX_Merge(src proto.Message)

                                                                                                        func (*StartCommitResponse) XXX_Size

                                                                                                        func (m *StartCommitResponse) XXX_Size() int

                                                                                                        func (*StartCommitResponse) XXX_Unmarshal

                                                                                                        func (m *StartCommitResponse) XXX_Unmarshal(b []byte) error

                                                                                                        type StreamEvent

                                                                                                        type StreamEvent struct {
                                                                                                        	// The statements in this transaction.
                                                                                                        	Statements []*StreamEvent_Statement `protobuf:"bytes,1,rep,name=statements,proto3" json:"statements,omitempty"`
                                                                                                        	// The Event Token for this event.
                                                                                                        	EventToken           *EventToken `protobuf:"bytes,2,opt,name=event_token,json=eventToken,proto3" json:"event_token,omitempty"`
                                                                                                        	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
                                                                                                        	XXX_unrecognized     []byte      `json:"-"`
                                                                                                        	XXX_sizecache        int32       `json:"-"`
                                                                                                        }

                                                                                                          StreamEvent describes a set of transformations that happened as a single transactional unit on a server. It is streamed back by the Update Stream calls.

                                                                                                          func (*StreamEvent) Descriptor

                                                                                                          func (*StreamEvent) Descriptor() ([]byte, []int)

                                                                                                          func (*StreamEvent) GetEventToken

                                                                                                          func (m *StreamEvent) GetEventToken() *EventToken

                                                                                                          func (*StreamEvent) GetStatements

                                                                                                          func (m *StreamEvent) GetStatements() []*StreamEvent_Statement

                                                                                                          func (*StreamEvent) ProtoMessage

                                                                                                          func (*StreamEvent) ProtoMessage()

                                                                                                          func (*StreamEvent) Reset

                                                                                                          func (m *StreamEvent) Reset()

                                                                                                          func (*StreamEvent) String

                                                                                                          func (m *StreamEvent) String() string

                                                                                                          func (*StreamEvent) XXX_DiscardUnknown

                                                                                                          func (m *StreamEvent) XXX_DiscardUnknown()

                                                                                                          func (*StreamEvent) XXX_Marshal

                                                                                                          func (m *StreamEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                          func (*StreamEvent) XXX_Merge

                                                                                                          func (dst *StreamEvent) XXX_Merge(src proto.Message)

                                                                                                          func (*StreamEvent) XXX_Size

                                                                                                          func (m *StreamEvent) XXX_Size() int

                                                                                                          func (*StreamEvent) XXX_Unmarshal

                                                                                                          func (m *StreamEvent) XXX_Unmarshal(b []byte) error

                                                                                                          type StreamEvent_Statement

                                                                                                          type StreamEvent_Statement struct {
                                                                                                          	Category StreamEvent_Statement_Category `protobuf:"varint,1,opt,name=category,proto3,enum=query.StreamEvent_Statement_Category" json:"category,omitempty"`
                                                                                                          	// table_name, primary_key_fields and primary_key_values are set for DML.
                                                                                                          	TableName        string   `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
                                                                                                          	PrimaryKeyFields []*Field `protobuf:"bytes,3,rep,name=primary_key_fields,json=primaryKeyFields,proto3" json:"primary_key_fields,omitempty"`
                                                                                                          	PrimaryKeyValues []*Row   `protobuf:"bytes,4,rep,name=primary_key_values,json=primaryKeyValues,proto3" json:"primary_key_values,omitempty"`
                                                                                                          	// sql is set for all queries.
                                                                                                          	// FIXME(alainjobart) we may not need it for DMLs.
                                                                                                          	Sql                  []byte   `protobuf:"bytes,5,opt,name=sql,proto3" json:"sql,omitempty"`
                                                                                                          	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                                          	XXX_unrecognized     []byte   `json:"-"`
                                                                                                          	XXX_sizecache        int32    `json:"-"`
                                                                                                          }

                                                                                                            One individual Statement in a transaction.

                                                                                                            func (*StreamEvent_Statement) Descriptor

                                                                                                            func (*StreamEvent_Statement) Descriptor() ([]byte, []int)

                                                                                                            func (*StreamEvent_Statement) GetCategory

                                                                                                            func (*StreamEvent_Statement) GetPrimaryKeyFields

                                                                                                            func (m *StreamEvent_Statement) GetPrimaryKeyFields() []*Field

                                                                                                            func (*StreamEvent_Statement) GetPrimaryKeyValues

                                                                                                            func (m *StreamEvent_Statement) GetPrimaryKeyValues() []*Row

                                                                                                            func (*StreamEvent_Statement) GetSql

                                                                                                            func (m *StreamEvent_Statement) GetSql() []byte

                                                                                                            func (*StreamEvent_Statement) GetTableName

                                                                                                            func (m *StreamEvent_Statement) GetTableName() string

                                                                                                            func (*StreamEvent_Statement) ProtoMessage

                                                                                                            func (*StreamEvent_Statement) ProtoMessage()

                                                                                                            func (*StreamEvent_Statement) Reset

                                                                                                            func (m *StreamEvent_Statement) Reset()

                                                                                                            func (*StreamEvent_Statement) String

                                                                                                            func (m *StreamEvent_Statement) String() string

                                                                                                            func (*StreamEvent_Statement) XXX_DiscardUnknown

                                                                                                            func (m *StreamEvent_Statement) XXX_DiscardUnknown()

                                                                                                            func (*StreamEvent_Statement) XXX_Marshal

                                                                                                            func (m *StreamEvent_Statement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                            func (*StreamEvent_Statement) XXX_Merge

                                                                                                            func (dst *StreamEvent_Statement) XXX_Merge(src proto.Message)

                                                                                                            func (*StreamEvent_Statement) XXX_Size

                                                                                                            func (m *StreamEvent_Statement) XXX_Size() int

                                                                                                            func (*StreamEvent_Statement) XXX_Unmarshal

                                                                                                            func (m *StreamEvent_Statement) XXX_Unmarshal(b []byte) error

                                                                                                            type StreamEvent_Statement_Category

                                                                                                            type StreamEvent_Statement_Category int32

                                                                                                              The category of one statement.

                                                                                                              const (
                                                                                                              	StreamEvent_Statement_Error StreamEvent_Statement_Category = 0
                                                                                                              	StreamEvent_Statement_DML   StreamEvent_Statement_Category = 1
                                                                                                              	StreamEvent_Statement_DDL   StreamEvent_Statement_Category = 2
                                                                                                              )

                                                                                                              func (StreamEvent_Statement_Category) EnumDescriptor

                                                                                                              func (StreamEvent_Statement_Category) EnumDescriptor() ([]byte, []int)

                                                                                                              func (StreamEvent_Statement_Category) String

                                                                                                              type StreamExecuteRequest

                                                                                                              type StreamExecuteRequest struct {
                                                                                                              	EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
                                                                                                              	ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
                                                                                                              	Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
                                                                                                              	Query                *BoundQuery     `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
                                                                                                              	Options              *ExecuteOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
                                                                                                              	TransactionId        int64           `protobuf:"varint,6,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
                                                                                                              	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
                                                                                                              	XXX_unrecognized     []byte          `json:"-"`
                                                                                                              	XXX_sizecache        int32           `json:"-"`
                                                                                                              }

                                                                                                                StreamExecuteRequest is the payload to StreamExecute

                                                                                                                func (*StreamExecuteRequest) Descriptor

                                                                                                                func (*StreamExecuteRequest) Descriptor() ([]byte, []int)

                                                                                                                func (*StreamExecuteRequest) GetEffectiveCallerId

                                                                                                                func (m *StreamExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

                                                                                                                func (*StreamExecuteRequest) GetImmediateCallerId

                                                                                                                func (m *StreamExecuteRequest) GetImmediateCallerId() *VTGateCallerID

                                                                                                                func (*StreamExecuteRequest) GetOptions

                                                                                                                func (m *StreamExecuteRequest) GetOptions() *ExecuteOptions

                                                                                                                func (*StreamExecuteRequest) GetQuery

                                                                                                                func (m *StreamExecuteRequest) GetQuery() *BoundQuery

                                                                                                                func (*StreamExecuteRequest) GetTarget

                                                                                                                func (m *StreamExecuteRequest) GetTarget() *Target

                                                                                                                func (*StreamExecuteRequest) GetTransactionId

                                                                                                                func (m *StreamExecuteRequest) GetTransactionId() int64

                                                                                                                func (*StreamExecuteRequest) ProtoMessage

                                                                                                                func (*StreamExecuteRequest) ProtoMessage()

                                                                                                                func (*StreamExecuteRequest) Reset

                                                                                                                func (m *StreamExecuteRequest) Reset()

                                                                                                                func (*StreamExecuteRequest) String

                                                                                                                func (m *StreamExecuteRequest) String() string

                                                                                                                func (*StreamExecuteRequest) XXX_DiscardUnknown

                                                                                                                func (m *StreamExecuteRequest) XXX_DiscardUnknown()

                                                                                                                func (*StreamExecuteRequest) XXX_Marshal

                                                                                                                func (m *StreamExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                                func (*StreamExecuteRequest) XXX_Merge

                                                                                                                func (dst *StreamExecuteRequest) XXX_Merge(src proto.Message)

                                                                                                                func (*StreamExecuteRequest) XXX_Size

                                                                                                                func (m *StreamExecuteRequest) XXX_Size() int

                                                                                                                func (*StreamExecuteRequest) XXX_Unmarshal

                                                                                                                func (m *StreamExecuteRequest) XXX_Unmarshal(b []byte) error

                                                                                                                type StreamExecuteResponse

                                                                                                                type StreamExecuteResponse struct {
                                                                                                                	Result               *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
                                                                                                                	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
                                                                                                                	XXX_unrecognized     []byte       `json:"-"`
                                                                                                                	XXX_sizecache        int32        `json:"-"`
                                                                                                                }

                                                                                                                  StreamExecuteResponse is the returned value from StreamExecute

                                                                                                                  func (*StreamExecuteResponse) Descriptor

                                                                                                                  func (*StreamExecuteResponse) Descriptor() ([]byte, []int)

                                                                                                                  func (*StreamExecuteResponse) GetResult

                                                                                                                  func (m *StreamExecuteResponse) GetResult() *QueryResult

                                                                                                                  func (*StreamExecuteResponse) ProtoMessage

                                                                                                                  func (*StreamExecuteResponse) ProtoMessage()

                                                                                                                  func (*StreamExecuteResponse) Reset

                                                                                                                  func (m *StreamExecuteResponse) Reset()

                                                                                                                  func (*StreamExecuteResponse) String

                                                                                                                  func (m *StreamExecuteResponse) String() string

                                                                                                                  func (*StreamExecuteResponse) XXX_DiscardUnknown

                                                                                                                  func (m *StreamExecuteResponse) XXX_DiscardUnknown()

                                                                                                                  func (*StreamExecuteResponse) XXX_Marshal

                                                                                                                  func (m *StreamExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

                                                                                                                  func (*StreamExecuteResponse) XXX_Merge

                                                                                                                  func (dst *StreamExecuteResponse) XXX_Merge(src proto.Message)

                                                                                                                  func (*StreamExecuteResponse) XXX_Size

                                                                                                                  func (m *StreamExecuteResponse) XXX_Size() int

                                                                                                                  func (*StreamExecuteResponse) XXX_Unmarshal

                                                                                                                  func (m *StreamExecuteResponse) XXX_Unmarshal(b []byte) error

                                                                                                                  type StreamHealthRequest

                                                                                                                  type StreamHealthRequest struct {
                                                                                                                  	XXX_NoUnkeyedLiteral struct{} `json:"-"`
                                                                                                                  	XXX_unrecognized     []byte   `json:"-"`
                                                                                                                  	XXX_sizecache        int32    `json:"-"`
                                                                                                                  }

                                                                                                                    StreamHealthRequest is the payload for StreamHealth

                                                                                                                    func (*StreamHealthRequest) Descriptor

                                                                                                                    func (*StreamHealthRequest) Descriptor() ([]byte, []int)

                                                                                                                    func (*StreamHealthRequest) ProtoMessage

                                                                                                                    func (*StreamHealthRequest) ProtoMessage()

                                                                                                                    func (*StreamHealthRequest) Reset

                                                                                                                    func (m *StreamHealthRequest) Reset()

                                                                                                                    func (*StreamHealthRequest) String

                                                                                                                    func (m *StreamHealthRequest) String() string

                                                                                                                    func (*StreamHealthRequest) XXX_DiscardUnknown <