package vtgate

Get desktop application:
View/edit binary Protocol Buffers messages

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

• NORMAL = 0

  NORMAL is the default commit order.

• PRE = 1

  PRE is used to designate pre_sessions.

• POST = 2

  POST is used to designate post_sessions.

• AUTOCOMMIT = 3

  AUTOCOMMIT is used to run the statement as autocommitted transaction.

ExecuteBatchRequest is the payload to ExecuteBatch.

Used as request type in: vtgateservice.Vitess.ExecuteBatch

• optional vtrpc.CallerID caller_id = 1

  caller_id identifies the caller. This is the effective caller ID, set by the application to further identify the caller.

• optional Session session = 2

  session carries the session state.

• repeated query.BoundQuery queries = 3

  queries is a list of query and bind variables to execute.

• topodata.TabletType tablet_type = 4

  These values are deprecated. Use session instead. TODO(sougou): remove in 3.1

• bool as_transaction = 5

• string keyspace_shard = 6

• optional query.ExecuteOptions options = 7

ExecuteBatchResponse is the returned value from ExecuteBatch.

Used as response type in: vtgateservice.Vitess.ExecuteBatch

• optional vtrpc.RPCError error = 1

  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).

• optional Session session = 2

  session is the updated session information.

• repeated query.ResultWithError results = 3

  results contains the query results, only set if application level error is unset.

ExecuteRequest is the payload to Execute.

Used as request type in: vtgateservice.Vitess.Execute

• optional vtrpc.CallerID caller_id = 1

  caller_id identifies the caller. This is the effective caller ID, set by the application to further identify the caller.

• optional Session session = 2

  session carries the session state.

• optional query.BoundQuery query = 3

  query is the query and bind variables to execute.

• topodata.TabletType tablet_type = 4

  These values are deprecated. Use session instead. TODO(sougou): remove in 3.1

• string keyspace_shard = 6

• optional query.ExecuteOptions options = 7

ExecuteResponse is the returned value from Execute.

Used as response type in: vtgateservice.Vitess.Execute

• optional vtrpc.RPCError error = 1

  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).

• optional Session session = 2

  session is the updated session information.

• optional query.QueryResult result = 3

  result contains the query result, only set if error is unset.

ResolveTransactionRequest is the payload to ResolveTransaction.

Used as request type in: vtgateservice.Vitess.ResolveTransaction

• optional vtrpc.CallerID caller_id = 1

  caller_id identifies the caller. This is the effective caller ID, set by the application to further identify the caller.

• string dtid = 2

  dtid is the dtid of the transaction to be resolved.

ResolveTransactionResponse is the returned value from Rollback.

Used as response type in: vtgateservice.Vitess.ResolveTransaction

(message has no fields)

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.

Used in: ExecuteBatchRequest, ExecuteBatchResponse, ExecuteRequest, ExecuteResponse, StreamExecuteRequest

• bool in_transaction = 1

  in_transaction is set to true if the session is in a transaction.

• repeated Session.ShardSession shard_sessions = 2

  shard_sessions keep track of per-shard transaction info.

• bool autocommit = 4

  autocommit specifies if the session is in autocommit mode. This is used only for V3.

• string target_string = 5

  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.

• optional query.ExecuteOptions options = 6

  options is used only for V3.

• TransactionMode transaction_mode = 7

  transaction_mode specifies the current transaction mode.

• repeated query.QueryWarning warnings = 8

  warnings contains non-fatal warnings from the previous query

• repeated Session.ShardSession pre_sessions = 9

  pre_sessions contains sessions that have to be committed first.

• repeated Session.ShardSession post_sessions = 10

  post_sessions contains sessions that have to be committed last.

• uint64 last_insert_id = 11

  last_insert_id keeps track of the last seen insert_id for this session

• uint64 found_rows = 12

  found_rows keeps track of how many rows the last query returned

• map<string, query.BindVariable> user_defined_variables = 13

  user_defined_variables contains all the @variables defined for this session

• map<string, string> system_variables = 14

  system_variables keeps track of all session variables set for this connection TODO: systay should we keep this so we can apply it ordered?

• int64 row_count = 15

  row_count keeps track of the last seen rows affected for this session

• repeated string savepoints = 16

  Stores savepoint and release savepoint calls inside a transaction and is reset once transaction is committed or rolled back.

• bool in_reserved_conn = 17

  in_reserved_conn is set to true if the session should be using reserved connections.

• optional Session.ShardSession lock_session = 18

  lock_session keep tracks of shard on which the lock query is sent.

Used in: Session

• optional query.Target target = 1

• int64 transaction_id = 2

• optional topodata.TabletAlias tablet_alias = 3

• int64 reserved_id = 4

  reserved connection if a dedicated connection is needed

StreamExecuteRequest is the payload to StreamExecute.

Used as request type in: vtgateservice.Vitess.StreamExecute

• optional vtrpc.CallerID caller_id = 1

  caller_id identifies the caller. This is the effective caller ID, set by the application to further identify the caller.

• optional query.BoundQuery query = 2

  query is the query and bind variables to execute.

• topodata.TabletType tablet_type = 3

  These values are deprecated. Use session instead. TODO(sougou): remove in 3.1

• string keyspace_shard = 4

• optional query.ExecuteOptions options = 5

• optional Session session = 6

  session carries the session state.

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

Used as response type in: vtgateservice.Vitess.StreamExecute

• optional query.QueryResult result = 1

  result contains the result data. The first value contains only Fields information. The next values contain the actual rows, a few values per result.

TransactionMode controls the execution of distributed transaction across multiple shards.

Used in: Session

• UNSPECIFIED = 0

  UNSPECIFIED uses the transaction mode set by the VTGate flag 'transaction_mode'.

• SINGLE = 1

  SINGLE disallows distributed transactions.

• MULTI = 2

  MULTI allows distributed transactions with best effort commit.

• TWOPC = 3

  TWOPC is for distributed transactions with atomic commits.

VStreamRequest is the payload for VStream.

Used as request type in: vtgateservice.Vitess.VStream

• optional vtrpc.CallerID caller_id = 1

• topodata.TabletType tablet_type = 2

• optional binlogdata.VGtid vgtid = 3

  position specifies the starting point of the bin log positions as well as the keyspace-shards to pull events from. position is of the form 'ks1:0@MySQL56/<mysql_pos>|ks2:-80@MySQL56/<mysql_pos>'.

• optional binlogdata.Filter filter = 4

VStreamResponse is streamed by VStream.

Used as response type in: vtgateservice.Vitess.VStream

• repeated binlogdata.VEvent events = 1