go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/proto/vtgate Index | Files

package vtgate

import "gopkg.in/src-d/go-vitess.v1/vt/proto/vtgate"

Index

Package Files

vtgate.pb.go

Variables

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

type BeginRequest Uses

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 Uses

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

func (*BeginRequest) GetCallerId Uses

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

func (*BeginRequest) GetSingleDb Uses

func (m *BeginRequest) GetSingleDb() bool

func (*BeginRequest) ProtoMessage Uses

func (*BeginRequest) ProtoMessage()

func (*BeginRequest) Reset Uses

func (m *BeginRequest) Reset()

func (*BeginRequest) String Uses

func (m *BeginRequest) String() string

func (*BeginRequest) XXX_DiscardUnknown Uses

func (m *BeginRequest) XXX_DiscardUnknown()

func (*BeginRequest) XXX_Marshal Uses

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

func (*BeginRequest) XXX_Merge Uses

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

func (*BeginRequest) XXX_Size Uses

func (m *BeginRequest) XXX_Size() int

func (*BeginRequest) XXX_Unmarshal Uses

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

type BeginResponse Uses

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 Uses

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

func (*BeginResponse) GetSession Uses

func (m *BeginResponse) GetSession() *Session

func (*BeginResponse) ProtoMessage Uses

func (*BeginResponse) ProtoMessage()

func (*BeginResponse) Reset Uses

func (m *BeginResponse) Reset()

func (*BeginResponse) String Uses

func (m *BeginResponse) String() string

func (*BeginResponse) XXX_DiscardUnknown Uses

func (m *BeginResponse) XXX_DiscardUnknown()

func (*BeginResponse) XXX_Marshal Uses

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

func (*BeginResponse) XXX_Merge Uses

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

func (*BeginResponse) XXX_Size Uses

func (m *BeginResponse) XXX_Size() int

func (*BeginResponse) XXX_Unmarshal Uses

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

type BoundKeyspaceIdQuery Uses

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 Uses

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

func (*BoundKeyspaceIdQuery) GetKeyspace Uses

func (m *BoundKeyspaceIdQuery) GetKeyspace() string

func (*BoundKeyspaceIdQuery) GetKeyspaceIds Uses

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

func (*BoundKeyspaceIdQuery) GetQuery Uses

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

func (*BoundKeyspaceIdQuery) ProtoMessage Uses

func (*BoundKeyspaceIdQuery) ProtoMessage()

func (*BoundKeyspaceIdQuery) Reset Uses

func (m *BoundKeyspaceIdQuery) Reset()

func (*BoundKeyspaceIdQuery) String Uses

func (m *BoundKeyspaceIdQuery) String() string

func (*BoundKeyspaceIdQuery) XXX_DiscardUnknown Uses

func (m *BoundKeyspaceIdQuery) XXX_DiscardUnknown()

func (*BoundKeyspaceIdQuery) XXX_Marshal Uses

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

func (*BoundKeyspaceIdQuery) XXX_Merge Uses

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

func (*BoundKeyspaceIdQuery) XXX_Size Uses

func (m *BoundKeyspaceIdQuery) XXX_Size() int

func (*BoundKeyspaceIdQuery) XXX_Unmarshal Uses

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

type BoundShardQuery Uses

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 Uses

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

func (*BoundShardQuery) GetKeyspace Uses

func (m *BoundShardQuery) GetKeyspace() string

func (*BoundShardQuery) GetQuery Uses

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

func (*BoundShardQuery) GetShards Uses

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

func (*BoundShardQuery) ProtoMessage Uses

func (*BoundShardQuery) ProtoMessage()

func (*BoundShardQuery) Reset Uses

func (m *BoundShardQuery) Reset()

func (*BoundShardQuery) String Uses

func (m *BoundShardQuery) String() string

func (*BoundShardQuery) XXX_DiscardUnknown Uses

func (m *BoundShardQuery) XXX_DiscardUnknown()

func (*BoundShardQuery) XXX_Marshal Uses

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

func (*BoundShardQuery) XXX_Merge Uses

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

func (*BoundShardQuery) XXX_Size Uses

func (m *BoundShardQuery) XXX_Size() int

func (*BoundShardQuery) XXX_Unmarshal Uses

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

type CommitOrder Uses

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 Uses

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

func (CommitOrder) String Uses

func (x CommitOrder) String() string

type CommitRequest Uses

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 Uses

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

func (*CommitRequest) GetAtomic Uses

func (m *CommitRequest) GetAtomic() bool

func (*CommitRequest) GetCallerId Uses

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

func (*CommitRequest) GetSession Uses

func (m *CommitRequest) GetSession() *Session

func (*CommitRequest) ProtoMessage Uses

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) Reset Uses

func (m *CommitRequest) Reset()

func (*CommitRequest) String Uses

func (m *CommitRequest) String() string

func (*CommitRequest) XXX_DiscardUnknown Uses

func (m *CommitRequest) XXX_DiscardUnknown()

func (*CommitRequest) XXX_Marshal Uses

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

func (*CommitRequest) XXX_Merge Uses

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

func (*CommitRequest) XXX_Size Uses

func (m *CommitRequest) XXX_Size() int

func (*CommitRequest) XXX_Unmarshal Uses

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

type CommitResponse Uses

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 Uses

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

func (*CommitResponse) ProtoMessage Uses

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) Reset Uses

func (m *CommitResponse) Reset()

func (*CommitResponse) String Uses

func (m *CommitResponse) String() string

func (*CommitResponse) XXX_DiscardUnknown Uses

func (m *CommitResponse) XXX_DiscardUnknown()

func (*CommitResponse) XXX_Marshal Uses

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

func (*CommitResponse) XXX_Merge Uses

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

func (*CommitResponse) XXX_Size Uses

func (m *CommitResponse) XXX_Size() int

func (*CommitResponse) XXX_Unmarshal Uses

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

type ExecuteBatchKeyspaceIdsRequest Uses

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 Uses

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

func (*ExecuteBatchKeyspaceIdsRequest) GetAsTransaction Uses

func (m *ExecuteBatchKeyspaceIdsRequest) GetAsTransaction() bool

func (*ExecuteBatchKeyspaceIdsRequest) GetCallerId Uses

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

func (*ExecuteBatchKeyspaceIdsRequest) GetOptions Uses

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

func (*ExecuteBatchKeyspaceIdsRequest) GetQueries Uses

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

func (*ExecuteBatchKeyspaceIdsRequest) GetSession Uses

func (m *ExecuteBatchKeyspaceIdsRequest) GetSession() *Session

func (*ExecuteBatchKeyspaceIdsRequest) GetTabletType Uses

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

func (*ExecuteBatchKeyspaceIdsRequest) ProtoMessage Uses

func (*ExecuteBatchKeyspaceIdsRequest) ProtoMessage()

func (*ExecuteBatchKeyspaceIdsRequest) Reset Uses

func (m *ExecuteBatchKeyspaceIdsRequest) Reset()

func (*ExecuteBatchKeyspaceIdsRequest) String Uses

func (m *ExecuteBatchKeyspaceIdsRequest) String() string

func (*ExecuteBatchKeyspaceIdsRequest) XXX_DiscardUnknown Uses

func (m *ExecuteBatchKeyspaceIdsRequest) XXX_DiscardUnknown()

func (*ExecuteBatchKeyspaceIdsRequest) XXX_Marshal Uses

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

func (*ExecuteBatchKeyspaceIdsRequest) XXX_Merge Uses

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

func (*ExecuteBatchKeyspaceIdsRequest) XXX_Size Uses

func (m *ExecuteBatchKeyspaceIdsRequest) XXX_Size() int

func (*ExecuteBatchKeyspaceIdsRequest) XXX_Unmarshal Uses

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

type ExecuteBatchKeyspaceIdsResponse Uses

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 Uses

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

func (*ExecuteBatchKeyspaceIdsResponse) GetError Uses

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

func (*ExecuteBatchKeyspaceIdsResponse) GetResults Uses

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

func (*ExecuteBatchKeyspaceIdsResponse) GetSession Uses

func (m *ExecuteBatchKeyspaceIdsResponse) GetSession() *Session

func (*ExecuteBatchKeyspaceIdsResponse) ProtoMessage Uses

func (*ExecuteBatchKeyspaceIdsResponse) ProtoMessage()

func (*ExecuteBatchKeyspaceIdsResponse) Reset Uses

func (m *ExecuteBatchKeyspaceIdsResponse) Reset()

func (*ExecuteBatchKeyspaceIdsResponse) String Uses

func (m *ExecuteBatchKeyspaceIdsResponse) String() string

func (*ExecuteBatchKeyspaceIdsResponse) XXX_DiscardUnknown Uses

func (m *ExecuteBatchKeyspaceIdsResponse) XXX_DiscardUnknown()

func (*ExecuteBatchKeyspaceIdsResponse) XXX_Marshal Uses

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

func (*ExecuteBatchKeyspaceIdsResponse) XXX_Merge Uses

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

