import { Message, proto3, type BinaryReadOptions, type FieldList, type JsonReadOptions, type JsonValue, type PartialMessage, type PlainMessage } from '@bufbuild/protobuf'; import { TabletAlias, TabletType } from './topodata_pb.js'; import { CallerID, RPCError } from './vtrpc_pb.js'; /** * Flags sent from the MySQL C API * * @generated from enum query.MySqlFlag */ export declare enum MySqlFlag { /** * @generated from enum value: EMPTY = 0; */ EMPTY = 0, /** * @generated from enum value: NOT_NULL_FLAG = 1; */ NOT_NULL_FLAG = 1, /** * @generated from enum value: PRI_KEY_FLAG = 2; */ PRI_KEY_FLAG = 2, /** * @generated from enum value: UNIQUE_KEY_FLAG = 4; */ UNIQUE_KEY_FLAG = 4, /** * @generated from enum value: MULTIPLE_KEY_FLAG = 8; */ MULTIPLE_KEY_FLAG = 8, /** * @generated from enum value: BLOB_FLAG = 16; */ BLOB_FLAG = 16, /** * @generated from enum value: UNSIGNED_FLAG = 32; */ UNSIGNED_FLAG = 32, /** * @generated from enum value: ZEROFILL_FLAG = 64; */ ZEROFILL_FLAG = 64, /** * @generated from enum value: BINARY_FLAG = 128; */ BINARY_FLAG = 128, /** * @generated from enum value: ENUM_FLAG = 256; */ ENUM_FLAG = 256, /** * @generated from enum value: AUTO_INCREMENT_FLAG = 512; */ AUTO_INCREMENT_FLAG = 512, /** * @generated from enum value: TIMESTAMP_FLAG = 1024; */ TIMESTAMP_FLAG = 1024, /** * @generated from enum value: SET_FLAG = 2048; */ SET_FLAG = 2048, /** * @generated from enum value: NO_DEFAULT_VALUE_FLAG = 4096; */ NO_DEFAULT_VALUE_FLAG = 4096, /** * @generated from enum value: ON_UPDATE_NOW_FLAG = 8192; */ ON_UPDATE_NOW_FLAG = 8192, /** * @generated from enum value: NUM_FLAG = 32768; */ NUM_FLAG = 32768, /** * @generated from enum value: PART_KEY_FLAG = 16384; */ PART_KEY_FLAG = 16384, /** * @generated from enum value: GROUP_FLAG = 32768; */ GROUP_FLAG = 32768, /** * @generated from enum value: UNIQUE_FLAG = 65536; */ UNIQUE_FLAG = 65536, /** * @generated from enum value: BINCMP_FLAG = 131072; */ BINCMP_FLAG = 131072 } /** * Flag allows us to qualify types by their common properties. * * @generated from enum query.Flag */ export declare enum Flag { /** * @generated from enum value: NONE = 0; */ NONE = 0, /** * @generated from enum value: ISINTEGRAL = 256; */ ISINTEGRAL = 256, /** * @generated from enum value: ISUNSIGNED = 512; */ ISUNSIGNED = 512, /** * @generated from enum value: ISFLOAT = 1024; */ ISFLOAT = 1024, /** * @generated from enum value: ISQUOTED = 2048; */ ISQUOTED = 2048, /** * @generated from enum value: ISTEXT = 4096; */ ISTEXT = 4096, /** * @generated from enum value: ISBINARY = 8192; */ ISBINARY = 8192 } /** * Type defines the various supported data types in bind vars * and query results. * * @generated from enum query.Type */ export declare enum Type { /** * NULL_TYPE specifies a NULL type. * * @generated from enum value: NULL_TYPE = 0; */ NULL_TYPE = 0, /** * INT8 specifies a TINYINT type. * Properties: 1, IsNumber. * * @generated from enum value: INT8 = 257; */ INT8 = 257, /** * UINT8 specifies a TINYINT UNSIGNED type. * Properties: 2, IsNumber, IsUnsigned. * * @generated from enum value: UINT8 = 770; */ UINT8 = 770, /** * INT16 specifies a SMALLINT type. * Properties: 3, IsNumber. * * @generated from enum value: INT16 = 259; */ INT16 = 259, /** * UINT16 specifies a SMALLINT UNSIGNED type. * Properties: 4, IsNumber, IsUnsigned. * * @generated from enum value: UINT16 = 772; */ UINT16 = 772, /** * INT24 specifies a MEDIUMINT type. * Properties: 5, IsNumber. * * @generated from enum value: INT24 = 261; */ INT24 = 261, /** * UINT24 specifies a MEDIUMINT UNSIGNED type. * Properties: 6, IsNumber, IsUnsigned. * * @generated from enum value: UINT24 = 774; */ UINT24 = 774, /** * INT32 specifies a INTEGER type. * Properties: 7, IsNumber. * * @generated from enum value: INT32 = 263; */ INT32 = 263, /** * UINT32 specifies a INTEGER UNSIGNED type. * Properties: 8, IsNumber, IsUnsigned. * * @generated from enum value: UINT32 = 776; */ UINT32 = 776, /** * INT64 specifies a BIGINT type. * Properties: 9, IsNumber. * * @generated from enum value: INT64 = 265; */ INT64 = 265, /** * UINT64 specifies a BIGINT UNSIGNED type. * Properties: 10, IsNumber, IsUnsigned. * * @generated from enum value: UINT64 = 778; */ UINT64 = 778, /** * FLOAT32 specifies a FLOAT type. * Properties: 11, IsFloat. * * @generated from enum value: FLOAT32 = 1035; */ FLOAT32 = 1035, /** * FLOAT64 specifies a DOUBLE or REAL type. * Properties: 12, IsFloat. * * @generated from enum value: FLOAT64 = 1036; */ FLOAT64 = 1036, /** * TIMESTAMP specifies a TIMESTAMP type. * Properties: 13, IsQuoted. * * @generated from enum value: TIMESTAMP = 2061; */ TIMESTAMP = 2061, /** * DATE specifies a DATE type. * Properties: 14, IsQuoted. * * @generated from enum value: DATE = 2062; */ DATE = 2062, /** * TIME specifies a TIME type. * Properties: 15, IsQuoted. * * @generated from enum value: TIME = 2063; */ TIME = 2063, /** * DATETIME specifies a DATETIME type. * Properties: 16, IsQuoted. * * @generated from enum value: DATETIME = 2064; */ DATETIME = 2064, /** * YEAR specifies a YEAR type. * Properties: 17, IsNumber, IsUnsigned. * * @generated from enum value: YEAR = 785; */ YEAR = 785, /** * DECIMAL specifies a DECIMAL or NUMERIC type. * Properties: 18, None. * * @generated from enum value: DECIMAL = 18; */ DECIMAL = 18, /** * TEXT specifies a TEXT type. * Properties: 19, IsQuoted, IsText. * * @generated from enum value: TEXT = 6163; */ TEXT = 6163, /** * BLOB specifies a BLOB type. * Properties: 20, IsQuoted, IsBinary. * * @generated from enum value: BLOB = 10260; */ BLOB = 10260, /** * VARCHAR specifies a VARCHAR type. * Properties: 21, IsQuoted, IsText. * * @generated from enum value: VARCHAR = 6165; */ VARCHAR = 6165, /** * VARBINARY specifies a VARBINARY type. * Properties: 22, IsQuoted, IsBinary. * * @generated from enum value: VARBINARY = 10262; */ VARBINARY = 10262, /** * CHAR specifies a CHAR type. * Properties: 23, IsQuoted, IsText. * * @generated from enum value: CHAR = 6167; */ CHAR = 6167, /** * BINARY specifies a BINARY type. * Properties: 24, IsQuoted, IsBinary. * * @generated from enum value: BINARY = 10264; */ BINARY = 10264, /** * BIT specifies a BIT type. * Properties: 25, IsQuoted. * * @generated from enum value: BIT = 2073; */ BIT = 2073, /** * ENUM specifies an ENUM type. * Properties: 26, IsQuoted. * * @generated from enum value: ENUM = 2074; */ ENUM = 2074, /** * SET specifies a SET type. * Properties: 27, IsQuoted. * * @generated from enum value: SET = 2075; */ SET = 2075, /** * TUPLE specifies a tuple. This cannot * be returned in a QueryResult, but it can * be sent as a bind var. * Properties: 28, None. * * @generated from enum value: TUPLE = 28; */ TUPLE = 28, /** * GEOMETRY specifies a GEOMETRY type. * Properties: 29, IsQuoted. * * @generated from enum value: GEOMETRY = 2077; */ GEOMETRY = 2077, /** * JSON specifies a JSON type. * Properties: 30, IsQuoted. * * @generated from enum value: JSON = 2078; */ JSON = 2078, /** * EXPRESSION specifies a SQL expression. * This type is for internal use only. * Properties: 31, None. * * @generated from enum value: EXPRESSION = 31; */ EXPRESSION = 31, /** * HEXNUM specifies a HEXNUM type (unquoted varbinary). * Properties: 32, IsText. * * @generated from enum value: HEXNUM = 4128; */ HEXNUM = 4128, /** * HEXVAL specifies a HEXVAL type (unquoted varbinary). * Properties: 33, IsText. * * @generated from enum value: HEXVAL = 4129; */ HEXVAL = 4129, /** * BITNUM specifies a base 2 binary type (unquoted varbinary). * Properties: 34, IsText. * * @generated from enum value: BITNUM = 4130; */ BITNUM = 4130, /** * VECTOR specifies a VECTOR type * Properties: 35, IsQuoted. * * @generated from enum value: VECTOR = 2083; */ VECTOR = 2083, /** * RAW specifies a type which won't be quoted but the value used as-is while encoding. * * @generated from enum value: RAW = 2084; */ RAW = 2084 } /** * TransactionState represents the state of a distributed transaction. * * @generated from enum query.TransactionState */ export declare enum TransactionState { /** * @generated from enum value: UNKNOWN = 0; */ UNKNOWN = 0, /** * @generated from enum value: PREPARE = 1; */ PREPARE = 1, /** * @generated from enum value: ROLLBACK = 2; */ ROLLBACK = 2, /** * @generated from enum value: COMMIT = 3; */ COMMIT = 3 } /** * SchemaTableType represents the type of table requested. * * @generated from enum query.SchemaTableType */ export declare enum SchemaTableType { /** * @generated from enum value: VIEWS = 0; */ VIEWS = 0, /** * @generated from enum value: TABLES = 1; */ TABLES = 1, /** * @generated from enum value: ALL = 2; */ ALL = 2, /** * @generated from enum value: UDFS = 3; */ UDFS = 3 } /** * Target describes what the client expects the tablet is. * If the tablet does not match, an error is returned. * * @generated from message query.Target */ export declare class Target extends Message { /** * @generated from field: string keyspace = 1; */ keyspace: string; /** * @generated from field: string shard = 2; */ shard: string; /** * @generated from field: topodata.TabletType tablet_type = 3; */ tabletType: TabletType; /** * cell is used for routing queries between vtgate and vttablets. It * is not used when Target is part of the Session sent by the client. * * @generated from field: string cell = 4; */ cell: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.Target"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): Target; static fromJson(jsonValue: JsonValue, options?: Partial): Target; static fromJsonString(jsonString: string, options?: Partial): Target; static equals(a: Target | PlainMessage | undefined, b: Target | PlainMessage | undefined): boolean; } /** * VTGateCallerID is sent by VTGate to VTTablet to describe the * caller. If possible, this information is secure. For instance, * if using unique certificates that guarantee that VTGate->VTTablet * traffic cannot be spoofed, then VTTablet can trust this information, * and VTTablet will use it for tablet ACLs, for instance. * Because of this security guarantee, this is different than the CallerID * structure, which is not secure at all, because it is provided * by the Vitess client. * * @generated from message query.VTGateCallerID */ export declare class VTGateCallerID extends Message { /** * @generated from field: string username = 1; */ username: string; /** * @generated from field: repeated string groups = 2; */ groups: string[]; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.VTGateCallerID"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): VTGateCallerID; static fromJson(jsonValue: JsonValue, options?: Partial): VTGateCallerID; static fromJsonString(jsonString: string, options?: Partial): VTGateCallerID; static equals(a: VTGateCallerID | PlainMessage | undefined, b: VTGateCallerID | PlainMessage | undefined): boolean; } /** * EventToken is a structure that describes a point in time in a * replication stream on one shard. The most recent known replication * position can be retrieved from vttablet when executing a query. It * is also sent with the replication streams from the binlog service. * * @generated from message query.EventToken */ export declare class EventToken extends Message { /** * timestamp is the MySQL timestamp of the statements. Seconds since Epoch. * * @generated from field: int64 timestamp = 1; */ timestamp: bigint; /** * The shard name that applied the statements. Note this is not set when * streaming from a vttablet. It is only used on the client -> vtgate link. * * @generated from field: string shard = 2; */ shard: string; /** * The position on the replication stream after this statement was applied. * It is not the transaction ID / GTID, but the position / GTIDSet. * * @generated from field: string position = 3; */ position: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.EventToken"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): EventToken; static fromJson(jsonValue: JsonValue, options?: Partial): EventToken; static fromJsonString(jsonString: string, options?: Partial): EventToken; static equals(a: EventToken | PlainMessage | undefined, b: EventToken | PlainMessage | undefined): boolean; } /** * Value represents a typed value. * * @generated from message query.Value */ export declare class Value extends Message { /** * @generated from field: query.Type type = 1; */ type: Type; /** * @generated from field: bytes value = 2; */ value: Uint8Array; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.Value"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): Value; static fromJson(jsonValue: JsonValue, options?: Partial): Value; static fromJsonString(jsonString: string, options?: Partial): Value; static equals(a: Value | PlainMessage | undefined, b: Value | PlainMessage | undefined): boolean; } /** * BindVariable represents a single bind variable in a Query. * * @generated from message query.BindVariable */ export declare class BindVariable extends Message { /** * @generated from field: query.Type type = 1; */ type: Type; /** * @generated from field: bytes value = 2; */ value: Uint8Array; /** * values are set if type is TUPLE. * * @generated from field: repeated query.Value values = 3; */ values: Value[]; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.BindVariable"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): BindVariable; static fromJson(jsonValue: JsonValue, options?: Partial): BindVariable; static fromJsonString(jsonString: string, options?: Partial): BindVariable; static equals(a: BindVariable | PlainMessage | undefined, b: BindVariable | PlainMessage | undefined): boolean; } /** * BoundQuery is a query with its bind variables * * @generated from message query.BoundQuery */ export declare class BoundQuery extends Message { /** * sql is the SQL query to execute * * @generated from field: string sql = 1; */ sql: string; /** * bind_variables is a map of all bind variables to expand in the query. * nil values are not allowed. Use NULL_TYPE to express a NULL value. * * @generated from field: map bind_variables = 2; */ bindVariables: { [key: string]: BindVariable; }; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.BoundQuery"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): BoundQuery; static fromJson(jsonValue: JsonValue, options?: Partial): BoundQuery; static fromJsonString(jsonString: string, options?: Partial): BoundQuery; static equals(a: BoundQuery | PlainMessage | undefined, b: BoundQuery | PlainMessage | undefined): boolean; } /** * ExecuteOptions is passed around for all Execute calls. * * @generated from message query.ExecuteOptions */ export declare class ExecuteOptions extends Message { /** * Controls what fields are returned in Field message responses from mysql, i.e. * field name, table name, etc. This is an optimization for high-QPS queries where * the client knows what it's getting * * @generated from field: query.ExecuteOptions.IncludedFields included_fields = 4; */ includedFields: ExecuteOptions_IncludedFields; /** * client_rows_found specifies if rows_affected should return * rows found instead of rows affected. Behavior is defined * by MySQL's CLIENT_FOUND_ROWS flag. * * @generated from field: bool client_found_rows = 5; */ clientFoundRows: boolean; /** * workload specifies the type of workload: * OLTP: DMLs allowed, results have row count limit, and * query timeouts are shorter. * OLAP: DMLS not allowed, no limit on row count, timeouts * can be as high as desired. * DBA: no limit on rowcount or timeout, all queries allowed * but intended for long DMLs and DDLs. * * @generated from field: query.ExecuteOptions.Workload workload = 6; */ workload: ExecuteOptions_Workload; /** * sql_select_limit sets an implicit limit on all select statements. Since * vitess also sets a rowcount limit on queries, the smallest value wins. * * @generated from field: int64 sql_select_limit = 8; */ sqlSelectLimit: bigint; /** * @generated from field: query.ExecuteOptions.TransactionIsolation transaction_isolation = 9; */ transactionIsolation: ExecuteOptions_TransactionIsolation; /** * skip_query_plan_cache specifies if the query plan should be cached by vitess. * By default all query plans are cached. * * @generated from field: bool skip_query_plan_cache = 10; */ skipQueryPlanCache: boolean; /** * PlannerVersion specifies which planner to use. * If DEFAULT is chosen, whatever vtgate was started with will be used * * @generated from field: query.ExecuteOptions.PlannerVersion planner_version = 11; */ plannerVersion: ExecuteOptions_PlannerVersion; /** * has_created_temp_tables signals whether plans created in this session should be cached or not * if the user has created temp tables, Vitess will not reuse plans created for this session in other sessions. * The current session can still use other sessions cached plans. * * @generated from field: bool has_created_temp_tables = 12; */ hasCreatedTempTables: boolean; /** * @generated from field: query.ExecuteOptions.Consolidator consolidator = 13; */ consolidator: ExecuteOptions_Consolidator; /** * TransactionAccessMode specifies the access modes to be used while starting the transaction i.e. READ WRITE/READ ONLY/WITH CONSISTENT SNAPSHOT * If not specified, the transaction will be started with the default access mode on the connection. * * @generated from field: repeated query.ExecuteOptions.TransactionAccessMode transaction_access_mode = 14; */ transactionAccessMode: ExecuteOptions_TransactionAccessMode[]; /** * WorkloadName specifies the name of the workload as indicated in query directives. This is used for instrumentation * in metrics and tracing spans. * * @generated from field: string WorkloadName = 15; */ WorkloadName: string; /** * priority specifies the priority of the query, between 0 and 100. This is leveraged by the transaction * throttler to determine whether, under resource contention, a query should or should not be throttled. * * @generated from field: string priority = 16; */ priority: string; /** * timeout specifies the query timeout in milliseconds. If not set, the default timeout is used. * * @generated from oneof query.ExecuteOptions.timeout */ timeout: { /** * @generated from field: int64 authoritative_timeout = 17; */ value: bigint; case: 'authoritativeTimeout'; } | { case: undefined; value?: undefined; }; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ExecuteOptions"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ExecuteOptions; static fromJson(jsonValue: JsonValue, options?: Partial): ExecuteOptions; static fromJsonString(jsonString: string, options?: Partial): ExecuteOptions; static equals(a: ExecuteOptions | PlainMessage | undefined, b: ExecuteOptions | PlainMessage | undefined): boolean; } /** * @generated from enum query.ExecuteOptions.IncludedFields */ export declare enum ExecuteOptions_IncludedFields { /** * @generated from enum value: TYPE_AND_NAME = 0; */ TYPE_AND_NAME = 0, /** * @generated from enum value: TYPE_ONLY = 1; */ TYPE_ONLY = 1, /** * @generated from enum value: ALL = 2; */ ALL = 2 } /** * @generated from enum query.ExecuteOptions.Workload */ export declare enum ExecuteOptions_Workload { /** * @generated from enum value: UNSPECIFIED = 0; */ UNSPECIFIED = 0, /** * @generated from enum value: OLTP = 1; */ OLTP = 1, /** * @generated from enum value: OLAP = 2; */ OLAP = 2, /** * @generated from enum value: DBA = 3; */ DBA = 3 } /** * @generated from enum query.ExecuteOptions.TransactionIsolation */ export declare enum ExecuteOptions_TransactionIsolation { /** * @generated from enum value: DEFAULT = 0; */ DEFAULT = 0, /** * @generated from enum value: REPEATABLE_READ = 1; */ REPEATABLE_READ = 1, /** * @generated from enum value: READ_COMMITTED = 2; */ READ_COMMITTED = 2, /** * @generated from enum value: READ_UNCOMMITTED = 3; */ READ_UNCOMMITTED = 3, /** * @generated from enum value: SERIALIZABLE = 4; */ SERIALIZABLE = 4, /** * This is not an "official" transaction level but it will do a * START TRANSACTION WITH CONSISTENT SNAPSHOT, READ ONLY * * @generated from enum value: CONSISTENT_SNAPSHOT_READ_ONLY = 5; */ CONSISTENT_SNAPSHOT_READ_ONLY = 5, /** * This not an "official" transaction level, it will send queries to mysql * without wrapping them in a transaction * * @generated from enum value: AUTOCOMMIT = 6; */ AUTOCOMMIT = 6 } /** * @generated from enum query.ExecuteOptions.PlannerVersion */ export declare enum ExecuteOptions_PlannerVersion { /** * @generated from enum value: DEFAULT_PLANNER = 0; */ DEFAULT_PLANNER = 0, /** * @generated from enum value: V3 = 1; */ V3 = 1, /** * @generated from enum value: Gen4 = 2; */ Gen4 = 2, /** * @generated from enum value: Gen4Greedy = 3; */ Gen4Greedy = 3, /** * @generated from enum value: Gen4Left2Right = 4; */ Gen4Left2Right = 4, /** * @generated from enum value: Gen4WithFallback = 5; */ Gen4WithFallback = 5, /** * @generated from enum value: Gen4CompareV3 = 6; */ Gen4CompareV3 = 6, /** * @generated from enum value: V3Insert = 7; */ V3Insert = 7 } /** * @generated from enum query.ExecuteOptions.Consolidator */ export declare enum ExecuteOptions_Consolidator { /** * @generated from enum value: CONSOLIDATOR_UNSPECIFIED = 0; */ UNSPECIFIED = 0, /** * @generated from enum value: CONSOLIDATOR_DISABLED = 1; */ DISABLED = 1, /** * @generated from enum value: CONSOLIDATOR_ENABLED = 2; */ ENABLED = 2, /** * @generated from enum value: CONSOLIDATOR_ENABLED_REPLICAS = 3; */ ENABLED_REPLICAS = 3 } /** * @generated from enum query.ExecuteOptions.TransactionAccessMode */ export declare enum ExecuteOptions_TransactionAccessMode { /** * @generated from enum value: CONSISTENT_SNAPSHOT = 0; */ CONSISTENT_SNAPSHOT = 0, /** * @generated from enum value: READ_WRITE = 1; */ READ_WRITE = 1, /** * @generated from enum value: READ_ONLY = 2; */ READ_ONLY = 2 } /** * Field describes a single column returned by a query * * @generated from message query.Field */ export declare class Field extends Message { /** * name of the field as returned by mysql C API * * @generated from field: string name = 1; */ name: string; /** * vitess-defined type. Conversion function is in sqltypes package. * * @generated from field: query.Type type = 2; */ type: Type; /** * Remaining fields from mysql C API. * These fields are only populated when ExecuteOptions.included_fields * is set to IncludedFields.ALL. * * @generated from field: string table = 3; */ table: string; /** * @generated from field: string org_table = 4; */ orgTable: string; /** * @generated from field: string database = 5; */ database: string; /** * @generated from field: string org_name = 6; */ orgName: string; /** * column_length is really a uint32. All 32 bits can be used. * * @generated from field: uint32 column_length = 7; */ columnLength: number; /** * charset is actually a uint16. Only the lower 16 bits are used. * * @generated from field: uint32 charset = 8; */ charset: number; /** * decimals is actually a uint8. Only the lower 8 bits are used. * * @generated from field: uint32 decimals = 9; */ decimals: number; /** * flags is actually a uint16. Only the lower 16 bits are used. * * @generated from field: uint32 flags = 10; */ flags: number; /** * column_type is optionally populated from information_schema.columns * * @generated from field: string column_type = 11; */ columnType: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.Field"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): Field; static fromJson(jsonValue: JsonValue, options?: Partial): Field; static fromJsonString(jsonString: string, options?: Partial): Field; static equals(a: Field | PlainMessage | undefined, b: Field | PlainMessage | undefined): boolean; } /** * Row is a database row. * * @generated from message query.Row */ export declare class Row extends Message { /** * lengths contains the length of each value in values. * A length of -1 means that the field is NULL. While * reading values, you have to accummulate the length * to know the offset where the next value begins in values. * * @generated from field: repeated sint64 lengths = 1; */ lengths: bigint[]; /** * values contains a concatenation of all values in the row. * * @generated from field: bytes values = 2; */ values: Uint8Array; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.Row"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): Row; static fromJson(jsonValue: JsonValue, options?: Partial): Row; static fromJsonString(jsonString: string, options?: Partial): Row; static equals(a: Row | PlainMessage | undefined, b: Row | PlainMessage | undefined): boolean; } /** * QueryResult is returned by Execute and ExecuteStream. * * As returned by Execute, len(fields) is always equal to len(row) * (for each row in rows). * * As returned by StreamExecute, the first QueryResult has the fields * set, and subsequent QueryResult have rows set. And as Execute, * len(QueryResult[0].fields) is always equal to len(row) (for each * row in rows for each QueryResult in QueryResult[1:]). * * @generated from message query.QueryResult */ export declare class QueryResult extends Message { /** * @generated from field: repeated query.Field fields = 1; */ fields: Field[]; /** * @generated from field: uint64 rows_affected = 2; */ rowsAffected: bigint; /** * @generated from field: uint64 insert_id = 3; */ insertId: bigint; /** * @generated from field: repeated query.Row rows = 4; */ rows: Row[]; /** * @generated from field: string info = 6; */ info: string; /** * @generated from field: string session_state_changes = 7; */ sessionStateChanges: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.QueryResult"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): QueryResult; static fromJson(jsonValue: JsonValue, options?: Partial): QueryResult; static fromJsonString(jsonString: string, options?: Partial): QueryResult; static equals(a: QueryResult | PlainMessage | undefined, b: QueryResult | PlainMessage | undefined): boolean; } /** * QueryWarning is used to convey out of band query execution warnings * by storing in the vtgate.Session * * @generated from message query.QueryWarning */ export declare class QueryWarning extends Message { /** * @generated from field: uint32 code = 1; */ code: number; /** * @generated from field: string message = 2; */ message: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.QueryWarning"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): QueryWarning; static fromJson(jsonValue: JsonValue, options?: Partial): QueryWarning; static fromJsonString(jsonString: string, options?: Partial): QueryWarning; static equals(a: QueryWarning | PlainMessage | undefined, b: QueryWarning | PlainMessage | undefined): boolean; } /** * StreamEvent describes a set of transformations that happened as a * single transactional unit on a server. It is streamed back by the * Update Stream calls. * * @generated from message query.StreamEvent */ export declare class StreamEvent extends Message { /** * The statements in this transaction. * * @generated from field: repeated query.StreamEvent.Statement statements = 1; */ statements: StreamEvent_Statement[]; /** * The Event Token for this event. * * @generated from field: query.EventToken event_token = 2; */ eventToken?: EventToken; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.StreamEvent"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): StreamEvent; static fromJson(jsonValue: JsonValue, options?: Partial): StreamEvent; static fromJsonString(jsonString: string, options?: Partial): StreamEvent; static equals(a: StreamEvent | PlainMessage | undefined, b: StreamEvent | PlainMessage | undefined): boolean; } /** * One individual Statement in a transaction. * * @generated from message query.StreamEvent.Statement */ export declare class StreamEvent_Statement extends Message { /** * @generated from field: query.StreamEvent.Statement.Category category = 1; */ category: StreamEvent_Statement_Category; /** * table_name, primary_key_fields and primary_key_values are set for DML. * * @generated from field: string table_name = 2; */ tableName: string; /** * @generated from field: repeated query.Field primary_key_fields = 3; */ primaryKeyFields: Field[]; /** * @generated from field: repeated query.Row primary_key_values = 4; */ primaryKeyValues: Row[]; /** * sql is set for all queries. * FIXME(alainjobart) we may not need it for DMLs. * * @generated from field: bytes sql = 5; */ sql: Uint8Array; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.StreamEvent.Statement"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): StreamEvent_Statement; static fromJson(jsonValue: JsonValue, options?: Partial): StreamEvent_Statement; static fromJsonString(jsonString: string, options?: Partial): StreamEvent_Statement; static equals(a: StreamEvent_Statement | PlainMessage | undefined, b: StreamEvent_Statement | PlainMessage | undefined): boolean; } /** * The category of one statement. * * @generated from enum query.StreamEvent.Statement.Category */ export declare enum StreamEvent_Statement_Category { /** * @generated from enum value: Error = 0; */ Error = 0, /** * @generated from enum value: DML = 1; */ DML = 1, /** * @generated from enum value: DDL = 2; */ DDL = 2 } /** * ExecuteRequest is the payload to Execute * * @generated from message query.ExecuteRequest */ export declare class ExecuteRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: query.BoundQuery query = 4; */ query?: BoundQuery; /** * @generated from field: int64 transaction_id = 5; */ transactionId: bigint; /** * @generated from field: query.ExecuteOptions options = 6; */ options?: ExecuteOptions; /** * @generated from field: int64 reserved_id = 7; */ reservedId: bigint; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ExecuteRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ExecuteRequest; static fromJson(jsonValue: JsonValue, options?: Partial): ExecuteRequest; static fromJsonString(jsonString: string, options?: Partial): ExecuteRequest; static equals(a: ExecuteRequest | PlainMessage | undefined, b: ExecuteRequest | PlainMessage | undefined): boolean; } /** * ExecuteResponse is the returned value from Execute * * @generated from message query.ExecuteResponse */ export declare class ExecuteResponse extends Message { /** * @generated from field: query.QueryResult result = 1; */ result?: QueryResult; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ExecuteResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ExecuteResponse; static fromJson(jsonValue: JsonValue, options?: Partial): ExecuteResponse; static fromJsonString(jsonString: string, options?: Partial): ExecuteResponse; static equals(a: ExecuteResponse | PlainMessage | undefined, b: ExecuteResponse | PlainMessage | undefined): boolean; } /** * ResultWithError represents a query response * in the form of result or error but not both. * TODO: To be used in ExecuteBatchResponse and BeginExecuteBatchResponse. * * @generated from message query.ResultWithError */ export declare class ResultWithError extends Message { /** * error contains an query level error, only set if result is unset. * * @generated from field: vtrpc.RPCError error = 1; */ error?: RPCError; /** * result contains the query result, only set if error is unset. * * @generated from field: query.QueryResult result = 2; */ result?: QueryResult; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ResultWithError"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ResultWithError; static fromJson(jsonValue: JsonValue, options?: Partial): ResultWithError; static fromJsonString(jsonString: string, options?: Partial): ResultWithError; static equals(a: ResultWithError | PlainMessage | undefined, b: ResultWithError | PlainMessage | undefined): boolean; } /** * StreamExecuteRequest is the payload to StreamExecute * * @generated from message query.StreamExecuteRequest */ export declare class StreamExecuteRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: query.BoundQuery query = 4; */ query?: BoundQuery; /** * @generated from field: query.ExecuteOptions options = 5; */ options?: ExecuteOptions; /** * @generated from field: int64 transaction_id = 6; */ transactionId: bigint; /** * @generated from field: int64 reserved_id = 7; */ reservedId: bigint; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.StreamExecuteRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): StreamExecuteRequest; static fromJson(jsonValue: JsonValue, options?: Partial): StreamExecuteRequest; static fromJsonString(jsonString: string, options?: Partial): StreamExecuteRequest; static equals(a: StreamExecuteRequest | PlainMessage | undefined, b: StreamExecuteRequest | PlainMessage | undefined): boolean; } /** * StreamExecuteResponse is the returned value from StreamExecute * * @generated from message query.StreamExecuteResponse */ export declare class StreamExecuteResponse extends Message { /** * @generated from field: query.QueryResult result = 1; */ result?: QueryResult; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.StreamExecuteResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): StreamExecuteResponse; static fromJson(jsonValue: JsonValue, options?: Partial): StreamExecuteResponse; static fromJsonString(jsonString: string, options?: Partial): StreamExecuteResponse; static equals(a: StreamExecuteResponse | PlainMessage | undefined, b: StreamExecuteResponse | PlainMessage | undefined): boolean; } /** * BeginRequest is the payload to Begin * * @generated from message query.BeginRequest */ export declare class BeginRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: query.ExecuteOptions options = 4; */ options?: ExecuteOptions; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.BeginRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): BeginRequest; static fromJson(jsonValue: JsonValue, options?: Partial): BeginRequest; static fromJsonString(jsonString: string, options?: Partial): BeginRequest; static equals(a: BeginRequest | PlainMessage | undefined, b: BeginRequest | PlainMessage | undefined): boolean; } /** * BeginResponse is the returned value from Begin * * @generated from message query.BeginResponse */ export declare class BeginResponse extends Message { /** * @generated from field: int64 transaction_id = 1; */ transactionId: bigint; /** * @generated from field: topodata.TabletAlias tablet_alias = 2; */ tabletAlias?: TabletAlias; /** * The session_state_changes might be set if the transaction is a snapshot transaction * and the MySQL implementation supports getting a start gtid on snapshot * * @generated from field: string session_state_changes = 3; */ sessionStateChanges: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.BeginResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): BeginResponse; static fromJson(jsonValue: JsonValue, options?: Partial): BeginResponse; static fromJsonString(jsonString: string, options?: Partial): BeginResponse; static equals(a: BeginResponse | PlainMessage | undefined, b: BeginResponse | PlainMessage | undefined): boolean; } /** * CommitRequest is the payload to Commit * * @generated from message query.CommitRequest */ export declare class CommitRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: int64 transaction_id = 4; */ transactionId: bigint; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.CommitRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): CommitRequest; static fromJson(jsonValue: JsonValue, options?: Partial): CommitRequest; static fromJsonString(jsonString: string, options?: Partial): CommitRequest; static equals(a: CommitRequest | PlainMessage | undefined, b: CommitRequest | PlainMessage | undefined): boolean; } /** * CommitResponse is the returned value from Commit * * @generated from message query.CommitResponse */ export declare class CommitResponse extends Message { /** * @generated from field: int64 reserved_id = 1; */ reservedId: bigint; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.CommitResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): CommitResponse; static fromJson(jsonValue: JsonValue, options?: Partial): CommitResponse; static fromJsonString(jsonString: string, options?: Partial): CommitResponse; static equals(a: CommitResponse | PlainMessage | undefined, b: CommitResponse | PlainMessage | undefined): boolean; } /** * RollbackRequest is the payload to Rollback * * @generated from message query.RollbackRequest */ export declare class RollbackRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: int64 transaction_id = 4; */ transactionId: bigint; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.RollbackRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): RollbackRequest; static fromJson(jsonValue: JsonValue, options?: Partial): RollbackRequest; static fromJsonString(jsonString: string, options?: Partial): RollbackRequest; static equals(a: RollbackRequest | PlainMessage | undefined, b: RollbackRequest | PlainMessage | undefined): boolean; } /** * RollbackResponse is the returned value from Rollback * * @generated from message query.RollbackResponse */ export declare class RollbackResponse extends Message { /** * @generated from field: int64 reserved_id = 1; */ reservedId: bigint; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.RollbackResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): RollbackResponse; static fromJson(jsonValue: JsonValue, options?: Partial): RollbackResponse; static fromJsonString(jsonString: string, options?: Partial): RollbackResponse; static equals(a: RollbackResponse | PlainMessage | undefined, b: RollbackResponse | PlainMessage | undefined): boolean; } /** * PrepareRequest is the payload to Prepare * * @generated from message query.PrepareRequest */ export declare class PrepareRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: int64 transaction_id = 4; */ transactionId: bigint; /** * @generated from field: string dtid = 5; */ dtid: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.PrepareRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): PrepareRequest; static fromJson(jsonValue: JsonValue, options?: Partial): PrepareRequest; static fromJsonString(jsonString: string, options?: Partial): PrepareRequest; static equals(a: PrepareRequest | PlainMessage | undefined, b: PrepareRequest | PlainMessage | undefined): boolean; } /** * PrepareResponse is the returned value from Prepare * * @generated from message query.PrepareResponse */ export declare class PrepareResponse extends Message { constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.PrepareResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): PrepareResponse; static fromJson(jsonValue: JsonValue, options?: Partial): PrepareResponse; static fromJsonString(jsonString: string, options?: Partial): PrepareResponse; static equals(a: PrepareResponse | PlainMessage | undefined, b: PrepareResponse | PlainMessage | undefined): boolean; } /** * CommitPreparedRequest is the payload to CommitPrepared * * @generated from message query.CommitPreparedRequest */ export declare class CommitPreparedRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: string dtid = 4; */ dtid: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.CommitPreparedRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): CommitPreparedRequest; static fromJson(jsonValue: JsonValue, options?: Partial): CommitPreparedRequest; static fromJsonString(jsonString: string, options?: Partial): CommitPreparedRequest; static equals(a: CommitPreparedRequest | PlainMessage | undefined, b: CommitPreparedRequest | PlainMessage | undefined): boolean; } /** * CommitPreparedResponse is the returned value from CommitPrepared * * @generated from message query.CommitPreparedResponse */ export declare class CommitPreparedResponse extends Message { constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.CommitPreparedResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): CommitPreparedResponse; static fromJson(jsonValue: JsonValue, options?: Partial): CommitPreparedResponse; static fromJsonString(jsonString: string, options?: Partial): CommitPreparedResponse; static equals(a: CommitPreparedResponse | PlainMessage | undefined, b: CommitPreparedResponse | PlainMessage | undefined): boolean; } /** * RollbackPreparedRequest is the payload to RollbackPrepared * * @generated from message query.RollbackPreparedRequest */ export declare class RollbackPreparedRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: int64 transaction_id = 4; */ transactionId: bigint; /** * @generated from field: string dtid = 5; */ dtid: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.RollbackPreparedRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): RollbackPreparedRequest; static fromJson(jsonValue: JsonValue, options?: Partial): RollbackPreparedRequest; static fromJsonString(jsonString: string, options?: Partial): RollbackPreparedRequest; static equals(a: RollbackPreparedRequest | PlainMessage | undefined, b: RollbackPreparedRequest | PlainMessage | undefined): boolean; } /** * RollbackPreparedResponse is the returned value from RollbackPrepared * * @generated from message query.RollbackPreparedResponse */ export declare class RollbackPreparedResponse extends Message { constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.RollbackPreparedResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): RollbackPreparedResponse; static fromJson(jsonValue: JsonValue, options?: Partial): RollbackPreparedResponse; static fromJsonString(jsonString: string, options?: Partial): RollbackPreparedResponse; static equals(a: RollbackPreparedResponse | PlainMessage | undefined, b: RollbackPreparedResponse | PlainMessage | undefined): boolean; } /** * CreateTransactionRequest is the payload to CreateTransaction * * @generated from message query.CreateTransactionRequest */ export declare class CreateTransactionRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: string dtid = 4; */ dtid: string; /** * @generated from field: repeated query.Target participants = 5; */ participants: Target[]; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.CreateTransactionRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): CreateTransactionRequest; static fromJson(jsonValue: JsonValue, options?: Partial): CreateTransactionRequest; static fromJsonString(jsonString: string, options?: Partial): CreateTransactionRequest; static equals(a: CreateTransactionRequest | PlainMessage | undefined, b: CreateTransactionRequest | PlainMessage | undefined): boolean; } /** * CreateTransactionResponse is the returned value from CreateTransaction * * @generated from message query.CreateTransactionResponse */ export declare class CreateTransactionResponse extends Message { constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.CreateTransactionResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): CreateTransactionResponse; static fromJson(jsonValue: JsonValue, options?: Partial): CreateTransactionResponse; static fromJsonString(jsonString: string, options?: Partial): CreateTransactionResponse; static equals(a: CreateTransactionResponse | PlainMessage | undefined, b: CreateTransactionResponse | PlainMessage | undefined): boolean; } /** * StartCommitRequest is the payload to StartCommit * * @generated from message query.StartCommitRequest */ export declare class StartCommitRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: int64 transaction_id = 4; */ transactionId: bigint; /** * @generated from field: string dtid = 5; */ dtid: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.StartCommitRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): StartCommitRequest; static fromJson(jsonValue: JsonValue, options?: Partial): StartCommitRequest; static fromJsonString(jsonString: string, options?: Partial): StartCommitRequest; static equals(a: StartCommitRequest | PlainMessage | undefined, b: StartCommitRequest | PlainMessage | undefined): boolean; } /** * StartCommitResponse is the returned value from StartCommit * * @generated from message query.StartCommitResponse */ export declare class StartCommitResponse extends Message { constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.StartCommitResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): StartCommitResponse; static fromJson(jsonValue: JsonValue, options?: Partial): StartCommitResponse; static fromJsonString(jsonString: string, options?: Partial): StartCommitResponse; static equals(a: StartCommitResponse | PlainMessage | undefined, b: StartCommitResponse | PlainMessage | undefined): boolean; } /** * SetRollbackRequest is the payload to SetRollback * * @generated from message query.SetRollbackRequest */ export declare class SetRollbackRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: int64 transaction_id = 4; */ transactionId: bigint; /** * @generated from field: string dtid = 5; */ dtid: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.SetRollbackRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): SetRollbackRequest; static fromJson(jsonValue: JsonValue, options?: Partial): SetRollbackRequest; static fromJsonString(jsonString: string, options?: Partial): SetRollbackRequest; static equals(a: SetRollbackRequest | PlainMessage | undefined, b: SetRollbackRequest | PlainMessage | undefined): boolean; } /** * SetRollbackResponse is the returned value from SetRollback * * @generated from message query.SetRollbackResponse */ export declare class SetRollbackResponse extends Message { constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.SetRollbackResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): SetRollbackResponse; static fromJson(jsonValue: JsonValue, options?: Partial): SetRollbackResponse; static fromJsonString(jsonString: string, options?: Partial): SetRollbackResponse; static equals(a: SetRollbackResponse | PlainMessage | undefined, b: SetRollbackResponse | PlainMessage | undefined): boolean; } /** * ConcludeTransactionRequest is the payload to ConcludeTransaction * * @generated from message query.ConcludeTransactionRequest */ export declare class ConcludeTransactionRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: string dtid = 4; */ dtid: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ConcludeTransactionRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ConcludeTransactionRequest; static fromJson(jsonValue: JsonValue, options?: Partial): ConcludeTransactionRequest; static fromJsonString(jsonString: string, options?: Partial): ConcludeTransactionRequest; static equals(a: ConcludeTransactionRequest | PlainMessage | undefined, b: ConcludeTransactionRequest | PlainMessage | undefined): boolean; } /** * ConcludeTransactionResponse is the returned value from ConcludeTransaction * * @generated from message query.ConcludeTransactionResponse */ export declare class ConcludeTransactionResponse extends Message { constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ConcludeTransactionResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ConcludeTransactionResponse; static fromJson(jsonValue: JsonValue, options?: Partial): ConcludeTransactionResponse; static fromJsonString(jsonString: string, options?: Partial): ConcludeTransactionResponse; static equals(a: ConcludeTransactionResponse | PlainMessage | undefined, b: ConcludeTransactionResponse | PlainMessage | undefined): boolean; } /** * ReadTransactionRequest is the payload to ReadTransaction * * @generated from message query.ReadTransactionRequest */ export declare class ReadTransactionRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: string dtid = 4; */ dtid: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ReadTransactionRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ReadTransactionRequest; static fromJson(jsonValue: JsonValue, options?: Partial): ReadTransactionRequest; static fromJsonString(jsonString: string, options?: Partial): ReadTransactionRequest; static equals(a: ReadTransactionRequest | PlainMessage | undefined, b: ReadTransactionRequest | PlainMessage | undefined): boolean; } /** * ReadTransactionResponse is the returned value from ReadTransaction * * @generated from message query.ReadTransactionResponse */ export declare class ReadTransactionResponse extends Message { /** * @generated from field: query.TransactionMetadata metadata = 1; */ metadata?: TransactionMetadata; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ReadTransactionResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ReadTransactionResponse; static fromJson(jsonValue: JsonValue, options?: Partial): ReadTransactionResponse; static fromJsonString(jsonString: string, options?: Partial): ReadTransactionResponse; static equals(a: ReadTransactionResponse | PlainMessage | undefined, b: ReadTransactionResponse | PlainMessage | undefined): boolean; } /** * UnresolvedTransactionsRequest is the payload to UnresolvedTransactions * * @generated from message query.UnresolvedTransactionsRequest */ export declare class UnresolvedTransactionsRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * Unresolved Transactions older than this (in seconds). * * @generated from field: int64 abandon_age = 4; */ abandonAge: bigint; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.UnresolvedTransactionsRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): UnresolvedTransactionsRequest; static fromJson(jsonValue: JsonValue, options?: Partial): UnresolvedTransactionsRequest; static fromJsonString(jsonString: string, options?: Partial): UnresolvedTransactionsRequest; static equals(a: UnresolvedTransactionsRequest | PlainMessage | undefined, b: UnresolvedTransactionsRequest | PlainMessage | undefined): boolean; } /** * UnresolvedTransactionsResponse is the returned value from UnresolvedTransactions * * @generated from message query.UnresolvedTransactionsResponse */ export declare class UnresolvedTransactionsResponse extends Message { /** * @generated from field: repeated query.TransactionMetadata transactions = 1; */ transactions: TransactionMetadata[]; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.UnresolvedTransactionsResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): UnresolvedTransactionsResponse; static fromJson(jsonValue: JsonValue, options?: Partial): UnresolvedTransactionsResponse; static fromJsonString(jsonString: string, options?: Partial): UnresolvedTransactionsResponse; static equals(a: UnresolvedTransactionsResponse | PlainMessage | undefined, b: UnresolvedTransactionsResponse | PlainMessage | undefined): boolean; } /** * BeginExecuteRequest is the payload to BeginExecute * * @generated from message query.BeginExecuteRequest */ export declare class BeginExecuteRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: query.BoundQuery query = 4; */ query?: BoundQuery; /** * @generated from field: query.ExecuteOptions options = 5; */ options?: ExecuteOptions; /** * @generated from field: int64 reserved_id = 6; */ reservedId: bigint; /** * @generated from field: repeated string pre_queries = 7; */ preQueries: string[]; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.BeginExecuteRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): BeginExecuteRequest; static fromJson(jsonValue: JsonValue, options?: Partial): BeginExecuteRequest; static fromJsonString(jsonString: string, options?: Partial): BeginExecuteRequest; static equals(a: BeginExecuteRequest | PlainMessage | undefined, b: BeginExecuteRequest | PlainMessage | undefined): boolean; } /** * BeginExecuteResponse is the returned value from BeginExecute * * @generated from message query.BeginExecuteResponse */ export declare class BeginExecuteResponse extends Message { /** * error contains an application level error if necessary. Note the * transaction_id may be set, even when an error is returned, if the begin * worked but the execute failed. * * @generated from field: vtrpc.RPCError error = 1; */ error?: RPCError; /** * @generated from field: query.QueryResult result = 2; */ result?: QueryResult; /** * transaction_id might be non-zero even if an error is present. * * @generated from field: int64 transaction_id = 3; */ transactionId: bigint; /** * @generated from field: topodata.TabletAlias tablet_alias = 4; */ tabletAlias?: TabletAlias; /** * The session_state_changes might be set if the transaction is a snapshot transaction * and the MySQL implementation supports getting a start gtid on snapshot * * @generated from field: string session_state_changes = 5; */ sessionStateChanges: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.BeginExecuteResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): BeginExecuteResponse; static fromJson(jsonValue: JsonValue, options?: Partial): BeginExecuteResponse; static fromJsonString(jsonString: string, options?: Partial): BeginExecuteResponse; static equals(a: BeginExecuteResponse | PlainMessage | undefined, b: BeginExecuteResponse | PlainMessage | undefined): boolean; } /** * BeginStreamExecuteRequest is the payload to BeginStreamExecute * * @generated from message query.BeginStreamExecuteRequest */ export declare class BeginStreamExecuteRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: query.BoundQuery query = 4; */ query?: BoundQuery; /** * @generated from field: query.ExecuteOptions options = 5; */ options?: ExecuteOptions; /** * @generated from field: repeated string pre_queries = 6; */ preQueries: string[]; /** * @generated from field: int64 reserved_id = 7; */ reservedId: bigint; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.BeginStreamExecuteRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): BeginStreamExecuteRequest; static fromJson(jsonValue: JsonValue, options?: Partial): BeginStreamExecuteRequest; static fromJsonString(jsonString: string, options?: Partial): BeginStreamExecuteRequest; static equals(a: BeginStreamExecuteRequest | PlainMessage | undefined, b: BeginStreamExecuteRequest | PlainMessage | undefined): boolean; } /** * BeginStreamExecuteResponse is the returned value from BeginStreamExecute * * @generated from message query.BeginStreamExecuteResponse */ export declare class BeginStreamExecuteResponse extends Message { /** * error contains an application level error if necessary. Note the * transaction_id may be set, even when an error is returned, if the begin * worked but the stream execute failed. * * @generated from field: vtrpc.RPCError error = 1; */ error?: RPCError; /** * @generated from field: query.QueryResult result = 2; */ result?: QueryResult; /** * transaction_id might be non-zero even if an error is present. * * @generated from field: int64 transaction_id = 3; */ transactionId: bigint; /** * @generated from field: topodata.TabletAlias tablet_alias = 4; */ tabletAlias?: TabletAlias; /** * The session_state_changes might be set if the transaction is a snapshot transaction * and the MySQL implementation supports getting a start gtid on snapshot * * @generated from field: string session_state_changes = 5; */ sessionStateChanges: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.BeginStreamExecuteResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): BeginStreamExecuteResponse; static fromJson(jsonValue: JsonValue, options?: Partial): BeginStreamExecuteResponse; static fromJsonString(jsonString: string, options?: Partial): BeginStreamExecuteResponse; static equals(a: BeginStreamExecuteResponse | PlainMessage | undefined, b: BeginStreamExecuteResponse | PlainMessage | undefined): boolean; } /** * MessageStreamRequest is the request payload for MessageStream. * * @generated from message query.MessageStreamRequest */ export declare class MessageStreamRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * name is the message table name. * * @generated from field: string name = 4; */ name: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.MessageStreamRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): MessageStreamRequest; static fromJson(jsonValue: JsonValue, options?: Partial): MessageStreamRequest; static fromJsonString(jsonString: string, options?: Partial): MessageStreamRequest; static equals(a: MessageStreamRequest | PlainMessage | undefined, b: MessageStreamRequest | PlainMessage | undefined): boolean; } /** * MessageStreamResponse is a response for MessageStream. * * @generated from message query.MessageStreamResponse */ export declare class MessageStreamResponse extends Message { /** * @generated from field: query.QueryResult result = 1; */ result?: QueryResult; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.MessageStreamResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): MessageStreamResponse; static fromJson(jsonValue: JsonValue, options?: Partial): MessageStreamResponse; static fromJsonString(jsonString: string, options?: Partial): MessageStreamResponse; static equals(a: MessageStreamResponse | PlainMessage | undefined, b: MessageStreamResponse | PlainMessage | undefined): boolean; } /** * MessageAckRequest is the request payload for MessageAck. * * @generated from message query.MessageAckRequest */ export declare class MessageAckRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * name is the message table name. * * @generated from field: string name = 4; */ name: string; /** * @generated from field: repeated query.Value ids = 5; */ ids: Value[]; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.MessageAckRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): MessageAckRequest; static fromJson(jsonValue: JsonValue, options?: Partial): MessageAckRequest; static fromJsonString(jsonString: string, options?: Partial): MessageAckRequest; static equals(a: MessageAckRequest | PlainMessage | undefined, b: MessageAckRequest | PlainMessage | undefined): boolean; } /** * MessageAckResponse is the response for MessageAck. * * @generated from message query.MessageAckResponse */ export declare class MessageAckResponse extends Message { /** * result contains the result of the ack operation. * Since this acts like a DML, only * RowsAffected is returned in the result. * * @generated from field: query.QueryResult result = 1; */ result?: QueryResult; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.MessageAckResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): MessageAckResponse; static fromJson(jsonValue: JsonValue, options?: Partial): MessageAckResponse; static fromJsonString(jsonString: string, options?: Partial): MessageAckResponse; static equals(a: MessageAckResponse | PlainMessage | undefined, b: MessageAckResponse | PlainMessage | undefined): boolean; } /** * ReserveExecuteRequest is the payload to ReserveExecute * * @generated from message query.ReserveExecuteRequest */ export declare class ReserveExecuteRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: query.BoundQuery query = 4; */ query?: BoundQuery; /** * @generated from field: int64 transaction_id = 5; */ transactionId: bigint; /** * @generated from field: query.ExecuteOptions options = 6; */ options?: ExecuteOptions; /** * @generated from field: repeated string pre_queries = 7; */ preQueries: string[]; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ReserveExecuteRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ReserveExecuteRequest; static fromJson(jsonValue: JsonValue, options?: Partial): ReserveExecuteRequest; static fromJsonString(jsonString: string, options?: Partial): ReserveExecuteRequest; static equals(a: ReserveExecuteRequest | PlainMessage | undefined, b: ReserveExecuteRequest | PlainMessage | undefined): boolean; } /** * ReserveExecuteResponse is the returned value from ReserveExecute * * @generated from message query.ReserveExecuteResponse */ export declare class ReserveExecuteResponse extends Message { /** * @generated from field: vtrpc.RPCError error = 1; */ error?: RPCError; /** * @generated from field: query.QueryResult result = 2; */ result?: QueryResult; /** * The following fields might be non-zero even if an error is present. * * @generated from field: int64 reserved_id = 3; */ reservedId: bigint; /** * @generated from field: topodata.TabletAlias tablet_alias = 4; */ tabletAlias?: TabletAlias; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ReserveExecuteResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ReserveExecuteResponse; static fromJson(jsonValue: JsonValue, options?: Partial): ReserveExecuteResponse; static fromJsonString(jsonString: string, options?: Partial): ReserveExecuteResponse; static equals(a: ReserveExecuteResponse | PlainMessage | undefined, b: ReserveExecuteResponse | PlainMessage | undefined): boolean; } /** * ReserveStreamExecuteRequest is the payload to ReserveStreamExecute * * @generated from message query.ReserveStreamExecuteRequest */ export declare class ReserveStreamExecuteRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: query.BoundQuery query = 4; */ query?: BoundQuery; /** * @generated from field: query.ExecuteOptions options = 5; */ options?: ExecuteOptions; /** * @generated from field: int64 transaction_id = 6; */ transactionId: bigint; /** * @generated from field: repeated string pre_queries = 7; */ preQueries: string[]; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ReserveStreamExecuteRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ReserveStreamExecuteRequest; static fromJson(jsonValue: JsonValue, options?: Partial): ReserveStreamExecuteRequest; static fromJsonString(jsonString: string, options?: Partial): ReserveStreamExecuteRequest; static equals(a: ReserveStreamExecuteRequest | PlainMessage | undefined, b: ReserveStreamExecuteRequest | PlainMessage | undefined): boolean; } /** * ReserveStreamExecuteResponse is the returned value from ReserveStreamExecute * * @generated from message query.ReserveStreamExecuteResponse */ export declare class ReserveStreamExecuteResponse extends Message { /** * @generated from field: vtrpc.RPCError error = 1; */ error?: RPCError; /** * @generated from field: query.QueryResult result = 2; */ result?: QueryResult; /** * The following fields might be non-zero even if an error is present. * * @generated from field: int64 reserved_id = 3; */ reservedId: bigint; /** * @generated from field: topodata.TabletAlias tablet_alias = 4; */ tabletAlias?: TabletAlias; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ReserveStreamExecuteResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ReserveStreamExecuteResponse; static fromJson(jsonValue: JsonValue, options?: Partial): ReserveStreamExecuteResponse; static fromJsonString(jsonString: string, options?: Partial): ReserveStreamExecuteResponse; static equals(a: ReserveStreamExecuteResponse | PlainMessage | undefined, b: ReserveStreamExecuteResponse | PlainMessage | undefined): boolean; } /** * ReserveBeginExecuteRequest is the payload to ReserveBeginExecute * * @generated from message query.ReserveBeginExecuteRequest */ export declare class ReserveBeginExecuteRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: query.BoundQuery query = 4; */ query?: BoundQuery; /** * @generated from field: query.ExecuteOptions options = 5; */ options?: ExecuteOptions; /** * @generated from field: repeated string pre_queries = 6; */ preQueries: string[]; /** * @generated from field: repeated string post_begin_queries = 7; */ postBeginQueries: string[]; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ReserveBeginExecuteRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ReserveBeginExecuteRequest; static fromJson(jsonValue: JsonValue, options?: Partial): ReserveBeginExecuteRequest; static fromJsonString(jsonString: string, options?: Partial): ReserveBeginExecuteRequest; static equals(a: ReserveBeginExecuteRequest | PlainMessage | undefined, b: ReserveBeginExecuteRequest | PlainMessage | undefined): boolean; } /** * ReserveBeginExecuteResponse is the returned value from ReserveBeginExecute * * @generated from message query.ReserveBeginExecuteResponse */ export declare class ReserveBeginExecuteResponse extends Message { /** * error contains an application level error if necessary. Note the * transaction_id may be set, even when an error is returned, if the begin * worked but the execute failed. * * @generated from field: vtrpc.RPCError error = 1; */ error?: RPCError; /** * @generated from field: query.QueryResult result = 2; */ result?: QueryResult; /** * The following fields might be non-zero even if an error is present. * * @generated from field: int64 transaction_id = 3; */ transactionId: bigint; /** * @generated from field: int64 reserved_id = 4; */ reservedId: bigint; /** * @generated from field: topodata.TabletAlias tablet_alias = 5; */ tabletAlias?: TabletAlias; /** * The session_state_changes might be set if the transaction is a snapshot transaction * and the MySQL implementation supports getting a start gtid on snapshot * * @generated from field: string session_state_changes = 6; */ sessionStateChanges: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ReserveBeginExecuteResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ReserveBeginExecuteResponse; static fromJson(jsonValue: JsonValue, options?: Partial): ReserveBeginExecuteResponse; static fromJsonString(jsonString: string, options?: Partial): ReserveBeginExecuteResponse; static equals(a: ReserveBeginExecuteResponse | PlainMessage | undefined, b: ReserveBeginExecuteResponse | PlainMessage | undefined): boolean; } /** * ReserveBeginStreamExecuteRequest is the payload to ReserveBeginStreamExecute * * @generated from message query.ReserveBeginStreamExecuteRequest */ export declare class ReserveBeginStreamExecuteRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: query.BoundQuery query = 4; */ query?: BoundQuery; /** * @generated from field: query.ExecuteOptions options = 5; */ options?: ExecuteOptions; /** * @generated from field: repeated string pre_queries = 6; */ preQueries: string[]; /** * @generated from field: repeated string post_begin_queries = 7; */ postBeginQueries: string[]; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ReserveBeginStreamExecuteRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ReserveBeginStreamExecuteRequest; static fromJson(jsonValue: JsonValue, options?: Partial): ReserveBeginStreamExecuteRequest; static fromJsonString(jsonString: string, options?: Partial): ReserveBeginStreamExecuteRequest; static equals(a: ReserveBeginStreamExecuteRequest | PlainMessage | undefined, b: ReserveBeginStreamExecuteRequest | PlainMessage | undefined): boolean; } /** * ReserveBeginStreamExecuteResponse is the returned value from ReserveBeginStreamExecute * * @generated from message query.ReserveBeginStreamExecuteResponse */ export declare class ReserveBeginStreamExecuteResponse extends Message { /** * error contains an application level error if necessary. Note the * transaction_id may be set, even when an error is returned, if the begin * worked but the stream execute failed. * * @generated from field: vtrpc.RPCError error = 1; */ error?: RPCError; /** * @generated from field: query.QueryResult result = 2; */ result?: QueryResult; /** * The following fields might be non-zero even if an error is present. * * @generated from field: int64 transaction_id = 3; */ transactionId: bigint; /** * @generated from field: int64 reserved_id = 4; */ reservedId: bigint; /** * @generated from field: topodata.TabletAlias tablet_alias = 5; */ tabletAlias?: TabletAlias; /** * The session_state_changes might be set if the transaction is a snapshot transaction * and the MySQL implementation supports getting a start gtid on snapshot * * @generated from field: string session_state_changes = 6; */ sessionStateChanges: string; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ReserveBeginStreamExecuteResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ReserveBeginStreamExecuteResponse; static fromJson(jsonValue: JsonValue, options?: Partial): ReserveBeginStreamExecuteResponse; static fromJsonString(jsonString: string, options?: Partial): ReserveBeginStreamExecuteResponse; static equals(a: ReserveBeginStreamExecuteResponse | PlainMessage | undefined, b: ReserveBeginStreamExecuteResponse | PlainMessage | undefined): boolean; } /** * ReleaseRequest is the payload to Release * * @generated from message query.ReleaseRequest */ export declare class ReleaseRequest extends Message { /** * @generated from field: vtrpc.CallerID effective_caller_id = 1; */ effectiveCallerId?: CallerID; /** * @generated from field: query.VTGateCallerID immediate_caller_id = 2; */ immediateCallerId?: VTGateCallerID; /** * @generated from field: query.Target target = 3; */ target?: Target; /** * @generated from field: int64 transaction_id = 4; */ transactionId: bigint; /** * @generated from field: int64 reserved_id = 5; */ reservedId: bigint; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ReleaseRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ReleaseRequest; static fromJson(jsonValue: JsonValue, options?: Partial): ReleaseRequest; static fromJsonString(jsonString: string, options?: Partial): ReleaseRequest; static equals(a: ReleaseRequest | PlainMessage | undefined, b: ReleaseRequest | PlainMessage | undefined): boolean; } /** * ReleaseResponse is the returned value from Release * * @generated from message query.ReleaseResponse */ export declare class ReleaseResponse extends Message { constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.ReleaseResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): ReleaseResponse; static fromJson(jsonValue: JsonValue, options?: Partial): ReleaseResponse; static fromJsonString(jsonString: string, options?: Partial): ReleaseResponse; static equals(a: ReleaseResponse | PlainMessage | undefined, b: ReleaseResponse | PlainMessage | undefined): boolean; } /** * StreamHealthRequest is the payload for StreamHealth * * @generated from message query.StreamHealthRequest */ export declare class StreamHealthRequest extends Message { constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.StreamHealthRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): StreamHealthRequest; static fromJson(jsonValue: JsonValue, options?: Partial): StreamHealthRequest; static fromJsonString(jsonString: string, options?: Partial): StreamHealthRequest; static equals(a: StreamHealthRequest | PlainMessage | undefined, b: StreamHealthRequest | PlainMessage | undefined): boolean; } /** * RealtimeStats contains information about the tablet status. * It is only valid for a single tablet. * * @generated from message query.RealtimeStats */ export declare class RealtimeStats extends Message { /** * health_error is the last error we got from health check, * or empty is the server is healthy. This is used for subset selection, * we do not send queries to servers that are not healthy. * * @generated from field: string health_error = 1; */ healthError: string; /** * replication_lag_seconds is populated for replicas only. It indicates * how far behind on (MySQL) replication a replica currently is. It is used * by clients for subset selection (so we don't try to send traffic * to tablets that are too far behind). * NOTE: This field must not be evaluated if "health_error" is not empty. * TODO(mberlin): Let's switch it to int64 instead? * * @generated from field: uint32 replication_lag_seconds = 2; */ replicationLagSeconds: number; /** * bin_log_players_count is the number of currently running binlog players. * if the value is 0, it means that filtered replication is currently not * running on the tablet. If >0, filtered replication is running. * NOTE: This field must not be evaluated if "health_error" is not empty. * * @generated from field: int32 binlog_players_count = 3; */ binlogPlayersCount: number; /** * filtered_replication_lag_seconds is populated for the receiving * primary of an ongoing filtered replication only. * It specifies how far the receiving primary lags behind the sending primary. * NOTE: This field must not be evaluated if "health_error" is not empty. * NOTE: This field must not be evaluated if "bin_log_players_count" is 0. * * @generated from field: int64 filtered_replication_lag_seconds = 4; */ filteredReplicationLagSeconds: bigint; /** * cpu_usage is used for load-based balancing * * @generated from field: double cpu_usage = 5; */ cpuUsage: number; /** * qps is the average QPS (queries per second) rate in the last XX seconds * where XX is usually 60 (See query_service_stats.go). * * @generated from field: double qps = 6; */ qps: number; /** * table_schema_changed is to provide list of tables that have schema changes detected by the tablet. * * @generated from field: repeated string table_schema_changed = 7; */ tableSchemaChanged: string[]; /** * view_schema_changed is to provide list of views that have schema changes detected by the tablet. * * @generated from field: repeated string view_schema_changed = 8; */ viewSchemaChanged: string[]; /** * udfs_changed is used to signal that the UDFs have changed on the tablet. * * @generated from field: bool udfs_changed = 9; */ udfsChanged: boolean; /** * @generated from field: bool tx_unresolved = 10; */ txUnresolved: boolean; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.RealtimeStats"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): RealtimeStats; static fromJson(jsonValue: JsonValue, options?: Partial): RealtimeStats; static fromJsonString(jsonString: string, options?: Partial): RealtimeStats; static equals(a: RealtimeStats | PlainMessage | undefined, b: RealtimeStats | PlainMessage | undefined): boolean; } /** * AggregateStats contains information about the health of a group of * tablets for a Target. It is used to propagate stats from a vtgate * to another, or from the Gateway layer of a vtgate to the routing * layer. * * @generated from message query.AggregateStats */ export declare class AggregateStats extends Message { /** * healthy_tablet_count is the number of healthy tablets in the group. * * @generated from field: int32 healthy_tablet_count = 1; */ healthyTabletCount: number; /** * unhealthy_tablet_count is the number of unhealthy tablets in the group. * * @generated from field: int32 unhealthy_tablet_count = 2; */ unhealthyTabletCount: number; /** * replication_lag_seconds_min is the minimum of the * replication_lag_seconds values of the healthy tablets. It is unset * if the tablet type is primary. * * @generated from field: uint32 replication_lag_seconds_min = 3; */ replicationLagSecondsMin: number; /** * replication_lag_seconds_max is the maximum of the * replication_lag_seconds values of the healthy tablets. It is unset * if the tablet type is primary. * * @generated from field: uint32 replication_lag_seconds_max = 4; */ replicationLagSecondsMax: number; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.AggregateStats"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): AggregateStats; static fromJson(jsonValue: JsonValue, options?: Partial): AggregateStats; static fromJsonString(jsonString: string, options?: Partial): AggregateStats; static equals(a: AggregateStats | PlainMessage | undefined, b: AggregateStats | PlainMessage | undefined): boolean; } /** * StreamHealthResponse is streamed by StreamHealth on a regular basis. * It is expected to be used between a vtgate and vttablet: * - target describes the tablet. * - realtime_stats is set. * - aggregate_stats is not set (deprecated) * * @generated from message query.StreamHealthResponse */ export declare class StreamHealthResponse extends Message { /** * target is the current server type. Only queries with that exact Target * record will be accepted (the cell may not match, however). * * @generated from field: query.Target target = 1; */ target?: Target; /** * serving is true iff the tablet is serving. A tablet may not be serving * if filtered replication is enabled on a primary for instance, * or if a replica should not be used because the keyspace is being resharded. * * @generated from field: bool serving = 2; */ serving: boolean; /** * primary_term_start_timestamp can be interpreted as the * last time we knew that this tablet was promoted to a PRIMARY of this shard * (if StreamHealthResponse describes a group of tablets, between * two vtgates, only one primary will be present in the group, and * this is this primary's value). * * It is used by vtgate when determining the current PRIMARY of a shard. * If vtgate sees more than one PRIMARY tablet, this timestamp is used * as tiebreaker where the PRIMARY with the highest timestamp wins. * Another usage of this timestamp is in go/vt/vtgate/buffer to detect the end * of a reparent (failover) and stop buffering. * * In practice, this field is set to: * a) the last time the RPC tabletmanager.TabletExternallyReparented was * called on this tablet (usually done by an external failover tool e.g. * Orchestrator). The failover tool can call this as long as we are the * primary i.e. even ages after the last reparent occurred. * OR * b) the last time an active reparent was executed through a vtctl command * (InitShardPrimary, PlannedReparentShard, EmergencyReparentShard) * OR * c) the last time vttablet was started and it initialized its tablet type * as PRIMARY because it was recorded as the shard's current primary in the * topology (see go/vt/vttablet/tabletmanager/init_tablet.go) * OR * d) 0 if the vttablet is not a PRIMARY. * * @generated from field: int64 primary_term_start_timestamp = 3; */ primaryTermStartTimestamp: bigint; /** * realtime_stats contains information about the tablet status. * It is only filled in if the information is about a tablet. * * @generated from field: query.RealtimeStats realtime_stats = 4; */ realtimeStats?: RealtimeStats; /** * tablet_alias is the alias of the sending tablet. The discovery/healthcheck.go * code uses it to verify that it's talking to the correct tablet and that it * hasn't changed in the meantime e.g. due to tablet restarts where ports or * ips have been reused but assigned differently. * * @generated from field: topodata.TabletAlias tablet_alias = 5; */ tabletAlias?: TabletAlias; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.StreamHealthResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): StreamHealthResponse; static fromJson(jsonValue: JsonValue, options?: Partial): StreamHealthResponse; static fromJsonString(jsonString: string, options?: Partial): StreamHealthResponse; static equals(a: StreamHealthResponse | PlainMessage | undefined, b: StreamHealthResponse | PlainMessage | undefined): boolean; } /** * TransactionMetadata contains the metadata for a distributed transaction. * * @generated from message query.TransactionMetadata */ export declare class TransactionMetadata extends Message { /** * @generated from field: string dtid = 1; */ dtid: string; /** * @generated from field: query.TransactionState state = 2; */ state: TransactionState; /** * @generated from field: int64 time_created = 3; */ timeCreated: bigint; /** * @generated from field: repeated query.Target participants = 4; */ participants: Target[]; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.TransactionMetadata"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): TransactionMetadata; static fromJson(jsonValue: JsonValue, options?: Partial): TransactionMetadata; static fromJsonString(jsonString: string, options?: Partial): TransactionMetadata; static equals(a: TransactionMetadata | PlainMessage | undefined, b: TransactionMetadata | PlainMessage | undefined): boolean; } /** * GetSchemaRequest is the payload to GetSchema * * @generated from message query.GetSchemaRequest */ export declare class GetSchemaRequest extends Message { /** * @generated from field: query.Target target = 1; */ target?: Target; /** * @generated from field: query.SchemaTableType table_type = 2; */ tableType: SchemaTableType; /** * @generated from field: repeated string table_names = 3; */ tableNames: string[]; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.GetSchemaRequest"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): GetSchemaRequest; static fromJson(jsonValue: JsonValue, options?: Partial): GetSchemaRequest; static fromJsonString(jsonString: string, options?: Partial): GetSchemaRequest; static equals(a: GetSchemaRequest | PlainMessage | undefined, b: GetSchemaRequest | PlainMessage | undefined): boolean; } /** * UDFInfo represents the information about a UDF. * * @generated from message query.UDFInfo */ export declare class UDFInfo extends Message { /** * @generated from field: string name = 1; */ name: string; /** * @generated from field: bool aggregating = 2; */ aggregating: boolean; /** * @generated from field: query.Type return_type = 3; */ returnType: Type; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.UDFInfo"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): UDFInfo; static fromJson(jsonValue: JsonValue, options?: Partial): UDFInfo; static fromJsonString(jsonString: string, options?: Partial): UDFInfo; static equals(a: UDFInfo | PlainMessage | undefined, b: UDFInfo | PlainMessage | undefined): boolean; } /** * GetSchemaResponse is the returned value from GetSchema * * @generated from message query.GetSchemaResponse */ export declare class GetSchemaResponse extends Message { /** * @generated from field: repeated query.UDFInfo udfs = 1; */ udfs: UDFInfo[]; /** * this is for the schema definition for the requested tables and views. * * @generated from field: map table_definition = 2; */ tableDefinition: { [key: string]: string; }; constructor(data?: PartialMessage); static readonly runtime: typeof proto3; static readonly typeName = "query.GetSchemaResponse"; static readonly fields: FieldList; static fromBinary(bytes: Uint8Array, options?: Partial): GetSchemaResponse; static fromJson(jsonValue: JsonValue, options?: Partial): GetSchemaResponse; static fromJsonString(jsonString: string, options?: Partial): GetSchemaResponse; static equals(a: GetSchemaResponse | PlainMessage | undefined, b: GetSchemaResponse | PlainMessage | undefined): boolean; }