= ({ 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 234c7e0f323..e8fd5040baf 100644
--- a/web/vtadmin/src/proto/vtadmin.d.ts
+++ b/web/vtadmin/src/proto/vtadmin.d.ts
@@ -34138,6 +34138,112 @@ export namespace tabletmanagerdata {
public static getTypeUrl(typeUrlPrefix?: string): string;
}
+ /** Properties of a VDiffTableLastPK. */
+ interface IVDiffTableLastPK {
+
+ /** VDiffTableLastPK target */
+ target?: (query.IQueryResult|null);
+
+ /** VDiffTableLastPK source */
+ source?: (query.IQueryResult|null);
+ }
+
+ /** Represents a VDiffTableLastPK. */
+ class VDiffTableLastPK implements IVDiffTableLastPK {
+
+ /**
+ * Constructs a new VDiffTableLastPK.
+ * @param [properties] Properties to set
+ */
+ constructor(properties?: tabletmanagerdata.IVDiffTableLastPK);
+
+ /** VDiffTableLastPK target. */
+ public target?: (query.IQueryResult|null);
+
+ /** 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
+ * @returns VDiffTableLastPK instance
+ */
+ public static create(properties?: tabletmanagerdata.IVDiffTableLastPK): tabletmanagerdata.VDiffTableLastPK;
+
+ /**
+ * Encodes the specified VDiffTableLastPK message. Does not implicitly {@link tabletmanagerdata.VDiffTableLastPK.verify|verify} messages.
+ * @param message VDiffTableLastPK message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encode(message: tabletmanagerdata.IVDiffTableLastPK, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Encodes the specified VDiffTableLastPK message, length delimited. Does not implicitly {@link tabletmanagerdata.VDiffTableLastPK.verify|verify} messages.
+ * @param message VDiffTableLastPK message or plain object to encode
+ * @param [writer] Writer to encode to
+ * @returns Writer
+ */
+ public static encodeDelimited(message: tabletmanagerdata.IVDiffTableLastPK, writer?: $protobuf.Writer): $protobuf.Writer;
+
+ /**
+ * Decodes a VDiffTableLastPK message from the specified reader or buffer.
+ * @param reader Reader or buffer to decode from
+ * @param [length] Message length if known beforehand
+ * @returns VDiffTableLastPK
+ * @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): tabletmanagerdata.VDiffTableLastPK;
+
+ /**
+ * Decodes a VDiffTableLastPK message from the specified reader or buffer, length delimited.
+ * @param reader Reader or buffer to decode from
+ * @returns VDiffTableLastPK
+ * @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)): tabletmanagerdata.VDiffTableLastPK;
+
+ /**
+ * Verifies a VDiffTableLastPK 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 VDiffTableLastPK message from a plain object. Also converts values to their respective internal types.
+ * @param object Plain object
+ * @returns VDiffTableLastPK
+ */
+ public static fromObject(object: { [k: string]: any }): tabletmanagerdata.VDiffTableLastPK;
+
+ /**
+ * Creates a plain object from a VDiffTableLastPK message. Also converts values to other types if specified.
+ * @param message VDiffTableLastPK
+ * @param [options] Conversion options
+ * @returns Plain object
+ */
+ public static toObject(message: tabletmanagerdata.VDiffTableLastPK, options?: $protobuf.IConversionOptions): { [k: string]: any };
+
+ /**
+ * Converts this VDiffTableLastPK to JSON.
+ * @returns JSON object
+ */
+ public toJSON(): { [k: string]: any };
+
+ /**
+ * Gets the default type url for VDiffTableLastPK
+ * @param [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns The default type url
+ */
+ public static getTypeUrl(typeUrlPrefix?: string): string;
+ }
+
/** Properties of an UpdateVReplicationWorkflowRequest. */
interface IUpdateVReplicationWorkflowRequest {
@@ -55874,6 +55980,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 {
@@ -75654,6 +75990,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 {
@@ -75671,6 +76201,9 @@ export namespace vtctldata {
/** ValidateSchemaKeyspaceRequest include_vschema */
include_vschema?: (boolean|null);
+
+ /** ValidateSchemaKeyspaceRequest shards */
+ shards?: (string[]|null);
}
/** Represents a ValidateSchemaKeyspaceRequest. */
@@ -75697,6 +76230,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
diff --git a/web/vtadmin/src/proto/vtadmin.js b/web/vtadmin/src/proto/vtadmin.js
index f1935b2a9b3..d215662ab7c 100644
--- a/web/vtadmin/src/proto/vtadmin.js
+++ b/web/vtadmin/src/proto/vtadmin.js
@@ -78899,6 +78899,262 @@ export const tabletmanagerdata = $root.tabletmanagerdata = (() => {
return VDiffOptions;
})();
+ tabletmanagerdata.VDiffTableLastPK = (function() {
+
+ /**
+ * Properties of a VDiffTableLastPK.
+ * @memberof tabletmanagerdata
+ * @interface IVDiffTableLastPK
+ * @property {query.IQueryResult|null} [target] VDiffTableLastPK target
+ * @property {query.IQueryResult|null} [source] VDiffTableLastPK source
+ */
+
+ /**
+ * Constructs a new VDiffTableLastPK.
+ * @memberof tabletmanagerdata
+ * @classdesc Represents a VDiffTableLastPK.
+ * @implements IVDiffTableLastPK
+ * @constructor
+ * @param {tabletmanagerdata.IVDiffTableLastPK=} [properties] Properties to set
+ */
+ function VDiffTableLastPK(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]];
+ }
+
+ /**
+ * VDiffTableLastPK target.
+ * @member {query.IQueryResult|null|undefined} target
+ * @memberof tabletmanagerdata.VDiffTableLastPK
+ * @instance
+ */
+ VDiffTableLastPK.prototype.target = null;
+
+ /**
+ * VDiffTableLastPK source.
+ * @member {query.IQueryResult|null|undefined} source
+ * @memberof tabletmanagerdata.VDiffTableLastPK
+ * @instance
+ */
+ VDiffTableLastPK.prototype.source = null;
+
+ // OneOf field names bound to virtual getters and setters
+ let $oneOfFields;
+
+ /**
+ * VDiffTableLastPK _source.
+ * @member {"source"|undefined} _source
+ * @memberof tabletmanagerdata.VDiffTableLastPK
+ * @instance
+ */
+ Object.defineProperty(VDiffTableLastPK.prototype, "_source", {
+ get: $util.oneOfGetter($oneOfFields = ["source"]),
+ set: $util.oneOfSetter($oneOfFields)
+ });
+
+ /**
+ * Creates a new VDiffTableLastPK instance using the specified properties.
+ * @function create
+ * @memberof tabletmanagerdata.VDiffTableLastPK
+ * @static
+ * @param {tabletmanagerdata.IVDiffTableLastPK=} [properties] Properties to set
+ * @returns {tabletmanagerdata.VDiffTableLastPK} VDiffTableLastPK instance
+ */
+ VDiffTableLastPK.create = function create(properties) {
+ return new VDiffTableLastPK(properties);
+ };
+
+ /**
+ * Encodes the specified VDiffTableLastPK message. Does not implicitly {@link tabletmanagerdata.VDiffTableLastPK.verify|verify} messages.
+ * @function encode
+ * @memberof tabletmanagerdata.VDiffTableLastPK
+ * @static
+ * @param {tabletmanagerdata.IVDiffTableLastPK} message VDiffTableLastPK message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ VDiffTableLastPK.encode = function encode(message, writer) {
+ if (!writer)
+ writer = $Writer.create();
+ if (message.target != null && Object.hasOwnProperty.call(message, "target"))
+ $root.query.QueryResult.encode(message.target, writer.uint32(/* id 1, wireType 2 =*/10).fork()).ldelim();
+ if (message.source != null && Object.hasOwnProperty.call(message, "source"))
+ $root.query.QueryResult.encode(message.source, writer.uint32(/* id 2, wireType 2 =*/18).fork()).ldelim();
+ return writer;
+ };
+
+ /**
+ * Encodes the specified VDiffTableLastPK message, length delimited. Does not implicitly {@link tabletmanagerdata.VDiffTableLastPK.verify|verify} messages.
+ * @function encodeDelimited
+ * @memberof tabletmanagerdata.VDiffTableLastPK
+ * @static
+ * @param {tabletmanagerdata.IVDiffTableLastPK} message VDiffTableLastPK message or plain object to encode
+ * @param {$protobuf.Writer} [writer] Writer to encode to
+ * @returns {$protobuf.Writer} Writer
+ */
+ VDiffTableLastPK.encodeDelimited = function encodeDelimited(message, writer) {
+ return this.encode(message, writer).ldelim();
+ };
+
+ /**
+ * Decodes a VDiffTableLastPK message from the specified reader or buffer.
+ * @function decode
+ * @memberof tabletmanagerdata.VDiffTableLastPK
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @param {number} [length] Message length if known beforehand
+ * @returns {tabletmanagerdata.VDiffTableLastPK} VDiffTableLastPK
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ VDiffTableLastPK.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.tabletmanagerdata.VDiffTableLastPK();
+ while (reader.pos < end) {
+ let tag = reader.uint32();
+ switch (tag >>> 3) {
+ case 1: {
+ message.target = $root.query.QueryResult.decode(reader, reader.uint32());
+ break;
+ }
+ case 2: {
+ message.source = $root.query.QueryResult.decode(reader, reader.uint32());
+ break;
+ }
+ default:
+ reader.skipType(tag & 7);
+ break;
+ }
+ }
+ return message;
+ };
+
+ /**
+ * Decodes a VDiffTableLastPK message from the specified reader or buffer, length delimited.
+ * @function decodeDelimited
+ * @memberof tabletmanagerdata.VDiffTableLastPK
+ * @static
+ * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from
+ * @returns {tabletmanagerdata.VDiffTableLastPK} VDiffTableLastPK
+ * @throws {Error} If the payload is not a reader or valid buffer
+ * @throws {$protobuf.util.ProtocolError} If required fields are missing
+ */
+ VDiffTableLastPK.decodeDelimited = function decodeDelimited(reader) {
+ if (!(reader instanceof $Reader))
+ reader = new $Reader(reader);
+ return this.decode(reader, reader.uint32());
+ };
+
+ /**
+ * Verifies a VDiffTableLastPK message.
+ * @function verify
+ * @memberof tabletmanagerdata.VDiffTableLastPK
+ * @static
+ * @param {Object.} message Plain object to verify
+ * @returns {string|null} `null` if valid, otherwise the reason why it is not
+ */
+ VDiffTableLastPK.verify = function verify(message) {
+ if (typeof message !== "object" || message === null)
+ return "object expected";
+ let properties = {};
+ if (message.target != null && message.hasOwnProperty("target")) {
+ let error = $root.query.QueryResult.verify(message.target);
+ if (error)
+ return "target." + error;
+ }
+ if (message.source != null && message.hasOwnProperty("source")) {
+ properties._source = 1;
+ {
+ let error = $root.query.QueryResult.verify(message.source);
+ if (error)
+ return "source." + error;
+ }
+ }
+ return null;
+ };
+
+ /**
+ * Creates a VDiffTableLastPK message from a plain object. Also converts values to their respective internal types.
+ * @function fromObject
+ * @memberof tabletmanagerdata.VDiffTableLastPK
+ * @static
+ * @param {Object.} object Plain object
+ * @returns {tabletmanagerdata.VDiffTableLastPK} VDiffTableLastPK
+ */
+ VDiffTableLastPK.fromObject = function fromObject(object) {
+ if (object instanceof $root.tabletmanagerdata.VDiffTableLastPK)
+ return object;
+ let message = new $root.tabletmanagerdata.VDiffTableLastPK();
+ if (object.target != null) {
+ if (typeof object.target !== "object")
+ throw TypeError(".tabletmanagerdata.VDiffTableLastPK.target: object expected");
+ message.target = $root.query.QueryResult.fromObject(object.target);
+ }
+ if (object.source != null) {
+ if (typeof object.source !== "object")
+ throw TypeError(".tabletmanagerdata.VDiffTableLastPK.source: object expected");
+ message.source = $root.query.QueryResult.fromObject(object.source);
+ }
+ return message;
+ };
+
+ /**
+ * Creates a plain object from a VDiffTableLastPK message. Also converts values to other types if specified.
+ * @function toObject
+ * @memberof tabletmanagerdata.VDiffTableLastPK
+ * @static
+ * @param {tabletmanagerdata.VDiffTableLastPK} message VDiffTableLastPK
+ * @param {$protobuf.IConversionOptions} [options] Conversion options
+ * @returns {Object.} Plain object
+ */
+ VDiffTableLastPK.toObject = function toObject(message, options) {
+ if (!options)
+ options = {};
+ let object = {};
+ if (options.defaults)
+ object.target = null;
+ if (message.target != null && message.hasOwnProperty("target"))
+ object.target = $root.query.QueryResult.toObject(message.target, options);
+ if (message.source != null && message.hasOwnProperty("source")) {
+ object.source = $root.query.QueryResult.toObject(message.source, options);
+ if (options.oneofs)
+ object._source = "source";
+ }
+ return object;
+ };
+
+ /**
+ * Converts this VDiffTableLastPK to JSON.
+ * @function toJSON
+ * @memberof tabletmanagerdata.VDiffTableLastPK
+ * @instance
+ * @returns {Object.} JSON object
+ */
+ VDiffTableLastPK.prototype.toJSON = function toJSON() {
+ return this.constructor.toObject(this, $protobuf.util.toJSONOptions);
+ };
+
+ /**
+ * Gets the default type url for VDiffTableLastPK
+ * @function getTypeUrl
+ * @memberof tabletmanagerdata.VDiffTableLastPK
+ * @static
+ * @param {string} [typeUrlPrefix] your custom typeUrlPrefix(default "type.googleapis.com")
+ * @returns {string} The default type url
+ */
+ VDiffTableLastPK.getTypeUrl = function getTypeUrl(typeUrlPrefix) {
+ if (typeUrlPrefix === undefined) {
+ typeUrlPrefix = "type.googleapis.com";
+ }
+ return typeUrlPrefix + "/tabletmanagerdata.VDiffTableLastPK";
+ };
+
+ return VDiffTableLastPK;
+ })();
+
tabletmanagerdata.UpdateVReplicationWorkflowRequest = (function() {
/**
@@ -138127,6 +138383,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() {
/**
@@ -184550,6 +185390,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() {
/**
@@ -184561,6 +185819,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
*/
/**
@@ -184573,6 +185832,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)
@@ -184619,6 +185879,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
@@ -184654,6 +185922,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;
};
@@ -184710,6 +185981,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;
@@ -184764,6 +186041,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;
};
@@ -184794,6 +186078,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;
};
@@ -184810,8 +186101,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;
@@ -184831,6 +186124,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;
};