package vtgate

Get desktop application:
View/edit binary Protocol Buffers messages

CloseSessionRequest is the payload to CloseSession.

Used as request type in: vtgateservice.Vitess.CloseSession

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

CloseSessionResponse is the returned value from CloseSession.

Used as response type in: vtgateservice.Vitess.CloseSession

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

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.

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.

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.

PrepareRequest is the payload to Prepare.

Used as request type in: vtgateservice.Vitess.Prepare

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

PrepareResponse is the returned value from Prepare.

Used as response type in: vtgateservice.Vitess.Prepare

• 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.Field fields = 3

  fields contains the fields, only set if error is unset.

ReadAfterWrite contains information regarding gtid set and timeout Also if the gtid information needs to be passed to client.

Used in: Session

• string read_after_write_gtid = 1

• double read_after_write_timeout = 2

• bool session_track_gtids = 3

• ReadAfterWriteConsistency read_after_write_consistency = 4

Used in: ReadAfterWrite

• EVENTUAL = 0

  NONE uses the read after write scope set by the VTGate flag 'read_after_write_consistency'.

• SESSION = 1

  SESSION is used to designate session read after write consistency.

• INSTANCE = 2

  INSTANCE is used to designate instance read after write consistency.

• GLOBAL = 3

  GLOBAL is used to designate global read after write consistency.

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)

Used in: Session

• topodata.TabletType user_hint_tablet_type = 1

• topodata.TabletType keyspace_tablet_type = 2

• topodata.TabletType suggested_tablet_type = 3

• int32 ReadWriteSplittingRatio = 4

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: CloseSessionRequest, ExecuteBatchRequest, ExecuteBatchResponse, ExecuteRequest, ExecuteResponse, PrepareRequest, PrepareResponse, 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.

• int64 last_lock_heartbeat = 19

  last_lock_heartbeat keep tracks of when last lock heartbeat was sent.

• optional ReadAfterWrite read_after_write = 20

  read_after_write tracks the ReadAfterWrite settings for this session.

• string DDLStrategy = 21

  DDL strategy

• string SessionUUID = 22

  Session UUID

• bool enable_system_settings = 23

  enable_system_settings defines if we can use reserved connections.

• map<string, int64> advisory_lock = 24

• int64 query_timeout = 25

  query_timeout is the maximum amount of time a query is permitted to run

• string ReadWriteSplittingPolicy = 26

  ReadWriteSplittingPolicy is the policy used for read write splitting

• int32 ReadWriteSplittingRatio = 27

  ReadWriteSplittingRatio is the ratio that request is sent to replica when read write splitting

• bool RewriteTableNameWithDbNamePrefix = 28

  RewriteTableNameWithDbNamePrefix is the flag to enable add database prefix for tableName

• bool EnableReadWriteSplitForReadOnlyTxn = 29

  read_only_transaction_policy is the policy used for read only transaction, such as enable and disable

• bool ReadWriteSplitForReadOnlyTxnUserInput = 30

  system var to receive input from user and change the EnableReadWriteSplitForReadOnlyTxn value when not in a txn

• TransactionAccessMode transaction_access_mode = 31

  TxAccessMode

• bool EnableInterceptionForDMLWithoutWhere = 32

  when enabled, vtgate will intercpet DELETE and UPDATE SQLs that are without WHERE condition

• bool EnableDisplaySQLExecutionVTTabletType = 33

  when enabled, vtgate will display the type of SQL execution vttablet

• optional ResolverOptions resolver_options = 34

  used to resolve tablet type/types to load balance

• bool EnableDeclarativeDDL = 35

  when enabled, vtgate will support declarative DDL

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

• bool vindex_only = 5

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.

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

Used in: Session

• INVALID = 0

  default value

• WITH_CONSISTENT_SNAPSHOT = 1

• READ_WRITE = 2

• READ_ONLY = 3

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.

Used in: VStreamRequest

• bool minimize_skew = 1

  align streams

• uint32 heartbeat_interval = 2

  how often heartbeats must be sent when idle (seconds)

• bool stop_on_reshard = 3

  stop streams on a reshard (journal event)

• string cells = 4

  if specified, these cells (comma-separated) are used to pick source tablets from. defaults to the cell of the vtgate serving the VStream API.

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

• optional VStreamFlags flags = 5

VStreamResponse is streamed by VStream.

Used as response type in: vtgateservice.Vitess.VStream

• repeated binlogdata.VEvent events = 1