func (*ExecuteBatchKeyspaceIdsResponse) XXX_Size Uses

func (m *ExecuteBatchKeyspaceIdsResponse) XXX_Size() int

func (*ExecuteBatchKeyspaceIdsResponse) XXX_Unmarshal Uses

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

type ExecuteBatchRequest Uses

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 Uses

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

func (*ExecuteBatchRequest) GetAsTransaction Uses

func (m *ExecuteBatchRequest) GetAsTransaction() bool

func (*ExecuteBatchRequest) GetCallerId Uses

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

func (*ExecuteBatchRequest) GetKeyspaceShard Uses

func (m *ExecuteBatchRequest) GetKeyspaceShard() string

func (*ExecuteBatchRequest) GetOptions Uses

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

func (*ExecuteBatchRequest) GetQueries Uses

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

func (*ExecuteBatchRequest) GetSession Uses

func (m *ExecuteBatchRequest) GetSession() *Session

func (*ExecuteBatchRequest) GetTabletType Uses

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

func (*ExecuteBatchRequest) ProtoMessage Uses

func (*ExecuteBatchRequest) ProtoMessage()

func (*ExecuteBatchRequest) Reset Uses

func (m *ExecuteBatchRequest) Reset()

func (*ExecuteBatchRequest) String Uses

func (m *ExecuteBatchRequest) String() string

func (*ExecuteBatchRequest) XXX_DiscardUnknown Uses

func (m *ExecuteBatchRequest) XXX_DiscardUnknown()

func (*ExecuteBatchRequest) XXX_Marshal Uses

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

func (*ExecuteBatchRequest) XXX_Merge Uses

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

func (*ExecuteBatchRequest) XXX_Size Uses

func (m *ExecuteBatchRequest) XXX_Size() int

func (*ExecuteBatchRequest) XXX_Unmarshal Uses

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

type ExecuteBatchResponse Uses

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 Uses

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

func (*ExecuteBatchResponse) GetError Uses

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

func (*ExecuteBatchResponse) GetResults Uses

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

func (*ExecuteBatchResponse) GetSession Uses

func (m *ExecuteBatchResponse) GetSession() *Session

func (*ExecuteBatchResponse) ProtoMessage Uses

func (*ExecuteBatchResponse) ProtoMessage()

func (*ExecuteBatchResponse) Reset Uses

func (m *ExecuteBatchResponse) Reset()

func (*ExecuteBatchResponse) String Uses

func (m *ExecuteBatchResponse) String() string

func (*ExecuteBatchResponse) XXX_DiscardUnknown Uses

func (m *ExecuteBatchResponse) XXX_DiscardUnknown()

func (*ExecuteBatchResponse) XXX_Marshal Uses

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

func (*ExecuteBatchResponse) XXX_Merge Uses

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

func (*ExecuteBatchResponse) XXX_Size Uses

func (m *ExecuteBatchResponse) XXX_Size() int

func (*ExecuteBatchResponse) XXX_Unmarshal Uses

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

type ExecuteBatchShardsRequest Uses

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 Uses

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

func (*ExecuteBatchShardsRequest) GetAsTransaction Uses

func (m *ExecuteBatchShardsRequest) GetAsTransaction() bool

func (*ExecuteBatchShardsRequest) GetCallerId Uses

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

func (*ExecuteBatchShardsRequest) GetOptions Uses

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

func (*ExecuteBatchShardsRequest) GetQueries Uses

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

func (*ExecuteBatchShardsRequest) GetSession Uses

func (m *ExecuteBatchShardsRequest) GetSession() *Session

func (*ExecuteBatchShardsRequest) GetTabletType Uses

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

func (*ExecuteBatchShardsRequest) ProtoMessage Uses

func (*ExecuteBatchShardsRequest) ProtoMessage()

func (*ExecuteBatchShardsRequest) Reset Uses

func (m *ExecuteBatchShardsRequest) Reset()

func (*ExecuteBatchShardsRequest) String Uses

func (m *ExecuteBatchShardsRequest) String() string

func (*ExecuteBatchShardsRequest) XXX_DiscardUnknown Uses

func (m *ExecuteBatchShardsRequest) XXX_DiscardUnknown()

func (*ExecuteBatchShardsRequest) XXX_Marshal Uses

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

func (*ExecuteBatchShardsRequest) XXX_Merge Uses

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

func (*ExecuteBatchShardsRequest) XXX_Size Uses

func (m *ExecuteBatchShardsRequest) XXX_Size() int

func (*ExecuteBatchShardsRequest) XXX_Unmarshal Uses

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

type ExecuteBatchShardsResponse Uses

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 Uses

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

func (*ExecuteBatchShardsResponse) GetError Uses

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

func (*ExecuteBatchShardsResponse) GetResults Uses

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

func (*ExecuteBatchShardsResponse) GetSession Uses

func (m *ExecuteBatchShardsResponse) GetSession() *Session

func (*ExecuteBatchShardsResponse) ProtoMessage Uses

func (*ExecuteBatchShardsResponse) ProtoMessage()

func (*ExecuteBatchShardsResponse) Reset Uses

func (m *ExecuteBatchShardsResponse) Reset()

func (*ExecuteBatchShardsResponse) String Uses

func (m *ExecuteBatchShardsResponse) String() string

func (*ExecuteBatchShardsResponse) XXX_DiscardUnknown Uses

func (m *ExecuteBatchShardsResponse) XXX_DiscardUnknown()

func (*ExecuteBatchShardsResponse) XXX_Marshal Uses

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

func (*ExecuteBatchShardsResponse) XXX_Merge Uses

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

func (*ExecuteBatchShardsResponse) XXX_Size Uses

func (m *ExecuteBatchShardsResponse) XXX_Size() int

func (*ExecuteBatchShardsResponse) XXX_Unmarshal Uses

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

type ExecuteEntityIdsRequest Uses

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 Uses

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

func (*ExecuteEntityIdsRequest) GetCallerId Uses

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

func (*ExecuteEntityIdsRequest) GetEntityColumnName Uses

func (m *ExecuteEntityIdsRequest) GetEntityColumnName() string

func (*ExecuteEntityIdsRequest) GetEntityKeyspaceIds Uses

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

func (*ExecuteEntityIdsRequest) GetKeyspace Uses

func (m *ExecuteEntityIdsRequest) GetKeyspace() string

func (*ExecuteEntityIdsRequest) GetNotInTransaction Uses

func (m *ExecuteEntityIdsRequest) GetNotInTransaction() bool

func (*ExecuteEntityIdsRequest) GetOptions Uses

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

func (*ExecuteEntityIdsRequest) GetQuery Uses

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

func (*ExecuteEntityIdsRequest) GetSession Uses

func (m *ExecuteEntityIdsRequest) GetSession() *Session

func (*ExecuteEntityIdsRequest) GetTabletType Uses

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

func (*ExecuteEntityIdsRequest) ProtoMessage Uses

func (*ExecuteEntityIdsRequest) ProtoMessage()

func (*ExecuteEntityIdsRequest) Reset Uses

func (m *ExecuteEntityIdsRequest) Reset()

func (*ExecuteEntityIdsRequest) String Uses

func (m *ExecuteEntityIdsRequest) String() string

func (*ExecuteEntityIdsRequest) XXX_DiscardUnknown Uses

func (m *ExecuteEntityIdsRequest) XXX_DiscardUnknown()

func (*ExecuteEntityIdsRequest) XXX_Marshal Uses

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

func (*ExecuteEntityIdsRequest) XXX_Merge Uses

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

func (*ExecuteEntityIdsRequest) XXX_Size Uses

func (m *ExecuteEntityIdsRequest) XXX_Size() int

func (*ExecuteEntityIdsRequest) XXX_Unmarshal Uses

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

type ExecuteEntityIdsRequest_EntityId Uses

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 Uses

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

func (*ExecuteEntityIdsRequest_EntityId) GetKeyspaceId Uses

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

func (*ExecuteEntityIdsRequest_EntityId) GetType Uses

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

func (*ExecuteEntityIdsRequest_EntityId) GetValue Uses

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

func (*ExecuteEntityIdsRequest_EntityId) ProtoMessage Uses

func (*ExecuteEntityIdsRequest_EntityId) ProtoMessage()

func (*ExecuteEntityIdsRequest_EntityId) Reset Uses

func (m *ExecuteEntityIdsRequest_EntityId) Reset()

func (*ExecuteEntityIdsRequest_EntityId) String Uses

func (m *ExecuteEntityIdsRequest_EntityId) String() string

func (*ExecuteEntityIdsRequest_EntityId) XXX_DiscardUnknown Uses

func (m *ExecuteEntityIdsRequest_EntityId) XXX_DiscardUnknown()

func (*ExecuteEntityIdsRequest_EntityId) XXX_Marshal Uses

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

func (*ExecuteEntityIdsRequest_EntityId) XXX_Merge Uses

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

