vtgate

package
v0.16.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 29, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CommitOrder_name = map[int32]string{
	0: "NORMAL",
	1: "PRE",
	2: "POST",
	3: "AUTOCOMMIT",
}
View Source 
var CommitOrder_value = map[string]int32{
	"NORMAL":     0,
	"PRE":        1,
	"POST":       2,
	"AUTOCOMMIT": 3,
}
View Source 
var TransactionMode_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "SINGLE",
	2: "MULTI",
	3: "TWOPC",
}
View Source 
var TransactionMode_value = map[string]int32{
	"UNSPECIFIED": 0,
	"SINGLE":      1,
	"MULTI":       2,
	"TWOPC":       3,
}

Functions

This section is empty.

Types

type BeginRequest 

type BeginRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// single_db is deprecated. Use transaction_mode instead.
	// The value specifies if the transaction should be restricted
	// to a single database.
	// TODO(sougou): remove in 3.1
	SingleDb             bool     `protobuf:"varint,2,opt,name=single_db,json=singleDb,proto3" json:"single_db,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) GetCallerId 

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

func (*BeginRequest) GetSingleDb 

func (m *BeginRequest) GetSingleDb() bool

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 (m *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 {
	// session is the initial session information to use for subsequent queries.
	Session              *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,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) GetSession 

func (m *BeginResponse) GetSession() *Session

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 (m *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 BoundKeyspaceIdQuery 

type BoundKeyspaceIdQuery struct {
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// keyspace_ids contains the list of keyspace_ids affected by this query.
	// Will be used to find the shards to send the query to.
	KeyspaceIds          [][]byte `protobuf:"bytes,3,rep,name=keyspace_ids,json=keyspaceIds,proto3" json:"keyspace_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

BoundKeyspaceIdQuery represents a single query request for the specified list of keyspace ids. This is used in a list for ExecuteBatchKeyspaceIdsRequest.

func (*BoundKeyspaceIdQuery) Descriptor 

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

func (*BoundKeyspaceIdQuery) GetKeyspace 

func (m *BoundKeyspaceIdQuery) GetKeyspace() string

func (*BoundKeyspaceIdQuery) GetKeyspaceIds 

func (m *BoundKeyspaceIdQuery) GetKeyspaceIds() [][]byte

func (*BoundKeyspaceIdQuery) GetQuery 

func (m *BoundKeyspaceIdQuery) GetQuery() *query.BoundQuery

func (*BoundKeyspaceIdQuery) ProtoMessage 

func (*BoundKeyspaceIdQuery) ProtoMessage()

func (*BoundKeyspaceIdQuery) Reset 

func (m *BoundKeyspaceIdQuery) Reset()

func (*BoundKeyspaceIdQuery) String 

func (m *BoundKeyspaceIdQuery) String() string

func (*BoundKeyspaceIdQuery) XXX_DiscardUnknown 

func (m *BoundKeyspaceIdQuery) XXX_DiscardUnknown()

func (*BoundKeyspaceIdQuery) XXX_Marshal 

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

func (*BoundKeyspaceIdQuery) XXX_Merge 

func (m *BoundKeyspaceIdQuery) XXX_Merge(src proto.Message)

func (*BoundKeyspaceIdQuery) XXX_Size 

func (m *BoundKeyspaceIdQuery) XXX_Size() int

func (*BoundKeyspaceIdQuery) XXX_Unmarshal 

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

type BoundShardQuery 

