= ({ keyspace, clusterID }
isOpen={currentDialog === 'Validate Schema'}
body={
- Validates that the schema on the primary tablet for shard 0 matches the schema on all of the
- other tablets in the keyspace {keyspace}.
+ Validates that the schema on the primary tablet for the first shard matches the schema on all of
+ the other tablets in the keyspace {keyspace}.
}
successBody={
diff --git a/web/vtadmin/src/proto/vtadmin.d.ts b/web/vtadmin/src/proto/vtadmin.d.ts
index 0e6790010bc..4411c436083 100644
--- a/web/vtadmin/src/proto/vtadmin.d.ts
+++ b/web/vtadmin/src/proto/vtadmin.d.ts
@@ -31327,9 +31327,6 @@ export namespace tabletmanagerdata {
/** BackupRequest backup_engine. */
public backup_engine?: (string|null);
- /** BackupRequest _backup_engine. */
- public _backup_engine?: "backup_engine";
-
/**
* Creates a new BackupRequest instance using the specified properties.
* @param [properties] Properties to set
@@ -33948,9 +33945,6 @@ export namespace tabletmanagerdata {
/** VDiffCoreOptions auto_start. */
public auto_start?: (boolean|null);
- /** VDiffCoreOptions _auto_start. */
- public _auto_start?: "auto_start";
-
/**
* Creates a new VDiffCoreOptions instance using the specified properties.
* @param [properties] Properties to set
@@ -34163,9 +34157,6 @@ export namespace tabletmanagerdata {
/** VDiffTableLastPK source. */
public source?: (query.IQueryResult|null);
- /** VDiffTableLastPK _source. */
- public _source?: "source";
-
/**
* Creates a new VDiffTableLastPK instance using the specified properties.
* @param [properties] Properties to set
@@ -34265,8 +34256,14 @@ export namespace tabletmanagerdata {
/** UpdateVReplicationWorkflowRequest state */
state?: (binlogdata.VReplicationWorkflowState|null);
+ /** UpdateVReplicationWorkflowRequest shards */
+ shards?: (string[]|null);
+
/** UpdateVReplicationWorkflowRequest config_overrides */
config_overrides?: ({ [k: string]: string }|null);
+
+ /** UpdateVReplicationWorkflowRequest message */
+ message?: (string|null);
}
/** Represents an UpdateVReplicationWorkflowRequest. */
@@ -34296,17 +34293,14 @@ export namespace tabletmanagerdata {
/** UpdateVReplicationWorkflowRequest state. */
public state?: (binlogdata.VReplicationWorkflowState|null);
+ /** UpdateVReplicationWorkflowRequest shards. */
+ public shards: string[];
+
/** UpdateVReplicationWorkflowRequest config_overrides. */
public config_overrides: { [k: string]: string };
- /** UpdateVReplicationWorkflowRequest _tablet_selection_preference. */
- public _tablet_selection_preference?: "tablet_selection_preference";
-
- /** UpdateVReplicationWorkflowRequest _on_ddl. */
- public _on_ddl?: "on_ddl";
-
- /** UpdateVReplicationWorkflowRequest _state. */
- public _state?: "state";
+ /** UpdateVReplicationWorkflowRequest message. */
+ public message?: (string|null);
/**
* Creates a new UpdateVReplicationWorkflowRequest instance using the specified properties.
@@ -34532,15 +34526,6 @@ export namespace tabletmanagerdata {
/** UpdateVReplicationWorkflowsRequest stop_position. */
public stop_position?: (string|null);
- /** UpdateVReplicationWorkflowsRequest _state. */
- public _state?: "state";
-
- /** UpdateVReplicationWorkflowsRequest _message. */
- public _message?: "message";
-
- /** UpdateVReplicationWorkflowsRequest _stop_position. */
- public _stop_position?: "stop_position";
-
/**
* Creates a new UpdateVReplicationWorkflowsRequest instance using the specified properties.
* @param [properties] Properties to set
@@ -49731,9 +49716,6 @@ export namespace vschema {
/** Column values. */
public values: string[];
- /** Column _nullable. */
- public _nullable?: "nullable";
-
/**
* Creates a new Column instance using the specified properties.
* @param [properties] Properties to set
@@ -54403,9 +54385,6 @@ export namespace vtctldata {
/** BackupRequest backup_engine. */
public backup_engine?: (string|null);
- /** BackupRequest _backup_engine. */
- public _backup_engine?: "backup_engine";
-
/**
* Creates a new BackupRequest instance using the specified properties.
* @param [properties] Properties to set
@@ -55980,6 +55959,236 @@ export namespace vtctldata {
public static getTypeUrl(typeUrlPrefix?: string): string;
}
+ /** Properties of a CopySchemaShardRequest. */
+ interface ICopySchemaShardRequest {
+
+ /** CopySchemaShardRequest source_tablet_alias */
+ source_tablet_alias?: (topodata.ITabletAlias|null);
+
+ /** CopySchemaShardRequest tables */
+ tables?: (string[]|null);
+
+ /** CopySchemaShardRequest exclude_tables */
+ exclude_tables?: (string[]|null);
+
+ /** CopySchemaShardRequest include_views */
+ include_views?: (boolean|null);
+
+ /** CopySchemaShardRequest skip_verify */
+ skip_verify?: (boolean|null);
+
+ /** CopySchemaShardRequest wait_replicas_timeout */
+ wait_replicas_timeout?: (vttime.IDuration|null);
+
+ /** CopySchemaShardRequest destination_keyspace */
+ destination_keyspace?: (string|null);
+
+ /** CopySchemaShardRequest destination_shard */
+ destination_shard?: (string|null);
+ }
+
+ /** Represents a CopySchemaShardRequest. */
+ class CopySchemaShardRequest implements ICopySchemaShardRequest {
+
+ /**
+ * Constructs a new CopySchemaShardRequest.
+ * @param [properties] Properties to set
+ */
+ constructor(properties?: vtctldata.ICopySchemaShardRequest);
+
+ /** CopySchemaShardRequest source_tablet_alias. */
+ public source_tablet_alias?: (topodata.ITabletAlias|null);
+
+ /** CopySchemaShardRequest tables. */
+ public tables: string[];
+
+ /** CopySchemaShardRequest exclude_tables. */
+ public exclude_tables: string[];
+
+ /** CopySchemaShardRequest include_views. */
+ public include_views: boolean;
+
+ /** CopySchemaShardRequest skip_verify. */
+ public skip_verify: boolean;
+
+ /** CopySchemaShardRequest wait_replicas_timeout. */
+ public wait_replicas_timeout?: (vttime.IDuration|null);
+
+ /** CopySchemaShardRequest destination_keyspace. */
+ public destination_keyspace: string;
+
+ /** CopySchemaShardRequest destination_shard. */
+ public destination_shard: string;
+
+ /**
+ * Creates a new CopySchemaShardRequest instance using the specified properties.
+ * @param [properties] Properties to set
+ * @returns CopySchemaShardRequest instance
+ */
+ public static create(properties?: vtctldata.ICopySchemaShardRequest): vtctldata.CopySchemaShardRequest;
+
+ /**
+ * Encodes the specified CopySchemaShardRequest message. Does not implicitly {@link vtctldata.CopySchemaShardRequest.verify|verify} messages.
+ * @param message CopySchemaShardRequest message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encode(message: vtctldata.ICopySchemaShardRequest, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Encodes the specified CopySchemaShardRequest message, length delimited. Does not implicitly {@link vtctldata.CopySchemaShardRequest.verify|verify} messages.
+ * @param message CopySchemaShardRequest message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encodeDelimited(message: vtctldata.ICopySchemaShardRequest, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Decodes a CopySchemaShardRequest message from the specified reader or buffer.
+ * @param reader Reader or buffer to decode from
+ * @param [length] Message length if known beforehand
+ * @returns CopySchemaShardRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): vtctldata.CopySchemaShardRequest;
+
+ /**
+ * Decodes a CopySchemaShardRequest message from the specified reader or buffer, length delimited.
+ * @param reader Reader or buffer to decode from
+ * @returns CopySchemaShardRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): vtctldata.CopySchemaShardRequest;
+
+ /**
+ * Verifies a CopySchemaShardRequest message.
+ * @param message Plain object to verify
+ * @returns `null` if valid, otherwise the reason why it is not
+ */
+ public static verify(message: { [k: string]: any }): (string|null);
+
+ /**
+ * Creates a CopySchemaShardRequest message from a plain object. Also converts values to their respective internal types.
+ * @param object Plain object
+ * @returns CopySchemaShardRequest
+ */
+ public static fromObject(object: { [k: string]: any }): vtctldata.CopySchemaShardRequest;
+
+ /**
+ * Creates a plain object from a CopySchemaShardRequest message. Also converts values to other types if specified.
+ * @param message CopySchemaShardRequest
+ * @param [options] Conversion options
+ * @returns Plain object
+ */
+ public static toObject(message: vtctldata.CopySchemaShardRequest, options?: $protobuf.IConversionOptions): { [k: string]: any };
+
+ /**
+ * Converts this CopySchemaShardRequest to JSON.
+ * @returns JSON object
+ */
+ public toJSON(): { [k: string]: any };
+
+ /**
+ * Gets the default type url for CopySchemaShardRequest
+ * @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns The default type url
+ */
+ public static getTypeUrl(typeUrlPrefix?: string): string;
+ }
+
+ /** Properties of a CopySchemaShardResponse. */
+ interface ICopySchemaShardResponse {
+ }
+
+ /** Represents a CopySchemaShardResponse. */
+ class CopySchemaShardResponse implements ICopySchemaShardResponse {
+
+ /**
+ * Constructs a new CopySchemaShardResponse.
+ * @param [properties] Properties to set
+ */
+ constructor(properties?: vtctldata.ICopySchemaShardResponse);
+
+ /**
+ * Creates a new CopySchemaShardResponse instance using the specified properties.
+ * @param [properties] Properties to set
+ * @returns CopySchemaShardResponse instance
+ */
+ public static create(properties?: vtctldata.ICopySchemaShardResponse): vtctldata.CopySchemaShardResponse;
+
+ /**
+ * Encodes the specified CopySchemaShardResponse message. Does not implicitly {@link vtctldata.CopySchemaShardResponse.verify|verify} messages.
+ * @param message CopySchemaShardResponse message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encode(message: vtctldata.ICopySchemaShardResponse, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Encodes the specified CopySchemaShardResponse message, length delimited. Does not implicitly {@link vtctldata.CopySchemaShardResponse.verify|verify} messages.
+ * @param message CopySchemaShardResponse message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encodeDelimited(message: vtctldata.ICopySchemaShardResponse, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Decodes a CopySchemaShardResponse message from the specified reader or buffer.
+ * @param reader Reader or buffer to decode from
+ * @param [length] Message length if known beforehand
+ * @returns CopySchemaShardResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): vtctldata.CopySchemaShardResponse;
+
+ /**
+ * Decodes a CopySchemaShardResponse message from the specified reader or buffer, length delimited.
+ * @param reader Reader or buffer to decode from
+ * @returns CopySchemaShardResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): vtctldata.CopySchemaShardResponse;
+
+ /**
+ * Verifies a CopySchemaShardResponse message.
+ * @param message Plain object to verify
+ * @returns `null` if valid, otherwise the reason why it is not
+ */
+ public static verify(message: { [k: string]: any }): (string|null);
+
+ /**
+ * Creates a CopySchemaShardResponse message from a plain object. Also converts values to their respective internal types.
+ * @param object Plain object
+ * @returns CopySchemaShardResponse
+ */
+ public static fromObject(object: { [k: string]: any }): vtctldata.CopySchemaShardResponse;
+
+ /**
+ * Creates a plain object from a CopySchemaShardResponse message. Also converts values to other types if specified.
+ * @param message CopySchemaShardResponse
+ * @param [options] Conversion options
+ * @returns Plain object
+ */
+ public static toObject(message: vtctldata.CopySchemaShardResponse, options?: $protobuf.IConversionOptions): { [k: string]: any };
+
+ /**
+ * Converts this CopySchemaShardResponse to JSON.
+ * @returns JSON object
+ */
+ public toJSON(): { [k: string]: any };
+
+ /**
+ * Gets the default type url for CopySchemaShardResponse
+ * @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns The default type url
+ */
+ public static getTypeUrl(typeUrlPrefix?: string): string;
+ }
+
/** Properties of a CreateKeyspaceRequest. */
interface ICreateKeyspaceRequest {
@@ -65920,6 +66129,206 @@ export namespace vtctldata {
public static getTypeUrl(typeUrlPrefix?: string): string;
}
+ /** Properties of a LookupVindexCompleteRequest. */
+ interface ILookupVindexCompleteRequest {
+
+ /** LookupVindexCompleteRequest keyspace */
+ keyspace?: (string|null);
+
+ /** LookupVindexCompleteRequest name */
+ name?: (string|null);
+
+ /** LookupVindexCompleteRequest table_keyspace */
+ table_keyspace?: (string|null);
+ }
+
+ /** Represents a LookupVindexCompleteRequest. */
+ class LookupVindexCompleteRequest implements ILookupVindexCompleteRequest {
+
+ /**
+ * Constructs a new LookupVindexCompleteRequest.
+ * @param [properties] Properties to set
+ */
+ constructor(properties?: vtctldata.ILookupVindexCompleteRequest);
+
+ /** LookupVindexCompleteRequest keyspace. */
+ public keyspace: string;
+
+ /** LookupVindexCompleteRequest name. */
+ public name: string;
+
+ /** LookupVindexCompleteRequest table_keyspace. */
+ public table_keyspace: string;
+
+ /**
+ * Creates a new LookupVindexCompleteRequest instance using the specified properties.
+ * @param [properties] Properties to set
+ * @returns LookupVindexCompleteRequest instance
+ */
+ public static create(properties?: vtctldata.ILookupVindexCompleteRequest): vtctldata.LookupVindexCompleteRequest;
+
+ /**
+ * Encodes the specified LookupVindexCompleteRequest message. Does not implicitly {@link vtctldata.LookupVindexCompleteRequest.verify|verify} messages.
+ * @param message LookupVindexCompleteRequest message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encode(message: vtctldata.ILookupVindexCompleteRequest, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Encodes the specified LookupVindexCompleteRequest message, length delimited. Does not implicitly {@link vtctldata.LookupVindexCompleteRequest.verify|verify} messages.
+ * @param message LookupVindexCompleteRequest message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encodeDelimited(message: vtctldata.ILookupVindexCompleteRequest, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Decodes a LookupVindexCompleteRequest message from the specified reader or buffer.
+ * @param reader Reader or buffer to decode from
+ * @param [length] Message length if known beforehand
+ * @returns LookupVindexCompleteRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): vtctldata.LookupVindexCompleteRequest;
+
+ /**
+ * Decodes a LookupVindexCompleteRequest message from the specified reader or buffer, length delimited.
+ * @param reader Reader or buffer to decode from
+ * @returns LookupVindexCompleteRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): vtctldata.LookupVindexCompleteRequest;
+
+ /**
+ * Verifies a LookupVindexCompleteRequest message.
+ * @param message Plain object to verify
+ * @returns `null` if valid, otherwise the reason why it is not
+ */
+ public static verify(message: { [k: string]: any }): (string|null);
+
+ /**
+ * Creates a LookupVindexCompleteRequest message from a plain object. Also converts values to their respective internal types.
+ * @param object Plain object
+ * @returns LookupVindexCompleteRequest
+ */
+ public static fromObject(object: { [k: string]: any }): vtctldata.LookupVindexCompleteRequest;
+
+ /**
+ * Creates a plain object from a LookupVindexCompleteRequest message. Also converts values to other types if specified.
+ * @param message LookupVindexCompleteRequest
+ * @param [options] Conversion options
+ * @returns Plain object
+ */
+ public static toObject(message: vtctldata.LookupVindexCompleteRequest, options?: $protobuf.IConversionOptions): { [k: string]: any };
+
+ /**
+ * Converts this LookupVindexCompleteRequest to JSON.
+ * @returns JSON object
+ */
+ public toJSON(): { [k: string]: any };
+
+ /**
+ * Gets the default type url for LookupVindexCompleteRequest
+ * @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns The default type url
+ */
+ public static getTypeUrl(typeUrlPrefix?: string): string;
+ }
+
+ /** Properties of a LookupVindexCompleteResponse. */
+ interface ILookupVindexCompleteResponse {
+ }
+
+ /** Represents a LookupVindexCompleteResponse. */
+ class LookupVindexCompleteResponse implements ILookupVindexCompleteResponse {
+
+ /**
+ * Constructs a new LookupVindexCompleteResponse.
+ * @param [properties] Properties to set
+ */
+ constructor(properties?: vtctldata.ILookupVindexCompleteResponse);
+
+ /**
+ * Creates a new LookupVindexCompleteResponse instance using the specified properties.
+ * @param [properties] Properties to set
+ * @returns LookupVindexCompleteResponse instance
+ */
+ public static create(properties?: vtctldata.ILookupVindexCompleteResponse): vtctldata.LookupVindexCompleteResponse;
+
+ /**
+ * Encodes the specified LookupVindexCompleteResponse message. Does not implicitly {@link vtctldata.LookupVindexCompleteResponse.verify|verify} messages.
+ * @param message LookupVindexCompleteResponse message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encode(message: vtctldata.ILookupVindexCompleteResponse, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Encodes the specified LookupVindexCompleteResponse message, length delimited. Does not implicitly {@link vtctldata.LookupVindexCompleteResponse.verify|verify} messages.
+ * @param message LookupVindexCompleteResponse message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encodeDelimited(message: vtctldata.ILookupVindexCompleteResponse, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Decodes a LookupVindexCompleteResponse message from the specified reader or buffer.
+ * @param reader Reader or buffer to decode from
+ * @param [length] Message length if known beforehand
+ * @returns LookupVindexCompleteResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): vtctldata.LookupVindexCompleteResponse;
+
+ /**
+ * Decodes a LookupVindexCompleteResponse message from the specified reader or buffer, length delimited.
+ * @param reader Reader or buffer to decode from
+ * @returns LookupVindexCompleteResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): vtctldata.LookupVindexCompleteResponse;
+
+ /**
+ * Verifies a LookupVindexCompleteResponse message.
+ * @param message Plain object to verify
+ * @returns `null` if valid, otherwise the reason why it is not
+ */
+ public static verify(message: { [k: string]: any }): (string|null);
+
+ /**
+ * Creates a LookupVindexCompleteResponse message from a plain object. Also converts values to their respective internal types.
+ * @param object Plain object
+ * @returns LookupVindexCompleteResponse
+ */
+ public static fromObject(object: { [k: string]: any }): vtctldata.LookupVindexCompleteResponse;
+
+ /**
+ * Creates a plain object from a LookupVindexCompleteResponse message. Also converts values to other types if specified.
+ * @param message LookupVindexCompleteResponse
+ * @param [options] Conversion options
+ * @returns Plain object
+ */
+ public static toObject(message: vtctldata.LookupVindexCompleteResponse, options?: $protobuf.IConversionOptions): { [k: string]: any };
+
+ /**
+ * Converts this LookupVindexCompleteResponse to JSON.
+ * @returns JSON object
+ */
+ public toJSON(): { [k: string]: any };
+
+ /**
+ * Gets the default type url for LookupVindexCompleteResponse
+ * @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns The default type url
+ */
+ public static getTypeUrl(typeUrlPrefix?: string): string;
+ }
+
/** Properties of a LookupVindexCreateRequest. */
interface ILookupVindexCreateRequest {
@@ -66155,6 +66564,9 @@ export namespace vtctldata {
/** LookupVindexExternalizeRequest table_keyspace */
table_keyspace?: (string|null);
+
+ /** LookupVindexExternalizeRequest delete_workflow */
+ delete_workflow?: (boolean|null);
}
/** Represents a LookupVindexExternalizeRequest. */
@@ -66175,6 +66587,9 @@ export namespace vtctldata {
/** LookupVindexExternalizeRequest table_keyspace. */
public table_keyspace: string;
+ /** LookupVindexExternalizeRequest delete_workflow. */
+ public delete_workflow: boolean;
+
/**
* Creates a new LookupVindexExternalizeRequest instance using the specified properties.
* @param [properties] Properties to set
@@ -66256,6 +66671,9 @@ export namespace vtctldata {
/** Properties of a LookupVindexExternalizeResponse. */
interface ILookupVindexExternalizeResponse {
+ /** LookupVindexExternalizeResponse workflow_stopped */
+ workflow_stopped?: (boolean|null);
+
/** LookupVindexExternalizeResponse workflow_deleted */
workflow_deleted?: (boolean|null);
}
@@ -66269,6 +66687,9 @@ export namespace vtctldata {
*/
constructor(properties?: vtctldata.ILookupVindexExternalizeResponse);
+ /** LookupVindexExternalizeResponse workflow_stopped. */
+ public workflow_stopped: boolean;
+
/** LookupVindexExternalizeResponse workflow_deleted. */
public workflow_deleted: boolean;
@@ -66350,6 +66771,206 @@ export namespace vtctldata {
public static getTypeUrl(typeUrlPrefix?: string): string;
}
+ /** Properties of a LookupVindexInternalizeRequest. */
+ interface ILookupVindexInternalizeRequest {
+
+ /** LookupVindexInternalizeRequest keyspace */
+ keyspace?: (string|null);
+
+ /** LookupVindexInternalizeRequest name */
+ name?: (string|null);
+
+ /** LookupVindexInternalizeRequest table_keyspace */
+ table_keyspace?: (string|null);
+ }
+
+ /** Represents a LookupVindexInternalizeRequest. */
+ class LookupVindexInternalizeRequest implements ILookupVindexInternalizeRequest {
+
+ /**
+ * Constructs a new LookupVindexInternalizeRequest.
+ * @param [properties] Properties to set
+ */
+ constructor(properties?: vtctldata.ILookupVindexInternalizeRequest);
+
+ /** LookupVindexInternalizeRequest keyspace. */
+ public keyspace: string;
+
+ /** LookupVindexInternalizeRequest name. */
+ public name: string;
+
+ /** LookupVindexInternalizeRequest table_keyspace. */
+ public table_keyspace: string;
+
+ /**
+ * Creates a new LookupVindexInternalizeRequest instance using the specified properties.
+ * @param [properties] Properties to set
+ * @returns LookupVindexInternalizeRequest instance
+ */
+ public static create(properties?: vtctldata.ILookupVindexInternalizeRequest): vtctldata.LookupVindexInternalizeRequest;
+
+ /**
+ * Encodes the specified LookupVindexInternalizeRequest message. Does not implicitly {@link vtctldata.LookupVindexInternalizeRequest.verify|verify} messages.
+ * @param message LookupVindexInternalizeRequest message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encode(message: vtctldata.ILookupVindexInternalizeRequest, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Encodes the specified LookupVindexInternalizeRequest message, length delimited. Does not implicitly {@link vtctldata.LookupVindexInternalizeRequest.verify|verify} messages.
+ * @param message LookupVindexInternalizeRequest message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encodeDelimited(message: vtctldata.ILookupVindexInternalizeRequest, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Decodes a LookupVindexInternalizeRequest message from the specified reader or buffer.
+ * @param reader Reader or buffer to decode from
+ * @param [length] Message length if known beforehand
+ * @returns LookupVindexInternalizeRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): vtctldata.LookupVindexInternalizeRequest;
+
+ /**
+ * Decodes a LookupVindexInternalizeRequest message from the specified reader or buffer, length delimited.
+ * @param reader Reader or buffer to decode from
+ * @returns LookupVindexInternalizeRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): vtctldata.LookupVindexInternalizeRequest;
+
+ /**
+ * Verifies a LookupVindexInternalizeRequest message.
+ * @param message Plain object to verify
+ * @returns `null` if valid, otherwise the reason why it is not
+ */
+ public static verify(message: { [k: string]: any }): (string|null);
+
+ /**
+ * Creates a LookupVindexInternalizeRequest message from a plain object. Also converts values to their respective internal types.
+ * @param object Plain object
+ * @returns LookupVindexInternalizeRequest
+ */
+ public static fromObject(object: { [k: string]: any }): vtctldata.LookupVindexInternalizeRequest;
+
+ /**
+ * Creates a plain object from a LookupVindexInternalizeRequest message. Also converts values to other types if specified.
+ * @param message LookupVindexInternalizeRequest
+ * @param [options] Conversion options
+ * @returns Plain object
+ */
+ public static toObject(message: vtctldata.LookupVindexInternalizeRequest, options?: $protobuf.IConversionOptions): { [k: string]: any };
+
+ /**
+ * Converts this LookupVindexInternalizeRequest to JSON.
+ * @returns JSON object
+ */
+ public toJSON(): { [k: string]: any };
+
+ /**
+ * Gets the default type url for LookupVindexInternalizeRequest
+ * @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns The default type url
+ */
+ public static getTypeUrl(typeUrlPrefix?: string): string;
+ }
+
+ /** Properties of a LookupVindexInternalizeResponse. */
+ interface ILookupVindexInternalizeResponse {
+ }
+
+ /** Represents a LookupVindexInternalizeResponse. */
+ class LookupVindexInternalizeResponse implements ILookupVindexInternalizeResponse {
+
+ /**
+ * Constructs a new LookupVindexInternalizeResponse.
+ * @param [properties] Properties to set
+ */
+ constructor(properties?: vtctldata.ILookupVindexInternalizeResponse);
+
+ /**
+ * Creates a new LookupVindexInternalizeResponse instance using the specified properties.
+ * @param [properties] Properties to set
+ * @returns LookupVindexInternalizeResponse instance
+ */
+ public static create(properties?: vtctldata.ILookupVindexInternalizeResponse): vtctldata.LookupVindexInternalizeResponse;
+
+ /**
+ * Encodes the specified LookupVindexInternalizeResponse message. Does not implicitly {@link vtctldata.LookupVindexInternalizeResponse.verify|verify} messages.
+ * @param message LookupVindexInternalizeResponse message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encode(message: vtctldata.ILookupVindexInternalizeResponse, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Encodes the specified LookupVindexInternalizeResponse message, length delimited. Does not implicitly {@link vtctldata.LookupVindexInternalizeResponse.verify|verify} messages.
+ * @param message LookupVindexInternalizeResponse message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encodeDelimited(message: vtctldata.ILookupVindexInternalizeResponse, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Decodes a LookupVindexInternalizeResponse message from the specified reader or buffer.
+ * @param reader Reader or buffer to decode from
+ * @param [length] Message length if known beforehand
+ * @returns LookupVindexInternalizeResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): vtctldata.LookupVindexInternalizeResponse;
+
+ /**
+ * Decodes a LookupVindexInternalizeResponse message from the specified reader or buffer, length delimited.
+ * @param reader Reader or buffer to decode from
+ * @returns LookupVindexInternalizeResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): vtctldata.LookupVindexInternalizeResponse;
+
+ /**
+ * Verifies a LookupVindexInternalizeResponse message.
+ * @param message Plain object to verify
+ * @returns `null` if valid, otherwise the reason why it is not
+ */
+ public static verify(message: { [k: string]: any }): (string|null);
+
+ /**
+ * Creates a LookupVindexInternalizeResponse message from a plain object. Also converts values to their respective internal types.
+ * @param object Plain object
+ * @returns LookupVindexInternalizeResponse
+ */
+ public static fromObject(object: { [k: string]: any }): vtctldata.LookupVindexInternalizeResponse;
+
+ /**
+ * Creates a plain object from a LookupVindexInternalizeResponse message. Also converts values to other types if specified.
+ * @param message LookupVindexInternalizeResponse
+ * @param [options] Conversion options
+ * @returns Plain object
+ */
+ public static toObject(message: vtctldata.LookupVindexInternalizeResponse, options?: $protobuf.IConversionOptions): { [k: string]: any };
+
+ /**
+ * Converts this LookupVindexInternalizeResponse to JSON.
+ * @returns JSON object
+ */
+ public toJSON(): { [k: string]: any };
+
+ /**
+ * Gets the default type url for LookupVindexInternalizeResponse
+ * @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns The default type url
+ */
+ public static getTypeUrl(typeUrlPrefix?: string): string;
+ }
+
/** Properties of a MaterializeCreateRequest. */
interface IMaterializeCreateRequest {
@@ -75760,6 +76381,200 @@ export namespace vtctldata {
public static getTypeUrl(typeUrlPrefix?: string): string;
}
+ /** Properties of a ValidatePermissionsKeyspaceRequest. */
+ interface IValidatePermissionsKeyspaceRequest {
+
+ /** ValidatePermissionsKeyspaceRequest keyspace */
+ keyspace?: (string|null);
+
+ /** ValidatePermissionsKeyspaceRequest shards */
+ shards?: (string[]|null);
+ }
+
+ /** Represents a ValidatePermissionsKeyspaceRequest. */
+ class ValidatePermissionsKeyspaceRequest implements IValidatePermissionsKeyspaceRequest {
+
+ /**
+ * Constructs a new ValidatePermissionsKeyspaceRequest.
+ * @param [properties] Properties to set
+ */
+ constructor(properties?: vtctldata.IValidatePermissionsKeyspaceRequest);
+
+ /** ValidatePermissionsKeyspaceRequest keyspace. */
+ public keyspace: string;
+
+ /** ValidatePermissionsKeyspaceRequest shards. */
+ public shards: string[];
+
+ /**
+ * Creates a new ValidatePermissionsKeyspaceRequest instance using the specified properties.
+ * @param [properties] Properties to set
+ * @returns ValidatePermissionsKeyspaceRequest instance
+ */
+ public static create(properties?: vtctldata.IValidatePermissionsKeyspaceRequest): vtctldata.ValidatePermissionsKeyspaceRequest;
+
+ /**
+ * Encodes the specified ValidatePermissionsKeyspaceRequest message. Does not implicitly {@link vtctldata.ValidatePermissionsKeyspaceRequest.verify|verify} messages.
+ * @param message ValidatePermissionsKeyspaceRequest message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encode(message: vtctldata.IValidatePermissionsKeyspaceRequest, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Encodes the specified ValidatePermissionsKeyspaceRequest message, length delimited. Does not implicitly {@link vtctldata.ValidatePermissionsKeyspaceRequest.verify|verify} messages.
+ * @param message ValidatePermissionsKeyspaceRequest message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encodeDelimited(message: vtctldata.IValidatePermissionsKeyspaceRequest, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Decodes a ValidatePermissionsKeyspaceRequest message from the specified reader or buffer.
+ * @param reader Reader or buffer to decode from
+ * @param [length] Message length if known beforehand
+ * @returns ValidatePermissionsKeyspaceRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): vtctldata.ValidatePermissionsKeyspaceRequest;
+
+ /**
+ * Decodes a ValidatePermissionsKeyspaceRequest message from the specified reader or buffer, length delimited.
+ * @param reader Reader or buffer to decode from
+ * @returns ValidatePermissionsKeyspaceRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): vtctldata.ValidatePermissionsKeyspaceRequest;
+
+ /**
+ * Verifies a ValidatePermissionsKeyspaceRequest message.
+ * @param message Plain object to verify
+ * @returns `null` if valid, otherwise the reason why it is not
+ */
+ public static verify(message: { [k: string]: any }): (string|null);
+
+ /**
+ * Creates a ValidatePermissionsKeyspaceRequest message from a plain object. Also converts values to their respective internal types.
+ * @param object Plain object
+ * @returns ValidatePermissionsKeyspaceRequest
+ */
+ public static fromObject(object: { [k: string]: any }): vtctldata.ValidatePermissionsKeyspaceRequest;
+
+ /**
+ * Creates a plain object from a ValidatePermissionsKeyspaceRequest message. Also converts values to other types if specified.
+ * @param message ValidatePermissionsKeyspaceRequest
+ * @param [options] Conversion options
+ * @returns Plain object
+ */
+ public static toObject(message: vtctldata.ValidatePermissionsKeyspaceRequest, options?: $protobuf.IConversionOptions): { [k: string]: any };
+
+ /**
+ * Converts this ValidatePermissionsKeyspaceRequest to JSON.
+ * @returns JSON object
+ */
+ public toJSON(): { [k: string]: any };
+
+ /**
+ * Gets the default type url for ValidatePermissionsKeyspaceRequest
+ * @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns The default type url
+ */
+ public static getTypeUrl(typeUrlPrefix?: string): string;
+ }
+
+ /** Properties of a ValidatePermissionsKeyspaceResponse. */
+ interface IValidatePermissionsKeyspaceResponse {
+ }
+
+ /** Represents a ValidatePermissionsKeyspaceResponse. */
+ class ValidatePermissionsKeyspaceResponse implements IValidatePermissionsKeyspaceResponse {
+
+ /**
+ * Constructs a new ValidatePermissionsKeyspaceResponse.
+ * @param [properties] Properties to set
+ */
+ constructor(properties?: vtctldata.IValidatePermissionsKeyspaceResponse);
+
+ /**
+ * Creates a new ValidatePermissionsKeyspaceResponse instance using the specified properties.
+ * @param [properties] Properties to set
+ * @returns ValidatePermissionsKeyspaceResponse instance
+ */
+ public static create(properties?: vtctldata.IValidatePermissionsKeyspaceResponse): vtctldata.ValidatePermissionsKeyspaceResponse;
+
+ /**
+ * Encodes the specified ValidatePermissionsKeyspaceResponse message. Does not implicitly {@link vtctldata.ValidatePermissionsKeyspaceResponse.verify|verify} messages.
+ * @param message ValidatePermissionsKeyspaceResponse message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encode(message: vtctldata.IValidatePermissionsKeyspaceResponse, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Encodes the specified ValidatePermissionsKeyspaceResponse message, length delimited. Does not implicitly {@link vtctldata.ValidatePermissionsKeyspaceResponse.verify|verify} messages.
+ * @param message ValidatePermissionsKeyspaceResponse message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encodeDelimited(message: vtctldata.IValidatePermissionsKeyspaceResponse, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Decodes a ValidatePermissionsKeyspaceResponse message from the specified reader or buffer.
+ * @param reader Reader or buffer to decode from
+ * @param [length] Message length if known beforehand
+ * @returns ValidatePermissionsKeyspaceResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): vtctldata.ValidatePermissionsKeyspaceResponse;
+
+ /**
+ * Decodes a ValidatePermissionsKeyspaceResponse message from the specified reader or buffer, length delimited.
+ * @param reader Reader or buffer to decode from
+ * @returns ValidatePermissionsKeyspaceResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): vtctldata.ValidatePermissionsKeyspaceResponse;
+
+ /**
+ * Verifies a ValidatePermissionsKeyspaceResponse message.
+ * @param message Plain object to verify
+ * @returns `null` if valid, otherwise the reason why it is not
+ */
+ public static verify(message: { [k: string]: any }): (string|null);
+
+ /**
+ * Creates a ValidatePermissionsKeyspaceResponse message from a plain object. Also converts values to their respective internal types.
+ * @param object Plain object
+ * @returns ValidatePermissionsKeyspaceResponse
+ */
+ public static fromObject(object: { [k: string]: any }): vtctldata.ValidatePermissionsKeyspaceResponse;
+
+ /**
+ * Creates a plain object from a ValidatePermissionsKeyspaceResponse message. Also converts values to other types if specified.
+ * @param message ValidatePermissionsKeyspaceResponse
+ * @param [options] Conversion options
+ * @returns Plain object
+ */
+ public static toObject(message: vtctldata.ValidatePermissionsKeyspaceResponse, options?: $protobuf.IConversionOptions): { [k: string]: any };
+
+ /**
+ * Converts this ValidatePermissionsKeyspaceResponse to JSON.
+ * @returns JSON object
+ */
+ public toJSON(): { [k: string]: any };
+
+ /**
+ * Gets the default type url for ValidatePermissionsKeyspaceResponse
+ * @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns The default type url
+ */
+ public static getTypeUrl(typeUrlPrefix?: string): string;
+ }
+
/** Properties of a ValidateSchemaKeyspaceRequest. */
interface IValidateSchemaKeyspaceRequest {
@@ -75777,6 +76592,9 @@ export namespace vtctldata {
/** ValidateSchemaKeyspaceRequest include_vschema */
include_vschema?: (boolean|null);
+
+ /** ValidateSchemaKeyspaceRequest shards */
+ shards?: (string[]|null);
}
/** Represents a ValidateSchemaKeyspaceRequest. */
@@ -75803,6 +76621,9 @@ export namespace vtctldata {
/** ValidateSchemaKeyspaceRequest include_vschema. */
public include_vschema: boolean;
+ /** ValidateSchemaKeyspaceRequest shards. */
+ public shards: string[];
+
/**
* Creates a new ValidateSchemaKeyspaceRequest instance using the specified properties.
* @param [properties] Properties to set
@@ -76953,9 +77774,6 @@ export namespace vtctldata {
/** VDiffCreateRequest auto_start. */
public auto_start?: (boolean|null);
- /** VDiffCreateRequest _auto_start. */
- public _auto_start?: "auto_start";
-
/**
* Creates a new VDiffCreateRequest instance using the specified properties.
* @param [properties] Properties to set
diff --git a/web/vtadmin/src/proto/vtadmin.js b/web/vtadmin/src/proto/vtadmin.js
index ed8ce616076..457ae6e4214 100644
--- a/web/vtadmin/src/proto/vtadmin.js
+++ b/web/vtadmin/src/proto/vtadmin.js
@@ -71242,12 +71242,7 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
// OneOf field names bound to virtual getters and setters
let $oneOfFields;
- /**
- * BackupRequest _backup_engine.
- * @member {"backup_engine"|undefined} _backup_engine
- * @memberof tabletmanagerdata.BackupRequest
- * @instance
- */
+ // Virtual OneOf for proto3 optional field
Object.defineProperty(BackupRequest.prototype, "_backup_engine", {
get: $util.oneOfGetter($oneOfFields = ["backup_engine"]),
set: $util.oneOfSetter($oneOfFields)
@@ -78250,12 +78245,7 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
// OneOf field names bound to virtual getters and setters
let $oneOfFields;
- /**
- * VDiffCoreOptions _auto_start.
- * @member {"auto_start"|undefined} _auto_start
- * @memberof tabletmanagerdata.VDiffCoreOptions
- * @instance
- */
+ // Virtual OneOf for proto3 optional field
Object.defineProperty(VDiffCoreOptions.prototype, "_auto_start", {
get: $util.oneOfGetter($oneOfFields = ["auto_start"]),
set: $util.oneOfSetter($oneOfFields)
@@ -78943,12 +78933,7 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
// OneOf field names bound to virtual getters and setters
let $oneOfFields;
- /**
- * VDiffTableLastPK _source.
- * @member {"source"|undefined} _source
- * @memberof tabletmanagerdata.VDiffTableLastPK
- * @instance
- */
+ // Virtual OneOf for proto3 optional field
Object.defineProperty(VDiffTableLastPK.prototype, "_source", {
get: $util.oneOfGetter($oneOfFields = ["source"]),
set: $util.oneOfSetter($oneOfFields)
@@ -79167,7 +79152,9 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
* @property {tabletmanagerdata.TabletSelectionPreference|null} [tablet_selection_preference] UpdateVReplicationWorkflowRequest tablet_selection_preference
* @property {binlogdata.OnDDLAction|null} [on_ddl] UpdateVReplicationWorkflowRequest on_ddl
* @property {binlogdata.VReplicationWorkflowState|null} [state] UpdateVReplicationWorkflowRequest state
+ * @property {Array.|null} [shards] UpdateVReplicationWorkflowRequest shards
* @property {Object.|null} [config_overrides] UpdateVReplicationWorkflowRequest config_overrides
+ * @property {string|null} [message] UpdateVReplicationWorkflowRequest message
*/
/**
@@ -79181,6 +79168,7 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
function UpdateVReplicationWorkflowRequest(properties) {
this.cells = [];
this.tablet_types = [];
+ this.shards = [];
this.config_overrides = {};
if (properties)
for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
@@ -79236,6 +79224,14 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
*/
UpdateVReplicationWorkflowRequest.prototype.state = null;
+ /**
+ * UpdateVReplicationWorkflowRequest shards.
+ * @member {Array.} shards
+ * @memberof tabletmanagerdata.UpdateVReplicationWorkflowRequest
+ * @instance
+ */
+ UpdateVReplicationWorkflowRequest.prototype.shards = $util.emptyArray;
+
/**
* UpdateVReplicationWorkflowRequest config_overrides.
* @member {Object.} config_overrides
@@ -79244,42 +79240,41 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
*/
UpdateVReplicationWorkflowRequest.prototype.config_overrides = $util.emptyObject;
- // OneOf field names bound to virtual getters and setters
- let $oneOfFields;
-
/**
- * UpdateVReplicationWorkflowRequest _tablet_selection_preference.
- * @member {"tablet_selection_preference"|undefined} _tablet_selection_preference
+ * UpdateVReplicationWorkflowRequest message.
+ * @member {string|null|undefined} message
* @memberof tabletmanagerdata.UpdateVReplicationWorkflowRequest
* @instance
*/
+ UpdateVReplicationWorkflowRequest.prototype.message = null;
+
+ // OneOf field names bound to virtual getters and setters
+ let $oneOfFields;
+
+ // Virtual OneOf for proto3 optional field
Object.defineProperty(UpdateVReplicationWorkflowRequest.prototype, "_tablet_selection_preference", {
get: $util.oneOfGetter($oneOfFields = ["tablet_selection_preference"]),
set: $util.oneOfSetter($oneOfFields)
});
- /**
- * UpdateVReplicationWorkflowRequest _on_ddl.
- * @member {"on_ddl"|undefined} _on_ddl
- * @memberof tabletmanagerdata.UpdateVReplicationWorkflowRequest
- * @instance
- */
+ // Virtual OneOf for proto3 optional field
Object.defineProperty(UpdateVReplicationWorkflowRequest.prototype, "_on_ddl", {
get: $util.oneOfGetter($oneOfFields = ["on_ddl"]),
set: $util.oneOfSetter($oneOfFields)
});
- /**
- * UpdateVReplicationWorkflowRequest _state.
- * @member {"state"|undefined} _state
- * @memberof tabletmanagerdata.UpdateVReplicationWorkflowRequest
- * @instance
- */
+ // Virtual OneOf for proto3 optional field
Object.defineProperty(UpdateVReplicationWorkflowRequest.prototype, "_state", {
get: $util.oneOfGetter($oneOfFields = ["state"]),
set: $util.oneOfSetter($oneOfFields)
});
+ // Virtual OneOf for proto3 optional field
+ Object.defineProperty(UpdateVReplicationWorkflowRequest.prototype, "_message", {
+ get: $util.oneOfGetter($oneOfFields = ["message"]),
+ set: $util.oneOfSetter($oneOfFields)
+ });
+
/**
* Creates a new UpdateVReplicationWorkflowRequest instance using the specified properties.
* @function create
@@ -79321,9 +79316,14 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
writer.uint32(/* id 5, wireType 0 =*/40).int32(message.on_ddl);
if (message.state != null && Object.hasOwnProperty.call(message, "state"))
writer.uint32(/* id 6, wireType 0 =*/48).int32(message.state);
+ if (message.shards != null && message.shards.length)
+ for (let i = 0; i < message.shards.length; ++i)
+ writer.uint32(/* id 7, wireType 2 =*/58).string(message.shards[i]);
if (message.config_overrides != null && Object.hasOwnProperty.call(message, "config_overrides"))
for (let keys = Object.keys(message.config_overrides), i = 0; i < keys.length; ++i)
writer.uint32(/* id 8, wireType 2 =*/66).fork().uint32(/* id 1, wireType 2 =*/10).string(keys[i]).uint32(/* id 2, wireType 2 =*/18).string(message.config_overrides[keys[i]]).ldelim();
+ if (message.message != null && Object.hasOwnProperty.call(message, "message"))
+ writer.uint32(/* id 9, wireType 2 =*/74).string(message.message);
return writer;
};
@@ -79391,6 +79391,12 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
message.state = reader.int32();
break;
}
+ case 7: {
+ if (!(message.shards && message.shards.length))
+ message.shards = [];
+ message.shards.push(reader.string());
+ break;
+ }
case 8: {
if (message.config_overrides === $util.emptyObject)
message.config_overrides = {};
@@ -79414,6 +79420,10 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
message.config_overrides[key] = value;
break;
}
+ case 9: {
+ message.message = reader.string();
+ break;
+ }
default:
reader.skipType(tag & 7);
break;
@@ -79519,6 +79529,13 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
break;
}
}
+ if (message.shards != null && message.hasOwnProperty("shards")) {
+ if (!Array.isArray(message.shards))
+ return "shards: array expected";
+ for (let i = 0; i < message.shards.length; ++i)
+ if (!$util.isString(message.shards[i]))
+ return "shards: string[] expected";
+ }
if (message.config_overrides != null && message.hasOwnProperty("config_overrides")) {
if (!$util.isObject(message.config_overrides))
return "config_overrides: object expected";
@@ -79527,6 +79544,11 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
if (!$util.isString(message.config_overrides[key[i]]))
return "config_overrides: string{k:string} expected";
}
+ if (message.message != null && message.hasOwnProperty("message")) {
+ properties._message = 1;
+ if (!$util.isString(message.message))
+ return "message: string expected";
+ }
return null;
};
@@ -79688,6 +79710,13 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
message.state = 6;
break;
}
+ if (object.shards) {
+ if (!Array.isArray(object.shards))
+ throw TypeError(".tabletmanagerdata.UpdateVReplicationWorkflowRequest.shards: array expected");
+ message.shards = [];
+ for (let i = 0; i < object.shards.length; ++i)
+ message.shards[i] = String(object.shards[i]);
+ }
if (object.config_overrides) {
if (typeof object.config_overrides !== "object")
throw TypeError(".tabletmanagerdata.UpdateVReplicationWorkflowRequest.config_overrides: object expected");
@@ -79695,6 +79724,8 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
for (let keys = Object.keys(object.config_overrides), i = 0; i < keys.length; ++i)
message.config_overrides[keys[i]] = String(object.config_overrides[keys[i]]);
}
+ if (object.message != null)
+ message.message = String(object.message);
return message;
};
@@ -79714,6 +79745,7 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
if (options.arrays || options.defaults) {
object.cells = [];
object.tablet_types = [];
+ object.shards = [];
}
if (options.objects || options.defaults)
object.config_overrides = {};
@@ -79746,12 +79778,22 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
if (options.oneofs)
object._state = "state";
}
+ if (message.shards && message.shards.length) {
+ object.shards = [];
+ for (let j = 0; j < message.shards.length; ++j)
+ object.shards[j] = message.shards[j];
+ }
let keys2;
if (message.config_overrides && (keys2 = Object.keys(message.config_overrides)).length) {
object.config_overrides = {};
for (let j = 0; j < keys2.length; ++j)
object.config_overrides[keys2[j]] = message.config_overrides[keys2[j]];
}
+ if (message.message != null && message.hasOwnProperty("message")) {
+ object.message = message.message;
+ if (options.oneofs)
+ object._message = "message";
+ }
return object;
};
@@ -80074,34 +80116,19 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
// OneOf field names bound to virtual getters and setters
let $oneOfFields;
- /**
- * UpdateVReplicationWorkflowsRequest _state.
- * @member {"state"|undefined} _state
- * @memberof tabletmanagerdata.UpdateVReplicationWorkflowsRequest
- * @instance
- */
+ // Virtual OneOf for proto3 optional field
Object.defineProperty(UpdateVReplicationWorkflowsRequest.prototype, "_state", {
get: $util.oneOfGetter($oneOfFields = ["state"]),
set: $util.oneOfSetter($oneOfFields)
});
- /**
- * UpdateVReplicationWorkflowsRequest _message.
- * @member {"message"|undefined} _message
- * @memberof tabletmanagerdata.UpdateVReplicationWorkflowsRequest
- * @instance
- */
+ // Virtual OneOf for proto3 optional field
Object.defineProperty(UpdateVReplicationWorkflowsRequest.prototype, "_message", {
get: $util.oneOfGetter($oneOfFields = ["message"]),
set: $util.oneOfSetter($oneOfFields)
});
- /**
- * UpdateVReplicationWorkflowsRequest _stop_position.
- * @member {"stop_position"|undefined} _stop_position
- * @memberof tabletmanagerdata.UpdateVReplicationWorkflowsRequest
- * @instance
- */
+ // Virtual OneOf for proto3 optional field
Object.defineProperty(UpdateVReplicationWorkflowsRequest.prototype, "_stop_position", {
get: $util.oneOfGetter($oneOfFields = ["stop_position"]),
set: $util.oneOfSetter($oneOfFields)
@@ -121409,12 +121436,7 @@ export const vschema = $root.vschema = (() => {
// OneOf field names bound to virtual getters and setters
let $oneOfFields;
- /**
- * Column _nullable.
- * @member {"nullable"|undefined} _nullable
- * @memberof vschema.Column
- * @instance
- */
+ // Virtual OneOf for proto3 optional field
Object.defineProperty(Column.prototype, "_nullable", {
get: $util.oneOfGetter($oneOfFields = ["nullable"]),
set: $util.oneOfSetter($oneOfFields)
@@ -134389,12 +134411,7 @@ export const vtctldata = $root.vtctldata = (() => {
// OneOf field names bound to virtual getters and setters
let $oneOfFields;
- /**
- * BackupRequest _backup_engine.
- * @member {"backup_engine"|undefined} _backup_engine
- * @memberof vtctldata.BackupRequest
- * @instance
- */
+ // Virtual OneOf for proto3 optional field
Object.defineProperty(BackupRequest.prototype, "_backup_engine", {
get: $util.oneOfGetter($oneOfFields = ["backup_engine"]),
set: $util.oneOfSetter($oneOfFields)
@@ -138383,6 +138400,590 @@ export const vtctldata = $root.vtctldata = (() => {
return CompleteSchemaMigrationResponse;
})();
+ vtctldata.CopySchemaShardRequest = (function() {
+
+ /**
+ * Properties of a CopySchemaShardRequest.
+ * @memberof vtctldata
+ * @interface ICopySchemaShardRequest
+ * @property {topodata.ITabletAlias|null} [source_tablet_alias] CopySchemaShardRequest source_tablet_alias
+ * @property {Array.|null} [tables] CopySchemaShardRequest tables
+ * @property {Array.|null} [exclude_tables] CopySchemaShardRequest exclude_tables
+ * @property {boolean|null} [include_views] CopySchemaShardRequest include_views
+ * @property {boolean|null} [skip_verify] CopySchemaShardRequest skip_verify
+ * @property {vttime.IDuration|null} [wait_replicas_timeout] CopySchemaShardRequest wait_replicas_timeout
+ * @property {string|null} [destination_keyspace] CopySchemaShardRequest destination_keyspace
+ * @property {string|null} [destination_shard] CopySchemaShardRequest destination_shard
+ */
+
+ /**
+ * Constructs a new CopySchemaShardRequest.
+ * @memberof vtctldata
+ * @classdesc Represents a CopySchemaShardRequest.
+ * @implements ICopySchemaShardRequest
+ * @constructor
+ * @param {vtctldata.ICopySchemaShardRequest=} [properties] Properties to set
+ */
+ function CopySchemaShardRequest(properties) {
+ this.tables = [];
+ this.exclude_tables = [];
+ if (properties)
+ for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
+ if (properties[keys[i]] != null)
+ this[keys[i]] = properties[keys[i]];
+ }
+
+ /**
+ * CopySchemaShardRequest source_tablet_alias.
+ * @member {topodata.ITabletAlias|null|undefined} source_tablet_alias
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @instance
+ */
+ CopySchemaShardRequest.prototype.source_tablet_alias = null;
+
+ /**
+ * CopySchemaShardRequest tables.
+ * @member {Array.} tables
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @instance
+ */
+ CopySchemaShardRequest.prototype.tables = $util.emptyArray;
+
+ /**
+ * CopySchemaShardRequest exclude_tables.
+ * @member {Array.} exclude_tables
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @instance
+ */
+ CopySchemaShardRequest.prototype.exclude_tables = $util.emptyArray;
+
+ /**
+ * CopySchemaShardRequest include_views.
+ * @member {boolean} include_views
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @instance
+ */
+ CopySchemaShardRequest.prototype.include_views = false;
+
+ /**
+ * CopySchemaShardRequest skip_verify.
+ * @member {boolean} skip_verify
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @instance
+ */
+ CopySchemaShardRequest.prototype.skip_verify = false;
+
+ /**
+ * CopySchemaShardRequest wait_replicas_timeout.
+ * @member {vttime.IDuration|null|undefined} wait_replicas_timeout
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @instance
+ */
+ CopySchemaShardRequest.prototype.wait_replicas_timeout = null;
+
+ /**
+ * CopySchemaShardRequest destination_keyspace.
+ * @member {string} destination_keyspace
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @instance
+ */
+ CopySchemaShardRequest.prototype.destination_keyspace = "";
+
+ /**
+ * CopySchemaShardRequest destination_shard.
+ * @member {string} destination_shard
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @instance
+ */
+ CopySchemaShardRequest.prototype.destination_shard = "";
+
+ /**
+ * Creates a new CopySchemaShardRequest instance using the specified properties.
+ * @function create
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @static
+ * @param {vtctldata.ICopySchemaShardRequest=} [properties] Properties to set
+ * @returns {vtctldata.CopySchemaShardRequest} CopySchemaShardRequest instance
+ */
+ CopySchemaShardRequest.create = function create(properties) {
+ return new CopySchemaShardRequest(properties);
+ };
+
+ /**
+ * Encodes the specified CopySchemaShardRequest message. Does not implicitly {@link vtctldata.CopySchemaShardRequest.verify|verify} messages.
+ * @function encode
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @static
+ * @param {vtctldata.ICopySchemaShardRequest} message CopySchemaShardRequest message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ CopySchemaShardRequest.encode = function encode(message, writer) {
+ if (!writer)
+ writer = $Writer.create();
+ if (message.source_tablet_alias != null && Object.hasOwnProperty.call(message, "source_tablet_alias"))
+ $root.topodata.TabletAlias.encode(message.source_tablet_alias, writer.uint32(/* id 1, wireType 2 =*/10).fork()).ldelim();
+ if (message.tables != null && message.tables.length)
+ for (let i = 0; i < message.tables.length; ++i)
+ writer.uint32(/* id 2, wireType 2 =*/18).string(message.tables[i]);
+ if (message.exclude_tables != null && message.exclude_tables.length)
+ for (let i = 0; i < message.exclude_tables.length; ++i)
+ writer.uint32(/* id 3, wireType 2 =*/26).string(message.exclude_tables[i]);
+ if (message.include_views != null && Object.hasOwnProperty.call(message, "include_views"))
+ writer.uint32(/* id 4, wireType 0 =*/32).bool(message.include_views);
+ if (message.skip_verify != null && Object.hasOwnProperty.call(message, "skip_verify"))
+ writer.uint32(/* id 5, wireType 0 =*/40).bool(message.skip_verify);
+ if (message.wait_replicas_timeout != null && Object.hasOwnProperty.call(message, "wait_replicas_timeout"))
+ $root.vttime.Duration.encode(message.wait_replicas_timeout, writer.uint32(/* id 6, wireType 2 =*/50).fork()).ldelim();
+ if (message.destination_keyspace != null && Object.hasOwnProperty.call(message, "destination_keyspace"))
+ writer.uint32(/* id 7, wireType 2 =*/58).string(message.destination_keyspace);
+ if (message.destination_shard != null && Object.hasOwnProperty.call(message, "destination_shard"))
+ writer.uint32(/* id 8, wireType 2 =*/66).string(message.destination_shard);
+ return writer;
+ };
+
+ /**
+ * Encodes the specified CopySchemaShardRequest message, length delimited. Does not implicitly {@link vtctldata.CopySchemaShardRequest.verify|verify} messages.
+ * @function encodeDelimited
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @static
+ * @param {vtctldata.ICopySchemaShardRequest} message CopySchemaShardRequest message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ CopySchemaShardRequest.encodeDelimited = function encodeDelimited(message, writer) {
+ return this.encode(message, writer).ldelim();
+ };
+
+ /**
+ * Decodes a CopySchemaShardRequest message from the specified reader or buffer.
+ * @function decode
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @param {number} [length] Message length if known beforehand
+ * @returns {vtctldata.CopySchemaShardRequest} CopySchemaShardRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ CopySchemaShardRequest.decode = function decode(reader, length) {
+ if (!(reader instanceof $Reader))
+ reader = $Reader.create(reader);
+ let end = length === undefined ? reader.len : reader.pos + length, message = new $root.vtctldata.CopySchemaShardRequest();
+ while (reader.pos < end) {
+ let tag = reader.uint32();
+ switch (tag >>> 3) {
+ case 1: {
+ message.source_tablet_alias = $root.topodata.TabletAlias.decode(reader, reader.uint32());
+ break;
+ }
+ case 2: {
+ if (!(message.tables && message.tables.length))
+ message.tables = [];
+ message.tables.push(reader.string());
+ break;
+ }
+ case 3: {
+ if (!(message.exclude_tables && message.exclude_tables.length))
+ message.exclude_tables = [];
+ message.exclude_tables.push(reader.string());
+ break;
+ }
+ case 4: {
+ message.include_views = reader.bool();
+ break;
+ }
+ case 5: {
+ message.skip_verify = reader.bool();
+ break;
+ }
+ case 6: {
+ message.wait_replicas_timeout = $root.vttime.Duration.decode(reader, reader.uint32());
+ break;
+ }
+ case 7: {
+ message.destination_keyspace = reader.string();
+ break;
+ }
+ case 8: {
+ message.destination_shard = reader.string();
+ break;
+ }
+ default:
+ reader.skipType(tag & 7);
+ break;
+ }
+ }
+ return message;
+ };
+
+ /**
+ * Decodes a CopySchemaShardRequest message from the specified reader or buffer, length delimited.
+ * @function decodeDelimited
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @returns {vtctldata.CopySchemaShardRequest} CopySchemaShardRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ CopySchemaShardRequest.decodeDelimited = function decodeDelimited(reader) {
+ if (!(reader instanceof $Reader))
+ reader = new $Reader(reader);
+ return this.decode(reader, reader.uint32());
+ };
+
+ /**
+ * Verifies a CopySchemaShardRequest message.
+ * @function verify
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @static
+ * @param {Object.} message Plain object to verify
+ * @returns {string|null} `null` if valid, otherwise the reason why it is not
+ */
+ CopySchemaShardRequest.verify = function verify(message) {
+ if (typeof message !== "object" || message === null)
+ return "object expected";
+ if (message.source_tablet_alias != null && message.hasOwnProperty("source_tablet_alias")) {
+ let error = $root.topodata.TabletAlias.verify(message.source_tablet_alias);
+ if (error)
+ return "source_tablet_alias." + error;
+ }
+ if (message.tables != null && message.hasOwnProperty("tables")) {
+ if (!Array.isArray(message.tables))
+ return "tables: array expected";
+ for (let i = 0; i < message.tables.length; ++i)
+ if (!$util.isString(message.tables[i]))
+ return "tables: string[] expected";
+ }
+ if (message.exclude_tables != null && message.hasOwnProperty("exclude_tables")) {
+ if (!Array.isArray(message.exclude_tables))
+ return "exclude_tables: array expected";
+ for (let i = 0; i < message.exclude_tables.length; ++i)
+ if (!$util.isString(message.exclude_tables[i]))
+ return "exclude_tables: string[] expected";
+ }
+ if (message.include_views != null && message.hasOwnProperty("include_views"))
+ if (typeof message.include_views !== "boolean")
+ return "include_views: boolean expected";
+ if (message.skip_verify != null && message.hasOwnProperty("skip_verify"))
+ if (typeof message.skip_verify !== "boolean")
+ return "skip_verify: boolean expected";
+ if (message.wait_replicas_timeout != null && message.hasOwnProperty("wait_replicas_timeout")) {
+ let error = $root.vttime.Duration.verify(message.wait_replicas_timeout);
+ if (error)
+ return "wait_replicas_timeout." + error;
+ }
+ if (message.destination_keyspace != null && message.hasOwnProperty("destination_keyspace"))
+ if (!$util.isString(message.destination_keyspace))
+ return "destination_keyspace: string expected";
+ if (message.destination_shard != null && message.hasOwnProperty("destination_shard"))
+ if (!$util.isString(message.destination_shard))
+ return "destination_shard: string expected";
+ return null;
+ };
+
+ /**
+ * Creates a CopySchemaShardRequest message from a plain object. Also converts values to their respective internal types.
+ * @function fromObject
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @static
+ * @param {Object.} object Plain object
+ * @returns {vtctldata.CopySchemaShardRequest} CopySchemaShardRequest
+ */
+ CopySchemaShardRequest.fromObject = function fromObject(object) {
+ if (object instanceof $root.vtctldata.CopySchemaShardRequest)
+ return object;
+ let message = new $root.vtctldata.CopySchemaShardRequest();
+ if (object.source_tablet_alias != null) {
+ if (typeof object.source_tablet_alias !== "object")
+ throw TypeError(".vtctldata.CopySchemaShardRequest.source_tablet_alias: object expected");
+ message.source_tablet_alias = $root.topodata.TabletAlias.fromObject(object.source_tablet_alias);
+ }
+ if (object.tables) {
+ if (!Array.isArray(object.tables))
+ throw TypeError(".vtctldata.CopySchemaShardRequest.tables: array expected");
+ message.tables = [];
+ for (let i = 0; i < object.tables.length; ++i)
+ message.tables[i] = String(object.tables[i]);
+ }
+ if (object.exclude_tables) {
+ if (!Array.isArray(object.exclude_tables))
+ throw TypeError(".vtctldata.CopySchemaShardRequest.exclude_tables: array expected");
+ message.exclude_tables = [];
+ for (let i = 0; i < object.exclude_tables.length; ++i)
+ message.exclude_tables[i] = String(object.exclude_tables[i]);
+ }
+ if (object.include_views != null)
+ message.include_views = Boolean(object.include_views);
+ if (object.skip_verify != null)
+ message.skip_verify = Boolean(object.skip_verify);
+ if (object.wait_replicas_timeout != null) {
+ if (typeof object.wait_replicas_timeout !== "object")
+ throw TypeError(".vtctldata.CopySchemaShardRequest.wait_replicas_timeout: object expected");
+ message.wait_replicas_timeout = $root.vttime.Duration.fromObject(object.wait_replicas_timeout);
+ }
+ if (object.destination_keyspace != null)
+ message.destination_keyspace = String(object.destination_keyspace);
+ if (object.destination_shard != null)
+ message.destination_shard = String(object.destination_shard);
+ return message;
+ };
+
+ /**
+ * Creates a plain object from a CopySchemaShardRequest message. Also converts values to other types if specified.
+ * @function toObject
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @static
+ * @param {vtctldata.CopySchemaShardRequest} message CopySchemaShardRequest
+ * @param {$protobuf.IConversionOptions} [options] Conversion options
+ * @returns {Object.} Plain object
+ */
+ CopySchemaShardRequest.toObject = function toObject(message, options) {
+ if (!options)
+ options = {};
+ let object = {};
+ if (options.arrays || options.defaults) {
+ object.tables = [];
+ object.exclude_tables = [];
+ }
+ if (options.defaults) {
+ object.source_tablet_alias = null;
+ object.include_views = false;
+ object.skip_verify = false;
+ object.wait_replicas_timeout = null;
+ object.destination_keyspace = "";
+ object.destination_shard = "";
+ }
+ if (message.source_tablet_alias != null && message.hasOwnProperty("source_tablet_alias"))
+ object.source_tablet_alias = $root.topodata.TabletAlias.toObject(message.source_tablet_alias, options);
+ if (message.tables && message.tables.length) {
+ object.tables = [];
+ for (let j = 0; j < message.tables.length; ++j)
+ object.tables[j] = message.tables[j];
+ }
+ if (message.exclude_tables && message.exclude_tables.length) {
+ object.exclude_tables = [];
+ for (let j = 0; j < message.exclude_tables.length; ++j)
+ object.exclude_tables[j] = message.exclude_tables[j];
+ }
+ if (message.include_views != null && message.hasOwnProperty("include_views"))
+ object.include_views = message.include_views;
+ if (message.skip_verify != null && message.hasOwnProperty("skip_verify"))
+ object.skip_verify = message.skip_verify;
+ if (message.wait_replicas_timeout != null && message.hasOwnProperty("wait_replicas_timeout"))
+ object.wait_replicas_timeout = $root.vttime.Duration.toObject(message.wait_replicas_timeout, options);
+ if (message.destination_keyspace != null && message.hasOwnProperty("destination_keyspace"))
+ object.destination_keyspace = message.destination_keyspace;
+ if (message.destination_shard != null && message.hasOwnProperty("destination_shard"))
+ object.destination_shard = message.destination_shard;
+ return object;
+ };
+
+ /**
+ * Converts this CopySchemaShardRequest to JSON.
+ * @function toJSON
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @instance
+ * @returns {Object.} JSON object
+ */
+ CopySchemaShardRequest.prototype.toJSON = function toJSON() {
+ return this.constructor.toObject(this, $protobuf.util.toJSONOptions);
+ };
+
+ /**
+ * Gets the default type url for CopySchemaShardRequest
+ * @function getTypeUrl
+ * @memberof vtctldata.CopySchemaShardRequest
+ * @static
+ * @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns {string} The default type url
+ */
+ CopySchemaShardRequest.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
+ if (typeUrlPrefix === undefined) {
+ typeUrlPrefix = "type.googleapis.com";
+ }
+ return typeUrlPrefix + "/vtctldata.CopySchemaShardRequest";
+ };
+
+ return CopySchemaShardRequest;
+ })();
+
+ vtctldata.CopySchemaShardResponse = (function() {
+
+ /**
+ * Properties of a CopySchemaShardResponse.
+ * @memberof vtctldata
+ * @interface ICopySchemaShardResponse
+ */
+
+ /**
+ * Constructs a new CopySchemaShardResponse.
+ * @memberof vtctldata
+ * @classdesc Represents a CopySchemaShardResponse.
+ * @implements ICopySchemaShardResponse
+ * @constructor
+ * @param {vtctldata.ICopySchemaShardResponse=} [properties] Properties to set
+ */
+ function CopySchemaShardResponse(properties) {
+ if (properties)
+ for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
+ if (properties[keys[i]] != null)
+ this[keys[i]] = properties[keys[i]];
+ }
+
+ /**
+ * Creates a new CopySchemaShardResponse instance using the specified properties.
+ * @function create
+ * @memberof vtctldata.CopySchemaShardResponse
+ * @static
+ * @param {vtctldata.ICopySchemaShardResponse=} [properties] Properties to set
+ * @returns {vtctldata.CopySchemaShardResponse} CopySchemaShardResponse instance
+ */
+ CopySchemaShardResponse.create = function create(properties) {
+ return new CopySchemaShardResponse(properties);
+ };
+
+ /**
+ * Encodes the specified CopySchemaShardResponse message. Does not implicitly {@link vtctldata.CopySchemaShardResponse.verify|verify} messages.
+ * @function encode
+ * @memberof vtctldata.CopySchemaShardResponse
+ * @static
+ * @param {vtctldata.ICopySchemaShardResponse} message CopySchemaShardResponse message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ CopySchemaShardResponse.encode = function encode(message, writer) {
+ if (!writer)
+ writer = $Writer.create();
+ return writer;
+ };
+
+ /**
+ * Encodes the specified CopySchemaShardResponse message, length delimited. Does not implicitly {@link vtctldata.CopySchemaShardResponse.verify|verify} messages.
+ * @function encodeDelimited
+ * @memberof vtctldata.CopySchemaShardResponse
+ * @static
+ * @param {vtctldata.ICopySchemaShardResponse} message CopySchemaShardResponse message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ CopySchemaShardResponse.encodeDelimited = function encodeDelimited(message, writer) {
+ return this.encode(message, writer).ldelim();
+ };
+
+ /**
+ * Decodes a CopySchemaShardResponse message from the specified reader or buffer.
+ * @function decode
+ * @memberof vtctldata.CopySchemaShardResponse
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @param {number} [length] Message length if known beforehand
+ * @returns {vtctldata.CopySchemaShardResponse} CopySchemaShardResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ CopySchemaShardResponse.decode = function decode(reader, length) {
+ if (!(reader instanceof $Reader))
+ reader = $Reader.create(reader);
+ let end = length === undefined ? reader.len : reader.pos + length, message = new $root.vtctldata.CopySchemaShardResponse();
+ while (reader.pos < end) {
+ let tag = reader.uint32();
+ switch (tag >>> 3) {
+ default:
+ reader.skipType(tag & 7);
+ break;
+ }
+ }
+ return message;
+ };
+
+ /**
+ * Decodes a CopySchemaShardResponse message from the specified reader or buffer, length delimited.
+ * @function decodeDelimited
+ * @memberof vtctldata.CopySchemaShardResponse
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @returns {vtctldata.CopySchemaShardResponse} CopySchemaShardResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ CopySchemaShardResponse.decodeDelimited = function decodeDelimited(reader) {
+ if (!(reader instanceof $Reader))
+ reader = new $Reader(reader);
+ return this.decode(reader, reader.uint32());
+ };
+
+ /**
+ * Verifies a CopySchemaShardResponse message.
+ * @function verify
+ * @memberof vtctldata.CopySchemaShardResponse
+ * @static
+ * @param {Object.} message Plain object to verify
+ * @returns {string|null} `null` if valid, otherwise the reason why it is not
+ */
+ CopySchemaShardResponse.verify = function verify(message) {
+ if (typeof message !== "object" || message === null)
+ return "object expected";
+ return null;
+ };
+
+ /**
+ * Creates a CopySchemaShardResponse message from a plain object. Also converts values to their respective internal types.
+ * @function fromObject
+ * @memberof vtctldata.CopySchemaShardResponse
+ * @static
+ * @param {Object.} object Plain object
+ * @returns {vtctldata.CopySchemaShardResponse} CopySchemaShardResponse
+ */
+ CopySchemaShardResponse.fromObject = function fromObject(object) {
+ if (object instanceof $root.vtctldata.CopySchemaShardResponse)
+ return object;
+ return new $root.vtctldata.CopySchemaShardResponse();
+ };
+
+ /**
+ * Creates a plain object from a CopySchemaShardResponse message. Also converts values to other types if specified.
+ * @function toObject
+ * @memberof vtctldata.CopySchemaShardResponse
+ * @static
+ * @param {vtctldata.CopySchemaShardResponse} message CopySchemaShardResponse
+ * @param {$protobuf.IConversionOptions} [options] Conversion options
+ * @returns {Object.} Plain object
+ */
+ CopySchemaShardResponse.toObject = function toObject() {
+ return {};
+ };
+
+ /**
+ * Converts this CopySchemaShardResponse to JSON.
+ * @function toJSON
+ * @memberof vtctldata.CopySchemaShardResponse
+ * @instance
+ * @returns {Object.} JSON object
+ */
+ CopySchemaShardResponse.prototype.toJSON = function toJSON() {
+ return this.constructor.toObject(this, $protobuf.util.toJSONOptions);
+ };
+
+ /**
+ * Gets the default type url for CopySchemaShardResponse
+ * @function getTypeUrl
+ * @memberof vtctldata.CopySchemaShardResponse
+ * @static
+ * @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns {string} The default type url
+ */
+ CopySchemaShardResponse.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
+ if (typeUrlPrefix === undefined) {
+ typeUrlPrefix = "type.googleapis.com";
+ }
+ return typeUrlPrefix + "/vtctldata.CopySchemaShardResponse";
+ };
+
+ return CopySchemaShardResponse;
+ })();
+
vtctldata.CreateKeyspaceRequest = (function() {
/**
@@ -161423,6 +162024,431 @@ export const vtctldata = $root.vtctldata = (() => {
return LaunchSchemaMigrationResponse;
})();
+ vtctldata.LookupVindexCompleteRequest = (function() {
+
+ /**
+ * Properties of a LookupVindexCompleteRequest.
+ * @memberof vtctldata
+ * @interface ILookupVindexCompleteRequest
+ * @property {string|null} [keyspace] LookupVindexCompleteRequest keyspace
+ * @property {string|null} [name] LookupVindexCompleteRequest name
+ * @property {string|null} [table_keyspace] LookupVindexCompleteRequest table_keyspace
+ */
+
+ /**
+ * Constructs a new LookupVindexCompleteRequest.
+ * @memberof vtctldata
+ * @classdesc Represents a LookupVindexCompleteRequest.
+ * @implements ILookupVindexCompleteRequest
+ * @constructor
+ * @param {vtctldata.ILookupVindexCompleteRequest=} [properties] Properties to set
+ */
+ function LookupVindexCompleteRequest(properties) {
+ if (properties)
+ for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
+ if (properties[keys[i]] != null)
+ this[keys[i]] = properties[keys[i]];
+ }
+
+ /**
+ * LookupVindexCompleteRequest keyspace.
+ * @member {string} keyspace
+ * @memberof vtctldata.LookupVindexCompleteRequest
+ * @instance
+ */
+ LookupVindexCompleteRequest.prototype.keyspace = "";
+
+ /**
+ * LookupVindexCompleteRequest name.
+ * @member {string} name
+ * @memberof vtctldata.LookupVindexCompleteRequest
+ * @instance
+ */
+ LookupVindexCompleteRequest.prototype.name = "";
+
+ /**
+ * LookupVindexCompleteRequest table_keyspace.
+ * @member {string} table_keyspace
+ * @memberof vtctldata.LookupVindexCompleteRequest
+ * @instance
+ */
+ LookupVindexCompleteRequest.prototype.table_keyspace = "";
+
+ /**
+ * Creates a new LookupVindexCompleteRequest instance using the specified properties.
+ * @function create
+ * @memberof vtctldata.LookupVindexCompleteRequest
+ * @static
+ * @param {vtctldata.ILookupVindexCompleteRequest=} [properties] Properties to set
+ * @returns {vtctldata.LookupVindexCompleteRequest} LookupVindexCompleteRequest instance
+ */
+ LookupVindexCompleteRequest.create = function create(properties) {
+ return new LookupVindexCompleteRequest(properties);
+ };
+
+ /**
+ * Encodes the specified LookupVindexCompleteRequest message. Does not implicitly {@link vtctldata.LookupVindexCompleteRequest.verify|verify} messages.
+ * @function encode
+ * @memberof vtctldata.LookupVindexCompleteRequest
+ * @static
+ * @param {vtctldata.ILookupVindexCompleteRequest} message LookupVindexCompleteRequest message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ LookupVindexCompleteRequest.encode = function encode(message, writer) {
+ if (!writer)
+ writer = $Writer.create();
+ if (message.keyspace != null && Object.hasOwnProperty.call(message, "keyspace"))
+ writer.uint32(/* id 1, wireType 2 =*/10).string(message.keyspace);
+ if (message.name != null && Object.hasOwnProperty.call(message, "name"))
+ writer.uint32(/* id 2, wireType 2 =*/18).string(message.name);
+ if (message.table_keyspace != null && Object.hasOwnProperty.call(message, "table_keyspace"))
+ writer.uint32(/* id 3, wireType 2 =*/26).string(message.table_keyspace);
+ return writer;
+ };
+
+ /**
+ * Encodes the specified LookupVindexCompleteRequest message, length delimited. Does not implicitly {@link vtctldata.LookupVindexCompleteRequest.verify|verify} messages.
+ * @function encodeDelimited
+ * @memberof vtctldata.LookupVindexCompleteRequest
+ * @static
+ * @param {vtctldata.ILookupVindexCompleteRequest} message LookupVindexCompleteRequest message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ LookupVindexCompleteRequest.encodeDelimited = function encodeDelimited(message, writer) {
+ return this.encode(message, writer).ldelim();
+ };
+
+ /**
+ * Decodes a LookupVindexCompleteRequest message from the specified reader or buffer.
+ * @function decode
+ * @memberof vtctldata.LookupVindexCompleteRequest
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @param {number} [length] Message length if known beforehand
+ * @returns {vtctldata.LookupVindexCompleteRequest} LookupVindexCompleteRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ LookupVindexCompleteRequest.decode = function decode(reader, length) {
+ if (!(reader instanceof $Reader))
+ reader = $Reader.create(reader);
+ let end = length === undefined ? reader.len : reader.pos + length, message = new $root.vtctldata.LookupVindexCompleteRequest();
+ while (reader.pos < end) {
+ let tag = reader.uint32();
+ switch (tag >>> 3) {
+ case 1: {
+ message.keyspace = reader.string();
+ break;
+ }
+ case 2: {
+ message.name = reader.string();
+ break;
+ }
+ case 3: {
+ message.table_keyspace = reader.string();
+ break;
+ }
+ default:
+ reader.skipType(tag & 7);
+ break;
+ }
+ }
+ return message;
+ };
+
+ /**
+ * Decodes a LookupVindexCompleteRequest message from the specified reader or buffer, length delimited.
+ * @function decodeDelimited
+ * @memberof vtctldata.LookupVindexCompleteRequest
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @returns {vtctldata.LookupVindexCompleteRequest} LookupVindexCompleteRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ LookupVindexCompleteRequest.decodeDelimited = function decodeDelimited(reader) {
+ if (!(reader instanceof $Reader))
+ reader = new $Reader(reader);
+ return this.decode(reader, reader.uint32());
+ };
+
+ /**
+ * Verifies a LookupVindexCompleteRequest message.
+ * @function verify
+ * @memberof vtctldata.LookupVindexCompleteRequest
+ * @static
+ * @param {Object.} message Plain object to verify
+ * @returns {string|null} `null` if valid, otherwise the reason why it is not
+ */
+ LookupVindexCompleteRequest.verify = function verify(message) {
+ if (typeof message !== "object" || message === null)
+ return "object expected";
+ if (message.keyspace != null && message.hasOwnProperty("keyspace"))
+ if (!$util.isString(message.keyspace))
+ return "keyspace: string expected";
+ if (message.name != null && message.hasOwnProperty("name"))
+ if (!$util.isString(message.name))
+ return "name: string expected";
+ if (message.table_keyspace != null && message.hasOwnProperty("table_keyspace"))
+ if (!$util.isString(message.table_keyspace))
+ return "table_keyspace: string expected";
+ return null;
+ };
+
+ /**
+ * Creates a LookupVindexCompleteRequest message from a plain object. Also converts values to their respective internal types.
+ * @function fromObject
+ * @memberof vtctldata.LookupVindexCompleteRequest
+ * @static
+ * @param {Object.} object Plain object
+ * @returns {vtctldata.LookupVindexCompleteRequest} LookupVindexCompleteRequest
+ */
+ LookupVindexCompleteRequest.fromObject = function fromObject(object) {
+ if (object instanceof $root.vtctldata.LookupVindexCompleteRequest)
+ return object;
+ let message = new $root.vtctldata.LookupVindexCompleteRequest();
+ if (object.keyspace != null)
+ message.keyspace = String(object.keyspace);
+ if (object.name != null)
+ message.name = String(object.name);
+ if (object.table_keyspace != null)
+ message.table_keyspace = String(object.table_keyspace);
+ return message;
+ };
+
+ /**
+ * Creates a plain object from a LookupVindexCompleteRequest message. Also converts values to other types if specified.
+ * @function toObject
+ * @memberof vtctldata.LookupVindexCompleteRequest
+ * @static
+ * @param {vtctldata.LookupVindexCompleteRequest} message LookupVindexCompleteRequest
+ * @param {$protobuf.IConversionOptions} [options] Conversion options
+ * @returns {Object.} Plain object
+ */
+ LookupVindexCompleteRequest.toObject = function toObject(message, options) {
+ if (!options)
+ options = {};
+ let object = {};
+ if (options.defaults) {
+ object.keyspace = "";
+ object.name = "";
+ object.table_keyspace = "";
+ }
+ if (message.keyspace != null && message.hasOwnProperty("keyspace"))
+ object.keyspace = message.keyspace;
+ if (message.name != null && message.hasOwnProperty("name"))
+ object.name = message.name;
+ if (message.table_keyspace != null && message.hasOwnProperty("table_keyspace"))
+ object.table_keyspace = message.table_keyspace;
+ return object;
+ };
+
+ /**
+ * Converts this LookupVindexCompleteRequest to JSON.
+ * @function toJSON
+ * @memberof vtctldata.LookupVindexCompleteRequest
+ * @instance
+ * @returns {Object.} JSON object
+ */
+ LookupVindexCompleteRequest.prototype.toJSON = function toJSON() {
+ return this.constructor.toObject(this, $protobuf.util.toJSONOptions);
+ };
+
+ /**
+ * Gets the default type url for LookupVindexCompleteRequest
+ * @function getTypeUrl
+ * @memberof vtctldata.LookupVindexCompleteRequest
+ * @static
+ * @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns {string} The default type url
+ */
+ LookupVindexCompleteRequest.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
+ if (typeUrlPrefix === undefined) {
+ typeUrlPrefix = "type.googleapis.com";
+ }
+ return typeUrlPrefix + "/vtctldata.LookupVindexCompleteRequest";
+ };
+
+ return LookupVindexCompleteRequest;
+ })();
+
+ vtctldata.LookupVindexCompleteResponse = (function() {
+
+ /**
+ * Properties of a LookupVindexCompleteResponse.
+ * @memberof vtctldata
+ * @interface ILookupVindexCompleteResponse
+ */
+
+ /**
+ * Constructs a new LookupVindexCompleteResponse.
+ * @memberof vtctldata
+ * @classdesc Represents a LookupVindexCompleteResponse.
+ * @implements ILookupVindexCompleteResponse
+ * @constructor
+ * @param {vtctldata.ILookupVindexCompleteResponse=} [properties] Properties to set
+ */
+ function LookupVindexCompleteResponse(properties) {
+ if (properties)
+ for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
+ if (properties[keys[i]] != null)
+ this[keys[i]] = properties[keys[i]];
+ }
+
+ /**
+ * Creates a new LookupVindexCompleteResponse instance using the specified properties.
+ * @function create
+ * @memberof vtctldata.LookupVindexCompleteResponse
+ * @static
+ * @param {vtctldata.ILookupVindexCompleteResponse=} [properties] Properties to set
+ * @returns {vtctldata.LookupVindexCompleteResponse} LookupVindexCompleteResponse instance
+ */
+ LookupVindexCompleteResponse.create = function create(properties) {
+ return new LookupVindexCompleteResponse(properties);
+ };
+
+ /**
+ * Encodes the specified LookupVindexCompleteResponse message. Does not implicitly {@link vtctldata.LookupVindexCompleteResponse.verify|verify} messages.
+ * @function encode
+ * @memberof vtctldata.LookupVindexCompleteResponse
+ * @static
+ * @param {vtctldata.ILookupVindexCompleteResponse} message LookupVindexCompleteResponse message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ LookupVindexCompleteResponse.encode = function encode(message, writer) {
+ if (!writer)
+ writer = $Writer.create();
+ return writer;
+ };
+
+ /**
+ * Encodes the specified LookupVindexCompleteResponse message, length delimited. Does not implicitly {@link vtctldata.LookupVindexCompleteResponse.verify|verify} messages.
+ * @function encodeDelimited
+ * @memberof vtctldata.LookupVindexCompleteResponse
+ * @static
+ * @param {vtctldata.ILookupVindexCompleteResponse} message LookupVindexCompleteResponse message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ LookupVindexCompleteResponse.encodeDelimited = function encodeDelimited(message, writer) {
+ return this.encode(message, writer).ldelim();
+ };
+
+ /**
+ * Decodes a LookupVindexCompleteResponse message from the specified reader or buffer.
+ * @function decode
+ * @memberof vtctldata.LookupVindexCompleteResponse
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @param {number} [length] Message length if known beforehand
+ * @returns {vtctldata.LookupVindexCompleteResponse} LookupVindexCompleteResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ LookupVindexCompleteResponse.decode = function decode(reader, length) {
+ if (!(reader instanceof $Reader))
+ reader = $Reader.create(reader);
+ let end = length === undefined ? reader.len : reader.pos + length, message = new $root.vtctldata.LookupVindexCompleteResponse();
+ while (reader.pos < end) {
+ let tag = reader.uint32();
+ switch (tag >>> 3) {
+ default:
+ reader.skipType(tag & 7);
+ break;
+ }
+ }
+ return message;
+ };
+
+ /**
+ * Decodes a LookupVindexCompleteResponse message from the specified reader or buffer, length delimited.
+ * @function decodeDelimited
+ * @memberof vtctldata.LookupVindexCompleteResponse
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @returns {vtctldata.LookupVindexCompleteResponse} LookupVindexCompleteResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ LookupVindexCompleteResponse.decodeDelimited = function decodeDelimited(reader) {
+ if (!(reader instanceof $Reader))
+ reader = new $Reader(reader);
+ return this.decode(reader, reader.uint32());
+ };
+
+ /**
+ * Verifies a LookupVindexCompleteResponse message.
+ * @function verify
+ * @memberof vtctldata.LookupVindexCompleteResponse
+ * @static
+ * @param {Object.} message Plain object to verify
+ * @returns {string|null} `null` if valid, otherwise the reason why it is not
+ */
+ LookupVindexCompleteResponse.verify = function verify(message) {
+ if (typeof message !== "object" || message === null)
+ return "object expected";
+ return null;
+ };
+
+ /**
+ * Creates a LookupVindexCompleteResponse message from a plain object. Also converts values to their respective internal types.
+ * @function fromObject
+ * @memberof vtctldata.LookupVindexCompleteResponse
+ * @static
+ * @param {Object.} object Plain object
+ * @returns {vtctldata.LookupVindexCompleteResponse} LookupVindexCompleteResponse
+ */
+ LookupVindexCompleteResponse.fromObject = function fromObject(object) {
+ if (object instanceof $root.vtctldata.LookupVindexCompleteResponse)
+ return object;
+ return new $root.vtctldata.LookupVindexCompleteResponse();
+ };
+
+ /**
+ * Creates a plain object from a LookupVindexCompleteResponse message. Also converts values to other types if specified.
+ * @function toObject
+ * @memberof vtctldata.LookupVindexCompleteResponse
+ * @static
+ * @param {vtctldata.LookupVindexCompleteResponse} message LookupVindexCompleteResponse
+ * @param {$protobuf.IConversionOptions} [options] Conversion options
+ * @returns {Object.} Plain object
+ */
+ LookupVindexCompleteResponse.toObject = function toObject() {
+ return {};
+ };
+
+ /**
+ * Converts this LookupVindexCompleteResponse to JSON.
+ * @function toJSON
+ * @memberof vtctldata.LookupVindexCompleteResponse
+ * @instance
+ * @returns {Object.} JSON object
+ */
+ LookupVindexCompleteResponse.prototype.toJSON = function toJSON() {
+ return this.constructor.toObject(this, $protobuf.util.toJSONOptions);
+ };
+
+ /**
+ * Gets the default type url for LookupVindexCompleteResponse
+ * @function getTypeUrl
+ * @memberof vtctldata.LookupVindexCompleteResponse
+ * @static
+ * @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns {string} The default type url
+ */
+ LookupVindexCompleteResponse.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
+ if (typeUrlPrefix === undefined) {
+ typeUrlPrefix = "type.googleapis.com";
+ }
+ return typeUrlPrefix + "/vtctldata.LookupVindexCompleteResponse";
+ };
+
+ return LookupVindexCompleteResponse;
+ })();
+
vtctldata.LookupVindexCreateRequest = (function() {
/**
@@ -162084,6 +163110,7 @@ export const vtctldata = $root.vtctldata = (() => {
* @property {string|null} [keyspace] LookupVindexExternalizeRequest keyspace
* @property {string|null} [name] LookupVindexExternalizeRequest name
* @property {string|null} [table_keyspace] LookupVindexExternalizeRequest table_keyspace
+ * @property {boolean|null} [delete_workflow] LookupVindexExternalizeRequest delete_workflow
*/
/**
@@ -162125,6 +163152,14 @@ export const vtctldata = $root.vtctldata = (() => {
*/
LookupVindexExternalizeRequest.prototype.table_keyspace = "";
+ /**
+ * LookupVindexExternalizeRequest delete_workflow.
+ * @member {boolean} delete_workflow
+ * @memberof vtctldata.LookupVindexExternalizeRequest
+ * @instance
+ */
+ LookupVindexExternalizeRequest.prototype.delete_workflow = false;
+
/**
* Creates a new LookupVindexExternalizeRequest instance using the specified properties.
* @function create
@@ -162155,6 +163190,8 @@ export const vtctldata = $root.vtctldata = (() => {
writer.uint32(/* id 2, wireType 2 =*/18).string(message.name);
if (message.table_keyspace != null && Object.hasOwnProperty.call(message, "table_keyspace"))
writer.uint32(/* id 3, wireType 2 =*/26).string(message.table_keyspace);
+ if (message.delete_workflow != null && Object.hasOwnProperty.call(message, "delete_workflow"))
+ writer.uint32(/* id 4, wireType 0 =*/32).bool(message.delete_workflow);
return writer;
};
@@ -162201,6 +163238,10 @@ export const vtctldata = $root.vtctldata = (() => {
message.table_keyspace = reader.string();
break;
}
+ case 4: {
+ message.delete_workflow = reader.bool();
+ break;
+ }
default:
reader.skipType(tag & 7);
break;
@@ -162245,6 +163286,9 @@ export const vtctldata = $root.vtctldata = (() => {
if (message.table_keyspace != null && message.hasOwnProperty("table_keyspace"))
if (!$util.isString(message.table_keyspace))
return "table_keyspace: string expected";
+ if (message.delete_workflow != null && message.hasOwnProperty("delete_workflow"))
+ if (typeof message.delete_workflow !== "boolean")
+ return "delete_workflow: boolean expected";
return null;
};
@@ -162266,6 +163310,8 @@ export const vtctldata = $root.vtctldata = (() => {
message.name = String(object.name);
if (object.table_keyspace != null)
message.table_keyspace = String(object.table_keyspace);
+ if (object.delete_workflow != null)
+ message.delete_workflow = Boolean(object.delete_workflow);
return message;
};
@@ -162286,6 +163332,7 @@ export const vtctldata = $root.vtctldata = (() => {
object.keyspace = "";
object.name = "";
object.table_keyspace = "";
+ object.delete_workflow = false;
}
if (message.keyspace != null && message.hasOwnProperty("keyspace"))
object.keyspace = message.keyspace;
@@ -162293,6 +163340,8 @@ export const vtctldata = $root.vtctldata = (() => {
object.name = message.name;
if (message.table_keyspace != null && message.hasOwnProperty("table_keyspace"))
object.table_keyspace = message.table_keyspace;
+ if (message.delete_workflow != null && message.hasOwnProperty("delete_workflow"))
+ object.delete_workflow = message.delete_workflow;
return object;
};
@@ -162331,6 +163380,7 @@ export const vtctldata = $root.vtctldata = (() => {
* Properties of a LookupVindexExternalizeResponse.
* @memberof vtctldata
* @interface ILookupVindexExternalizeResponse
+ * @property {boolean|null} [workflow_stopped] LookupVindexExternalizeResponse workflow_stopped
* @property {boolean|null} [workflow_deleted] LookupVindexExternalizeResponse workflow_deleted
*/
@@ -162349,6 +163399,14 @@ export const vtctldata = $root.vtctldata = (() => {
this[keys[i]] = properties[keys[i]];
}
+ /**
+ * LookupVindexExternalizeResponse workflow_stopped.
+ * @member {boolean} workflow_stopped
+ * @memberof vtctldata.LookupVindexExternalizeResponse
+ * @instance
+ */
+ LookupVindexExternalizeResponse.prototype.workflow_stopped = false;
+
/**
* LookupVindexExternalizeResponse workflow_deleted.
* @member {boolean} workflow_deleted
@@ -162381,8 +163439,10 @@ export const vtctldata = $root.vtctldata = (() => {
LookupVindexExternalizeResponse.encode = function encode(message, writer) {
if (!writer)
writer = $Writer.create();
+ if (message.workflow_stopped != null && Object.hasOwnProperty.call(message, "workflow_stopped"))
+ writer.uint32(/* id 1, wireType 0 =*/8).bool(message.workflow_stopped);
if (message.workflow_deleted != null && Object.hasOwnProperty.call(message, "workflow_deleted"))
- writer.uint32(/* id 1, wireType 0 =*/8).bool(message.workflow_deleted);
+ writer.uint32(/* id 2, wireType 0 =*/16).bool(message.workflow_deleted);
return writer;
};
@@ -162418,6 +163478,10 @@ export const vtctldata = $root.vtctldata = (() => {
let tag = reader.uint32();
switch (tag >>> 3) {
case 1: {
+ message.workflow_stopped = reader.bool();
+ break;
+ }
+ case 2: {
message.workflow_deleted = reader.bool();
break;
}
@@ -162456,6 +163520,9 @@ export const vtctldata = $root.vtctldata = (() => {
LookupVindexExternalizeResponse.verify = function verify(message) {
if (typeof message !== "object" || message === null)
return "object expected";
+ if (message.workflow_stopped != null && message.hasOwnProperty("workflow_stopped"))
+ if (typeof message.workflow_stopped !== "boolean")
+ return "workflow_stopped: boolean expected";
if (message.workflow_deleted != null && message.hasOwnProperty("workflow_deleted"))
if (typeof message.workflow_deleted !== "boolean")
return "workflow_deleted: boolean expected";
@@ -162474,6 +163541,8 @@ export const vtctldata = $root.vtctldata = (() => {
if (object instanceof $root.vtctldata.LookupVindexExternalizeResponse)
return object;
let message = new $root.vtctldata.LookupVindexExternalizeResponse();
+ if (object.workflow_stopped != null)
+ message.workflow_stopped = Boolean(object.workflow_stopped);
if (object.workflow_deleted != null)
message.workflow_deleted = Boolean(object.workflow_deleted);
return message;
@@ -162492,8 +163561,12 @@ export const vtctldata = $root.vtctldata = (() => {
if (!options)
options = {};
let object = {};
- if (options.defaults)
+ if (options.defaults) {
+ object.workflow_stopped = false;
object.workflow_deleted = false;
+ }
+ if (message.workflow_stopped != null && message.hasOwnProperty("workflow_stopped"))
+ object.workflow_stopped = message.workflow_stopped;
if (message.workflow_deleted != null && message.hasOwnProperty("workflow_deleted"))
object.workflow_deleted = message.workflow_deleted;
return object;
@@ -162528,6 +163601,431 @@ export const vtctldata = $root.vtctldata = (() => {
return LookupVindexExternalizeResponse;
})();
+ vtctldata.LookupVindexInternalizeRequest = (function() {
+
+ /**
+ * Properties of a LookupVindexInternalizeRequest.
+ * @memberof vtctldata
+ * @interface ILookupVindexInternalizeRequest
+ * @property {string|null} [keyspace] LookupVindexInternalizeRequest keyspace
+ * @property {string|null} [name] LookupVindexInternalizeRequest name
+ * @property {string|null} [table_keyspace] LookupVindexInternalizeRequest table_keyspace
+ */
+
+ /**
+ * Constructs a new LookupVindexInternalizeRequest.
+ * @memberof vtctldata
+ * @classdesc Represents a LookupVindexInternalizeRequest.
+ * @implements ILookupVindexInternalizeRequest
+ * @constructor
+ * @param {vtctldata.ILookupVindexInternalizeRequest=} [properties] Properties to set
+ */
+ function LookupVindexInternalizeRequest(properties) {
+ if (properties)
+ for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
+ if (properties[keys[i]] != null)
+ this[keys[i]] = properties[keys[i]];
+ }
+
+ /**
+ * LookupVindexInternalizeRequest keyspace.
+ * @member {string} keyspace
+ * @memberof vtctldata.LookupVindexInternalizeRequest
+ * @instance
+ */
+ LookupVindexInternalizeRequest.prototype.keyspace = "";
+
+ /**
+ * LookupVindexInternalizeRequest name.
+ * @member {string} name
+ * @memberof vtctldata.LookupVindexInternalizeRequest
+ * @instance
+ */
+ LookupVindexInternalizeRequest.prototype.name = "";
+
+ /**
+ * LookupVindexInternalizeRequest table_keyspace.
+ * @member {string} table_keyspace
+ * @memberof vtctldata.LookupVindexInternalizeRequest
+ * @instance
+ */
+ LookupVindexInternalizeRequest.prototype.table_keyspace = "";
+
+ /**
+ * Creates a new LookupVindexInternalizeRequest instance using the specified properties.
+ * @function create
+ * @memberof vtctldata.LookupVindexInternalizeRequest
+ * @static
+ * @param {vtctldata.ILookupVindexInternalizeRequest=} [properties] Properties to set
+ * @returns {vtctldata.LookupVindexInternalizeRequest} LookupVindexInternalizeRequest instance
+ */
+ LookupVindexInternalizeRequest.create = function create(properties) {
+ return new LookupVindexInternalizeRequest(properties);
+ };
+
+ /**
+ * Encodes the specified LookupVindexInternalizeRequest message. Does not implicitly {@link vtctldata.LookupVindexInternalizeRequest.verify|verify} messages.
+ * @function encode
+ * @memberof vtctldata.LookupVindexInternalizeRequest
+ * @static
+ * @param {vtctldata.ILookupVindexInternalizeRequest} message LookupVindexInternalizeRequest message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ LookupVindexInternalizeRequest.encode = function encode(message, writer) {
+ if (!writer)
+ writer = $Writer.create();
+ if (message.keyspace != null && Object.hasOwnProperty.call(message, "keyspace"))
+ writer.uint32(/* id 1, wireType 2 =*/10).string(message.keyspace);
+ if (message.name != null && Object.hasOwnProperty.call(message, "name"))
+ writer.uint32(/* id 2, wireType 2 =*/18).string(message.name);
+ if (message.table_keyspace != null && Object.hasOwnProperty.call(message, "table_keyspace"))
+ writer.uint32(/* id 3, wireType 2 =*/26).string(message.table_keyspace);
+ return writer;
+ };
+
+ /**
+ * Encodes the specified LookupVindexInternalizeRequest message, length delimited. Does not implicitly {@link vtctldata.LookupVindexInternalizeRequest.verify|verify} messages.
+ * @function encodeDelimited
+ * @memberof vtctldata.LookupVindexInternalizeRequest
+ * @static
+ * @param {vtctldata.ILookupVindexInternalizeRequest} message LookupVindexInternalizeRequest message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ LookupVindexInternalizeRequest.encodeDelimited = function encodeDelimited(message, writer) {
+ return this.encode(message, writer).ldelim();
+ };
+
+ /**
+ * Decodes a LookupVindexInternalizeRequest message from the specified reader or buffer.
+ * @function decode
+ * @memberof vtctldata.LookupVindexInternalizeRequest
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @param {number} [length] Message length if known beforehand
+ * @returns {vtctldata.LookupVindexInternalizeRequest} LookupVindexInternalizeRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ LookupVindexInternalizeRequest.decode = function decode(reader, length) {
+ if (!(reader instanceof $Reader))
+ reader = $Reader.create(reader);
+ let end = length === undefined ? reader.len : reader.pos + length, message = new $root.vtctldata.LookupVindexInternalizeRequest();
+ while (reader.pos < end) {
+ let tag = reader.uint32();
+ switch (tag >>> 3) {
+ case 1: {
+ message.keyspace = reader.string();
+ break;
+ }
+ case 2: {
+ message.name = reader.string();
+ break;
+ }
+ case 3: {
+ message.table_keyspace = reader.string();
+ break;
+ }
+ default:
+ reader.skipType(tag & 7);
+ break;
+ }
+ }
+ return message;
+ };
+
+ /**
+ * Decodes a LookupVindexInternalizeRequest message from the specified reader or buffer, length delimited.
+ * @function decodeDelimited
+ * @memberof vtctldata.LookupVindexInternalizeRequest
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @returns {vtctldata.LookupVindexInternalizeRequest} LookupVindexInternalizeRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ LookupVindexInternalizeRequest.decodeDelimited = function decodeDelimited(reader) {
+ if (!(reader instanceof $Reader))
+ reader = new $Reader(reader);
+ return this.decode(reader, reader.uint32());
+ };
+
+ /**
+ * Verifies a LookupVindexInternalizeRequest message.
+ * @function verify
+ * @memberof vtctldata.LookupVindexInternalizeRequest
+ * @static
+ * @param {Object.} message Plain object to verify
+ * @returns {string|null} `null` if valid, otherwise the reason why it is not
+ */
+ LookupVindexInternalizeRequest.verify = function verify(message) {
+ if (typeof message !== "object" || message === null)
+ return "object expected";
+ if (message.keyspace != null && message.hasOwnProperty("keyspace"))
+ if (!$util.isString(message.keyspace))
+ return "keyspace: string expected";
+ if (message.name != null && message.hasOwnProperty("name"))
+ if (!$util.isString(message.name))
+ return "name: string expected";
+ if (message.table_keyspace != null && message.hasOwnProperty("table_keyspace"))
+ if (!$util.isString(message.table_keyspace))
+ return "table_keyspace: string expected";
+ return null;
+ };
+
+ /**
+ * Creates a LookupVindexInternalizeRequest message from a plain object. Also converts values to their respective internal types.
+ * @function fromObject
+ * @memberof vtctldata.LookupVindexInternalizeRequest
+ * @static
+ * @param {Object.} object Plain object
+ * @returns {vtctldata.LookupVindexInternalizeRequest} LookupVindexInternalizeRequest
+ */
+ LookupVindexInternalizeRequest.fromObject = function fromObject(object) {
+ if (object instanceof $root.vtctldata.LookupVindexInternalizeRequest)
+ return object;
+ let message = new $root.vtctldata.LookupVindexInternalizeRequest();
+ if (object.keyspace != null)
+ message.keyspace = String(object.keyspace);
+ if (object.name != null)
+ message.name = String(object.name);
+ if (object.table_keyspace != null)
+ message.table_keyspace = String(object.table_keyspace);
+ return message;
+ };
+
+ /**
+ * Creates a plain object from a LookupVindexInternalizeRequest message. Also converts values to other types if specified.
+ * @function toObject
+ * @memberof vtctldata.LookupVindexInternalizeRequest
+ * @static
+ * @param {vtctldata.LookupVindexInternalizeRequest} message LookupVindexInternalizeRequest
+ * @param {$protobuf.IConversionOptions} [options] Conversion options
+ * @returns {Object.} Plain object
+ */
+ LookupVindexInternalizeRequest.toObject = function toObject(message, options) {
+ if (!options)
+ options = {};
+ let object = {};
+ if (options.defaults) {
+ object.keyspace = "";
+ object.name = "";
+ object.table_keyspace = "";
+ }
+ if (message.keyspace != null && message.hasOwnProperty("keyspace"))
+ object.keyspace = message.keyspace;
+ if (message.name != null && message.hasOwnProperty("name"))
+ object.name = message.name;
+ if (message.table_keyspace != null && message.hasOwnProperty("table_keyspace"))
+ object.table_keyspace = message.table_keyspace;
+ return object;
+ };
+
+ /**
+ * Converts this LookupVindexInternalizeRequest to JSON.
+ * @function toJSON
+ * @memberof vtctldata.LookupVindexInternalizeRequest
+ * @instance
+ * @returns {Object.} JSON object
+ */
+ LookupVindexInternalizeRequest.prototype.toJSON = function toJSON() {
+ return this.constructor.toObject(this, $protobuf.util.toJSONOptions);
+ };
+
+ /**
+ * Gets the default type url for LookupVindexInternalizeRequest
+ * @function getTypeUrl
+ * @memberof vtctldata.LookupVindexInternalizeRequest
+ * @static
+ * @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns {string} The default type url
+ */
+ LookupVindexInternalizeRequest.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
+ if (typeUrlPrefix === undefined) {
+ typeUrlPrefix = "type.googleapis.com";
+ }
+ return typeUrlPrefix + "/vtctldata.LookupVindexInternalizeRequest";
+ };
+
+ return LookupVindexInternalizeRequest;
+ })();
+
+ vtctldata.LookupVindexInternalizeResponse = (function() {
+
+ /**
+ * Properties of a LookupVindexInternalizeResponse.
+ * @memberof vtctldata
+ * @interface ILookupVindexInternalizeResponse
+ */
+
+ /**
+ * Constructs a new LookupVindexInternalizeResponse.
+ * @memberof vtctldata
+ * @classdesc Represents a LookupVindexInternalizeResponse.
+ * @implements ILookupVindexInternalizeResponse
+ * @constructor
+ * @param {vtctldata.ILookupVindexInternalizeResponse=} [properties] Properties to set
+ */
+ function LookupVindexInternalizeResponse(properties) {
+ if (properties)
+ for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
+ if (properties[keys[i]] != null)
+ this[keys[i]] = properties[keys[i]];
+ }
+
+ /**
+ * Creates a new LookupVindexInternalizeResponse instance using the specified properties.
+ * @function create
+ * @memberof vtctldata.LookupVindexInternalizeResponse
+ * @static
+ * @param {vtctldata.ILookupVindexInternalizeResponse=} [properties] Properties to set
+ * @returns {vtctldata.LookupVindexInternalizeResponse} LookupVindexInternalizeResponse instance
+ */
+ LookupVindexInternalizeResponse.create = function create(properties) {
+ return new LookupVindexInternalizeResponse(properties);
+ };
+
+ /**
+ * Encodes the specified LookupVindexInternalizeResponse message. Does not implicitly {@link vtctldata.LookupVindexInternalizeResponse.verify|verify} messages.
+ * @function encode
+ * @memberof vtctldata.LookupVindexInternalizeResponse
+ * @static
+ * @param {vtctldata.ILookupVindexInternalizeResponse} message LookupVindexInternalizeResponse message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ LookupVindexInternalizeResponse.encode = function encode(message, writer) {
+ if (!writer)
+ writer = $Writer.create();
+ return writer;
+ };
+
+ /**
+ * Encodes the specified LookupVindexInternalizeResponse message, length delimited. Does not implicitly {@link vtctldata.LookupVindexInternalizeResponse.verify|verify} messages.
+ * @function encodeDelimited
+ * @memberof vtctldata.LookupVindexInternalizeResponse
+ * @static
+ * @param {vtctldata.ILookupVindexInternalizeResponse} message LookupVindexInternalizeResponse message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ LookupVindexInternalizeResponse.encodeDelimited = function encodeDelimited(message, writer) {
+ return this.encode(message, writer).ldelim();
+ };
+
+ /**
+ * Decodes a LookupVindexInternalizeResponse message from the specified reader or buffer.
+ * @function decode
+ * @memberof vtctldata.LookupVindexInternalizeResponse
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @param {number} [length] Message length if known beforehand
+ * @returns {vtctldata.LookupVindexInternalizeResponse} LookupVindexInternalizeResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ LookupVindexInternalizeResponse.decode = function decode(reader, length) {
+ if (!(reader instanceof $Reader))
+ reader = $Reader.create(reader);
+ let end = length === undefined ? reader.len : reader.pos + length, message = new $root.vtctldata.LookupVindexInternalizeResponse();
+ while (reader.pos < end) {
+ let tag = reader.uint32();
+ switch (tag >>> 3) {
+ default:
+ reader.skipType(tag & 7);
+ break;
+ }
+ }
+ return message;
+ };
+
+ /**
+ * Decodes a LookupVindexInternalizeResponse message from the specified reader or buffer, length delimited.
+ * @function decodeDelimited
+ * @memberof vtctldata.LookupVindexInternalizeResponse
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @returns {vtctldata.LookupVindexInternalizeResponse} LookupVindexInternalizeResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ LookupVindexInternalizeResponse.decodeDelimited = function decodeDelimited(reader) {
+ if (!(reader instanceof $Reader))
+ reader = new $Reader(reader);
+ return this.decode(reader, reader.uint32());
+ };
+
+ /**
+ * Verifies a LookupVindexInternalizeResponse message.
+ * @function verify
+ * @memberof vtctldata.LookupVindexInternalizeResponse
+ * @static
+ * @param {Object.} message Plain object to verify
+ * @returns {string|null} `null` if valid, otherwise the reason why it is not
+ */
+ LookupVindexInternalizeResponse.verify = function verify(message) {
+ if (typeof message !== "object" || message === null)
+ return "object expected";
+ return null;
+ };
+
+ /**
+ * Creates a LookupVindexInternalizeResponse message from a plain object. Also converts values to their respective internal types.
+ * @function fromObject
+ * @memberof vtctldata.LookupVindexInternalizeResponse
+ * @static
+ * @param {Object.} object Plain object
+ * @returns {vtctldata.LookupVindexInternalizeResponse} LookupVindexInternalizeResponse
+ */
+ LookupVindexInternalizeResponse.fromObject = function fromObject(object) {
+ if (object instanceof $root.vtctldata.LookupVindexInternalizeResponse)
+ return object;
+ return new $root.vtctldata.LookupVindexInternalizeResponse();
+ };
+
+ /**
+ * Creates a plain object from a LookupVindexInternalizeResponse message. Also converts values to other types if specified.
+ * @function toObject
+ * @memberof vtctldata.LookupVindexInternalizeResponse
+ * @static
+ * @param {vtctldata.LookupVindexInternalizeResponse} message LookupVindexInternalizeResponse
+ * @param {$protobuf.IConversionOptions} [options] Conversion options
+ * @returns {Object.} Plain object
+ */
+ LookupVindexInternalizeResponse.toObject = function toObject() {
+ return {};
+ };
+
+ /**
+ * Converts this LookupVindexInternalizeResponse to JSON.
+ * @function toJSON
+ * @memberof vtctldata.LookupVindexInternalizeResponse
+ * @instance
+ * @returns {Object.} JSON object
+ */
+ LookupVindexInternalizeResponse.prototype.toJSON = function toJSON() {
+ return this.constructor.toObject(this, $protobuf.util.toJSONOptions);
+ };
+
+ /**
+ * Gets the default type url for LookupVindexInternalizeResponse
+ * @function getTypeUrl
+ * @memberof vtctldata.LookupVindexInternalizeResponse
+ * @static
+ * @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns {string} The default type url
+ */
+ LookupVindexInternalizeResponse.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
+ if (typeUrlPrefix === undefined) {
+ typeUrlPrefix = "type.googleapis.com";
+ }
+ return typeUrlPrefix + "/vtctldata.LookupVindexInternalizeResponse";
+ };
+
+ return LookupVindexInternalizeResponse;
+ })();
+
vtctldata.MaterializeCreateRequest = (function() {
/**
@@ -184806,6 +186304,424 @@ export const vtctldata = $root.vtctldata = (() => {
return ValidateKeyspaceResponse;
})();
+ vtctldata.ValidatePermissionsKeyspaceRequest = (function() {
+
+ /**
+ * Properties of a ValidatePermissionsKeyspaceRequest.
+ * @memberof vtctldata
+ * @interface IValidatePermissionsKeyspaceRequest
+ * @property {string|null} [keyspace] ValidatePermissionsKeyspaceRequest keyspace
+ * @property {Array.|null} [shards] ValidatePermissionsKeyspaceRequest shards
+ */
+
+ /**
+ * Constructs a new ValidatePermissionsKeyspaceRequest.
+ * @memberof vtctldata
+ * @classdesc Represents a ValidatePermissionsKeyspaceRequest.
+ * @implements IValidatePermissionsKeyspaceRequest
+ * @constructor
+ * @param {vtctldata.IValidatePermissionsKeyspaceRequest=} [properties] Properties to set
+ */
+ function ValidatePermissionsKeyspaceRequest(properties) {
+ this.shards = [];
+ if (properties)
+ for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
+ if (properties[keys[i]] != null)
+ this[keys[i]] = properties[keys[i]];
+ }
+
+ /**
+ * ValidatePermissionsKeyspaceRequest keyspace.
+ * @member {string} keyspace
+ * @memberof vtctldata.ValidatePermissionsKeyspaceRequest
+ * @instance
+ */
+ ValidatePermissionsKeyspaceRequest.prototype.keyspace = "";
+
+ /**
+ * ValidatePermissionsKeyspaceRequest shards.
+ * @member {Array.} shards
+ * @memberof vtctldata.ValidatePermissionsKeyspaceRequest
+ * @instance
+ */
+ ValidatePermissionsKeyspaceRequest.prototype.shards = $util.emptyArray;
+
+ /**
+ * Creates a new ValidatePermissionsKeyspaceRequest instance using the specified properties.
+ * @function create
+ * @memberof vtctldata.ValidatePermissionsKeyspaceRequest
+ * @static
+ * @param {vtctldata.IValidatePermissionsKeyspaceRequest=} [properties] Properties to set
+ * @returns {vtctldata.ValidatePermissionsKeyspaceRequest} ValidatePermissionsKeyspaceRequest instance
+ */
+ ValidatePermissionsKeyspaceRequest.create = function create(properties) {
+ return new ValidatePermissionsKeyspaceRequest(properties);
+ };
+
+ /**
+ * Encodes the specified ValidatePermissionsKeyspaceRequest message. Does not implicitly {@link vtctldata.ValidatePermissionsKeyspaceRequest.verify|verify} messages.
+ * @function encode
+ * @memberof vtctldata.ValidatePermissionsKeyspaceRequest
+ * @static
+ * @param {vtctldata.IValidatePermissionsKeyspaceRequest} message ValidatePermissionsKeyspaceRequest message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ ValidatePermissionsKeyspaceRequest.encode = function encode(message, writer) {
+ if (!writer)
+ writer = $Writer.create();
+ if (message.keyspace != null && Object.hasOwnProperty.call(message, "keyspace"))
+ writer.uint32(/* id 1, wireType 2 =*/10).string(message.keyspace);
+ if (message.shards != null && message.shards.length)
+ for (let i = 0; i < message.shards.length; ++i)
+ writer.uint32(/* id 2, wireType 2 =*/18).string(message.shards[i]);
+ return writer;
+ };
+
+ /**
+ * Encodes the specified ValidatePermissionsKeyspaceRequest message, length delimited. Does not implicitly {@link vtctldata.ValidatePermissionsKeyspaceRequest.verify|verify} messages.
+ * @function encodeDelimited
+ * @memberof vtctldata.ValidatePermissionsKeyspaceRequest
+ * @static
+ * @param {vtctldata.IValidatePermissionsKeyspaceRequest} message ValidatePermissionsKeyspaceRequest message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ ValidatePermissionsKeyspaceRequest.encodeDelimited = function encodeDelimited(message, writer) {
+ return this.encode(message, writer).ldelim();
+ };
+
+ /**
+ * Decodes a ValidatePermissionsKeyspaceRequest message from the specified reader or buffer.
+ * @function decode
+ * @memberof vtctldata.ValidatePermissionsKeyspaceRequest
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @param {number} [length] Message length if known beforehand
+ * @returns {vtctldata.ValidatePermissionsKeyspaceRequest} ValidatePermissionsKeyspaceRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ ValidatePermissionsKeyspaceRequest.decode = function decode(reader, length) {
+ if (!(reader instanceof $Reader))
+ reader = $Reader.create(reader);
+ let end = length === undefined ? reader.len : reader.pos + length, message = new $root.vtctldata.ValidatePermissionsKeyspaceRequest();
+ while (reader.pos < end) {
+ let tag = reader.uint32();
+ switch (tag >>> 3) {
+ case 1: {
+ message.keyspace = reader.string();
+ break;
+ }
+ case 2: {
+ if (!(message.shards && message.shards.length))
+ message.shards = [];
+ message.shards.push(reader.string());
+ break;
+ }
+ default:
+ reader.skipType(tag & 7);
+ break;
+ }
+ }
+ return message;
+ };
+
+ /**
+ * Decodes a ValidatePermissionsKeyspaceRequest message from the specified reader or buffer, length delimited.
+ * @function decodeDelimited
+ * @memberof vtctldata.ValidatePermissionsKeyspaceRequest
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @returns {vtctldata.ValidatePermissionsKeyspaceRequest} ValidatePermissionsKeyspaceRequest
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ ValidatePermissionsKeyspaceRequest.decodeDelimited = function decodeDelimited(reader) {
+ if (!(reader instanceof $Reader))
+ reader = new $Reader(reader);
+ return this.decode(reader, reader.uint32());
+ };
+
+ /**
+ * Verifies a ValidatePermissionsKeyspaceRequest message.
+ * @function verify
+ * @memberof vtctldata.ValidatePermissionsKeyspaceRequest
+ * @static
+ * @param {Object.} message Plain object to verify
+ * @returns {string|null} `null` if valid, otherwise the reason why it is not
+ */
+ ValidatePermissionsKeyspaceRequest.verify = function verify(message) {
+ if (typeof message !== "object" || message === null)
+ return "object expected";
+ if (message.keyspace != null && message.hasOwnProperty("keyspace"))
+ if (!$util.isString(message.keyspace))
+ return "keyspace: string expected";
+ if (message.shards != null && message.hasOwnProperty("shards")) {
+ if (!Array.isArray(message.shards))
+ return "shards: array expected";
+ for (let i = 0; i < message.shards.length; ++i)
+ if (!$util.isString(message.shards[i]))
+ return "shards: string[] expected";
+ }
+ return null;
+ };
+
+ /**
+ * Creates a ValidatePermissionsKeyspaceRequest message from a plain object. Also converts values to their respective internal types.
+ * @function fromObject
+ * @memberof vtctldata.ValidatePermissionsKeyspaceRequest
+ * @static
+ * @param {Object.} object Plain object
+ * @returns {vtctldata.ValidatePermissionsKeyspaceRequest} ValidatePermissionsKeyspaceRequest
+ */
+ ValidatePermissionsKeyspaceRequest.fromObject = function fromObject(object) {
+ if (object instanceof $root.vtctldata.ValidatePermissionsKeyspaceRequest)
+ return object;
+ let message = new $root.vtctldata.ValidatePermissionsKeyspaceRequest();
+ if (object.keyspace != null)
+ message.keyspace = String(object.keyspace);
+ if (object.shards) {
+ if (!Array.isArray(object.shards))
+ throw TypeError(".vtctldata.ValidatePermissionsKeyspaceRequest.shards: array expected");
+ message.shards = [];
+ for (let i = 0; i < object.shards.length; ++i)
+ message.shards[i] = String(object.shards[i]);
+ }
+ return message;
+ };
+
+ /**
+ * Creates a plain object from a ValidatePermissionsKeyspaceRequest message. Also converts values to other types if specified.
+ * @function toObject
+ * @memberof vtctldata.ValidatePermissionsKeyspaceRequest
+ * @static
+ * @param {vtctldata.ValidatePermissionsKeyspaceRequest} message ValidatePermissionsKeyspaceRequest
+ * @param {$protobuf.IConversionOptions} [options] Conversion options
+ * @returns {Object.} Plain object
+ */
+ ValidatePermissionsKeyspaceRequest.toObject = function toObject(message, options) {
+ if (!options)
+ options = {};
+ let object = {};
+ if (options.arrays || options.defaults)
+ object.shards = [];
+ if (options.defaults)
+ object.keyspace = "";
+ if (message.keyspace != null && message.hasOwnProperty("keyspace"))
+ object.keyspace = message.keyspace;
+ if (message.shards && message.shards.length) {
+ object.shards = [];
+ for (let j = 0; j < message.shards.length; ++j)
+ object.shards[j] = message.shards[j];
+ }
+ return object;
+ };
+
+ /**
+ * Converts this ValidatePermissionsKeyspaceRequest to JSON.
+ * @function toJSON
+ * @memberof vtctldata.ValidatePermissionsKeyspaceRequest
+ * @instance
+ * @returns {Object.} JSON object
+ */
+ ValidatePermissionsKeyspaceRequest.prototype.toJSON = function toJSON() {
+ return this.constructor.toObject(this, $protobuf.util.toJSONOptions);
+ };
+
+ /**
+ * Gets the default type url for ValidatePermissionsKeyspaceRequest
+ * @function getTypeUrl
+ * @memberof vtctldata.ValidatePermissionsKeyspaceRequest
+ * @static
+ * @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns {string} The default type url
+ */
+ ValidatePermissionsKeyspaceRequest.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
+ if (typeUrlPrefix === undefined) {
+ typeUrlPrefix = "type.googleapis.com";
+ }
+ return typeUrlPrefix + "/vtctldata.ValidatePermissionsKeyspaceRequest";
+ };
+
+ return ValidatePermissionsKeyspaceRequest;
+ })();
+
+ vtctldata.ValidatePermissionsKeyspaceResponse = (function() {
+
+ /**
+ * Properties of a ValidatePermissionsKeyspaceResponse.
+ * @memberof vtctldata
+ * @interface IValidatePermissionsKeyspaceResponse
+ */
+
+ /**
+ * Constructs a new ValidatePermissionsKeyspaceResponse.
+ * @memberof vtctldata
+ * @classdesc Represents a ValidatePermissionsKeyspaceResponse.
+ * @implements IValidatePermissionsKeyspaceResponse
+ * @constructor
+ * @param {vtctldata.IValidatePermissionsKeyspaceResponse=} [properties] Properties to set
+ */
+ function ValidatePermissionsKeyspaceResponse(properties) {
+ if (properties)
+ for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
+ if (properties[keys[i]] != null)
+ this[keys[i]] = properties[keys[i]];
+ }
+
+ /**
+ * Creates a new ValidatePermissionsKeyspaceResponse instance using the specified properties.
+ * @function create
+ * @memberof vtctldata.ValidatePermissionsKeyspaceResponse
+ * @static
+ * @param {vtctldata.IValidatePermissionsKeyspaceResponse=} [properties] Properties to set
+ * @returns {vtctldata.ValidatePermissionsKeyspaceResponse} ValidatePermissionsKeyspaceResponse instance
+ */
+ ValidatePermissionsKeyspaceResponse.create = function create(properties) {
+ return new ValidatePermissionsKeyspaceResponse(properties);
+ };
+
+ /**
+ * Encodes the specified ValidatePermissionsKeyspaceResponse message. Does not implicitly {@link vtctldata.ValidatePermissionsKeyspaceResponse.verify|verify} messages.
+ * @function encode
+ * @memberof vtctldata.ValidatePermissionsKeyspaceResponse
+ * @static
+ * @param {vtctldata.IValidatePermissionsKeyspaceResponse} message ValidatePermissionsKeyspaceResponse message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ ValidatePermissionsKeyspaceResponse.encode = function encode(message, writer) {
+ if (!writer)
+ writer = $Writer.create();
+ return writer;
+ };
+
+ /**
+ * Encodes the specified ValidatePermissionsKeyspaceResponse message, length delimited. Does not implicitly {@link vtctldata.ValidatePermissionsKeyspaceResponse.verify|verify} messages.
+ * @function encodeDelimited
+ * @memberof vtctldata.ValidatePermissionsKeyspaceResponse
+ * @static
+ * @param {vtctldata.IValidatePermissionsKeyspaceResponse} message ValidatePermissionsKeyspaceResponse message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ ValidatePermissionsKeyspaceResponse.encodeDelimited = function encodeDelimited(message, writer) {
+ return this.encode(message, writer).ldelim();
+ };
+
+ /**
+ * Decodes a ValidatePermissionsKeyspaceResponse message from the specified reader or buffer.
+ * @function decode
+ * @memberof vtctldata.ValidatePermissionsKeyspaceResponse
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @param {number} [length] Message length if known beforehand
+ * @returns {vtctldata.ValidatePermissionsKeyspaceResponse} ValidatePermissionsKeyspaceResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ ValidatePermissionsKeyspaceResponse.decode = function decode(reader, length) {
+ if (!(reader instanceof $Reader))
+ reader = $Reader.create(reader);
+ let end = length === undefined ? reader.len : reader.pos + length, message = new $root.vtctldata.ValidatePermissionsKeyspaceResponse();
+ while (reader.pos < end) {
+ let tag = reader.uint32();
+ switch (tag >>> 3) {
+ default:
+ reader.skipType(tag & 7);
+ break;
+ }
+ }
+ return message;
+ };
+
+ /**
+ * Decodes a ValidatePermissionsKeyspaceResponse message from the specified reader or buffer, length delimited.
+ * @function decodeDelimited
+ * @memberof vtctldata.ValidatePermissionsKeyspaceResponse
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @returns {vtctldata.ValidatePermissionsKeyspaceResponse} ValidatePermissionsKeyspaceResponse
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ ValidatePermissionsKeyspaceResponse.decodeDelimited = function decodeDelimited(reader) {
+ if (!(reader instanceof $Reader))
+ reader = new $Reader(reader);
+ return this.decode(reader, reader.uint32());
+ };
+
+ /**
+ * Verifies a ValidatePermissionsKeyspaceResponse message.
+ * @function verify
+ * @memberof vtctldata.ValidatePermissionsKeyspaceResponse
+ * @static
+ * @param {Object.} message Plain object to verify
+ * @returns {string|null} `null` if valid, otherwise the reason why it is not
+ */
+ ValidatePermissionsKeyspaceResponse.verify = function verify(message) {
+ if (typeof message !== "object" || message === null)
+ return "object expected";
+ return null;
+ };
+
+ /**
+ * Creates a ValidatePermissionsKeyspaceResponse message from a plain object. Also converts values to their respective internal types.
+ * @function fromObject
+ * @memberof vtctldata.ValidatePermissionsKeyspaceResponse
+ * @static
+ * @param {Object.} object Plain object
+ * @returns {vtctldata.ValidatePermissionsKeyspaceResponse} ValidatePermissionsKeyspaceResponse
+ */
+ ValidatePermissionsKeyspaceResponse.fromObject = function fromObject(object) {
+ if (object instanceof $root.vtctldata.ValidatePermissionsKeyspaceResponse)
+ return object;
+ return new $root.vtctldata.ValidatePermissionsKeyspaceResponse();
+ };
+
+ /**
+ * Creates a plain object from a ValidatePermissionsKeyspaceResponse message. Also converts values to other types if specified.
+ * @function toObject
+ * @memberof vtctldata.ValidatePermissionsKeyspaceResponse
+ * @static
+ * @param {vtctldata.ValidatePermissionsKeyspaceResponse} message ValidatePermissionsKeyspaceResponse
+ * @param {$protobuf.IConversionOptions} [options] Conversion options
+ * @returns {Object.} Plain object
+ */
+ ValidatePermissionsKeyspaceResponse.toObject = function toObject() {
+ return {};
+ };
+
+ /**
+ * Converts this ValidatePermissionsKeyspaceResponse to JSON.
+ * @function toJSON
+ * @memberof vtctldata.ValidatePermissionsKeyspaceResponse
+ * @instance
+ * @returns {Object.} JSON object
+ */
+ ValidatePermissionsKeyspaceResponse.prototype.toJSON = function toJSON() {
+ return this.constructor.toObject(this, $protobuf.util.toJSONOptions);
+ };
+
+ /**
+ * Gets the default type url for ValidatePermissionsKeyspaceResponse
+ * @function getTypeUrl
+ * @memberof vtctldata.ValidatePermissionsKeyspaceResponse
+ * @static
+ * @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns {string} The default type url
+ */
+ ValidatePermissionsKeyspaceResponse.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
+ if (typeUrlPrefix === undefined) {
+ typeUrlPrefix = "type.googleapis.com";
+ }
+ return typeUrlPrefix + "/vtctldata.ValidatePermissionsKeyspaceResponse";
+ };
+
+ return ValidatePermissionsKeyspaceResponse;
+ })();
+
vtctldata.ValidateSchemaKeyspaceRequest = (function() {
/**
@@ -184817,6 +186733,7 @@ export const vtctldata = $root.vtctldata = (() => {
* @property {boolean|null} [include_views] ValidateSchemaKeyspaceRequest include_views
* @property {boolean|null} [skip_no_primary] ValidateSchemaKeyspaceRequest skip_no_primary
* @property {boolean|null} [include_vschema] ValidateSchemaKeyspaceRequest include_vschema
+ * @property {Array.|null} [shards] ValidateSchemaKeyspaceRequest shards
*/
/**
@@ -184829,6 +186746,7 @@ export const vtctldata = $root.vtctldata = (() => {
*/
function ValidateSchemaKeyspaceRequest(properties) {
this.exclude_tables = [];
+ this.shards = [];
if (properties)
for (let keys = Object.keys(properties), i = 0; i < keys.length; ++i)
if (properties[keys[i]] != null)
@@ -184875,6 +186793,14 @@ export const vtctldata = $root.vtctldata = (() => {
*/
ValidateSchemaKeyspaceRequest.prototype.include_vschema = false;
+ /**
+ * ValidateSchemaKeyspaceRequest shards.
+ * @member {Array.} shards
+ * @memberof vtctldata.ValidateSchemaKeyspaceRequest
+ * @instance
+ */
+ ValidateSchemaKeyspaceRequest.prototype.shards = $util.emptyArray;
+
/**
* Creates a new ValidateSchemaKeyspaceRequest instance using the specified properties.
* @function create
@@ -184910,6 +186836,9 @@ export const vtctldata = $root.vtctldata = (() => {
writer.uint32(/* id 4, wireType 0 =*/32).bool(message.skip_no_primary);
if (message.include_vschema != null && Object.hasOwnProperty.call(message, "include_vschema"))
writer.uint32(/* id 5, wireType 0 =*/40).bool(message.include_vschema);
+ if (message.shards != null && message.shards.length)
+ for (let i = 0; i < message.shards.length; ++i)
+ writer.uint32(/* id 6, wireType 2 =*/50).string(message.shards[i]);
return writer;
};
@@ -184966,6 +186895,12 @@ export const vtctldata = $root.vtctldata = (() => {
message.include_vschema = reader.bool();
break;
}
+ case 6: {
+ if (!(message.shards && message.shards.length))
+ message.shards = [];
+ message.shards.push(reader.string());
+ break;
+ }
default:
reader.skipType(tag & 7);
break;
@@ -185020,6 +186955,13 @@ export const vtctldata = $root.vtctldata = (() => {
if (message.include_vschema != null && message.hasOwnProperty("include_vschema"))
if (typeof message.include_vschema !== "boolean")
return "include_vschema: boolean expected";
+ if (message.shards != null && message.hasOwnProperty("shards")) {
+ if (!Array.isArray(message.shards))
+ return "shards: array expected";
+ for (let i = 0; i < message.shards.length; ++i)
+ if (!$util.isString(message.shards[i]))
+ return "shards: string[] expected";
+ }
return null;
};
@@ -185050,6 +186992,13 @@ export const vtctldata = $root.vtctldata = (() => {
message.skip_no_primary = Boolean(object.skip_no_primary);
if (object.include_vschema != null)
message.include_vschema = Boolean(object.include_vschema);
+ if (object.shards) {
+ if (!Array.isArray(object.shards))
+ throw TypeError(".vtctldata.ValidateSchemaKeyspaceRequest.shards: array expected");
+ message.shards = [];
+ for (let i = 0; i < object.shards.length; ++i)
+ message.shards[i] = String(object.shards[i]);
+ }
return message;
};
@@ -185066,8 +187015,10 @@ export const vtctldata = $root.vtctldata = (() => {
if (!options)
options = {};
let object = {};
- if (options.arrays || options.defaults)
+ if (options.arrays || options.defaults) {
object.exclude_tables = [];
+ object.shards = [];
+ }
if (options.defaults) {
object.keyspace = "";
object.include_views = false;
@@ -185087,6 +187038,11 @@ export const vtctldata = $root.vtctldata = (() => {
object.skip_no_primary = message.skip_no_primary;
if (message.include_vschema != null && message.hasOwnProperty("include_vschema"))
object.include_vschema = message.include_vschema;
+ if (message.shards && message.shards.length) {
+ object.shards = [];
+ for (let j = 0; j < message.shards.length; ++j)
+ object.shards[j] = message.shards[j];
+ }
return object;
};
@@ -187627,12 +189583,7 @@ export const vtctldata = $root.vtctldata = (() => {
// OneOf field names bound to virtual getters and setters
let $oneOfFields;
- /**
- * VDiffCreateRequest _auto_start.
- * @member {"auto_start"|undefined} _auto_start
- * @memberof vtctldata.VDiffCreateRequest
- * @instance
- */
+ // Virtual OneOf for proto3 optional field
Object.defineProperty(VDiffCreateRequest.prototype, "_auto_start", {
get: $util.oneOfGetter($oneOfFields = ["auto_start"]),
set: $util.oneOfSetter($oneOfFields)