func (*ExecuteEntityIdsRequest_EntityId) XXX_Size Uses

func (m *ExecuteEntityIdsRequest_EntityId) XXX_Size() int

func (*ExecuteEntityIdsRequest_EntityId) XXX_Unmarshal Uses

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

type ExecuteEntityIdsResponse Uses

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 Uses

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

func (*ExecuteEntityIdsResponse) GetError Uses

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

func (*ExecuteEntityIdsResponse) GetResult Uses

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

func (*ExecuteEntityIdsResponse) GetSession Uses

func (m *ExecuteEntityIdsResponse) GetSession() *Session

func (*ExecuteEntityIdsResponse) ProtoMessage Uses

func (*ExecuteEntityIdsResponse) ProtoMessage()

func (*ExecuteEntityIdsResponse) Reset Uses

func (m *ExecuteEntityIdsResponse) Reset()

func (*ExecuteEntityIdsResponse) String Uses

func (m *ExecuteEntityIdsResponse) String() string

func (*ExecuteEntityIdsResponse) XXX_DiscardUnknown Uses

func (m *ExecuteEntityIdsResponse) XXX_DiscardUnknown()

func (*ExecuteEntityIdsResponse) XXX_Marshal Uses

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

func (*ExecuteEntityIdsResponse) XXX_Merge Uses

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

func (*ExecuteEntityIdsResponse) XXX_Size Uses

func (m *ExecuteEntityIdsResponse) XXX_Size() int

func (*ExecuteEntityIdsResponse) XXX_Unmarshal Uses

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

type ExecuteKeyRangesRequest Uses

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 Uses

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

func (*ExecuteKeyRangesRequest) GetCallerId Uses

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

func (*ExecuteKeyRangesRequest) GetKeyRanges Uses

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

func (*ExecuteKeyRangesRequest) GetKeyspace Uses

func (m *ExecuteKeyRangesRequest) GetKeyspace() string

func (*ExecuteKeyRangesRequest) GetNotInTransaction Uses

func (m *ExecuteKeyRangesRequest) GetNotInTransaction() bool

func (*ExecuteKeyRangesRequest) GetOptions Uses

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

func (*ExecuteKeyRangesRequest) GetQuery Uses

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

func (*ExecuteKeyRangesRequest) GetSession Uses

func (m *ExecuteKeyRangesRequest) GetSession() *Session

func (*ExecuteKeyRangesRequest) GetTabletType Uses

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

func (*ExecuteKeyRangesRequest) ProtoMessage Uses

func (*ExecuteKeyRangesRequest) ProtoMessage()

func (*ExecuteKeyRangesRequest) Reset Uses

func (m *ExecuteKeyRangesRequest) Reset()

func (*ExecuteKeyRangesRequest) String Uses

func (m *ExecuteKeyRangesRequest) String() string

func (*ExecuteKeyRangesRequest) XXX_DiscardUnknown Uses

func (m *ExecuteKeyRangesRequest) XXX_DiscardUnknown()

func (*ExecuteKeyRangesRequest) XXX_Marshal Uses

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

func (*ExecuteKeyRangesRequest) XXX_Merge Uses

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

func (*ExecuteKeyRangesRequest) XXX_Size Uses

func (m *ExecuteKeyRangesRequest) XXX_Size() int

func (*ExecuteKeyRangesRequest) XXX_Unmarshal Uses

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

type ExecuteKeyRangesResponse Uses

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 Uses

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

func (*ExecuteKeyRangesResponse) GetError Uses

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

func (*ExecuteKeyRangesResponse) GetResult Uses

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

func (*ExecuteKeyRangesResponse) GetSession Uses

func (m *ExecuteKeyRangesResponse) GetSession() *Session

func (*ExecuteKeyRangesResponse) ProtoMessage Uses

func (*ExecuteKeyRangesResponse) ProtoMessage()

func (*ExecuteKeyRangesResponse) Reset Uses

func (m *ExecuteKeyRangesResponse) Reset()

func (*ExecuteKeyRangesResponse) String Uses

func (m *ExecuteKeyRangesResponse) String() string

func (*ExecuteKeyRangesResponse) XXX_DiscardUnknown Uses

func (m *ExecuteKeyRangesResponse) XXX_DiscardUnknown()

func (*ExecuteKeyRangesResponse) XXX_Marshal Uses

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

func (*ExecuteKeyRangesResponse) XXX_Merge Uses

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

func (*ExecuteKeyRangesResponse) XXX_Size Uses

func (m *ExecuteKeyRangesResponse) XXX_Size() int

func (*ExecuteKeyRangesResponse) XXX_Unmarshal Uses

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

type ExecuteKeyspaceIdsRequest Uses

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 Uses

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

func (*ExecuteKeyspaceIdsRequest) GetCallerId Uses

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

func (*ExecuteKeyspaceIdsRequest) GetKeyspace Uses

func (m *ExecuteKeyspaceIdsRequest) GetKeyspace() string

func (*ExecuteKeyspaceIdsRequest) GetKeyspaceIds Uses

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

func (*ExecuteKeyspaceIdsRequest) GetNotInTransaction Uses

func (m *ExecuteKeyspaceIdsRequest) GetNotInTransaction() bool

func (*ExecuteKeyspaceIdsRequest) GetOptions Uses

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

func (*ExecuteKeyspaceIdsRequest) GetQuery Uses

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

func (*ExecuteKeyspaceIdsRequest) GetSession Uses

func (m *ExecuteKeyspaceIdsRequest) GetSession() *Session

func (*ExecuteKeyspaceIdsRequest) GetTabletType Uses

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

func (*ExecuteKeyspaceIdsRequest) ProtoMessage Uses

func (*ExecuteKeyspaceIdsRequest) ProtoMessage()

func (*ExecuteKeyspaceIdsRequest) Reset Uses

func (m *ExecuteKeyspaceIdsRequest) Reset()

func (*ExecuteKeyspaceIdsRequest) String Uses

func (m *ExecuteKeyspaceIdsRequest) String() string

func (*ExecuteKeyspaceIdsRequest) XXX_DiscardUnknown Uses

func (m *ExecuteKeyspaceIdsRequest) XXX_DiscardUnknown()

func (*ExecuteKeyspaceIdsRequest) XXX_Marshal Uses

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

func (*ExecuteKeyspaceIdsRequest) XXX_Merge Uses

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

func (*ExecuteKeyspaceIdsRequest) XXX_Size Uses

func (m *ExecuteKeyspaceIdsRequest) XXX_Size() int

func (*ExecuteKeyspaceIdsRequest) XXX_Unmarshal Uses

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

type ExecuteKeyspaceIdsResponse Uses

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 Uses

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

func (*ExecuteKeyspaceIdsResponse) GetError Uses

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

func (*ExecuteKeyspaceIdsResponse) GetResult Uses

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

func (*ExecuteKeyspaceIdsResponse) GetSession Uses

func (m *ExecuteKeyspaceIdsResponse) GetSession() *Session

func (*ExecuteKeyspaceIdsResponse) ProtoMessage Uses

func (*ExecuteKeyspaceIdsResponse) ProtoMessage()

func (*ExecuteKeyspaceIdsResponse) Reset Uses

func (m *ExecuteKeyspaceIdsResponse) Reset()

func (*ExecuteKeyspaceIdsResponse) String Uses

func (m *ExecuteKeyspaceIdsResponse) String() string

func (*ExecuteKeyspaceIdsResponse) XXX_DiscardUnknown Uses

func (m *ExecuteKeyspaceIdsResponse) XXX_DiscardUnknown()

func (*ExecuteKeyspaceIdsResponse) XXX_Marshal Uses

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

func (*ExecuteKeyspaceIdsResponse) XXX_Merge Uses

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

func (*ExecuteKeyspaceIdsResponse) XXX_Size Uses

func (m *ExecuteKeyspaceIdsResponse) XXX_Size() int

func (*ExecuteKeyspaceIdsResponse) XXX_Unmarshal Uses

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

type ExecuteRequest Uses

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 Uses

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

func (*ExecuteRequest) GetCallerId Uses

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

func (*ExecuteRequest) GetKeyspaceShard Uses

func (m *ExecuteRequest) GetKeyspaceShard() string

func (*ExecuteRequest) GetNotInTransaction Uses

func (m *ExecuteRequest) GetNotInTransaction() bool

func (*ExecuteRequest) GetOptions Uses

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

func (*ExecuteRequest) GetQuery Uses

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

func (*ExecuteRequest) GetSession Uses

func (m *ExecuteRequest) GetSession() *Session

func (*ExecuteRequest) GetTabletType Uses

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

func (*ExecuteRequest) ProtoMessage Uses

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) Reset Uses

func (m *ExecuteRequest) Reset()

func (*ExecuteRequest) String Uses

func (m *ExecuteRequest) String() string

func (*ExecuteRequest) XXX_DiscardUnknown Uses

func (m *ExecuteRequest) XXX_DiscardUnknown()