type BoundShardQuery struct {
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// shards to target the query to. A DML can only target one shard.
	Shards               []string `protobuf:"bytes,3,rep,name=shards,proto3" json:"shards,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

BoundShardQuery represents a single query request for the specified list of shards. This is used in a list for ExecuteBatchShardsRequest.

func (*BoundShardQuery) Descriptor 

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

func (*BoundShardQuery) GetKeyspace 

func (m *BoundShardQuery) GetKeyspace() string

func (*BoundShardQuery) GetQuery 

func (m *BoundShardQuery) GetQuery() *query.BoundQuery

func (*BoundShardQuery) GetShards 

func (m *BoundShardQuery) GetShards() []string

func (*BoundShardQuery) ProtoMessage 

func (*BoundShardQuery) ProtoMessage()

func (*BoundShardQuery) Reset 

func (m *BoundShardQuery) Reset()

func (*BoundShardQuery) String 

func (m *BoundShardQuery) String() string

func (*BoundShardQuery) XXX_DiscardUnknown 

func (m *BoundShardQuery) XXX_DiscardUnknown()

func (*BoundShardQuery) XXX_Marshal 

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

func (*BoundShardQuery) XXX_Merge 

func (m *BoundShardQuery) XXX_Merge(src proto.Message)

func (*BoundShardQuery) XXX_Size 

func (m *BoundShardQuery) XXX_Size() int

func (*BoundShardQuery) XXX_Unmarshal 

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

type CommitOrder 

type CommitOrder int32

CommitOrder is used to designate which of the ShardSessions get used for transactions. 

const (
	// NORMAL is the default commit order.
	CommitOrder_NORMAL CommitOrder = 0
	// PRE is used to designate pre_sessions.
	CommitOrder_PRE CommitOrder = 1
	// POST is used to designate post_sessions.
	CommitOrder_POST CommitOrder = 2
	// AUTOCOMMIT is used to run the statement as autocommitted transaction.
	CommitOrder_AUTOCOMMIT CommitOrder = 3
)

func (CommitOrder) EnumDescriptor 

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

func (CommitOrder) String 

func (x CommitOrder) String() string

type CommitRequest 

type CommitRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// session carries the current transaction data to commit.
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// atomic is deprecated. Use transaction_mode instead.
	// The value specifies if the commit should go through the
	// 2PC workflow to ensure atomicity.
	// TODO(sougou): remove in 3.1
	Atomic               bool     `protobuf:"varint,3,opt,name=atomic,proto3" json:"atomic,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) GetAtomic 

func (m *CommitRequest) GetAtomic() bool

func (*CommitRequest) GetCallerId 

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

func (*CommitRequest) GetSession 

func (m *CommitRequest) GetSession() *Session

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 (m *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 (m *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 ExecuteBatchKeyspaceIdsRequest 

type ExecuteBatchKeyspaceIdsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// session carries the current transaction data. It is returned by Begin.
	// Do not fill it in if outside of a transaction.
	Session *Session                `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	Queries []*BoundKeyspaceIdQuery `protobuf:"bytes,3,rep,name=queries,proto3" json:"queries,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,4,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// as_transaction will execute the queries in this batch in a single transaction per shard, created for this purpose.
	// (this can be seen as adding a 'begin' before and 'commit' after the queries).
	// Only makes sense if tablet_type is master. If set, the Session is ignored.
	AsTransaction bool `protobuf:"varint,5,opt,name=as_transaction,json=asTransaction,proto3" json:"as_transaction,omitempty"`
	// options
	Options              *query.ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ExecuteBatchKeyspaceIdsRequest is the payload to ExecuteBatchKeyspaceId.

func (*ExecuteBatchKeyspaceIdsRequest) Descriptor 

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

func (*ExecuteBatchKeyspaceIdsRequest) GetAsTransaction 

func (m *ExecuteBatchKeyspaceIdsRequest) GetAsTransaction() bool

func (*ExecuteBatchKeyspaceIdsRequest) GetCallerId 

func (m *ExecuteBatchKeyspaceIdsRequest) GetCallerId() *vtrpc.CallerID

func (*ExecuteBatchKeyspaceIdsRequest) GetOptions 

func (m *ExecuteBatchKeyspaceIdsRequest) GetOptions() *query.ExecuteOptions

func (*ExecuteBatchKeyspaceIdsRequest) GetQueries 

func (m *ExecuteBatchKeyspaceIdsRequest) GetQueries() []*BoundKeyspaceIdQuery

func (*ExecuteBatchKeyspaceIdsRequest) GetSession 

func (m *ExecuteBatchKeyspaceIdsRequest) GetSession() *Session

func (*ExecuteBatchKeyspaceIdsRequest) GetTabletType 

func (m *ExecuteBatchKeyspaceIdsRequest) GetTabletType() topodata.TabletType

func (*ExecuteBatchKeyspaceIdsRequest) ProtoMessage 

func (*ExecuteBatchKeyspaceIdsRequest) ProtoMessage()

func (*ExecuteBatchKeyspaceIdsRequest) Reset 

func (m *ExecuteBatchKeyspaceIdsRequest) Reset()

func (*ExecuteBatchKeyspaceIdsRequest) String 

func (m *ExecuteBatchKeyspaceIdsRequest) String() string

func (*ExecuteBatchKeyspaceIdsRequest) XXX_DiscardUnknown 

func (m *ExecuteBatchKeyspaceIdsRequest) XXX_DiscardUnknown()

func (*ExecuteBatchKeyspaceIdsRequest) XXX_Marshal 

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

func (*ExecuteBatchKeyspaceIdsRequest) XXX_Merge 

func (m *ExecuteBatchKeyspaceIdsRequest) XXX_Merge(src proto.Message)

func (*ExecuteBatchKeyspaceIdsRequest) XXX_Size 

func (m *ExecuteBatchKeyspaceIdsRequest) XXX_Size() int

func (*ExecuteBatchKeyspaceIdsRequest) XXX_Unmarshal 

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

type ExecuteBatchKeyspaceIdsResponse 

type ExecuteBatchKeyspaceIdsResponse struct {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// session is the updated session information (only returned inside a transaction).
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Results              []*query.QueryResult `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

ExecuteBatchKeyspaceIdsResponse is the returned value from ExecuteBatchKeyspaceId.

func (*ExecuteBatchKeyspaceIdsResponse) Descriptor 

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

func (*ExecuteBatchKeyspaceIdsResponse) GetError 

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

func (*ExecuteBatchKeyspaceIdsResponse) GetResults 

func (m *ExecuteBatchKeyspaceIdsResponse) GetResults() []*query.QueryResult

func (*ExecuteBatchKeyspaceIdsResponse) GetSession 

func (m *ExecuteBatchKeyspaceIdsResponse) GetSession() *Session

func (*ExecuteBatchKeyspaceIdsResponse) ProtoMessage 

func (*ExecuteBatchKeyspaceIdsResponse) ProtoMessage()

func (*ExecuteBatchKeyspaceIdsResponse) Reset 

func (m *ExecuteBatchKeyspaceIdsResponse) Reset()

func (*ExecuteBatchKeyspaceIdsResponse) String 

func (m *ExecuteBatchKeyspaceIdsResponse) String() string

func (*ExecuteBatchKeyspaceIdsResponse) XXX_DiscardUnknown 

func (m *ExecuteBatchKeyspaceIdsResponse) XXX_DiscardUnknown()

func (*ExecuteBatchKeyspaceIdsResponse) XXX_Marshal 

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

func (*ExecuteBatchKeyspaceIdsResponse) XXX_Merge 

func (m *ExecuteBatchKeyspaceIdsResponse) XXX_Merge(src proto.Message)

func (*ExecuteBatchKeyspaceIdsResponse) XXX_Size 

func (m *ExecuteBatchKeyspaceIdsResponse) XXX_Size() int

func (*ExecuteBatchKeyspaceIdsResponse) XXX_Unmarshal 

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

type ExecuteBatchRequest 

type ExecuteBatchRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// session carries the session state.
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// queries is a list of query and bind variables to execute.
	Queries []*query.BoundQuery `protobuf:"bytes,3,rep,name=queries,proto3" json:"queries,omitempty"`
	// These values are deprecated. Use session instead.
	// TODO(sougou): remove in 3.1
	TabletType           topodata.TabletType   `protobuf:"varint,4,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	AsTransaction        bool                  `protobuf:"varint,5,opt,name=as_transaction,json=asTransaction,proto3" json:"as_transaction,omitempty"`
	KeyspaceShard        string                `protobuf:"bytes,6,opt,name=keyspace_shard,json=keyspaceShard,proto3" json:"keyspace_shard,omitempty"`
	Options              *query.ExecuteOptions `protobuf:"bytes,7,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ExecuteBatchRequest is the payload to ExecuteBatch.

func (*ExecuteBatchRequest) Descriptor 

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

func (*ExecuteBatchRequest) GetAsTransaction 

func (m *ExecuteBatchRequest) GetAsTransaction() bool

func (*ExecuteBatchRequest) GetCallerId 

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

func (*ExecuteBatchRequest) GetKeyspaceShard 

func (m *ExecuteBatchRequest) GetKeyspaceShard() string

func (*ExecuteBatchRequest) GetOptions 

func (m *ExecuteBatchRequest) GetOptions() *query.ExecuteOptions

func (*ExecuteBatchRequest) GetQueries 

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

func (*ExecuteBatchRequest) GetSession 

func (m *ExecuteBatchRequest) GetSession() *Session

func (*ExecuteBatchRequest) GetTabletType 

func (m *ExecuteBatchRequest) GetTabletType() topodata.TabletType

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 (m *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 {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// session is the updated session information.
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// results contains the query results, only set if application level error is unset.
	Results              []*query.ResultWithError `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

ExecuteBatchResponse is the returned value from ExecuteBatch.

func (*ExecuteBatchResponse) Descriptor 

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

func (*ExecuteBatchResponse) GetError 

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

func (*ExecuteBatchResponse) GetResults 

func (m *ExecuteBatchResponse) GetResults() []*query.ResultWithError

func (*ExecuteBatchResponse) GetSession 

func (m *ExecuteBatchResponse) GetSession() *Session

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 (m *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 ExecuteBatchShardsRequest 

type ExecuteBatchShardsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// session carries the current transaction data. It is returned by Begin.
	// Do not fill it in if outside of a transaction.
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// queries carries all the queries to execute.
	Queries []*BoundShardQuery `protobuf:"bytes,3,rep,name=queries,proto3" json:"queries,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,4,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// as_transaction will execute the queries in this batch in a single transaction per shard, created for this purpose.
	// (this can be seen as adding a 'begin' before and 'commit' after the queries).
	// Only makes sense if tablet_type is master. If set, the Session is ignored.
	AsTransaction bool `protobuf:"varint,5,opt,name=as_transaction,json=asTransaction,proto3" json:"as_transaction,omitempty"`
	// options
	Options              *query.ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ExecuteBatchShardsRequest is the payload to ExecuteBatchShards

func (*ExecuteBatchShardsRequest) Descriptor 

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

func (*ExecuteBatchShardsRequest) GetAsTransaction 

func (m *ExecuteBatchShardsRequest) GetAsTransaction() bool

func (*ExecuteBatchShardsRequest) GetCallerId 

func (m *ExecuteBatchShardsRequest) GetCallerId() *vtrpc.CallerID

func (*ExecuteBatchShardsRequest) GetOptions 

func (m *ExecuteBatchShardsRequest) GetOptions() *query.ExecuteOptions

func (*ExecuteBatchShardsRequest) GetQueries 

func (m *ExecuteBatchShardsRequest) GetQueries() []*BoundShardQuery

func (*ExecuteBatchShardsRequest) GetSession 

func (m *ExecuteBatchShardsRequest) GetSession() *Session

func (*ExecuteBatchShardsRequest) GetTabletType 

func (m *ExecuteBatchShardsRequest) GetTabletType() topodata.TabletType

func (*ExecuteBatchShardsRequest) ProtoMessage 

func (*ExecuteBatchShardsRequest) ProtoMessage()

func (*ExecuteBatchShardsRequest) Reset 

func (m *ExecuteBatchShardsRequest) Reset()

func (*ExecuteBatchShardsRequest) String 

func (m *ExecuteBatchShardsRequest) String() string

func (*ExecuteBatchShardsRequest) XXX_DiscardUnknown 

func (m *ExecuteBatchShardsRequest) XXX_DiscardUnknown()

func (*ExecuteBatchShardsRequest) XXX_Marshal 

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

func (*ExecuteBatchShardsRequest) XXX_Merge 

func (m *ExecuteBatchShardsRequest) XXX_Merge(src proto.Message)

func (*ExecuteBatchShardsRequest) XXX_Size 

func (m *ExecuteBatchShardsRequest) XXX_Size() int

func (*ExecuteBatchShardsRequest) XXX_Unmarshal 

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

type ExecuteBatchShardsResponse 

type ExecuteBatchShardsResponse struct {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// session is the updated session information (only returned inside a transaction).
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Results              []*query.QueryResult `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

ExecuteBatchShardsResponse is the returned value from ExecuteBatchShards.

func (*ExecuteBatchShardsResponse) Descriptor 

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

func (*ExecuteBatchShardsResponse) GetError 

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

func (*ExecuteBatchShardsResponse) GetResults 

func (m *ExecuteBatchShardsResponse) GetResults() []*query.QueryResult

func (*ExecuteBatchShardsResponse) GetSession 

func (m *ExecuteBatchShardsResponse) GetSession() *Session

func (*ExecuteBatchShardsResponse) ProtoMessage 

func (*ExecuteBatchShardsResponse) ProtoMessage()

func (*ExecuteBatchShardsResponse) Reset 

func (m *ExecuteBatchShardsResponse) Reset()

func (*ExecuteBatchShardsResponse) String 

func (m *ExecuteBatchShardsResponse) String() string

func (*ExecuteBatchShardsResponse) XXX_DiscardUnknown 

func (m *ExecuteBatchShardsResponse) XXX_DiscardUnknown()

func (*ExecuteBatchShardsResponse) XXX_Marshal 

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

func (*ExecuteBatchShardsResponse) XXX_Merge 

func (m *ExecuteBatchShardsResponse) XXX_Merge(src proto.Message)

func (*ExecuteBatchShardsResponse) XXX_Size 

func (m *ExecuteBatchShardsResponse) XXX_Size() int

func (*ExecuteBatchShardsResponse) XXX_Unmarshal 

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

type ExecuteEntityIdsRequest 

type ExecuteEntityIdsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// session carries the current transaction data. It is returned by Begin.
	// Do not fill it in if outside of a transaction.
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,4,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// entity_column_name is the column name to use.
	EntityColumnName string `protobuf:"bytes,5,opt,name=entity_column_name,json=entityColumnName,proto3" json:"entity_column_name,omitempty"`
	// entity_keyspace_ids are pairs of entity_column_name values
	// associated with its corresponding keyspace_id.
	EntityKeyspaceIds []*ExecuteEntityIdsRequest_EntityId `protobuf:"bytes,6,rep,name=entity_keyspace_ids,json=entityKeyspaceIds,proto3" json:"entity_keyspace_ids,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,7,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// not_in_transaction is deprecated.
	NotInTransaction bool `protobuf:"varint,8,opt,name=not_in_transaction,json=notInTransaction,proto3" json:"not_in_transaction,omitempty"`
	// options
	Options              *query.ExecuteOptions `protobuf:"bytes,9,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ExecuteEntityIdsRequest is the payload to ExecuteEntityIds.

func (*ExecuteEntityIdsRequest) Descriptor 

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

func (*ExecuteEntityIdsRequest) GetCallerId 

func (m *ExecuteEntityIdsRequest) GetCallerId() *vtrpc.CallerID

func (*ExecuteEntityIdsRequest) GetEntityColumnName 

func (m *ExecuteEntityIdsRequest) GetEntityColumnName() string

func (*ExecuteEntityIdsRequest) GetEntityKeyspaceIds 

func (m *ExecuteEntityIdsRequest) GetEntityKeyspaceIds() []*ExecuteEntityIdsRequest_EntityId

func (*ExecuteEntityIdsRequest) GetKeyspace 

func (m *ExecuteEntityIdsRequest) GetKeyspace() string

func (*ExecuteEntityIdsRequest) GetNotInTransaction 

func (m *ExecuteEntityIdsRequest) GetNotInTransaction() bool

func (*ExecuteEntityIdsRequest) GetOptions 

func (m *ExecuteEntityIdsRequest) GetOptions() *query.ExecuteOptions

func (*ExecuteEntityIdsRequest) GetQuery 

func (m *ExecuteEntityIdsRequest) GetQuery() *query.BoundQuery

func (*ExecuteEntityIdsRequest) GetSession 

func (m *ExecuteEntityIdsRequest) GetSession() *Session

func (*ExecuteEntityIdsRequest) GetTabletType 

func (m *ExecuteEntityIdsRequest) GetTabletType() topodata.TabletType

func (*ExecuteEntityIdsRequest) ProtoMessage 

func (*ExecuteEntityIdsRequest) ProtoMessage()

func (*ExecuteEntityIdsRequest) Reset 

func (m *ExecuteEntityIdsRequest) Reset()

func (*ExecuteEntityIdsRequest) String 

func (m *ExecuteEntityIdsRequest) String() string

func (*ExecuteEntityIdsRequest) XXX_DiscardUnknown 

func (m *ExecuteEntityIdsRequest) XXX_DiscardUnknown()

func (*ExecuteEntityIdsRequest) XXX_Marshal 

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

func (*ExecuteEntityIdsRequest) XXX_Merge 

func (m *ExecuteEntityIdsRequest) XXX_Merge(src proto.Message)

func (*ExecuteEntityIdsRequest) XXX_Size 

func (m *ExecuteEntityIdsRequest) XXX_Size() int

func (*ExecuteEntityIdsRequest) XXX_Unmarshal 

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

type ExecuteEntityIdsRequest_EntityId 

type ExecuteEntityIdsRequest_EntityId struct {
	// type is the type of the entity's value. Can be NULL_TYPE.
	Type query.Type `protobuf:"varint,1,opt,name=type,proto3,enum=query.Type" json:"type,omitempty"`
	// value is the value for the entity. Not set if type is NULL_TYPE.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// keyspace_id is the associated keyspace_id for the entity.
	KeyspaceId           []byte   `protobuf:"bytes,3,opt,name=keyspace_id,json=keyspaceId,proto3" json:"keyspace_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecuteEntityIdsRequest_EntityId) Descriptor 

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

func (*ExecuteEntityIdsRequest_EntityId) GetKeyspaceId 

func (m *ExecuteEntityIdsRequest_EntityId) GetKeyspaceId() []byte

func (*ExecuteEntityIdsRequest_EntityId) GetType 

func (m *ExecuteEntityIdsRequest_EntityId) GetType() query.Type

func (*ExecuteEntityIdsRequest_EntityId) GetValue 

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

func (*ExecuteEntityIdsRequest_EntityId) ProtoMessage 

func (*ExecuteEntityIdsRequest_EntityId) ProtoMessage()

func (*ExecuteEntityIdsRequest_EntityId) Reset 

func (m *ExecuteEntityIdsRequest_EntityId) Reset()

func (*ExecuteEntityIdsRequest_EntityId) String 

func (m *ExecuteEntityIdsRequest_EntityId) String() string

func (*ExecuteEntityIdsRequest_EntityId) XXX_DiscardUnknown 

func (m *ExecuteEntityIdsRequest_EntityId) XXX_DiscardUnknown()

func (*ExecuteEntityIdsRequest_EntityId) XXX_Marshal 

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

func (*ExecuteEntityIdsRequest_EntityId) XXX_Merge 

func (m *ExecuteEntityIdsRequest_EntityId) XXX_Merge(src proto.Message)

func (*ExecuteEntityIdsRequest_EntityId) XXX_Size 

func (m *ExecuteEntityIdsRequest_EntityId) XXX_Size() int

func (*ExecuteEntityIdsRequest_EntityId) XXX_Unmarshal 

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

type ExecuteEntityIdsResponse 

type ExecuteEntityIdsResponse struct {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// session is the updated session information (only returned inside a transaction).
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Result               *query.QueryResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

ExecuteEntityIdsResponse is the returned value from ExecuteEntityIds.

func (*ExecuteEntityIdsResponse) Descriptor 

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

func (*ExecuteEntityIdsResponse) GetError 

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

func (*ExecuteEntityIdsResponse) GetResult 

func (m *ExecuteEntityIdsResponse) GetResult() *query.QueryResult

func (*ExecuteEntityIdsResponse) GetSession 

func (m *ExecuteEntityIdsResponse) GetSession() *Session

func (*ExecuteEntityIdsResponse) ProtoMessage 

func (*ExecuteEntityIdsResponse) ProtoMessage()

func (*ExecuteEntityIdsResponse) Reset 

func (m *ExecuteEntityIdsResponse) Reset()

func (*ExecuteEntityIdsResponse) String 

func (m *ExecuteEntityIdsResponse) String() string

func (*ExecuteEntityIdsResponse) XXX_DiscardUnknown 

func (m *ExecuteEntityIdsResponse) XXX_DiscardUnknown()

func (*ExecuteEntityIdsResponse) XXX_Marshal 

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

func (*ExecuteEntityIdsResponse) XXX_Merge 

func (m *ExecuteEntityIdsResponse) XXX_Merge(src proto.Message)

func (*ExecuteEntityIdsResponse) XXX_Size 

func (m *ExecuteEntityIdsResponse) XXX_Size() int

func (*ExecuteEntityIdsResponse) XXX_Unmarshal 

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

type ExecuteKeyRangesRequest 

type ExecuteKeyRangesRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// session carries the current transaction data. It is returned by Begin.
	// Do not fill it in if outside of a transaction.
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// keyspace to target the query to
	Keyspace string `protobuf:"bytes,4,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// key_ranges contains the list of key ranges affected by this query.
	// Will be used to find the shards to send the query to.
	KeyRanges []*topodata.KeyRange `protobuf:"bytes,5,rep,name=key_ranges,json=keyRanges,proto3" json:"key_ranges,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,6,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// not_in_transaction is deprecated.
	NotInTransaction bool `protobuf:"varint,7,opt,name=not_in_transaction,json=notInTransaction,proto3" json:"not_in_transaction,omitempty"`
	// options
	Options              *query.ExecuteOptions `protobuf:"bytes,8,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ExecuteKeyRangesRequest is the payload to ExecuteKeyRanges.

func (*ExecuteKeyRangesRequest) Descriptor 

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

func (*ExecuteKeyRangesRequest) GetCallerId 

func (m *ExecuteKeyRangesRequest) GetCallerId() *vtrpc.CallerID

func (*ExecuteKeyRangesRequest) GetKeyRanges 

func (m *ExecuteKeyRangesRequest) GetKeyRanges() []*topodata.KeyRange

func (*ExecuteKeyRangesRequest) GetKeyspace 

func (m *ExecuteKeyRangesRequest) GetKeyspace() string

func (*ExecuteKeyRangesRequest) GetNotInTransaction 

func (m *ExecuteKeyRangesRequest) GetNotInTransaction() bool

func (*ExecuteKeyRangesRequest) GetOptions 

func (m *ExecuteKeyRangesRequest) GetOptions() *query.ExecuteOptions

func (*ExecuteKeyRangesRequest) GetQuery 

func (m *ExecuteKeyRangesRequest) GetQuery() *query.BoundQuery

func (*ExecuteKeyRangesRequest) GetSession 

func (m *ExecuteKeyRangesRequest) GetSession() *Session

func (*ExecuteKeyRangesRequest) GetTabletType 

func (m *ExecuteKeyRangesRequest) GetTabletType() topodata.TabletType

func (*ExecuteKeyRangesRequest) ProtoMessage 

func (*ExecuteKeyRangesRequest) ProtoMessage()

func (*ExecuteKeyRangesRequest) Reset 

func (m *ExecuteKeyRangesRequest) Reset()

func (*ExecuteKeyRangesRequest) String 

func (m *ExecuteKeyRangesRequest) String() string

func (*ExecuteKeyRangesRequest) XXX_DiscardUnknown 

func (m *ExecuteKeyRangesRequest) XXX_DiscardUnknown()

func (*ExecuteKeyRangesRequest) XXX_Marshal 

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

func (*ExecuteKeyRangesRequest) XXX_Merge 

func (m *ExecuteKeyRangesRequest) XXX_Merge(src proto.Message)

func (*ExecuteKeyRangesRequest) XXX_Size 

func (m *ExecuteKeyRangesRequest) XXX_Size() int

func (*ExecuteKeyRangesRequest) XXX_Unmarshal 

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

type ExecuteKeyRangesResponse 

type ExecuteKeyRangesResponse struct {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// session is the updated session information (only returned inside a transaction).
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Result               *query.QueryResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

ExecuteKeyRangesResponse is the returned value from ExecuteKeyRanges.

func (*ExecuteKeyRangesResponse) Descriptor 

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

func (*ExecuteKeyRangesResponse) GetError 

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

func (*ExecuteKeyRangesResponse) GetResult 

func (m *ExecuteKeyRangesResponse) GetResult() *query.QueryResult

func (*ExecuteKeyRangesResponse) GetSession 

func (m *ExecuteKeyRangesResponse) GetSession() *Session

func (*ExecuteKeyRangesResponse) ProtoMessage 

func (*ExecuteKeyRangesResponse) ProtoMessage()

func (*ExecuteKeyRangesResponse) Reset 

func (m *ExecuteKeyRangesResponse) Reset()

func (*ExecuteKeyRangesResponse) String 

func (m *ExecuteKeyRangesResponse) String() string

func (*ExecuteKeyRangesResponse) XXX_DiscardUnknown 

func (m *ExecuteKeyRangesResponse) XXX_DiscardUnknown()

func (*ExecuteKeyRangesResponse) XXX_Marshal 

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

func (*ExecuteKeyRangesResponse) XXX_Merge 

func (m *ExecuteKeyRangesResponse) XXX_Merge(src proto.Message)

func (*ExecuteKeyRangesResponse) XXX_Size 

func (m *ExecuteKeyRangesResponse) XXX_Size() int

func (*ExecuteKeyRangesResponse) XXX_Unmarshal 

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

type ExecuteKeyspaceIdsRequest 

type ExecuteKeyspaceIdsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// session carries the current transaction data. It is returned by Begin.
	// Do not fill it in if outside of a transaction.
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,4,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// keyspace_ids contains the list of keyspace_ids affected by this query.
	// Will be used to find the shards to send the query to.
	KeyspaceIds [][]byte `protobuf:"bytes,5,rep,name=keyspace_ids,json=keyspaceIds,proto3" json:"keyspace_ids,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,6,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// not_in_transaction is deprecated.
	NotInTransaction bool `protobuf:"varint,7,opt,name=not_in_transaction,json=notInTransaction,proto3" json:"not_in_transaction,omitempty"`
	// options
	Options              *query.ExecuteOptions `protobuf:"bytes,8,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ExecuteKeyspaceIdsRequest is the payload to ExecuteKeyspaceIds.

func (*ExecuteKeyspaceIdsRequest) Descriptor 

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

func (*ExecuteKeyspaceIdsRequest) GetCallerId 

func (m *ExecuteKeyspaceIdsRequest) GetCallerId() *vtrpc.CallerID

func (*ExecuteKeyspaceIdsRequest) GetKeyspace 

func (m *ExecuteKeyspaceIdsRequest) GetKeyspace() string

func (*ExecuteKeyspaceIdsRequest) GetKeyspaceIds 

func (m *ExecuteKeyspaceIdsRequest) GetKeyspaceIds() [][]byte

func (*ExecuteKeyspaceIdsRequest) GetNotInTransaction 

func (m *ExecuteKeyspaceIdsRequest) GetNotInTransaction() bool

func (*ExecuteKeyspaceIdsRequest) GetOptions 

func (m *ExecuteKeyspaceIdsRequest) GetOptions() *query.ExecuteOptions

func (*ExecuteKeyspaceIdsRequest) GetQuery 

func (m *ExecuteKeyspaceIdsRequest) GetQuery() *query.BoundQuery

func (*ExecuteKeyspaceIdsRequest) GetSession 

func (m *ExecuteKeyspaceIdsRequest) GetSession() *Session

func (*ExecuteKeyspaceIdsRequest) GetTabletType 

func (m *ExecuteKeyspaceIdsRequest) GetTabletType() topodata.TabletType

func (*ExecuteKeyspaceIdsRequest) ProtoMessage 

func (*ExecuteKeyspaceIdsRequest) ProtoMessage()

func (*ExecuteKeyspaceIdsRequest) Reset 

func (m *ExecuteKeyspaceIdsRequest) Reset()

func (*ExecuteKeyspaceIdsRequest) String 

func (m *ExecuteKeyspaceIdsRequest) String() string

func (*ExecuteKeyspaceIdsRequest) XXX_DiscardUnknown 

func (m *ExecuteKeyspaceIdsRequest) XXX_DiscardUnknown()

func (*ExecuteKeyspaceIdsRequest) XXX_Marshal 

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

func (*ExecuteKeyspaceIdsRequest) XXX_Merge 

func (m *ExecuteKeyspaceIdsRequest) XXX_Merge(src proto.Message)

func (*ExecuteKeyspaceIdsRequest) XXX_Size 

func (m *ExecuteKeyspaceIdsRequest) XXX_Size() int

func (*ExecuteKeyspaceIdsRequest) XXX_Unmarshal 

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

type ExecuteKeyspaceIdsResponse 

type ExecuteKeyspaceIdsResponse struct {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// session is the updated session information (only returned inside a transaction).
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Result               *query.QueryResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

ExecuteKeyspaceIdsResponse is the returned value from ExecuteKeyspaceIds.

func (*ExecuteKeyspaceIdsResponse) Descriptor 

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

func (*ExecuteKeyspaceIdsResponse) GetError 

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

func (*ExecuteKeyspaceIdsResponse) GetResult 

func (m *ExecuteKeyspaceIdsResponse) GetResult() *query.QueryResult

func (*ExecuteKeyspaceIdsResponse) GetSession 

func (m *ExecuteKeyspaceIdsResponse) GetSession() *Session

func (*ExecuteKeyspaceIdsResponse) ProtoMessage 

func (*ExecuteKeyspaceIdsResponse) ProtoMessage()

func (*ExecuteKeyspaceIdsResponse) Reset 

func (m *ExecuteKeyspaceIdsResponse) Reset()

func (*ExecuteKeyspaceIdsResponse) String 

func (m *ExecuteKeyspaceIdsResponse) String() string

func (*ExecuteKeyspaceIdsResponse) XXX_DiscardUnknown 

func (m *ExecuteKeyspaceIdsResponse) XXX_DiscardUnknown()

func (*ExecuteKeyspaceIdsResponse) XXX_Marshal 

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

func (*ExecuteKeyspaceIdsResponse) XXX_Merge 

func (m *ExecuteKeyspaceIdsResponse) XXX_Merge(src proto.Message)

func (*ExecuteKeyspaceIdsResponse) XXX_Size 

func (m *ExecuteKeyspaceIdsResponse) XXX_Size() int

func (*ExecuteKeyspaceIdsResponse) XXX_Unmarshal 

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

type ExecuteRequest 

type ExecuteRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// session carries the session state.
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// These values are deprecated. Use session instead.
	// TODO(sougou): remove in 3.1
	TabletType           topodata.TabletType   `protobuf:"varint,4,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	NotInTransaction     bool                  `protobuf:"varint,5,opt,name=not_in_transaction,json=notInTransaction,proto3" json:"not_in_transaction,omitempty"`
	KeyspaceShard        string                `protobuf:"bytes,6,opt,name=keyspace_shard,json=keyspaceShard,proto3" json:"keyspace_shard,omitempty"`
	Options              *query.ExecuteOptions `protobuf:"bytes,7,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ExecuteRequest is the payload to Execute.

func (*ExecuteRequest) Descriptor 

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

func (*ExecuteRequest) GetCallerId 

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

func (*ExecuteRequest) GetKeyspaceShard 

func (m *ExecuteRequest) GetKeyspaceShard() string

func (*ExecuteRequest) GetNotInTransaction 

func (m *ExecuteRequest) GetNotInTransaction() bool

func (*ExecuteRequest) GetOptions 

func (m *ExecuteRequest) GetOptions() *query.ExecuteOptions

func (*ExecuteRequest) GetQuery 

func (m *ExecuteRequest) GetQuery() *query.BoundQuery

func (*ExecuteRequest) GetSession 

func (m *ExecuteRequest) GetSession() *Session

func (*ExecuteRequest) GetTabletType 

func (m *ExecuteRequest) GetTabletType() topodata.TabletType

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 (m *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 {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// session is the updated session information.
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Result               *query.QueryResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

ExecuteResponse is the returned value from Execute.

func (*ExecuteResponse) Descriptor 

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

func (*ExecuteResponse) GetError 

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

func (*ExecuteResponse) GetResult 

func (m *ExecuteResponse) GetResult() *query.QueryResult

func (*ExecuteResponse) GetSession 

func (m *ExecuteResponse) GetSession() *Session

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 (m *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 ExecuteShardsRequest 

type ExecuteShardsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// session carries the current transaction data. It is returned by Begin.
	// Do not fill it in if outside of a transaction.
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,4,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// shards to target the query to. A DML can only target one shard.
	Shards []string `protobuf:"bytes,5,rep,name=shards,proto3" json:"shards,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,6,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// not_in_transaction is deprecated.
	NotInTransaction bool `protobuf:"varint,7,opt,name=not_in_transaction,json=notInTransaction,proto3" json:"not_in_transaction,omitempty"`
	// options
	Options              *query.ExecuteOptions `protobuf:"bytes,8,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ExecuteShardsRequest is the payload to ExecuteShards.

func (*ExecuteShardsRequest) Descriptor 

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

func (*ExecuteShardsRequest) GetCallerId 

func (m *ExecuteShardsRequest) GetCallerId() *vtrpc.CallerID

func (*ExecuteShardsRequest) GetKeyspace 

func (m *ExecuteShardsRequest) GetKeyspace() string

func (*ExecuteShardsRequest) GetNotInTransaction 

func (m *ExecuteShardsRequest) GetNotInTransaction() bool

func (*ExecuteShardsRequest) GetOptions 

func (m *ExecuteShardsRequest) GetOptions() *query.ExecuteOptions

func (*ExecuteShardsRequest) GetQuery 

func (m *ExecuteShardsRequest) GetQuery() *query.BoundQuery

func (*ExecuteShardsRequest) GetSession 

func (m *ExecuteShardsRequest) GetSession() *Session

func (*ExecuteShardsRequest) GetShards 

func (m *ExecuteShardsRequest) GetShards() []string

func (*ExecuteShardsRequest) GetTabletType 

func (m *ExecuteShardsRequest) GetTabletType() topodata.TabletType

func (*ExecuteShardsRequest) ProtoMessage 

func (*ExecuteShardsRequest) ProtoMessage()

func (*ExecuteShardsRequest) Reset 

func (m *ExecuteShardsRequest) Reset()

func (*ExecuteShardsRequest) String 

func (m *ExecuteShardsRequest) String() string

func (*ExecuteShardsRequest) XXX_DiscardUnknown 

func (m *ExecuteShardsRequest) XXX_DiscardUnknown()

func (*ExecuteShardsRequest) XXX_Marshal 

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

func (*ExecuteShardsRequest) XXX_Merge 

func (m *ExecuteShardsRequest) XXX_Merge(src proto.Message)

func (*ExecuteShardsRequest) XXX_Size 

func (m *ExecuteShardsRequest) XXX_Size() int

func (*ExecuteShardsRequest) XXX_Unmarshal 

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

type ExecuteShardsResponse 

type ExecuteShardsResponse struct {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// session is the updated session information (only returned inside a transaction).
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Result               *query.QueryResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

ExecuteShardsResponse is the returned value from ExecuteShards.

func (*ExecuteShardsResponse) Descriptor 

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

func (*ExecuteShardsResponse) GetError 

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

func (*ExecuteShardsResponse) GetResult 

func (m *ExecuteShardsResponse) GetResult() *query.QueryResult

func (*ExecuteShardsResponse) GetSession 

func (m *ExecuteShardsResponse) GetSession() *Session

func (*ExecuteShardsResponse) ProtoMessage 

func (*ExecuteShardsResponse) ProtoMessage()

func (*ExecuteShardsResponse) Reset 

func (m *ExecuteShardsResponse) Reset()

func (*ExecuteShardsResponse) String 

func (m *ExecuteShardsResponse) String() string

func (*ExecuteShardsResponse) XXX_DiscardUnknown 

func (m *ExecuteShardsResponse) XXX_DiscardUnknown()

func (*ExecuteShardsResponse) XXX_Marshal 

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

func (*ExecuteShardsResponse) XXX_Merge 

func (m *ExecuteShardsResponse) XXX_Merge(src proto.Message)

func (*ExecuteShardsResponse) XXX_Size 

func (m *ExecuteShardsResponse) XXX_Size() int

func (*ExecuteShardsResponse) XXX_Unmarshal 

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

type GetSrvKeyspaceRequest 

type GetSrvKeyspaceRequest struct {
	// keyspace name to fetch.
	Keyspace             string   `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetSrvKeyspaceRequest is the payload to GetSrvKeyspace.

func (*GetSrvKeyspaceRequest) Descriptor 

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

func (*GetSrvKeyspaceRequest) GetKeyspace 

func (m *GetSrvKeyspaceRequest) GetKeyspace() string

func (*GetSrvKeyspaceRequest) ProtoMessage 

func (*GetSrvKeyspaceRequest) ProtoMessage()

func (*GetSrvKeyspaceRequest) Reset 

func (m *GetSrvKeyspaceRequest) Reset()

func (*GetSrvKeyspaceRequest) String 

func (m *GetSrvKeyspaceRequest) String() string

func (*GetSrvKeyspaceRequest) XXX_DiscardUnknown 

func (m *GetSrvKeyspaceRequest) XXX_DiscardUnknown()

func (*GetSrvKeyspaceRequest) XXX_Marshal 

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

func (*GetSrvKeyspaceRequest) XXX_Merge 

func (m *GetSrvKeyspaceRequest) XXX_Merge(src proto.Message)

func (*GetSrvKeyspaceRequest) XXX_Size 

func (m *GetSrvKeyspaceRequest) XXX_Size() int

func (*GetSrvKeyspaceRequest) XXX_Unmarshal 

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

type GetSrvKeyspaceResponse 

type GetSrvKeyspaceResponse struct {
	// srv_keyspace is the topology object for the SrvKeyspace.
	SrvKeyspace          *topodata.SrvKeyspace `protobuf:"bytes,1,opt,name=srv_keyspace,json=srvKeyspace,proto3" json:"srv_keyspace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

GetSrvKeyspaceResponse is the returned value from GetSrvKeyspace.

func (*GetSrvKeyspaceResponse) Descriptor 

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

func (*GetSrvKeyspaceResponse) GetSrvKeyspace 

func (m *GetSrvKeyspaceResponse) GetSrvKeyspace() *topodata.SrvKeyspace

func (*GetSrvKeyspaceResponse) ProtoMessage 

func (*GetSrvKeyspaceResponse) ProtoMessage()

func (*GetSrvKeyspaceResponse) Reset 

func (m *GetSrvKeyspaceResponse) Reset()

func (*GetSrvKeyspaceResponse) String 

func (m *GetSrvKeyspaceResponse) String() string

func (*GetSrvKeyspaceResponse) XXX_DiscardUnknown 

func (m *GetSrvKeyspaceResponse) XXX_DiscardUnknown()

func (*GetSrvKeyspaceResponse) XXX_Marshal 

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

func (*GetSrvKeyspaceResponse) XXX_Merge 

func (m *GetSrvKeyspaceResponse) XXX_Merge(src proto.Message)

func (*GetSrvKeyspaceResponse) XXX_Size 

func (m *GetSrvKeyspaceResponse) XXX_Size() int

func (*GetSrvKeyspaceResponse) XXX_Unmarshal 

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

type IdKeyspaceId 

type IdKeyspaceId struct {
	// id represents the message id.
	Id *query.Value `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// keyspace_id is the associated keyspace_id for the id.
	KeyspaceId           []byte   `protobuf:"bytes,2,opt,name=keyspace_id,json=keyspaceId,proto3" json:"keyspace_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

IdKeyspaceId represents an id and keyspace_id pair. The kesypace_id represents the routing info for id.

func (*IdKeyspaceId) Descriptor 

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

func (*IdKeyspaceId) GetId 

func (m *IdKeyspaceId) GetId() *query.Value

func (*IdKeyspaceId) GetKeyspaceId 

func (m *IdKeyspaceId) GetKeyspaceId() []byte

func (*IdKeyspaceId) ProtoMessage 

func (*IdKeyspaceId) ProtoMessage()

func (*IdKeyspaceId) Reset 

func (m *IdKeyspaceId) Reset()

func (*IdKeyspaceId) String 

func (m *IdKeyspaceId) String() string

func (*IdKeyspaceId) XXX_DiscardUnknown 

func (m *IdKeyspaceId) XXX_DiscardUnknown()

func (*IdKeyspaceId) XXX_Marshal 

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

func (*IdKeyspaceId) XXX_Merge 

func (m *IdKeyspaceId) XXX_Merge(src proto.Message)

func (*IdKeyspaceId) XXX_Size 

func (m *IdKeyspaceId) XXX_Size() int

func (*IdKeyspaceId) XXX_Unmarshal 

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

type MessageAckKeyspaceIdsRequest 

type MessageAckKeyspaceIdsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// Optional keyspace for message table.
	Keyspace string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// name is the message table name.
	Name                 string          `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	IdKeyspaceIds        []*IdKeyspaceId `protobuf:"bytes,4,rep,name=id_keyspace_ids,json=idKeyspaceIds,proto3" json:"id_keyspace_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

MessageAckKeyspaceIdsRequest is the payload to MessageAckKeyspaceIds.

func (*MessageAckKeyspaceIdsRequest) Descriptor 

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

func (*MessageAckKeyspaceIdsRequest) GetCallerId 

func (m *MessageAckKeyspaceIdsRequest) GetCallerId() *vtrpc.CallerID

func (*MessageAckKeyspaceIdsRequest) GetIdKeyspaceIds 

func (m *MessageAckKeyspaceIdsRequest) GetIdKeyspaceIds() []*IdKeyspaceId

func (*MessageAckKeyspaceIdsRequest) GetKeyspace 

func (m *MessageAckKeyspaceIdsRequest) GetKeyspace() string

func (*MessageAckKeyspaceIdsRequest) GetName 

func (m *MessageAckKeyspaceIdsRequest) GetName() string

func (*MessageAckKeyspaceIdsRequest) ProtoMessage 

func (*MessageAckKeyspaceIdsRequest) ProtoMessage()

func (*MessageAckKeyspaceIdsRequest) Reset 

func (m *MessageAckKeyspaceIdsRequest) Reset()

func (*MessageAckKeyspaceIdsRequest) String 

func (m *MessageAckKeyspaceIdsRequest) String() string

func (*MessageAckKeyspaceIdsRequest) XXX_DiscardUnknown 

func (m *MessageAckKeyspaceIdsRequest) XXX_DiscardUnknown()

func (*MessageAckKeyspaceIdsRequest) XXX_Marshal 

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

func (*MessageAckKeyspaceIdsRequest) XXX_Merge 

func (m *MessageAckKeyspaceIdsRequest) XXX_Merge(src proto.Message)

func (*MessageAckKeyspaceIdsRequest) XXX_Size 

func (m *MessageAckKeyspaceIdsRequest) XXX_Size() int

func (*MessageAckKeyspaceIdsRequest) XXX_Unmarshal 

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

type MessageAckRequest 

type MessageAckRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// keyspace to target the message to.
	Keyspace string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// name is the message table name.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// ids is the list of ids to ack.
	Ids                  []*query.Value `protobuf:"bytes,4,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) GetCallerId 

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

func (*MessageAckRequest) GetIds 

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

func (*MessageAckRequest) GetKeyspace 

func (m *MessageAckRequest) GetKeyspace() string

func (*MessageAckRequest) GetName 

func (m *MessageAckRequest) GetName() string

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 (m *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 MessageStreamRequest 

type MessageStreamRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// shard to target the query to, for unsharded keyspaces.
	Shard string `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	// KeyRange to target the query to, for sharded keyspaces.
	KeyRange *topodata.KeyRange `protobuf:"bytes,4,opt,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"`
	// name is the message table name.
	Name                 string   `protobuf:"bytes,5,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) GetCallerId 

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

func (*MessageStreamRequest) GetKeyRange 

func (m *MessageStreamRequest) GetKeyRange() *topodata.KeyRange

func (*MessageStreamRequest) GetKeyspace 

func (m *MessageStreamRequest) GetKeyspace() string

func (*MessageStreamRequest) GetName 

func (m *MessageStreamRequest) GetName() string

func (*MessageStreamRequest) GetShard 

func (m *MessageStreamRequest) GetShard() string

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 (m *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 ResolveTransactionRequest 

type ResolveTransactionRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// dtid is the dtid of the transaction to be resolved.
	Dtid                 string   `protobuf:"bytes,2,opt,name=dtid,proto3" json:"dtid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ResolveTransactionRequest is the payload to ResolveTransaction.

func (*ResolveTransactionRequest) Descriptor 

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

func (*ResolveTransactionRequest) GetCallerId 

func (m *ResolveTransactionRequest) GetCallerId() *vtrpc.CallerID

func (*ResolveTransactionRequest) GetDtid 

func (m *ResolveTransactionRequest) GetDtid() string

func (*ResolveTransactionRequest) ProtoMessage 

func (*ResolveTransactionRequest) ProtoMessage()

func (*ResolveTransactionRequest) Reset 

func (m *ResolveTransactionRequest) Reset()

func (*ResolveTransactionRequest) String 

func (m *ResolveTransactionRequest) String() string

func (*ResolveTransactionRequest) XXX_DiscardUnknown 

func (m *ResolveTransactionRequest) XXX_DiscardUnknown()

func (*ResolveTransactionRequest) XXX_Marshal 

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

func (*ResolveTransactionRequest) XXX_Merge 

func (m *ResolveTransactionRequest) XXX_Merge(src proto.Message)

func (*ResolveTransactionRequest) XXX_Size 

func (m *ResolveTransactionRequest) XXX_Size() int

func (*ResolveTransactionRequest) XXX_Unmarshal 

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

type ResolveTransactionResponse 

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

ResolveTransactionResponse is the returned value from Rollback.

func (*ResolveTransactionResponse) Descriptor 

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

func (*ResolveTransactionResponse) ProtoMessage 

func (*ResolveTransactionResponse) ProtoMessage()

func (*ResolveTransactionResponse) Reset 

func (m *ResolveTransactionResponse) Reset()

func (*ResolveTransactionResponse) String 

func (m *ResolveTransactionResponse) String() string

func (*ResolveTransactionResponse) XXX_DiscardUnknown 

func (m *ResolveTransactionResponse) XXX_DiscardUnknown()

func (*ResolveTransactionResponse) XXX_Marshal 

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

func (*ResolveTransactionResponse) XXX_Merge 

func (m *ResolveTransactionResponse) XXX_Merge(src proto.Message)

func (*ResolveTransactionResponse) XXX_Size 

func (m *ResolveTransactionResponse) XXX_Size() int

func (*ResolveTransactionResponse) XXX_Unmarshal 

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

type RollbackRequest 

type RollbackRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// session carries the current transaction data to rollback.
	Session              *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,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) GetCallerId 

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

func (*RollbackRequest) GetSession 

func (m *RollbackRequest) GetSession() *Session

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 (m *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 (m *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 Session 

type Session struct {
	// in_transaction is set to true if the session is in a transaction.
	InTransaction bool `protobuf:"varint,1,opt,name=in_transaction,json=inTransaction,proto3" json:"in_transaction,omitempty"`
	// shard_sessions keep track of per-shard transaction info.
	ShardSessions []*Session_ShardSession `protobuf:"bytes,2,rep,name=shard_sessions,json=shardSessions,proto3" json:"shard_sessions,omitempty"`
	// single_db is deprecated. Use transaction_mode instead.
	// The value specifies if the transaction should be restricted
	// to a single shard.
	// TODO(sougou): remove in 3.1
	SingleDb bool `protobuf:"varint,3,opt,name=single_db,json=singleDb,proto3" json:"single_db,omitempty"`
	// autocommit specifies if the session is in autocommit mode.
	// This is used only for V3.
	Autocommit bool `protobuf:"varint,4,opt,name=autocommit,proto3" json:"autocommit,omitempty"`
	// target_string is the target expressed as a string. Valid
	// names are: keyspace:shard@target, keyspace@target or @target.
	// This is used only for V3.
	TargetString string `protobuf:"bytes,5,opt,name=target_string,json=targetString,proto3" json:"target_string,omitempty"`
	// options is used only for V3.
	Options *query.ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	// transaction_mode specifies the current transaction mode.
	TransactionMode TransactionMode `` /* 135-byte string literal not displayed */
	// warnings contains non-fatal warnings from the previous query
	Warnings []*query.QueryWarning `protobuf:"bytes,8,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// pre_sessions contains sessions that have to be committed first.
	PreSessions []*Session_ShardSession `protobuf:"bytes,9,rep,name=pre_sessions,json=preSessions,proto3" json:"pre_sessions,omitempty"`
	// post_sessions contains sessions that have to be committed last.
	PostSessions []*Session_ShardSession `protobuf:"bytes,10,rep,name=post_sessions,json=postSessions,proto3" json:"post_sessions,omitempty"`
	// last_insert_id keeps track of the last seen insert_id for this session
	LastInsertId uint64 `protobuf:"varint,11,opt,name=last_insert_id,json=lastInsertId,proto3" json:"last_insert_id,omitempty"`
	// found_rows keeps track of how many rows the last query returned
	FoundRows uint64 `protobuf:"varint,12,opt,name=found_rows,json=foundRows,proto3" json:"found_rows,omitempty"`
	// user_defined_variables contains all the @variables defined for this session
	UserDefinedVariables map[string]*query.BindVariable `` /* 212-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

Session objects are exchanged like cookies through various calls to VTGate. The behavior differs between V2 & V3 APIs. V3 APIs are Execute, ExecuteBatch and StreamExecute. All other APIs are V2. For the V3 APIs, the session must be sent with every call to Execute or ExecuteBatch. For the V2 APIs, Begin does not accept a session. It instead returns a brand new one with in_transaction set to true. After a call to Commit or Rollback, the session can be discarded. If you're not in a transaction, Session is an optional parameter for the V2 APIs.

func (*Session) Descriptor 

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

func (*Session) GetAutocommit 

func (m *Session) GetAutocommit() bool

func (*Session) GetFoundRows 

func (m *Session) GetFoundRows() uint64

func (*Session) GetInTransaction 

func (m *Session) GetInTransaction() bool

func (*Session) GetLastInsertId 

func (m *Session) GetLastInsertId() uint64

func (*Session) GetOptions 

func (m *Session) GetOptions() *query.ExecuteOptions

func (*Session) GetPostSessions 

func (m *Session) GetPostSessions() []*Session_ShardSession

func (*Session) GetPreSessions 

func (m *Session) GetPreSessions() []*Session_ShardSession

func (*Session) GetShardSessions 

func (m *Session) GetShardSessions() []*Session_ShardSession

func (*Session) GetSingleDb 

func (m *Session) GetSingleDb() bool

func (*Session) GetTargetString 

func (m *Session) GetTargetString() string

func (*Session) GetTransactionMode 

func (m *Session) GetTransactionMode() TransactionMode

func (*Session) GetUserDefinedVariables 

func (m *Session) GetUserDefinedVariables() map[string]*query.BindVariable

func (*Session) GetWarnings 

func (m *Session) GetWarnings() []*query.QueryWarning

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) String 

func (m *Session) String() string

func (*Session) XXX_DiscardUnknown 

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal 

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

func (*Session) XXX_Merge 

func (m *Session) XXX_Merge(src proto.Message)

func (*Session) XXX_Size 

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal 

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

type Session_ShardSession 

type Session_ShardSession struct {
	Target               *query.Target `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	TransactionId        int64         `protobuf:"varint,2,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Session_ShardSession) Descriptor 

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

func (*Session_ShardSession) GetTarget 

func (m *Session_ShardSession) GetTarget() *query.Target

func (*Session_ShardSession) GetTransactionId 

func (m *Session_ShardSession) GetTransactionId() int64

func (*Session_ShardSession) ProtoMessage 

func (*Session_ShardSession) ProtoMessage()

func (*Session_ShardSession) Reset 

func (m *Session_ShardSession) Reset()

func (*Session_ShardSession) String 

func (m *Session_ShardSession) String() string

func (*Session_ShardSession) XXX_DiscardUnknown 

func (m *Session_ShardSession) XXX_DiscardUnknown()

func (*Session_ShardSession) XXX_Marshal 

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

func (*Session_ShardSession) XXX_Merge 

func (m *Session_ShardSession) XXX_Merge(src proto.Message)

func (*Session_ShardSession) XXX_Size 

func (m *Session_ShardSession) XXX_Size() int

func (*Session_ShardSession) XXX_Unmarshal 

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

type StreamExecuteKeyRangesRequest 

type StreamExecuteKeyRangesRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,3,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// key_ranges contains the list of key ranges affected by this query.
	// Will be used to find the shards to send the query to.
	KeyRanges []*topodata.KeyRange `protobuf:"bytes,4,rep,name=key_ranges,json=keyRanges,proto3" json:"key_ranges,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,5,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// options
	Options              *query.ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

StreamExecuteKeyRangesRequest is the payload to StreamExecuteKeyRanges.

func (*StreamExecuteKeyRangesRequest) Descriptor 

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

func (*StreamExecuteKeyRangesRequest) GetCallerId 

func (m *StreamExecuteKeyRangesRequest) GetCallerId() *vtrpc.CallerID

func (*StreamExecuteKeyRangesRequest) GetKeyRanges 

func (m *StreamExecuteKeyRangesRequest) GetKeyRanges() []*topodata.KeyRange

func (*StreamExecuteKeyRangesRequest) GetKeyspace 

func (m *StreamExecuteKeyRangesRequest) GetKeyspace() string

func (*StreamExecuteKeyRangesRequest) GetOptions 

func (m *StreamExecuteKeyRangesRequest) GetOptions() *query.ExecuteOptions

func (*StreamExecuteKeyRangesRequest) GetQuery 

func (m *StreamExecuteKeyRangesRequest) GetQuery() *query.BoundQuery

func (*StreamExecuteKeyRangesRequest) GetTabletType 

func (m *StreamExecuteKeyRangesRequest) GetTabletType() topodata.TabletType

func (*StreamExecuteKeyRangesRequest) ProtoMessage 

func (*StreamExecuteKeyRangesRequest) ProtoMessage()

func (*StreamExecuteKeyRangesRequest) Reset 

func (m *StreamExecuteKeyRangesRequest) Reset()

func (*StreamExecuteKeyRangesRequest) String 

func (m *StreamExecuteKeyRangesRequest) String() string

func (*StreamExecuteKeyRangesRequest) XXX_DiscardUnknown 

func (m *StreamExecuteKeyRangesRequest) XXX_DiscardUnknown()

func (*StreamExecuteKeyRangesRequest) XXX_Marshal 

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

func (*StreamExecuteKeyRangesRequest) XXX_Merge 

func (m *StreamExecuteKeyRangesRequest) XXX_Merge(src proto.Message)

func (*StreamExecuteKeyRangesRequest) XXX_Size 

func (m *StreamExecuteKeyRangesRequest) XXX_Size() int

func (*StreamExecuteKeyRangesRequest) XXX_Unmarshal 

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

type StreamExecuteKeyRangesResponse 

type StreamExecuteKeyRangesResponse struct {
	// result contains the result data.
	// The first value contains only Fields information.
	// The next values contain the actual rows, a few values per result.
	Result               *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

StreamExecuteKeyRangesResponse is the returned value from StreamExecuteKeyRanges.

func (*StreamExecuteKeyRangesResponse) Descriptor 

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

func (*StreamExecuteKeyRangesResponse) GetResult 

func (m *StreamExecuteKeyRangesResponse) GetResult() *query.QueryResult

func (*StreamExecuteKeyRangesResponse) ProtoMessage 

func (*StreamExecuteKeyRangesResponse) ProtoMessage()

func (*StreamExecuteKeyRangesResponse) Reset 

func (m *StreamExecuteKeyRangesResponse) Reset()

func (*StreamExecuteKeyRangesResponse) String 

func (m *StreamExecuteKeyRangesResponse) String() string

func (*StreamExecuteKeyRangesResponse) XXX_DiscardUnknown 

func (m *StreamExecuteKeyRangesResponse) XXX_DiscardUnknown()

func (*StreamExecuteKeyRangesResponse) XXX_Marshal 

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

func (*StreamExecuteKeyRangesResponse) XXX_Merge 

func (m *StreamExecuteKeyRangesResponse) XXX_Merge(src proto.Message)

func (*StreamExecuteKeyRangesResponse) XXX_Size 

func (m *StreamExecuteKeyRangesResponse) XXX_Size() int

func (*StreamExecuteKeyRangesResponse) XXX_Unmarshal 

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

type StreamExecuteKeyspaceIdsRequest 

type StreamExecuteKeyspaceIdsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,3,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// keyspace_ids contains the list of keyspace_ids affected by this query.
	// Will be used to find the shards to send the query to.
	KeyspaceIds [][]byte `protobuf:"bytes,4,rep,name=keyspace_ids,json=keyspaceIds,proto3" json:"keyspace_ids,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,5,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// options
	Options              *query.ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

StreamExecuteKeyspaceIdsRequest is the payload to StreamExecuteKeyspaceIds.

func (*StreamExecuteKeyspaceIdsRequest) Descriptor 

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

func (*StreamExecuteKeyspaceIdsRequest) GetCallerId 

func (m *StreamExecuteKeyspaceIdsRequest) GetCallerId() *vtrpc.CallerID

func (*StreamExecuteKeyspaceIdsRequest) GetKeyspace 

func (m *StreamExecuteKeyspaceIdsRequest) GetKeyspace() string

func (*StreamExecuteKeyspaceIdsRequest) GetKeyspaceIds 

func (m *StreamExecuteKeyspaceIdsRequest) GetKeyspaceIds() [][]byte

func (*StreamExecuteKeyspaceIdsRequest) GetOptions 

func (m *StreamExecuteKeyspaceIdsRequest) GetOptions() *query.ExecuteOptions

func (*StreamExecuteKeyspaceIdsRequest) GetQuery 

func (m *StreamExecuteKeyspaceIdsRequest) GetQuery() *query.BoundQuery

func (*StreamExecuteKeyspaceIdsRequest) GetTabletType 

func (m *StreamExecuteKeyspaceIdsRequest) GetTabletType() topodata.TabletType

func (*StreamExecuteKeyspaceIdsRequest) ProtoMessage 

func (*StreamExecuteKeyspaceIdsRequest) ProtoMessage()

func (*StreamExecuteKeyspaceIdsRequest) Reset 

func (m *StreamExecuteKeyspaceIdsRequest) Reset()

func (*StreamExecuteKeyspaceIdsRequest) String 

func (m *StreamExecuteKeyspaceIdsRequest) String() string

func (*StreamExecuteKeyspaceIdsRequest) XXX_DiscardUnknown 

func (m *StreamExecuteKeyspaceIdsRequest) XXX_DiscardUnknown()

func (*StreamExecuteKeyspaceIdsRequest) XXX_Marshal 

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

func (*StreamExecuteKeyspaceIdsRequest) XXX_Merge 

func (m *StreamExecuteKeyspaceIdsRequest) XXX_Merge(src proto.Message)

func (*StreamExecuteKeyspaceIdsRequest) XXX_Size 

func (m *StreamExecuteKeyspaceIdsRequest) XXX_Size() int

func (*StreamExecuteKeyspaceIdsRequest) XXX_Unmarshal 

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

type StreamExecuteKeyspaceIdsResponse 

type StreamExecuteKeyspaceIdsResponse struct {
	// result contains the result data.
	// The first value contains only Fields information.
	// The next values contain the actual rows, a few values per result.
	Result               *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

StreamExecuteKeyspaceIdsResponse is the returned value from StreamExecuteKeyspaceIds.

func (*StreamExecuteKeyspaceIdsResponse) Descriptor 

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

func (*StreamExecuteKeyspaceIdsResponse) GetResult 

func (m *StreamExecuteKeyspaceIdsResponse) GetResult() *query.QueryResult

func (*StreamExecuteKeyspaceIdsResponse) ProtoMessage 

func (*StreamExecuteKeyspaceIdsResponse) ProtoMessage()

func (*StreamExecuteKeyspaceIdsResponse) Reset 

func (m *StreamExecuteKeyspaceIdsResponse) Reset()

func (*StreamExecuteKeyspaceIdsResponse) String 

func (m *StreamExecuteKeyspaceIdsResponse) String() string

func (*StreamExecuteKeyspaceIdsResponse) XXX_DiscardUnknown 

func (m *StreamExecuteKeyspaceIdsResponse) XXX_DiscardUnknown()

func (*StreamExecuteKeyspaceIdsResponse) XXX_Marshal 

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

func (*StreamExecuteKeyspaceIdsResponse) XXX_Merge 

func (m *StreamExecuteKeyspaceIdsResponse) XXX_Merge(src proto.Message)

func (*StreamExecuteKeyspaceIdsResponse) XXX_Size 

func (m *StreamExecuteKeyspaceIdsResponse) XXX_Size() int

func (*StreamExecuteKeyspaceIdsResponse) XXX_Unmarshal 

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

type StreamExecuteRequest 

type StreamExecuteRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// These values are deprecated. Use session instead.
	// TODO(sougou): remove in 3.1
	TabletType    topodata.TabletType   `protobuf:"varint,3,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	KeyspaceShard string                `protobuf:"bytes,4,opt,name=keyspace_shard,json=keyspaceShard,proto3" json:"keyspace_shard,omitempty"`
	Options       *query.ExecuteOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	// session carries the session state.
	Session              *Session `protobuf:"bytes,6,opt,name=session,proto3" json:"session,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

StreamExecuteRequest is the payload to StreamExecute.

func (*StreamExecuteRequest) Descriptor 

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

func (*StreamExecuteRequest) GetCallerId 

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

func (*StreamExecuteRequest) GetKeyspaceShard 

func (m *StreamExecuteRequest) GetKeyspaceShard() string

func (*StreamExecuteRequest) GetOptions 

func (m *StreamExecuteRequest) GetOptions() *query.ExecuteOptions

func (*StreamExecuteRequest) GetQuery 

func (m *StreamExecuteRequest) GetQuery() *query.BoundQuery

func (*StreamExecuteRequest) GetSession 

func (m *StreamExecuteRequest) GetSession() *Session

func (*StreamExecuteRequest) GetTabletType 

func (m *StreamExecuteRequest) GetTabletType() topodata.TabletType

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 (m *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 contains the result data.
	// The first value contains only Fields information.
	// The next values contain the actual rows, a few values per result.
	Result               *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

StreamExecuteResponse is the returned value from StreamExecute. The session is currently not returned because StreamExecute is not expected to modify it.

func (*StreamExecuteResponse) Descriptor 

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

func (*StreamExecuteResponse) GetResult 

func (m *StreamExecuteResponse) GetResult() *query.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 (m *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 StreamExecuteShardsRequest 

type StreamExecuteShardsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,3,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// shards to target the query to.
	Shards []string `protobuf:"bytes,4,rep,name=shards,proto3" json:"shards,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,5,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// options
	Options              *query.ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

StreamExecuteShardsRequest is the payload to StreamExecuteShards.

func (*StreamExecuteShardsRequest) Descriptor 

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

func (*StreamExecuteShardsRequest) GetCallerId 

func (m *StreamExecuteShardsRequest) GetCallerId() *vtrpc.CallerID

func (*StreamExecuteShardsRequest) GetKeyspace 

func (m *StreamExecuteShardsRequest) GetKeyspace() string

func (*StreamExecuteShardsRequest) GetOptions 

func (m *StreamExecuteShardsRequest) GetOptions() *query.ExecuteOptions

func (*StreamExecuteShardsRequest) GetQuery 

func (m *StreamExecuteShardsRequest) GetQuery() *query.BoundQuery

func (*StreamExecuteShardsRequest) GetShards 

func (m *StreamExecuteShardsRequest) GetShards() []string

func (*StreamExecuteShardsRequest) GetTabletType 

func (m *StreamExecuteShardsRequest) GetTabletType() topodata.TabletType

func (*StreamExecuteShardsRequest) ProtoMessage 

func (*StreamExecuteShardsRequest) ProtoMessage()

func (*StreamExecuteShardsRequest) Reset 

func (m *StreamExecuteShardsRequest) Reset()

func (*StreamExecuteShardsRequest) String 

func (m *StreamExecuteShardsRequest) String() string

func (*StreamExecuteShardsRequest) XXX_DiscardUnknown 

func (m *StreamExecuteShardsRequest) XXX_DiscardUnknown()

func (*StreamExecuteShardsRequest) XXX_Marshal 

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

func (*StreamExecuteShardsRequest) XXX_Merge 

func (m *StreamExecuteShardsRequest) XXX_Merge(src proto.Message)

func (*StreamExecuteShardsRequest) XXX_Size 

func (m *StreamExecuteShardsRequest) XXX_Size() int

func (*StreamExecuteShardsRequest) XXX_Unmarshal 

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

type StreamExecuteShardsResponse 

type StreamExecuteShardsResponse struct {
	// result contains the result data.
	// The first value contains only Fields information.
	// The next values contain the actual rows, a few values per result.
	Result               *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

StreamExecuteShardsResponse is the returned value from StreamExecuteShards.

func (*StreamExecuteShardsResponse) Descriptor 

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

func (*StreamExecuteShardsResponse) GetResult 

func (m *StreamExecuteShardsResponse) GetResult() *query.QueryResult

func (*StreamExecuteShardsResponse) ProtoMessage 

func (*StreamExecuteShardsResponse) ProtoMessage()

func (*StreamExecuteShardsResponse) Reset 

func (m *StreamExecuteShardsResponse) Reset()

func (*StreamExecuteShardsResponse) String 

func (m *StreamExecuteShardsResponse) String() string

func (*StreamExecuteShardsResponse) XXX_DiscardUnknown 

func (m *StreamExecuteShardsResponse) XXX_DiscardUnknown()

func (*StreamExecuteShardsResponse) XXX_Marshal 

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

func (*StreamExecuteShardsResponse) XXX_Merge 

func (m *StreamExecuteShardsResponse) XXX_Merge(src proto.Message)

func (*StreamExecuteShardsResponse) XXX_Size 

func (m *StreamExecuteShardsResponse) XXX_Size() int

func (*StreamExecuteShardsResponse) XXX_Unmarshal 

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

type TransactionMode 

type TransactionMode int32

TransactionMode controls the execution of distributed transaction across multiple shards. 

const (
	// UNSPECIFIED uses the transaction mode set by the VTGate flag 'transaction_mode'.
	TransactionMode_UNSPECIFIED TransactionMode = 0
	// SINGLE disallows distributed transactions.
	TransactionMode_SINGLE TransactionMode = 1
	// MULTI allows distributed transactions with best effort commit.
	TransactionMode_MULTI TransactionMode = 2
	// TWOPC is for distributed transactions with atomic commits.
	TransactionMode_TWOPC TransactionMode = 3
)

func (TransactionMode) EnumDescriptor 

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

func (TransactionMode) String 

func (x TransactionMode) String() string

type VStreamRequest 

type VStreamRequest struct {
	CallerId   *vtrpc.CallerID     `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	TabletType topodata.TabletType `protobuf:"varint,2,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// position specifies the starting point of the bin log positions
	// as well as the keyspace-shards to pull events from.
	// position is of the form 'ks1:0@MySQL56/<mysql_pos>|ks2:-80@MySQL56/<mysql_pos>'.
	Vgtid                *binlogdata.VGtid  `protobuf:"bytes,3,opt,name=vgtid,proto3" json:"vgtid,omitempty"`
	Filter               *binlogdata.Filter `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

VStreamRequest is the payload for VStream.

func (*VStreamRequest) Descriptor 

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

func (*VStreamRequest) GetCallerId 

func (m *VStreamRequest) GetCallerId() *vtrpc.CallerID

func (*VStreamRequest) GetFilter 

func (m *VStreamRequest) GetFilter() *binlogdata.Filter

func (*VStreamRequest) GetTabletType 

func (m *VStreamRequest) GetTabletType() topodata.TabletType

func (*VStreamRequest) GetVgtid 

func (m *VStreamRequest) GetVgtid() *binlogdata.VGtid

func (*VStreamRequest) ProtoMessage 

func (*VStreamRequest) ProtoMessage()

func (*VStreamRequest) Reset 

func (m *VStreamRequest) Reset()

func (*VStreamRequest) String 

func (m *VStreamRequest) String() string

func (*VStreamRequest) XXX_DiscardUnknown 

func (m *VStreamRequest) XXX_DiscardUnknown()

func (*VStreamRequest) XXX_Marshal 

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

func (*VStreamRequest) XXX_Merge 

func (m *VStreamRequest) XXX_Merge(src proto.Message)

func (*VStreamRequest) XXX_Size 

func (m *VStreamRequest) XXX_Size() int

func (*VStreamRequest) XXX_Unmarshal 

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

type VStreamResponse 

type VStreamResponse struct {
	Events               []*binlogdata.VEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

VStreamResponse is streamed by VStream.

func (*VStreamResponse) Descriptor 

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

func (*VStreamResponse) GetEvents 

func (m *VStreamResponse) GetEvents() []*binlogdata.VEvent

func (*VStreamResponse) ProtoMessage 

func (*VStreamResponse) ProtoMessage()

func (*VStreamResponse) Reset 

func (m *VStreamResponse) Reset()

func (*VStreamResponse) String 

func (m *VStreamResponse) String() string

func (*VStreamResponse) XXX_DiscardUnknown 

func (m *VStreamResponse) XXX_DiscardUnknown()

func (*VStreamResponse) XXX_Marshal 

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

func (*VStreamResponse) XXX_Merge 

func (m *VStreamResponse) XXX_Merge(src proto.Message)

func (*VStreamResponse) XXX_Size 

func (m *VStreamResponse) XXX_Size() int

func (*VStreamResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.