func (*ExecuteRequest) XXX_Marshal Uses

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

func (*ExecuteRequest) XXX_Merge Uses

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

func (*ExecuteRequest) XXX_Size Uses

func (m *ExecuteRequest) XXX_Size() int

func (*ExecuteRequest) XXX_Unmarshal Uses

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

type ExecuteResponse Uses

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 Uses

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

func (*ExecuteResponse) GetError Uses

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

func (*ExecuteResponse) GetResult Uses

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

func (*ExecuteResponse) GetSession Uses

func (m *ExecuteResponse) GetSession() *Session

func (*ExecuteResponse) ProtoMessage Uses

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) Reset Uses

func (m *ExecuteResponse) Reset()

func (*ExecuteResponse) String Uses

func (m *ExecuteResponse) String() string

func (*ExecuteResponse) XXX_DiscardUnknown Uses

func (m *ExecuteResponse) XXX_DiscardUnknown()

func (*ExecuteResponse) XXX_Marshal Uses

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

func (*ExecuteResponse) XXX_Merge Uses

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

func (*ExecuteResponse) XXX_Size Uses

func (m *ExecuteResponse) XXX_Size() int

func (*ExecuteResponse) XXX_Unmarshal Uses

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

type ExecuteShardsRequest Uses

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 Uses

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

func (*ExecuteShardsRequest) GetCallerId Uses

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

func (*ExecuteShardsRequest) GetKeyspace Uses

func (m *ExecuteShardsRequest) GetKeyspace() string

func (*ExecuteShardsRequest) GetNotInTransaction Uses

func (m *ExecuteShardsRequest) GetNotInTransaction() bool

func (*ExecuteShardsRequest) GetOptions Uses

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

func (*ExecuteShardsRequest) GetQuery Uses

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

func (*ExecuteShardsRequest) GetSession Uses

func (m *ExecuteShardsRequest) GetSession() *Session

func (*ExecuteShardsRequest) GetShards Uses

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

func (*ExecuteShardsRequest) GetTabletType Uses

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

func (*ExecuteShardsRequest) ProtoMessage Uses

func (*ExecuteShardsRequest) ProtoMessage()

func (*ExecuteShardsRequest) Reset Uses

func (m *ExecuteShardsRequest) Reset()

func (*ExecuteShardsRequest) String Uses

func (m *ExecuteShardsRequest) String() string

func (*ExecuteShardsRequest) XXX_DiscardUnknown Uses

func (m *ExecuteShardsRequest) XXX_DiscardUnknown()

func (*ExecuteShardsRequest) XXX_Marshal Uses

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

func (*ExecuteShardsRequest) XXX_Merge Uses

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

func (*ExecuteShardsRequest) XXX_Size Uses

func (m *ExecuteShardsRequest) XXX_Size() int

func (*ExecuteShardsRequest) XXX_Unmarshal Uses

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

type ExecuteShardsResponse Uses

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 Uses

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

func (*ExecuteShardsResponse) GetError Uses

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

func (*ExecuteShardsResponse) GetResult Uses

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

func (*ExecuteShardsResponse) GetSession Uses

func (m *ExecuteShardsResponse) GetSession() *Session

func (*ExecuteShardsResponse) ProtoMessage Uses

func (*ExecuteShardsResponse) ProtoMessage()

func (*ExecuteShardsResponse) Reset Uses

func (m *ExecuteShardsResponse) Reset()

func (*ExecuteShardsResponse) String Uses

func (m *ExecuteShardsResponse) String() string

func (*ExecuteShardsResponse) XXX_DiscardUnknown Uses

func (m *ExecuteShardsResponse) XXX_DiscardUnknown()

func (*ExecuteShardsResponse) XXX_Marshal Uses

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

func (*ExecuteShardsResponse) XXX_Merge Uses

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

func (*ExecuteShardsResponse) XXX_Size Uses

func (m *ExecuteShardsResponse) XXX_Size() int

func (*ExecuteShardsResponse) XXX_Unmarshal Uses

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

type GetSrvKeyspaceRequest Uses

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 Uses

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

func (*GetSrvKeyspaceRequest) GetKeyspace Uses

func (m *GetSrvKeyspaceRequest) GetKeyspace() string

func (*GetSrvKeyspaceRequest) ProtoMessage Uses

func (*GetSrvKeyspaceRequest) ProtoMessage()

func (*GetSrvKeyspaceRequest) Reset Uses

func (m *GetSrvKeyspaceRequest) Reset()

func (*GetSrvKeyspaceRequest) String Uses

func (m *GetSrvKeyspaceRequest) String() string

func (*GetSrvKeyspaceRequest) XXX_DiscardUnknown Uses

func (m *GetSrvKeyspaceRequest) XXX_DiscardUnknown()

func (*GetSrvKeyspaceRequest) XXX_Marshal Uses

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

func (*GetSrvKeyspaceRequest) XXX_Merge Uses

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

func (*GetSrvKeyspaceRequest) XXX_Size Uses

func (m *GetSrvKeyspaceRequest) XXX_Size() int

func (*GetSrvKeyspaceRequest) XXX_Unmarshal Uses

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

type GetSrvKeyspaceResponse Uses

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 Uses

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

func (*GetSrvKeyspaceResponse) GetSrvKeyspace Uses

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

func (*GetSrvKeyspaceResponse) ProtoMessage Uses

func (*GetSrvKeyspaceResponse) ProtoMessage()

func (*GetSrvKeyspaceResponse) Reset Uses

func (m *GetSrvKeyspaceResponse) Reset()

func (*GetSrvKeyspaceResponse) String Uses

func (m *GetSrvKeyspaceResponse) String() string

func (*GetSrvKeyspaceResponse) XXX_DiscardUnknown Uses

func (m *GetSrvKeyspaceResponse) XXX_DiscardUnknown()

func (*GetSrvKeyspaceResponse) XXX_Marshal Uses

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

func (*GetSrvKeyspaceResponse) XXX_Merge Uses

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

func (*GetSrvKeyspaceResponse) XXX_Size Uses

func (m *GetSrvKeyspaceResponse) XXX_Size() int

func (*GetSrvKeyspaceResponse) XXX_Unmarshal Uses

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

type IdKeyspaceId Uses

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 Uses

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

func (*IdKeyspaceId) GetId Uses

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

func (*IdKeyspaceId) GetKeyspaceId Uses

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

func (*IdKeyspaceId) ProtoMessage Uses

func (*IdKeyspaceId) ProtoMessage()

func (*IdKeyspaceId) Reset Uses

func (m *IdKeyspaceId) Reset()

func (*IdKeyspaceId) String Uses

func (m *IdKeyspaceId) String() string

func (*IdKeyspaceId) XXX_DiscardUnknown Uses

func (m *IdKeyspaceId) XXX_DiscardUnknown()

func (*IdKeyspaceId) XXX_Marshal Uses

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

func (*IdKeyspaceId) XXX_Merge Uses

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

func (*IdKeyspaceId) XXX_Size Uses

func (m *IdKeyspaceId) XXX_Size() int

func (*IdKeyspaceId) XXX_Unmarshal Uses

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

type MessageAckKeyspaceIdsRequest Uses

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 Uses

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

func (*MessageAckKeyspaceIdsRequest) GetCallerId Uses

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

func (*MessageAckKeyspaceIdsRequest) GetIdKeyspaceIds Uses

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

func (*MessageAckKeyspaceIdsRequest) GetKeyspace Uses

func (m *MessageAckKeyspaceIdsRequest) GetKeyspace() string

func (*MessageAckKeyspaceIdsRequest) GetName Uses

func (m *MessageAckKeyspaceIdsRequest) GetName() string

func (*MessageAckKeyspaceIdsRequest) ProtoMessage Uses

func (*MessageAckKeyspaceIdsRequest) ProtoMessage()

func (*MessageAckKeyspaceIdsRequest) Reset Uses

func (m *MessageAckKeyspaceIdsRequest) Reset()

func (*MessageAckKeyspaceIdsRequest) String Uses

func (m *MessageAckKeyspaceIdsRequest) String() string

func (*MessageAckKeyspaceIdsRequest) XXX_DiscardUnknown Uses

func (m *MessageAckKeyspaceIdsRequest) XXX_DiscardUnknown()

func (*MessageAckKeyspaceIdsRequest) XXX_Marshal Uses

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

func (*MessageAckKeyspaceIdsRequest) XXX_Merge Uses

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

func (*MessageAckKeyspaceIdsRequest) XXX_Size Uses

func (m *MessageAckKeyspaceIdsRequest) XXX_Size() int

func (*MessageAckKeyspaceIdsRequest) XXX_Unmarshal Uses

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

type MessageAckRequest Uses

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 Uses

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

func (*MessageAckRequest) GetCallerId Uses

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

func (*MessageAckRequest) GetIds Uses

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

func (*MessageAckRequest) GetKeyspace Uses

func (m *MessageAckRequest) GetKeyspace() string

func (*MessageAckRequest) GetName Uses

func (m *MessageAckRequest) GetName() string

func (*MessageAckRequest) ProtoMessage Uses

func (*MessageAckRequest) ProtoMessage()

func (*MessageAckRequest) Reset Uses

func (m *MessageAckRequest) Reset()

func (*MessageAckRequest) String Uses

func (m *MessageAckRequest) String() string

func (*MessageAckRequest) XXX_DiscardUnknown Uses

func (m *MessageAckRequest) XXX_DiscardUnknown()

func (*MessageAckRequest) XXX_Marshal Uses

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

func (*MessageAckRequest) XXX_Merge Uses

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

func (*MessageAckRequest) XXX_Size Uses

func (m *MessageAckRequest) XXX_Size() int

func (*MessageAckRequest) XXX_Unmarshal Uses

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

type MessageStreamRequest Uses

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 Uses

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

func (*MessageStreamRequest) GetCallerId Uses

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

func (*MessageStreamRequest) GetKeyRange Uses

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

func (*MessageStreamRequest) GetKeyspace Uses

func (m *MessageStreamRequest) GetKeyspace() string

func (*MessageStreamRequest) GetName Uses

func (m *MessageStreamRequest) GetName() string

func (*MessageStreamRequest) GetShard Uses

func (m *MessageStreamRequest) GetShard() string

func (*MessageStreamRequest) ProtoMessage Uses

func (*MessageStreamRequest) ProtoMessage()

func (*MessageStreamRequest) Reset Uses

func (m *MessageStreamRequest) Reset()

func (*MessageStreamRequest) String Uses

func (m *MessageStreamRequest) String() string

func (*MessageStreamRequest) XXX_DiscardUnknown Uses

func (m *MessageStreamRequest) XXX_DiscardUnknown()

func (*MessageStreamRequest) XXX_Marshal Uses

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

func (*MessageStreamRequest) XXX_Merge Uses

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

func (*MessageStreamRequest) XXX_Size Uses

func (m *MessageStreamRequest) XXX_Size() int

func (*MessageStreamRequest) XXX_Unmarshal Uses

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

type ResolveTransactionRequest Uses

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 Uses

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

func (*ResolveTransactionRequest) GetCallerId Uses

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

func (*ResolveTransactionRequest) GetDtid Uses

func (m *ResolveTransactionRequest) GetDtid() string

func (*ResolveTransactionRequest) ProtoMessage Uses

func (*ResolveTransactionRequest) ProtoMessage()

func (*ResolveTransactionRequest) Reset Uses

func (m *ResolveTransactionRequest) Reset()

func (*ResolveTransactionRequest) String Uses

func (m *ResolveTransactionRequest) String() string

func (*ResolveTransactionRequest) XXX_DiscardUnknown Uses

func (m *ResolveTransactionRequest) XXX_DiscardUnknown()

func (*ResolveTransactionRequest) XXX_Marshal Uses

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

func (*ResolveTransactionRequest) XXX_Merge Uses

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

func (*ResolveTransactionRequest) XXX_Size Uses

func (m *ResolveTransactionRequest) XXX_Size() int

func (*ResolveTransactionRequest) XXX_Unmarshal Uses

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

type ResolveTransactionResponse Uses

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 Uses

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

func (*ResolveTransactionResponse) ProtoMessage Uses

func (*ResolveTransactionResponse) ProtoMessage()

func (*ResolveTransactionResponse) Reset Uses

func (m *ResolveTransactionResponse) Reset()

func (*ResolveTransactionResponse) String Uses

func (m *ResolveTransactionResponse) String() string

func (*ResolveTransactionResponse) XXX_DiscardUnknown Uses

func (m *ResolveTransactionResponse) XXX_DiscardUnknown()

func (*ResolveTransactionResponse) XXX_Marshal Uses

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

func (*ResolveTransactionResponse) XXX_Merge Uses

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

func (*ResolveTransactionResponse) XXX_Size Uses

func (m *ResolveTransactionResponse) XXX_Size() int

func (*ResolveTransactionResponse) XXX_Unmarshal Uses

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

type RollbackRequest Uses

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 Uses

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

func (*RollbackRequest) GetCallerId Uses

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

func (*RollbackRequest) GetSession Uses

func (m *RollbackRequest) GetSession() *Session

func (*RollbackRequest) ProtoMessage Uses

func (*RollbackRequest) ProtoMessage()

func (*RollbackRequest) Reset Uses

func (m *RollbackRequest) Reset()

func (*RollbackRequest) String Uses

func (m *RollbackRequest) String() string

func (*RollbackRequest) XXX_DiscardUnknown Uses

func (m *RollbackRequest) XXX_DiscardUnknown()

func (*RollbackRequest) XXX_Marshal Uses

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

func (*RollbackRequest) XXX_Merge Uses

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

func (*RollbackRequest) XXX_Size Uses

func (m *RollbackRequest) XXX_Size() int

func (*RollbackRequest) XXX_Unmarshal Uses

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

type RollbackResponse Uses

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 Uses

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

func (*RollbackResponse) ProtoMessage Uses

func (*RollbackResponse) ProtoMessage()

func (*RollbackResponse) Reset Uses

func (m *RollbackResponse) Reset()

func (*RollbackResponse) String Uses

func (m *RollbackResponse) String() string

func (*RollbackResponse) XXX_DiscardUnknown Uses

func (m *RollbackResponse) XXX_DiscardUnknown()

func (*RollbackResponse) XXX_Marshal Uses

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

func (*RollbackResponse) XXX_Merge Uses

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

func (*RollbackResponse) XXX_Size Uses

func (m *RollbackResponse) XXX_Size() int

func (*RollbackResponse) XXX_Unmarshal Uses

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

type Session Uses

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 `protobuf:"varint,7,opt,name=transaction_mode,json=transactionMode,proto3,enum=vtgate.TransactionMode" json:"transaction_mode,omitempty"`
    // 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"`
    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 Uses

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

func (*Session) GetAutocommit Uses

func (m *Session) GetAutocommit() bool

func (*Session) GetInTransaction Uses

func (m *Session) GetInTransaction() bool

func (*Session) GetOptions Uses

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

func (*Session) GetPostSessions Uses

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

func (*Session) GetPreSessions Uses

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

func (*Session) GetShardSessions Uses

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

func (*Session) GetSingleDb Uses

func (m *Session) GetSingleDb() bool

func (*Session) GetTargetString Uses

func (m *Session) GetTargetString() string

func (*Session) GetTransactionMode Uses

func (m *Session) GetTransactionMode() TransactionMode

func (*Session) GetWarnings Uses

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

func (*Session) ProtoMessage Uses

func (*Session) ProtoMessage()

func (*Session) Reset Uses

func (m *Session) Reset()

func (*Session) String Uses

func (m *Session) String() string

func (*Session) XXX_DiscardUnknown Uses

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal Uses

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

func (*Session) XXX_Merge Uses

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

func (*Session) XXX_Size Uses

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal Uses

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

type Session_ShardSession Uses

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 Uses

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

func (*Session_ShardSession) GetTarget Uses

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

func (*Session_ShardSession) GetTransactionId Uses

func (m *Session_ShardSession) GetTransactionId() int64

func (*Session_ShardSession) ProtoMessage Uses

func (*Session_ShardSession) ProtoMessage()

func (*Session_ShardSession) Reset Uses

func (m *Session_ShardSession) Reset()

func (*Session_ShardSession) String Uses

func (m *Session_ShardSession) String() string

func (*Session_ShardSession) XXX_DiscardUnknown Uses

func (m *Session_ShardSession) XXX_DiscardUnknown()

func (*Session_ShardSession) XXX_Marshal Uses

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

func (*Session_ShardSession) XXX_Merge Uses

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

func (*Session_ShardSession) XXX_Size Uses

func (m *Session_ShardSession) XXX_Size() int

func (*Session_ShardSession) XXX_Unmarshal Uses

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

type SplitQueryRequest Uses

type SplitQueryRequest 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"`
    // The query and bind variables to produce splits for.
    // The given query must be a simple query of the form
    // SELECT <cols> FROM <table> WHERE <filter>.
    // It must not contain subqueries nor any of the keywords
    // JOIN, GROUP BY, ORDER BY, LIMIT, DISTINCT.
    // Furthermore, <table> must be a single “concrete” table.
    // It cannot be a view.
    Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
    // Each generated query-part will be restricted to rows whose values
    // in the columns listed in this field are in a particular range.
    // The list of columns named here must be a prefix of the list of
    // columns defining some index or primary key of the table
    // referenced in 'query'. For many tables using the primary key columns
    // (in order) is sufficient and this is the default if this field is omitted.
    // See the comment on the 'algorithm' field for more restrictions and
    // information.
    SplitColumn []string `protobuf:"bytes,4,rep,name=split_column,json=splitColumn,proto3" json:"split_column,omitempty"`
    // You can specify either an estimate of the number of query-parts to
    // generate or an estimate of the number of rows each query-part should
    // return.
    // Thus, exactly one of split_count or num_rows_per_query_part
    // should be nonzero.
    // The non-given parameter is calculated from the given parameter
    // using the formula: split_count * num_rows_per_query_pary = table_size,
    // where table_size is an approximation of the number of rows in the
    // table.
    // Note that if "split_count" is given it is regarded as an estimate.
    // The number of query-parts returned may differ slightly (in particular,
    // if it's not a whole multiple of the number of vitess shards).
    SplitCount          int64 `protobuf:"varint,5,opt,name=split_count,json=splitCount,proto3" json:"split_count,omitempty"`
    NumRowsPerQueryPart int64 `protobuf:"varint,6,opt,name=num_rows_per_query_part,json=numRowsPerQueryPart,proto3" json:"num_rows_per_query_part,omitempty"`
    // The algorithm to use to split the query. The split algorithm is performed
    // on each database shard in parallel. The lists of query-parts generated
    // by the shards are merged and returned to the caller.
    // Two algorithms are supported:
    //  EQUAL_SPLITS
    //    If this algorithm is selected then only the first 'split_column' given
    //    is used (or the first primary key column if the 'split_column' field is
    //    empty). In the rest of this algorithm's description, we refer to
    //    this column as "the split column".
    //    The split column must have numeric type (integral or floating point).
    //    The algorithm works by taking the interval [min, max], where min and
    //    max are the minimum and maximum values of the split column in
    //    the table-shard, respectively, and partitioning it into 'split_count'
    //    sub-intervals of equal size. The added WHERE clause of each query-part
    //    restricts that part to rows whose value in the split column belongs to
    //    a particular sub-interval. This is fast, but requires that the
    //    distribution of values of the split column be uniform in [min, max]
    //    for the number of rows returned by each query part to be roughly the
    //    same.
    //  FULL_SCAN
    //    If this algorithm is used then the split_column must be the primary key
    //    columns (in order).
    //    This algorithm performs a full-scan of the table-shard referenced
    //    in 'query' to get "boundary" rows that are num_rows_per_query_part
    //    apart when the table is ordered by the columns listed in
    //    'split_column'. It then restricts each query-part to the rows
    //    located between two successive boundary rows.
    //    This algorithm supports multiple split_column's of any type,
    //    but is slower than EQUAL_SPLITS.
    Algorithm query.SplitQueryRequest_Algorithm `protobuf:"varint,7,opt,name=algorithm,proto3,enum=query.SplitQueryRequest_Algorithm" json:"algorithm,omitempty"`
    // TODO(erez): This field is no longer used by the server code.
    // Remove this field after this new server code is released to prod.
    // We must keep it for now, so that clients can still send it to the old
    // server code currently in production.
    UseSplitQueryV2      bool     `protobuf:"varint,8,opt,name=use_split_query_v2,json=useSplitQueryV2,proto3" json:"use_split_query_v2,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

SplitQueryRequest is the payload to SplitQuery.

SplitQuery takes a "SELECT" query and generates a list of queries called "query-parts". Each query-part consists of the original query with an added WHERE clause that restricts the query-part to operate only on rows whose values in the columns listed in the "split_column" field of the request (see below) are in a particular range.

It is guaranteed that the set of rows obtained from executing each query-part on a database snapshot and merging (without deduping) the results is equal to the set of rows obtained from executing the original query on the same snapshot with the rows containing NULL values in any of the split_column's excluded.

This is typically called by the MapReduce master when reading from Vitess. There it's desirable that the sets of rows returned by the query-parts have roughly the same size.

func (*SplitQueryRequest) Descriptor Uses

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

func (*SplitQueryRequest) GetAlgorithm Uses

func (m *SplitQueryRequest) GetAlgorithm() query.SplitQueryRequest_Algorithm

func (*SplitQueryRequest) GetCallerId Uses

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

func (*SplitQueryRequest) GetKeyspace Uses

func (m *SplitQueryRequest) GetKeyspace() string

func (*SplitQueryRequest) GetNumRowsPerQueryPart Uses

func (m *SplitQueryRequest) GetNumRowsPerQueryPart() int64

func (*SplitQueryRequest) GetQuery Uses

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

func (*SplitQueryRequest) GetSplitColumn Uses

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

func (*SplitQueryRequest) GetSplitCount Uses

func (m *SplitQueryRequest) GetSplitCount() int64

func (*SplitQueryRequest) GetUseSplitQueryV2 Uses

func (m *SplitQueryRequest) GetUseSplitQueryV2() bool

func (*SplitQueryRequest) ProtoMessage Uses

func (*SplitQueryRequest) ProtoMessage()

func (*SplitQueryRequest) Reset Uses

func (m *SplitQueryRequest) Reset()

func (*SplitQueryRequest) String Uses

func (m *SplitQueryRequest) String() string

func (*SplitQueryRequest) XXX_DiscardUnknown Uses

func (m *SplitQueryRequest) XXX_DiscardUnknown()

func (*SplitQueryRequest) XXX_Marshal Uses

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

func (*SplitQueryRequest) XXX_Merge Uses

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

func (*SplitQueryRequest) XXX_Size Uses

func (m *SplitQueryRequest) XXX_Size() int

func (*SplitQueryRequest) XXX_Unmarshal Uses

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

type SplitQueryResponse Uses

type SplitQueryResponse struct {
    // splits contains the queries to run to fetch the entire data set.
    Splits               []*SplitQueryResponse_Part `protobuf:"bytes,1,rep,name=splits,proto3" json:"splits,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
    XXX_unrecognized     []byte                     `json:"-"`
    XXX_sizecache        int32                      `json:"-"`
}

SplitQueryResponse is the returned value from SplitQuery.

func (*SplitQueryResponse) Descriptor Uses

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

func (*SplitQueryResponse) GetSplits Uses

func (m *SplitQueryResponse) GetSplits() []*SplitQueryResponse_Part

func (*SplitQueryResponse) ProtoMessage Uses

func (*SplitQueryResponse) ProtoMessage()

func (*SplitQueryResponse) Reset Uses

func (m *SplitQueryResponse) Reset()

func (*SplitQueryResponse) String Uses

func (m *SplitQueryResponse) String() string

func (*SplitQueryResponse) XXX_DiscardUnknown Uses

func (m *SplitQueryResponse) XXX_DiscardUnknown()

func (*SplitQueryResponse) XXX_Marshal Uses

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

func (*SplitQueryResponse) XXX_Merge Uses

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

func (*SplitQueryResponse) XXX_Size Uses

func (m *SplitQueryResponse) XXX_Size() int

func (*SplitQueryResponse) XXX_Unmarshal Uses

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

type SplitQueryResponse_KeyRangePart Uses

type SplitQueryResponse_KeyRangePart struct {
    // keyspace to target the query to.
    Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
    // key ranges to target the query to.
    KeyRanges            []*topodata.KeyRange `protobuf:"bytes,2,rep,name=key_ranges,json=keyRanges,proto3" json:"key_ranges,omitempty"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

func (*SplitQueryResponse_KeyRangePart) Descriptor Uses

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

func (*SplitQueryResponse_KeyRangePart) GetKeyRanges Uses

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

func (*SplitQueryResponse_KeyRangePart) GetKeyspace Uses

func (m *SplitQueryResponse_KeyRangePart) GetKeyspace() string

func (*SplitQueryResponse_KeyRangePart) ProtoMessage Uses

func (*SplitQueryResponse_KeyRangePart) ProtoMessage()

func (*SplitQueryResponse_KeyRangePart) Reset Uses

func (m *SplitQueryResponse_KeyRangePart) Reset()

func (*SplitQueryResponse_KeyRangePart) String Uses

func (m *SplitQueryResponse_KeyRangePart) String() string

func (*SplitQueryResponse_KeyRangePart) XXX_DiscardUnknown Uses

func (m *SplitQueryResponse_KeyRangePart) XXX_DiscardUnknown()

func (*SplitQueryResponse_KeyRangePart) XXX_Marshal Uses

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

func (*SplitQueryResponse_KeyRangePart) XXX_Merge Uses

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

func (*SplitQueryResponse_KeyRangePart) XXX_Size Uses

func (m *SplitQueryResponse_KeyRangePart) XXX_Size() int

func (*SplitQueryResponse_KeyRangePart) XXX_Unmarshal Uses

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

type SplitQueryResponse_Part Uses

type SplitQueryResponse_Part struct {
    // query is the query and bind variables to execute.
    Query *query.BoundQuery `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
    // key_range_part is set if the query should be executed by
    // ExecuteKeyRanges.
    KeyRangePart *SplitQueryResponse_KeyRangePart `protobuf:"bytes,2,opt,name=key_range_part,json=keyRangePart,proto3" json:"key_range_part,omitempty"`
    // shard_part is set if the query should be executed by ExecuteShards.
    ShardPart *SplitQueryResponse_ShardPart `protobuf:"bytes,3,opt,name=shard_part,json=shardPart,proto3" json:"shard_part,omitempty"`
    // size is the approximate number of rows this query will return.
    Size                 int64    `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*SplitQueryResponse_Part) Descriptor Uses

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

func (*SplitQueryResponse_Part) GetKeyRangePart Uses

func (m *SplitQueryResponse_Part) GetKeyRangePart() *SplitQueryResponse_KeyRangePart

func (*SplitQueryResponse_Part) GetQuery Uses

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

func (*SplitQueryResponse_Part) GetShardPart Uses

func (m *SplitQueryResponse_Part) GetShardPart() *SplitQueryResponse_ShardPart

func (*SplitQueryResponse_Part) GetSize Uses

func (m *SplitQueryResponse_Part) GetSize() int64

func (*SplitQueryResponse_Part) ProtoMessage Uses

func (*SplitQueryResponse_Part) ProtoMessage()

func (*SplitQueryResponse_Part) Reset Uses

func (m *SplitQueryResponse_Part) Reset()

func (*SplitQueryResponse_Part) String Uses

func (m *SplitQueryResponse_Part) String() string

func (*SplitQueryResponse_Part) XXX_DiscardUnknown Uses

func (m *SplitQueryResponse_Part) XXX_DiscardUnknown()

func (*SplitQueryResponse_Part) XXX_Marshal Uses

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

func (*SplitQueryResponse_Part) XXX_Merge Uses

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

func (*SplitQueryResponse_Part) XXX_Size Uses

func (m *SplitQueryResponse_Part) XXX_Size() int

func (*SplitQueryResponse_Part) XXX_Unmarshal Uses

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

type SplitQueryResponse_ShardPart Uses

type SplitQueryResponse_ShardPart struct {
    // keyspace to target the query to.
    Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
    // shards to target the query to.
    Shards               []string `protobuf:"bytes,2,rep,name=shards,proto3" json:"shards,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*SplitQueryResponse_ShardPart) Descriptor Uses

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

func (*SplitQueryResponse_ShardPart) GetKeyspace Uses

func (m *SplitQueryResponse_ShardPart) GetKeyspace() string

func (*SplitQueryResponse_ShardPart) GetShards Uses

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

func (*SplitQueryResponse_ShardPart) ProtoMessage Uses

func (*SplitQueryResponse_ShardPart) ProtoMessage()

func (*SplitQueryResponse_ShardPart) Reset Uses

func (m *SplitQueryResponse_ShardPart) Reset()

func (*SplitQueryResponse_ShardPart) String Uses

func (m *SplitQueryResponse_ShardPart) String() string

func (*SplitQueryResponse_ShardPart) XXX_DiscardUnknown Uses

func (m *SplitQueryResponse_ShardPart) XXX_DiscardUnknown()

func (*SplitQueryResponse_ShardPart) XXX_Marshal Uses

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

func (*SplitQueryResponse_ShardPart) XXX_Merge Uses

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

func (*SplitQueryResponse_ShardPart) XXX_Size Uses

func (m *SplitQueryResponse_ShardPart) XXX_Size() int

func (*SplitQueryResponse_ShardPart) XXX_Unmarshal Uses

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

type StreamExecuteKeyRangesRequest Uses

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 Uses

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

func (*StreamExecuteKeyRangesRequest) GetCallerId Uses

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

func (*StreamExecuteKeyRangesRequest) GetKeyRanges Uses

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

func (*StreamExecuteKeyRangesRequest) GetKeyspace Uses

func (m *StreamExecuteKeyRangesRequest) GetKeyspace() string

func (*StreamExecuteKeyRangesRequest) GetOptions Uses

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

func (*StreamExecuteKeyRangesRequest) GetQuery Uses

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

func (*StreamExecuteKeyRangesRequest) GetTabletType Uses

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

func (*StreamExecuteKeyRangesRequest) ProtoMessage Uses

func (*StreamExecuteKeyRangesRequest) ProtoMessage()

func (*StreamExecuteKeyRangesRequest) Reset Uses

func (m *StreamExecuteKeyRangesRequest) Reset()

func (*StreamExecuteKeyRangesRequest) String Uses

func (m *StreamExecuteKeyRangesRequest) String() string

func (*StreamExecuteKeyRangesRequest) XXX_DiscardUnknown Uses

func (m *StreamExecuteKeyRangesRequest) XXX_DiscardUnknown()

func (*StreamExecuteKeyRangesRequest) XXX_Marshal Uses

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

func (*StreamExecuteKeyRangesRequest) XXX_Merge Uses

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

func (*StreamExecuteKeyRangesRequest) XXX_Size Uses

func (m *StreamExecuteKeyRangesRequest) XXX_Size() int

func (*StreamExecuteKeyRangesRequest) XXX_Unmarshal Uses

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

type StreamExecuteKeyRangesResponse Uses

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 Uses

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

func (*StreamExecuteKeyRangesResponse) GetResult Uses

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

func (*StreamExecuteKeyRangesResponse) ProtoMessage Uses

func (*StreamExecuteKeyRangesResponse) ProtoMessage()

func (*StreamExecuteKeyRangesResponse) Reset Uses

func (m *StreamExecuteKeyRangesResponse) Reset()

func (*StreamExecuteKeyRangesResponse) String Uses

func (m *StreamExecuteKeyRangesResponse) String() string

func (*StreamExecuteKeyRangesResponse) XXX_DiscardUnknown Uses

func (m *StreamExecuteKeyRangesResponse) XXX_DiscardUnknown()

func (*StreamExecuteKeyRangesResponse) XXX_Marshal Uses

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

func (*StreamExecuteKeyRangesResponse) XXX_Merge Uses

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

func (*StreamExecuteKeyRangesResponse) XXX_Size Uses

func (m *StreamExecuteKeyRangesResponse) XXX_Size() int

func (*StreamExecuteKeyRangesResponse) XXX_Unmarshal Uses

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

type StreamExecuteKeyspaceIdsRequest Uses

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 Uses

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

func (*StreamExecuteKeyspaceIdsRequest) GetCallerId Uses

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

func (*StreamExecuteKeyspaceIdsRequest) GetKeyspace Uses

func (m *StreamExecuteKeyspaceIdsRequest) GetKeyspace() string

func (*StreamExecuteKeyspaceIdsRequest) GetKeyspaceIds Uses

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

func (*StreamExecuteKeyspaceIdsRequest) GetOptions Uses

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

func (*StreamExecuteKeyspaceIdsRequest) GetQuery Uses

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

func (*StreamExecuteKeyspaceIdsRequest) GetTabletType Uses

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

func (*StreamExecuteKeyspaceIdsRequest) ProtoMessage Uses

func (*StreamExecuteKeyspaceIdsRequest) ProtoMessage()

func (*StreamExecuteKeyspaceIdsRequest) Reset Uses

func (m *StreamExecuteKeyspaceIdsRequest) Reset()

func (*StreamExecuteKeyspaceIdsRequest) String Uses

func (m *StreamExecuteKeyspaceIdsRequest) String() string

func (*StreamExecuteKeyspaceIdsRequest) XXX_DiscardUnknown Uses

func (m *StreamExecuteKeyspaceIdsRequest) XXX_DiscardUnknown()

func (*StreamExecuteKeyspaceIdsRequest) XXX_Marshal Uses

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

func (*StreamExecuteKeyspaceIdsRequest) XXX_Merge Uses

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

func (*StreamExecuteKeyspaceIdsRequest) XXX_Size Uses

func (m *StreamExecuteKeyspaceIdsRequest) XXX_Size() int

func (*StreamExecuteKeyspaceIdsRequest) XXX_Unmarshal Uses

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

type StreamExecuteKeyspaceIdsResponse Uses

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 Uses

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

func (*StreamExecuteKeyspaceIdsResponse) GetResult Uses

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

func (*StreamExecuteKeyspaceIdsResponse) ProtoMessage Uses

func (*StreamExecuteKeyspaceIdsResponse) ProtoMessage()

func (*StreamExecuteKeyspaceIdsResponse) Reset Uses

func (m *StreamExecuteKeyspaceIdsResponse) Reset()

func (*StreamExecuteKeyspaceIdsResponse) String Uses

func (m *StreamExecuteKeyspaceIdsResponse) String() string

func (*StreamExecuteKeyspaceIdsResponse) XXX_DiscardUnknown Uses

func (m *StreamExecuteKeyspaceIdsResponse) XXX_DiscardUnknown()

func (*StreamExecuteKeyspaceIdsResponse) XXX_Marshal Uses

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

func (*StreamExecuteKeyspaceIdsResponse) XXX_Merge Uses

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

func (*StreamExecuteKeyspaceIdsResponse) XXX_Size Uses

func (m *StreamExecuteKeyspaceIdsResponse) XXX_Size() int

func (*StreamExecuteKeyspaceIdsResponse) XXX_Unmarshal Uses

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

type StreamExecuteRequest Uses

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 Uses

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

func (*StreamExecuteRequest) GetCallerId Uses

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

func (*StreamExecuteRequest) GetKeyspaceShard Uses

func (m *StreamExecuteRequest) GetKeyspaceShard() string

func (*StreamExecuteRequest) GetOptions Uses

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

func (*StreamExecuteRequest) GetQuery Uses

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

func (*StreamExecuteRequest) GetSession Uses

func (m *StreamExecuteRequest) GetSession() *Session

func (*StreamExecuteRequest) GetTabletType Uses

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

func (*StreamExecuteRequest) ProtoMessage Uses

func (*StreamExecuteRequest) ProtoMessage()

func (*StreamExecuteRequest) Reset Uses

func (m *StreamExecuteRequest) Reset()

func (*StreamExecuteRequest) String Uses

func (m *StreamExecuteRequest) String() string

func (*StreamExecuteRequest) XXX_DiscardUnknown Uses

func (m *StreamExecuteRequest) XXX_DiscardUnknown()

func (*StreamExecuteRequest) XXX_Marshal Uses

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

func (*StreamExecuteRequest) XXX_Merge Uses

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

func (*StreamExecuteRequest) XXX_Size Uses

func (m *StreamExecuteRequest) XXX_Size() int

func (*StreamExecuteRequest) XXX_Unmarshal Uses

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

type StreamExecuteResponse Uses

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 Uses

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

func (*StreamExecuteResponse) GetResult Uses

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

func (*StreamExecuteResponse) ProtoMessage Uses

func (*StreamExecuteResponse) ProtoMessage()

func (*StreamExecuteResponse) Reset Uses

func (m *StreamExecuteResponse) Reset()

func (*StreamExecuteResponse) String Uses

func (m *StreamExecuteResponse) String() string

func (*StreamExecuteResponse) XXX_DiscardUnknown Uses

func (m *StreamExecuteResponse) XXX_DiscardUnknown()

func (*StreamExecuteResponse) XXX_Marshal Uses

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

func (*StreamExecuteResponse) XXX_Merge Uses

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

func (*StreamExecuteResponse) XXX_Size Uses

func (m *StreamExecuteResponse) XXX_Size() int

func (*StreamExecuteResponse) XXX_Unmarshal Uses

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

type StreamExecuteShardsRequest Uses

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 Uses

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

func (*StreamExecuteShardsRequest) GetCallerId Uses

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

func (*StreamExecuteShardsRequest) GetKeyspace Uses

func (m *StreamExecuteShardsRequest) GetKeyspace() string

func (*StreamExecuteShardsRequest) GetOptions Uses

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

func (*StreamExecuteShardsRequest) GetQuery Uses

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

func (*StreamExecuteShardsRequest) GetShards Uses

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

func (*StreamExecuteShardsRequest) GetTabletType Uses

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

func (*StreamExecuteShardsRequest) ProtoMessage Uses

func (*StreamExecuteShardsRequest) ProtoMessage()

func (*StreamExecuteShardsRequest) Reset Uses

func (m *StreamExecuteShardsRequest) Reset()

func (*StreamExecuteShardsRequest) String Uses

func (m *StreamExecuteShardsRequest) String() string

func (*StreamExecuteShardsRequest) XXX_DiscardUnknown Uses

func (m *StreamExecuteShardsRequest) XXX_DiscardUnknown()

func (*StreamExecuteShardsRequest) XXX_Marshal Uses

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

func (*StreamExecuteShardsRequest) XXX_Merge Uses

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

func (*StreamExecuteShardsRequest) XXX_Size Uses

func (m *StreamExecuteShardsRequest) XXX_Size() int

func (*StreamExecuteShardsRequest) XXX_Unmarshal Uses

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

type StreamExecuteShardsResponse Uses

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 Uses

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

func (*StreamExecuteShardsResponse) GetResult Uses

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

func (*StreamExecuteShardsResponse) ProtoMessage Uses

func (*StreamExecuteShardsResponse) ProtoMessage()

func (*StreamExecuteShardsResponse) Reset Uses

func (m *StreamExecuteShardsResponse) Reset()

func (*StreamExecuteShardsResponse) String Uses

func (m *StreamExecuteShardsResponse) String() string

func (*StreamExecuteShardsResponse) XXX_DiscardUnknown Uses

func (m *StreamExecuteShardsResponse) XXX_DiscardUnknown()

func (*StreamExecuteShardsResponse) XXX_Marshal Uses

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

func (*StreamExecuteShardsResponse) XXX_Merge Uses

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

func (*StreamExecuteShardsResponse) XXX_Size Uses

func (m *StreamExecuteShardsResponse) XXX_Size() int

func (*StreamExecuteShardsResponse) XXX_Unmarshal Uses

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

type TransactionMode Uses

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 Uses

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

func (TransactionMode) String Uses

func (x TransactionMode) String() string

type UpdateStreamRequest Uses

type UpdateStreamRequest 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"`
    // tablet_type is the type of tablets that this request is targeted to.
    TabletType topodata.TabletType `protobuf:"varint,5,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
    // timestamp is the timestamp to start the stream from.  It is
    // unused is event is set, and we are only streaming from the shard
    // described by event.shard.
    Timestamp int64 `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
    // event is the event to start the stream from.
    // Note it is only used if we are streaming from exactly the same shard
    // as this event was coming from. Otherwise we can't use this event,
    // and will use the timestamp as a starting point.
    Event                *query.EventToken `protobuf:"bytes,7,opt,name=event,proto3" json:"event,omitempty"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

UpdateStreamRequest is the payload to UpdateStream.

func (*UpdateStreamRequest) Descriptor Uses

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

func (*UpdateStreamRequest) GetCallerId Uses

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

func (*UpdateStreamRequest) GetEvent Uses

func (m *UpdateStreamRequest) GetEvent() *query.EventToken

func (*UpdateStreamRequest) GetKeyRange Uses

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

func (*UpdateStreamRequest) GetKeyspace Uses

func (m *UpdateStreamRequest) GetKeyspace() string

func (*UpdateStreamRequest) GetShard Uses

func (m *UpdateStreamRequest) GetShard() string

func (*UpdateStreamRequest) GetTabletType Uses

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

func (*UpdateStreamRequest) GetTimestamp Uses

func (m *UpdateStreamRequest) GetTimestamp() int64

func (*UpdateStreamRequest) ProtoMessage Uses

func (*UpdateStreamRequest) ProtoMessage()

func (*UpdateStreamRequest) Reset Uses

func (m *UpdateStreamRequest) Reset()

func (*UpdateStreamRequest) String Uses

func (m *UpdateStreamRequest) String() string

func (*UpdateStreamRequest) XXX_DiscardUnknown Uses

func (m *UpdateStreamRequest) XXX_DiscardUnknown()

func (*UpdateStreamRequest) XXX_Marshal Uses

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

func (*UpdateStreamRequest) XXX_Merge Uses

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

func (*UpdateStreamRequest) XXX_Size Uses

func (m *UpdateStreamRequest) XXX_Size() int

func (*UpdateStreamRequest) XXX_Unmarshal Uses

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

type UpdateStreamResponse Uses

type UpdateStreamResponse struct {
    // event is one event from the stream.
    Event *query.StreamEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
    // resume_timestamp is the timestamp to resume streaming from if the
    // client is interrupted. If the Update Stream only goes to one
    // shard, this is equal to event.timestamp. If the Update Stream
    // goes to multiple shards and aggregates, this is the minimum value
    // of the current timestamp for all shards.
    ResumeTimestamp      int64    `protobuf:"varint,2,opt,name=resume_timestamp,json=resumeTimestamp,proto3" json:"resume_timestamp,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

UpdateStreamResponse is streamed by UpdateStream.

func (*UpdateStreamResponse) Descriptor Uses

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

func (*UpdateStreamResponse) GetEvent Uses

func (m *UpdateStreamResponse) GetEvent() *query.StreamEvent

func (*UpdateStreamResponse) GetResumeTimestamp Uses

func (m *UpdateStreamResponse) GetResumeTimestamp() int64

func (*UpdateStreamResponse) ProtoMessage Uses

func (*UpdateStreamResponse) ProtoMessage()

func (*UpdateStreamResponse) Reset Uses

func (m *UpdateStreamResponse) Reset()

func (*UpdateStreamResponse) String Uses

func (m *UpdateStreamResponse) String() string

func (*UpdateStreamResponse) XXX_DiscardUnknown Uses

func (m *UpdateStreamResponse) XXX_DiscardUnknown()

func (*UpdateStreamResponse) XXX_Marshal Uses

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

func (*UpdateStreamResponse) XXX_Merge Uses

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

func (*UpdateStreamResponse) XXX_Size Uses

func (m *UpdateStreamResponse) XXX_Size() int

func (*UpdateStreamResponse) XXX_Unmarshal Uses

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

Package vtgate imports 6 packages (graph) and is imported by 26 packages. Updated 2019-06-12. Refresh now. Tools for package owners.