///
import { ChannelCredentials, ChannelOptions, UntypedServiceImplementation, handleUnaryCall, Client, ClientUnaryCall, Metadata, CallOptions, ServiceError } from '@grpc/grpc-js';
import _m0 from 'protobufjs/minimal';
import { Runtime, TransferType, Transformation, DataObjects, Transfer } from '../../../../yandex/cloud/datatransfer/v1/transfer';
import { FieldMask } from '../../../../google/protobuf/field_mask';
import { Operation } from '../../../../yandex/cloud/operation/operation';
export declare const protobufPackage = "yandex.cloud.datatransfer.v1";
export interface CreateTransferRequest {
/** Identifier of the source endpoint. */
sourceId: string;
/** Identifier of the target endpoint. */
targetId: string;
/** Description of the transfer. */
description: string;
/**
* ID of the folder to create the transfer in.
*
* To get the folder ID, make a
* [yandex.cloud.resourcemanager.v1.FolderService.List] request.
*/
folderId: string;
runtime?: Runtime;
type: TransferType;
/** The transfer name. Must be unique within the folder. */
name: string;
/**
* Transfer labels as `key:value` pairs.
*
* For details about the concept, see [documentation]({{ api-url-prefix
* }}/resource-manager/concepts/labels).
*/
labels: {
[key: string]: string;
};
transformation?: Transformation;
dataObjects?: DataObjects;
}
export interface CreateTransferRequest_LabelsEntry {
key: string;
value: string;
}
export interface CreateTransferMetadata {
transferId: string;
}
export interface UpdateTransferRequest {
/** Identifier of the transfer to be updated. */
transferId: string;
/** The new description for the transfer. */
description: string;
runtime?: Runtime;
/** The new transfer name. Must be unique within the folder. */
name: string;
/**
* Field mask specifying transfer fields to be updated. Semantics for this field is
* described here:
*
* The only exception: if the repeated field is specified in the mask, then
* the new value replaces the old one instead of being appended to the old one.
*/
updateMask?: FieldMask;
/**
* Transfer labels as `key:value` pairs.
*
* For details about the concept, see [documentation]({{ api-url-prefix
* }}/resource-manager/concepts/labels).
*/
labels: {
[key: string]: string;
};
transformation?: Transformation;
dataObjects?: DataObjects;
}
export interface UpdateTransferRequest_LabelsEntry {
key: string;
value: string;
}
export interface UpdateTransferMetadata {
transferId: string;
}
export interface DeleteTransferRequest {
/** Identifier of the transfer to be deleted. */
transferId: string;
}
export interface DeleteTransferMetadata {
transferId: string;
}
export interface ListTransfersRequest {
/**
* Identifier of the folder containing the transfers to be listed.
*
* To get the folder ID, make a
* [yandex.cloud.resourcemanager.v1.FolderService.List] request.
*/
folderId: string;
/**
* The maximum number of transfers to be sent in the response message. If the
* folder contains more transfers than `page_size`, `next_page_token` will be
* included
* in the response message. Include it into the subsequent `ListTransfersRequest`
* to
* fetch the next page. Defaults to `100` if not specified. The maximum allowed
* value
* for this field is `500`.
*/
pageSize: number;
/**
* Opaque value identifying the transfers page to be fetched. Should be empty in
* the first `ListTransfersRequest`. Subsequent requests should have this field
* filled
* with the `next_page_token` from the previous `ListTransfersResponse`.
*/
pageToken: string;
}
export interface ListTransfersResponse {
/**
* The list of transfers. If there are more transfers in the folder, then
* `next_page_token` is a non-empty string to be included into the subsequent
* `ListTransfersRequest` to fetch the next transfers page.
*/
transfers: Transfer[];
/**
* Opaque value identifying the next transfers page. This field is empty if there
* are no more transfers in the folder. Otherwise it is non-empty and should be
* included in the subsequent `ListTransfersRequest` to fetch the next transfers
* page.
*/
nextPageToken: string;
}
export interface GetTransferRequest {
/**
* Identifier of the transfer to be returned.
*
* To get the list of all available transfers, make a [List] request.
*/
transferId: string;
}
export interface DeactivateTransferRequest {
/**
* Identifier of the transfer to be deactivated.
*
* To get the list of all available transfers, make a [List] request.
*/
transferId: string;
}
export interface DeactivateTransferMetadata {
transferId: string;
}
export interface ActivateTransferRequest {
/**
* Identifier of the transfer to be activated.
*
* To get the list of all available transfers, make a [List] request.
*/
transferId: string;
}
export interface ActivateTransferMetadata {
transferId: string;
}
export declare const CreateTransferRequest: {
encode(message: CreateTransferRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): CreateTransferRequest;
fromJSON(object: any): CreateTransferRequest;
toJSON(message: CreateTransferRequest): unknown;
fromPartial, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
type?: TransferType | undefined;
name?: string | undefined;
labels?: ({
[x: string]: string | undefined;
} & {
[x: string]: string | undefined;
} & Record, never>) | undefined;
transformation?: ({
transformers?: {
maskField?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
function?: {
maskFunctionHash?: {
userDefinedSalt?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
filterColumns?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} | undefined;
renameTables?: {
renameTables?: {
originalName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
newName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
}[] | undefined;
} | undefined;
replacePrimaryKey?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
keys?: string[] | undefined;
} | undefined;
convertToString?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} | undefined;
sharderTransformer?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
shardsCount?: number | undefined;
} | undefined;
tableSplitterTransformer?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
splitter?: string | undefined;
} | undefined;
filterRows?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
filter?: string | undefined;
filters?: string[] | undefined;
} | undefined;
}[] | undefined;
} & {
transformers?: ({
maskField?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
function?: {
maskFunctionHash?: {
userDefinedSalt?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
filterColumns?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} | undefined;
renameTables?: {
renameTables?: {
originalName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
newName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
}[] | undefined;
} | undefined;
replacePrimaryKey?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
keys?: string[] | undefined;
} | undefined;
convertToString?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} | undefined;
sharderTransformer?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
shardsCount?: number | undefined;
} | undefined;
tableSplitterTransformer?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
splitter?: string | undefined;
} | undefined;
filterRows?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
filter?: string | undefined;
filters?: string[] | undefined;
} | undefined;
}[] & ({
maskField?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
function?: {
maskFunctionHash?: {
userDefinedSalt?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
filterColumns?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} | undefined;
renameTables?: {
renameTables?: {
originalName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
newName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
}[] | undefined;
} | undefined;
replacePrimaryKey?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
keys?: string[] | undefined;
} | undefined;
convertToString?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} | undefined;
sharderTransformer?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
shardsCount?: number | undefined;
} | undefined;
tableSplitterTransformer?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
splitter?: string | undefined;
} | undefined;
filterRows?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
filter?: string | undefined;
filters?: string[] | undefined;
} | undefined;
} & {
maskField?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
function?: {
maskFunctionHash?: {
userDefinedSalt?: string | undefined;
} | undefined;
} | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
columns?: (string[] & string[] & Record, never>) | undefined;
function?: ({
maskFunctionHash?: {
userDefinedSalt?: string | undefined;
} | undefined;
} & {
maskFunctionHash?: ({
userDefinedSalt?: string | undefined;
} & {
userDefinedSalt?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
filterColumns?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
columns?: ({
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} & {
includeColumns?: (string[] & string[] & Record, never>) | undefined;
excludeColumns?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
renameTables?: ({
renameTables?: {
originalName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
newName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
}[] | undefined;
} & {
renameTables?: ({
originalName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
newName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
}[] & ({
originalName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
newName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
} & {
originalName?: ({
nameSpace?: string | undefined;
name?: string | undefined;
} & {
nameSpace?: string | undefined;
name?: string | undefined;
} & Record, never>) | undefined;
newName?: ({
nameSpace?: string | undefined;
name?: string | undefined;
} & {
nameSpace?: string | undefined;
name?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
replacePrimaryKey?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
keys?: string[] | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
keys?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
convertToString?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
columns?: ({
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} & {
includeColumns?: (string[] & string[] & Record, never>) | undefined;
excludeColumns?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
sharderTransformer?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
shardsCount?: number | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
columns?: ({
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} & {
includeColumns?: (string[] & string[] & Record, never>) | undefined;
excludeColumns?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
shardsCount?: number | undefined;
} & Record, never>) | undefined;
tableSplitterTransformer?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
splitter?: string | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
columns?: (string[] & string[] & Record, never>) | undefined;
splitter?: string | undefined;
} & Record, never>) | undefined;
filterRows?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
filter?: string | undefined;
filters?: string[] | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
filter?: string | undefined;
filters?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
dataObjects?: ({
includeObjects?: string[] | undefined;
} & {
includeObjects?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>>(object: I): CreateTransferRequest;
};
export declare const CreateTransferRequest_LabelsEntry: {
encode(message: CreateTransferRequest_LabelsEntry, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): CreateTransferRequest_LabelsEntry;
fromJSON(object: any): CreateTransferRequest_LabelsEntry;
toJSON(message: CreateTransferRequest_LabelsEntry): unknown;
fromPartial, never>>(object: I): CreateTransferRequest_LabelsEntry;
};
export declare const CreateTransferMetadata: {
encode(message: CreateTransferMetadata, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): CreateTransferMetadata;
fromJSON(object: any): CreateTransferMetadata;
toJSON(message: CreateTransferMetadata): unknown;
fromPartial, never>>(object: I): CreateTransferMetadata;
};
export declare const UpdateTransferRequest: {
encode(message: UpdateTransferRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): UpdateTransferRequest;
fromJSON(object: any): UpdateTransferRequest;
toJSON(message: UpdateTransferRequest): unknown;
fromPartial, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
name?: string | undefined;
updateMask?: ({
paths?: string[] | undefined;
} & {
paths?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
labels?: ({
[x: string]: string | undefined;
} & {
[x: string]: string | undefined;
} & Record, never>) | undefined;
transformation?: ({
transformers?: {
maskField?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
function?: {
maskFunctionHash?: {
userDefinedSalt?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
filterColumns?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} | undefined;
renameTables?: {
renameTables?: {
originalName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
newName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
}[] | undefined;
} | undefined;
replacePrimaryKey?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
keys?: string[] | undefined;
} | undefined;
convertToString?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} | undefined;
sharderTransformer?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
shardsCount?: number | undefined;
} | undefined;
tableSplitterTransformer?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
splitter?: string | undefined;
} | undefined;
filterRows?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
filter?: string | undefined;
filters?: string[] | undefined;
} | undefined;
}[] | undefined;
} & {
transformers?: ({
maskField?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
function?: {
maskFunctionHash?: {
userDefinedSalt?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
filterColumns?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} | undefined;
renameTables?: {
renameTables?: {
originalName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
newName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
}[] | undefined;
} | undefined;
replacePrimaryKey?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
keys?: string[] | undefined;
} | undefined;
convertToString?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} | undefined;
sharderTransformer?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
shardsCount?: number | undefined;
} | undefined;
tableSplitterTransformer?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
splitter?: string | undefined;
} | undefined;
filterRows?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
filter?: string | undefined;
filters?: string[] | undefined;
} | undefined;
}[] & ({
maskField?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
function?: {
maskFunctionHash?: {
userDefinedSalt?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
filterColumns?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} | undefined;
renameTables?: {
renameTables?: {
originalName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
newName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
}[] | undefined;
} | undefined;
replacePrimaryKey?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
keys?: string[] | undefined;
} | undefined;
convertToString?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} | undefined;
sharderTransformer?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
shardsCount?: number | undefined;
} | undefined;
tableSplitterTransformer?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
splitter?: string | undefined;
} | undefined;
filterRows?: {
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
filter?: string | undefined;
filters?: string[] | undefined;
} | undefined;
} & {
maskField?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
function?: {
maskFunctionHash?: {
userDefinedSalt?: string | undefined;
} | undefined;
} | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
columns?: (string[] & string[] & Record, never>) | undefined;
function?: ({
maskFunctionHash?: {
userDefinedSalt?: string | undefined;
} | undefined;
} & {
maskFunctionHash?: ({
userDefinedSalt?: string | undefined;
} & {
userDefinedSalt?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
filterColumns?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
columns?: ({
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} & {
includeColumns?: (string[] & string[] & Record, never>) | undefined;
excludeColumns?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
renameTables?: ({
renameTables?: {
originalName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
newName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
}[] | undefined;
} & {
renameTables?: ({
originalName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
newName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
}[] & ({
originalName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
newName?: {
nameSpace?: string | undefined;
name?: string | undefined;
} | undefined;
} & {
originalName?: ({
nameSpace?: string | undefined;
name?: string | undefined;
} & {
nameSpace?: string | undefined;
name?: string | undefined;
} & Record, never>) | undefined;
newName?: ({
nameSpace?: string | undefined;
name?: string | undefined;
} & {
nameSpace?: string | undefined;
name?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
replacePrimaryKey?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
keys?: string[] | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
keys?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
convertToString?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
columns?: ({
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} & {
includeColumns?: (string[] & string[] & Record, never>) | undefined;
excludeColumns?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
sharderTransformer?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: {
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} | undefined;
shardsCount?: number | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
columns?: ({
includeColumns?: string[] | undefined;
excludeColumns?: string[] | undefined;
} & {
includeColumns?: (string[] & string[] & Record, never>) | undefined;
excludeColumns?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
shardsCount?: number | undefined;
} & Record, never>) | undefined;
tableSplitterTransformer?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
columns?: string[] | undefined;
splitter?: string | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
columns?: (string[] & string[] & Record, never>) | undefined;
splitter?: string | undefined;
} & Record, never>) | undefined;
filterRows?: ({
tables?: {
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
filter?: string | undefined;
filters?: string[] | undefined;
} & {
tables?: ({
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
filter?: string | undefined;
filters?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
dataObjects?: ({
includeObjects?: string[] | undefined;
} & {
includeObjects?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>>(object: I): UpdateTransferRequest;
};
export declare const UpdateTransferRequest_LabelsEntry: {
encode(message: UpdateTransferRequest_LabelsEntry, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): UpdateTransferRequest_LabelsEntry;
fromJSON(object: any): UpdateTransferRequest_LabelsEntry;
toJSON(message: UpdateTransferRequest_LabelsEntry): unknown;
fromPartial, never>>(object: I): UpdateTransferRequest_LabelsEntry;
};
export declare const UpdateTransferMetadata: {
encode(message: UpdateTransferMetadata, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): UpdateTransferMetadata;
fromJSON(object: any): UpdateTransferMetadata;
toJSON(message: UpdateTransferMetadata): unknown;
fromPartial, never>>(object: I): UpdateTransferMetadata;
};
export declare const DeleteTransferRequest: {
encode(message: DeleteTransferRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): DeleteTransferRequest;
fromJSON(object: any): DeleteTransferRequest;
toJSON(message: DeleteTransferRequest): unknown;
fromPartial, never>>(object: I): DeleteTransferRequest;
};
export declare const DeleteTransferMetadata: {
encode(message: DeleteTransferMetadata, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): DeleteTransferMetadata;
fromJSON(object: any): DeleteTransferMetadata;
toJSON(message: DeleteTransferMetadata): unknown;
fromPartial, never>>(object: I): DeleteTransferMetadata;
};
export declare const ListTransfersRequest: {
encode(message: ListTransfersRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): ListTransfersRequest;
fromJSON(object: any): ListTransfersRequest;
toJSON(message: ListTransfersRequest): unknown;
fromPartial, never>>(object: I): ListTransfersRequest;
};
export declare const ListTransfersResponse: {
encode(message: ListTransfersResponse, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number): ListTransfersResponse;
fromJSON(object: any): ListTransfersResponse;
toJSON(message: ListTransfersResponse): unknown;
fromPartial, never>) | undefined;
source?: ({
id?: string | undefined;
folderId?: string | undefined;
name?: string | undefined;
description?: string | undefined;
labels?: {
[x: string]: string | undefined;
} | undefined;
settings?: {
mysqlSource?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
timezone?: string | undefined;
objectTransferSettings?: {
view?: import("./endpoint/common").ObjectTransferStage | undefined;
routine?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
tables?: import("./endpoint/common").ObjectTransferStage | undefined;
} | undefined;
includeTablesRegex?: string[] | undefined;
excludeTablesRegex?: string[] | undefined;
securityGroups?: string[] | undefined;
serviceDatabase?: string | undefined;
} | undefined;
postgresSource?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
slotByteLagLimit?: number | undefined;
serviceSchema?: string | undefined;
objectTransferSettings?: {
sequence?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceOwnedBy?: import("./endpoint/common").ObjectTransferStage | undefined;
table?: import("./endpoint/common").ObjectTransferStage | undefined;
primaryKey?: import("./endpoint/common").ObjectTransferStage | undefined;
fkConstraint?: import("./endpoint/common").ObjectTransferStage | undefined;
defaultValues?: import("./endpoint/common").ObjectTransferStage | undefined;
constraint?: import("./endpoint/common").ObjectTransferStage | undefined;
index?: import("./endpoint/common").ObjectTransferStage | undefined;
view?: import("./endpoint/common").ObjectTransferStage | undefined;
function?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
type?: import("./endpoint/common").ObjectTransferStage | undefined;
rule?: import("./endpoint/common").ObjectTransferStage | undefined;
collation?: import("./endpoint/common").ObjectTransferStage | undefined;
policy?: import("./endpoint/common").ObjectTransferStage | undefined;
cast?: import("./endpoint/common").ObjectTransferStage | undefined;
materializedView?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceSet?: import("./endpoint/common").ObjectTransferStage | undefined;
} | undefined;
securityGroups?: string[] | undefined;
} | undefined;
ydbSource?: {
database?: string | undefined;
instance?: string | undefined;
paths?: string[] | undefined;
serviceAccountId?: string | undefined;
subnetId?: string | undefined;
saKeyContent?: string | undefined;
securityGroups?: string[] | undefined;
changefeedCustomName?: string | undefined;
changefeedCustomConsumerName?: string | undefined;
} | undefined;
ydsSource?: {
database?: string | undefined;
stream?: string | undefined;
serviceAccountId?: string | undefined;
supportedCodecs?: import("./endpoint/yds").YdsCompressionCodec[] | undefined;
parser?: {
jsonParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
} | undefined;
allowTtlRewind?: boolean | undefined;
endpoint?: string | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
consumer?: string | undefined;
} | undefined;
kafkaSource?: {
connection?: {
clusterId?: string | undefined;
onPremise?: {
brokerUrls?: string[] | undefined;
subnetId?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
} | undefined;
auth?: {
sasl?: {
user?: string | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
noAuth?: {} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
topicName?: string | undefined;
transformer?: {
cloudFunction?: string | undefined;
numberOfRetries?: number | undefined;
bufferSize?: string | undefined;
bufferFlushInterval?: string | undefined;
invocationTimeout?: string | undefined;
serviceAccountId?: string | undefined;
} | undefined;
parser?: {
jsonParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
} | undefined;
topicNames?: string[] | undefined;
} | undefined;
mongoSource?: {
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
hosts?: string[] | undefined;
port?: number | undefined;
replicaSet?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
collections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
excludedCollections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
secondaryPreferredMode?: boolean | undefined;
securityGroups?: string[] | undefined;
} | undefined;
clickhouseSource?: {
connection?: {
connectionOptions?: {
onPremise?: {
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
mdbClusterId?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
database?: string | undefined;
} | undefined;
} | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
clickhouseClusterName?: string | undefined;
} | undefined;
mysqlTarget?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
sqlMode?: string | undefined;
skipConstraintChecks?: boolean | undefined;
timezone?: string | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
serviceDatabase?: string | undefined;
securityGroups?: string[] | undefined;
} | undefined;
postgresTarget?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
securityGroups?: string[] | undefined;
} | undefined;
clickhouseTarget?: {
connection?: {
connectionOptions?: {
onPremise?: {
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
mdbClusterId?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
database?: string | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
altNames?: {
fromName?: string | undefined;
toName?: string | undefined;
}[] | undefined;
cleanupPolicy?: import("./endpoint/clickhouse").ClickhouseCleanupPolicy | undefined;
sharding?: {
columnValueHash?: {
columnName?: string | undefined;
} | undefined;
customMapping?: {
columnName?: string | undefined;
mapping?: {
columnValue?: {
stringValue?: string | undefined;
} | undefined;
shardName?: string | undefined;
}[] | undefined;
} | undefined;
transferId?: {} | undefined;
roundRobin?: {} | undefined;
} | undefined;
clickhouseClusterName?: string | undefined;
securityGroups?: string[] | undefined;
} | undefined;
ydbTarget?: {
database?: string | undefined;
instance?: string | undefined;
path?: string | undefined;
serviceAccountId?: string | undefined;
cleanupPolicy?: import("./endpoint/ydb").YdbCleanupPolicy | undefined;
subnetId?: string | undefined;
saKeyContent?: string | undefined;
securityGroups?: string[] | undefined;
isTableColumnOriented?: boolean | undefined;
defaultCompression?: import("./endpoint/ydb").YdbDefaultCompression | undefined;
} | undefined;
kafkaTarget?: {
connection?: {
clusterId?: string | undefined;
onPremise?: {
brokerUrls?: string[] | undefined;
subnetId?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
} | undefined;
auth?: {
sasl?: {
user?: string | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
noAuth?: {} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
topicSettings?: {
topic?: {
topicName?: string | undefined;
saveTxOrder?: boolean | undefined;
} | undefined;
topicPrefix?: string | undefined;
} | undefined;
serializer?: {
serializerAuto?: {} | undefined;
serializerJson?: {} | undefined;
serializerDebezium?: {
serializerParameters?: {
key?: string | undefined;
value?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
} | undefined;
mongoTarget?: {
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
hosts?: string[] | undefined;
port?: number | undefined;
replicaSet?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
} | undefined;
metrikaSource?: {
counterIds?: number[] | undefined;
token?: {
raw?: string | undefined;
} | undefined;
streams?: {
type?: import("./endpoint/metrika").MetrikaStreamType | undefined;
columns?: string[] | undefined;
}[] | undefined;
} | undefined;
ydsTarget?: {
database?: string | undefined;
stream?: string | undefined;
serviceAccountId?: string | undefined;
saveTxOrder?: boolean | undefined;
compressionCodec?: import("./endpoint/yds").YdsCompressionCodec | undefined;
serializer?: {
serializerAuto?: {} | undefined;
serializerJson?: {} | undefined;
serializerDebezium?: {
serializerParameters?: {
key?: string | undefined;
value?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
endpoint?: string | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
} | undefined;
} | undefined;
} & {
id?: string | undefined;
folderId?: string | undefined;
name?: string | undefined;
description?: string | undefined;
labels?: ({
[x: string]: string | undefined;
} & {
[x: string]: string | undefined;
} & Record, never>) | undefined;
settings?: ({
mysqlSource?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
timezone?: string | undefined;
objectTransferSettings?: {
view?: import("./endpoint/common").ObjectTransferStage | undefined;
routine?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
tables?: import("./endpoint/common").ObjectTransferStage | undefined;
} | undefined;
includeTablesRegex?: string[] | undefined;
excludeTablesRegex?: string[] | undefined;
securityGroups?: string[] | undefined;
serviceDatabase?: string | undefined;
} | undefined;
postgresSource?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
slotByteLagLimit?: number | undefined;
serviceSchema?: string | undefined;
objectTransferSettings?: {
sequence?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceOwnedBy?: import("./endpoint/common").ObjectTransferStage | undefined;
table?: import("./endpoint/common").ObjectTransferStage | undefined;
primaryKey?: import("./endpoint/common").ObjectTransferStage | undefined;
fkConstraint?: import("./endpoint/common").ObjectTransferStage | undefined;
defaultValues?: import("./endpoint/common").ObjectTransferStage | undefined;
constraint?: import("./endpoint/common").ObjectTransferStage | undefined;
index?: import("./endpoint/common").ObjectTransferStage | undefined;
view?: import("./endpoint/common").ObjectTransferStage | undefined;
function?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
type?: import("./endpoint/common").ObjectTransferStage | undefined;
rule?: import("./endpoint/common").ObjectTransferStage | undefined;
collation?: import("./endpoint/common").ObjectTransferStage | undefined;
policy?: import("./endpoint/common").ObjectTransferStage | undefined;
cast?: import("./endpoint/common").ObjectTransferStage | undefined;
materializedView?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceSet?: import("./endpoint/common").ObjectTransferStage | undefined;
} | undefined;
securityGroups?: string[] | undefined;
} | undefined;
ydbSource?: {
database?: string | undefined;
instance?: string | undefined;
paths?: string[] | undefined;
serviceAccountId?: string | undefined;
subnetId?: string | undefined;
saKeyContent?: string | undefined;
securityGroups?: string[] | undefined;
changefeedCustomName?: string | undefined;
changefeedCustomConsumerName?: string | undefined;
} | undefined;
ydsSource?: {
database?: string | undefined;
stream?: string | undefined;
serviceAccountId?: string | undefined;
supportedCodecs?: import("./endpoint/yds").YdsCompressionCodec[] | undefined;
parser?: {
jsonParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
} | undefined;
allowTtlRewind?: boolean | undefined;
endpoint?: string | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
consumer?: string | undefined;
} | undefined;
kafkaSource?: {
connection?: {
clusterId?: string | undefined;
onPremise?: {
brokerUrls?: string[] | undefined;
subnetId?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
} | undefined;
auth?: {
sasl?: {
user?: string | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
noAuth?: {} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
topicName?: string | undefined;
transformer?: {
cloudFunction?: string | undefined;
numberOfRetries?: number | undefined;
bufferSize?: string | undefined;
bufferFlushInterval?: string | undefined;
invocationTimeout?: string | undefined;
serviceAccountId?: string | undefined;
} | undefined;
parser?: {
jsonParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
} | undefined;
topicNames?: string[] | undefined;
} | undefined;
mongoSource?: {
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
hosts?: string[] | undefined;
port?: number | undefined;
replicaSet?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
collections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
excludedCollections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
secondaryPreferredMode?: boolean | undefined;
securityGroups?: string[] | undefined;
} | undefined;
clickhouseSource?: {
connection?: {
connectionOptions?: {
onPremise?: {
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
mdbClusterId?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
database?: string | undefined;
} | undefined;
} | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
clickhouseClusterName?: string | undefined;
} | undefined;
mysqlTarget?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
sqlMode?: string | undefined;
skipConstraintChecks?: boolean | undefined;
timezone?: string | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
serviceDatabase?: string | undefined;
securityGroups?: string[] | undefined;
} | undefined;
postgresTarget?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
securityGroups?: string[] | undefined;
} | undefined;
clickhouseTarget?: {
connection?: {
connectionOptions?: {
onPremise?: {
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
mdbClusterId?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
database?: string | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
altNames?: {
fromName?: string | undefined;
toName?: string | undefined;
}[] | undefined;
cleanupPolicy?: import("./endpoint/clickhouse").ClickhouseCleanupPolicy | undefined;
sharding?: {
columnValueHash?: {
columnName?: string | undefined;
} | undefined;
customMapping?: {
columnName?: string | undefined;
mapping?: {
columnValue?: {
stringValue?: string | undefined;
} | undefined;
shardName?: string | undefined;
}[] | undefined;
} | undefined;
transferId?: {} | undefined;
roundRobin?: {} | undefined;
} | undefined;
clickhouseClusterName?: string | undefined;
securityGroups?: string[] | undefined;
} | undefined;
ydbTarget?: {
database?: string | undefined;
instance?: string | undefined;
path?: string | undefined;
serviceAccountId?: string | undefined;
cleanupPolicy?: import("./endpoint/ydb").YdbCleanupPolicy | undefined;
subnetId?: string | undefined;
saKeyContent?: string | undefined;
securityGroups?: string[] | undefined;
isTableColumnOriented?: boolean | undefined;
defaultCompression?: import("./endpoint/ydb").YdbDefaultCompression | undefined;
} | undefined;
kafkaTarget?: {
connection?: {
clusterId?: string | undefined;
onPremise?: {
brokerUrls?: string[] | undefined;
subnetId?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
} | undefined;
auth?: {
sasl?: {
user?: string | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
noAuth?: {} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
topicSettings?: {
topic?: {
topicName?: string | undefined;
saveTxOrder?: boolean | undefined;
} | undefined;
topicPrefix?: string | undefined;
} | undefined;
serializer?: {
serializerAuto?: {} | undefined;
serializerJson?: {} | undefined;
serializerDebezium?: {
serializerParameters?: {
key?: string | undefined;
value?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
} | undefined;
mongoTarget?: {
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
hosts?: string[] | undefined;
port?: number | undefined;
replicaSet?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
} | undefined;
metrikaSource?: {
counterIds?: number[] | undefined;
token?: {
raw?: string | undefined;
} | undefined;
streams?: {
type?: import("./endpoint/metrika").MetrikaStreamType | undefined;
columns?: string[] | undefined;
}[] | undefined;
} | undefined;
ydsTarget?: {
database?: string | undefined;
stream?: string | undefined;
serviceAccountId?: string | undefined;
saveTxOrder?: boolean | undefined;
compressionCodec?: import("./endpoint/yds").YdsCompressionCodec | undefined;
serializer?: {
serializerAuto?: {} | undefined;
serializerJson?: {} | undefined;
serializerDebezium?: {
serializerParameters?: {
key?: string | undefined;
value?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
endpoint?: string | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
} | undefined;
} & {
mysqlSource?: ({
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
timezone?: string | undefined;
objectTransferSettings?: {
view?: import("./endpoint/common").ObjectTransferStage | undefined;
routine?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
tables?: import("./endpoint/common").ObjectTransferStage | undefined;
} | undefined;
includeTablesRegex?: string[] | undefined;
excludeTablesRegex?: string[] | undefined;
securityGroups?: string[] | undefined;
serviceDatabase?: string | undefined;
} & {
connection?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} & {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} & {
disabled?: ({} & {} & Record, never>) | undefined;
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
connectionManagerConnection?: ({
connectionId?: string | undefined;
subnetId?: string | undefined;
} & {
connectionId?: string | undefined;
subnetId?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
database?: string | undefined;
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
timezone?: string | undefined;
objectTransferSettings?: ({
view?: import("./endpoint/common").ObjectTransferStage | undefined;
routine?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
tables?: import("./endpoint/common").ObjectTransferStage | undefined;
} & {
view?: import("./endpoint/common").ObjectTransferStage | undefined;
routine?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
tables?: import("./endpoint/common").ObjectTransferStage | undefined;
} & Record, never>) | undefined;
includeTablesRegex?: (string[] & string[] & Record, never>) | undefined;
excludeTablesRegex?: (string[] & string[] & Record, never>) | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
serviceDatabase?: string | undefined;
} & Record, never>) | undefined;
postgresSource?: ({
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
slotByteLagLimit?: number | undefined;
serviceSchema?: string | undefined;
objectTransferSettings?: {
sequence?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceOwnedBy?: import("./endpoint/common").ObjectTransferStage | undefined;
table?: import("./endpoint/common").ObjectTransferStage | undefined;
primaryKey?: import("./endpoint/common").ObjectTransferStage | undefined;
fkConstraint?: import("./endpoint/common").ObjectTransferStage | undefined;
defaultValues?: import("./endpoint/common").ObjectTransferStage | undefined;
constraint?: import("./endpoint/common").ObjectTransferStage | undefined;
index?: import("./endpoint/common").ObjectTransferStage | undefined;
view?: import("./endpoint/common").ObjectTransferStage | undefined;
function?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
type?: import("./endpoint/common").ObjectTransferStage | undefined;
rule?: import("./endpoint/common").ObjectTransferStage | undefined;
collation?: import("./endpoint/common").ObjectTransferStage | undefined;
policy?: import("./endpoint/common").ObjectTransferStage | undefined;
cast?: import("./endpoint/common").ObjectTransferStage | undefined;
materializedView?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceSet?: import("./endpoint/common").ObjectTransferStage | undefined;
} | undefined;
securityGroups?: string[] | undefined;
} & {
connection?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} & {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} & {
disabled?: ({} & {} & Record, never>) | undefined;
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
connectionManagerConnection?: ({
connectionId?: string | undefined;
subnetId?: string | undefined;
} & {
connectionId?: string | undefined;
subnetId?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
database?: string | undefined;
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
slotByteLagLimit?: number | undefined;
serviceSchema?: string | undefined;
objectTransferSettings?: ({
sequence?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceOwnedBy?: import("./endpoint/common").ObjectTransferStage | undefined;
table?: import("./endpoint/common").ObjectTransferStage | undefined;
primaryKey?: import("./endpoint/common").ObjectTransferStage | undefined;
fkConstraint?: import("./endpoint/common").ObjectTransferStage | undefined;
defaultValues?: import("./endpoint/common").ObjectTransferStage | undefined;
constraint?: import("./endpoint/common").ObjectTransferStage | undefined;
index?: import("./endpoint/common").ObjectTransferStage | undefined;
view?: import("./endpoint/common").ObjectTransferStage | undefined;
function?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
type?: import("./endpoint/common").ObjectTransferStage | undefined;
rule?: import("./endpoint/common").ObjectTransferStage | undefined;
collation?: import("./endpoint/common").ObjectTransferStage | undefined;
policy?: import("./endpoint/common").ObjectTransferStage | undefined;
cast?: import("./endpoint/common").ObjectTransferStage | undefined;
materializedView?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceSet?: import("./endpoint/common").ObjectTransferStage | undefined;
} & {
sequence?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceOwnedBy?: import("./endpoint/common").ObjectTransferStage | undefined;
table?: import("./endpoint/common").ObjectTransferStage | undefined;
primaryKey?: import("./endpoint/common").ObjectTransferStage | undefined;
fkConstraint?: import("./endpoint/common").ObjectTransferStage | undefined;
defaultValues?: import("./endpoint/common").ObjectTransferStage | undefined;
constraint?: import("./endpoint/common").ObjectTransferStage | undefined;
index?: import("./endpoint/common").ObjectTransferStage | undefined;
view?: import("./endpoint/common").ObjectTransferStage | undefined;
function?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
type?: import("./endpoint/common").ObjectTransferStage | undefined;
rule?: import("./endpoint/common").ObjectTransferStage | undefined;
collation?: import("./endpoint/common").ObjectTransferStage | undefined;
policy?: import("./endpoint/common").ObjectTransferStage | undefined;
cast?: import("./endpoint/common").ObjectTransferStage | undefined;
materializedView?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceSet?: import("./endpoint/common").ObjectTransferStage | undefined;
} & Record, never>) | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
ydbSource?: ({
database?: string | undefined;
instance?: string | undefined;
paths?: string[] | undefined;
serviceAccountId?: string | undefined;
subnetId?: string | undefined;
saKeyContent?: string | undefined;
securityGroups?: string[] | undefined;
changefeedCustomName?: string | undefined;
changefeedCustomConsumerName?: string | undefined;
} & {
database?: string | undefined;
instance?: string | undefined;
paths?: (string[] & string[] & Record, never>) | undefined;
serviceAccountId?: string | undefined;
subnetId?: string | undefined;
saKeyContent?: string | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
changefeedCustomName?: string | undefined;
changefeedCustomConsumerName?: string | undefined;
} & Record, never>) | undefined;
ydsSource?: ({
database?: string | undefined;
stream?: string | undefined;
serviceAccountId?: string | undefined;
supportedCodecs?: import("./endpoint/yds").YdsCompressionCodec[] | undefined;
parser?: {
jsonParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
} | undefined;
allowTtlRewind?: boolean | undefined;
endpoint?: string | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
consumer?: string | undefined;
} & {
database?: string | undefined;
stream?: string | undefined;
serviceAccountId?: string | undefined;
supportedCodecs?: (import("./endpoint/yds").YdsCompressionCodec[] & import("./endpoint/yds").YdsCompressionCodec[] & Record, never>) | undefined;
parser?: ({
jsonParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
} & {
jsonParser?: ({
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} & {
dataSchema?: ({
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} & {
jsonFields?: string | undefined;
fields?: ({
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} & {
fields?: ({
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] & ({
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
} & {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} & Record, never>) | undefined;
auditTrailsV1Parser?: ({} & {} & Record, never>) | undefined;
cloudLoggingParser?: ({} & {} & Record, never>) | undefined;
tskvParser?: ({
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} & {
dataSchema?: ({
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} & {
jsonFields?: string | undefined;
fields?: ({
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} & {
fields?: ({
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] & ({
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
} & {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
allowTtlRewind?: boolean | undefined;
endpoint?: string | undefined;
subnetId?: string | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
consumer?: string | undefined;
} & Record, never>) | undefined;
kafkaSource?: ({
connection?: {
clusterId?: string | undefined;
onPremise?: {
brokerUrls?: string[] | undefined;
subnetId?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
} | undefined;
auth?: {
sasl?: {
user?: string | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
noAuth?: {} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
topicName?: string | undefined;
transformer?: {
cloudFunction?: string | undefined;
numberOfRetries?: number | undefined;
bufferSize?: string | undefined;
bufferFlushInterval?: string | undefined;
invocationTimeout?: string | undefined;
serviceAccountId?: string | undefined;
} | undefined;
parser?: {
jsonParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
} | undefined;
topicNames?: string[] | undefined;
} & {
connection?: ({
clusterId?: string | undefined;
onPremise?: {
brokerUrls?: string[] | undefined;
subnetId?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
} & {
clusterId?: string | undefined;
onPremise?: ({
brokerUrls?: string[] | undefined;
subnetId?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} & {
brokerUrls?: (string[] & string[] & Record, never>) | undefined;
subnetId?: string | undefined;
tlsMode?: ({
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} & {
disabled?: ({} & {} & Record, never>) | undefined;
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
auth?: ({
sasl?: {
user?: string | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
noAuth?: {} | undefined;
} & {
sasl?: ({
user?: string | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} & {
user?: string | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
noAuth?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
topicName?: string | undefined;
transformer?: ({
cloudFunction?: string | undefined;
numberOfRetries?: number | undefined;
bufferSize?: string | undefined;
bufferFlushInterval?: string | undefined;
invocationTimeout?: string | undefined;
serviceAccountId?: string | undefined;
} & {
cloudFunction?: string | undefined;
numberOfRetries?: number | undefined;
bufferSize?: string | undefined;
bufferFlushInterval?: string | undefined;
invocationTimeout?: string | undefined;
serviceAccountId?: string | undefined;
} & Record, never>) | undefined;
parser?: ({
jsonParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} | undefined;
} & {
jsonParser?: ({
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} & {
dataSchema?: ({
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} & {
jsonFields?: string | undefined;
fields?: ({
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} & {
fields?: ({
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] & ({
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
} & {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} & Record, never>) | undefined;
auditTrailsV1Parser?: ({} & {} & Record, never>) | undefined;
cloudLoggingParser?: ({} & {} & Record, never>) | undefined;
tskvParser?: ({
dataSchema?: {
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} & {
dataSchema?: ({
jsonFields?: string | undefined;
fields?: {
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} | undefined;
} & {
jsonFields?: string | undefined;
fields?: ({
fields?: {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] | undefined;
} & {
fields?: ({
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
}[] & ({
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
} & {
name?: string | undefined;
type?: import("./endpoint/common").ColumnType | undefined;
key?: boolean | undefined;
required?: boolean | undefined;
path?: string | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
unescapeStringValues?: boolean | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
topicNames?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
mongoSource?: ({
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
hosts?: string[] | undefined;
port?: number | undefined;
replicaSet?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
collections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
excludedCollections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
secondaryPreferredMode?: boolean | undefined;
securityGroups?: string[] | undefined;
} & {
connection?: ({
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
hosts?: string[] | undefined;
port?: number | undefined;
replicaSet?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} & {
connectionOptions?: ({
mdbClusterId?: string | undefined;
onPremise?: {
hosts?: string[] | undefined;
port?: number | undefined;
replicaSet?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
hosts?: string[] | undefined;
port?: number | undefined;
replicaSet?: string | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} & {
hosts?: (string[] & string[] & Record, never>) | undefined;
port?: number | undefined;
replicaSet?: string | undefined;
tlsMode?: ({
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} & {
disabled?: ({} & {} & Record, never>) | undefined;
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
authSource?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
subnetId?: string | undefined;
collections?: ({
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] & ({
databaseName?: string | undefined;
collectionName?: string | undefined;
} & {
databaseName?: string | undefined;
collectionName?: string | undefined;
} & Record, never>)[] & Record, never>) | undefined;
excludedCollections?: ({
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] & ({
databaseName?: string | undefined;
collectionName?: string | undefined;
} & {
databaseName?: string | undefined;
collectionName?: string | undefined;
} & Record, never>)[] & Record, never>) | undefined;
secondaryPreferredMode?: boolean | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
clickhouseSource?: ({
connection?: {
connectionOptions?: {
onPremise?: {
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
mdbClusterId?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
database?: string | undefined;
} | undefined;
} | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
clickhouseClusterName?: string | undefined;
} & {
connection?: ({
connectionOptions?: {
onPremise?: {
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
mdbClusterId?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
database?: string | undefined;
} | undefined;
} & {
connectionOptions?: ({
onPremise?: {
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
mdbClusterId?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
database?: string | undefined;
} & {
onPremise?: ({
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} & {
shards?: ({
name?: string | undefined;
hosts?: string[] | undefined;
}[] & ({
name?: string | undefined;
hosts?: string[] | undefined;
} & {
name?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>)[] & Record, never>) | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: ({
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} & {
disabled?: ({} & {} & Record, never>) | undefined;
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
mdbClusterId?: string | undefined;
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
database?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
subnetId?: string | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
clickhouseClusterName?: string | undefined;
} & Record, never>) | undefined;
mysqlTarget?: ({
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
sqlMode?: string | undefined;
skipConstraintChecks?: boolean | undefined;
timezone?: string | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
serviceDatabase?: string | undefined;
securityGroups?: string[] | undefined;
} & {
connection?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} & {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} & {
disabled?: ({} & {} & Record, never>) | undefined;
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
connectionManagerConnection?: ({
connectionId?: string | undefined;
subnetId?: string | undefined;
} & {
connectionId?: string | undefined;
subnetId?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
database?: string | undefined;
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
sqlMode?: string | undefined;
skipConstraintChecks?: boolean | undefined;
timezone?: string | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
serviceDatabase?: string | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
postgresTarget?: ({
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
securityGroups?: string[] | undefined;
} & {
connection?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
connectionManagerConnection?: {
connectionId?: string | undefined;
subnetId?: string | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} & {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} & {
disabled?: ({} & {} & Record, never>) | undefined;
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
connectionManagerConnection?: ({
connectionId?: string | undefined;
subnetId?: string | undefined;
} & {
connectionId?: string | undefined;
subnetId?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
database?: string | undefined;
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
clickhouseTarget?: ({
connection?: {
connectionOptions?: {
onPremise?: {
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
mdbClusterId?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
database?: string | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
altNames?: {
fromName?: string | undefined;
toName?: string | undefined;
}[] | undefined;
cleanupPolicy?: import("./endpoint/clickhouse").ClickhouseCleanupPolicy | undefined;
sharding?: {
columnValueHash?: {
columnName?: string | undefined;
} | undefined;
customMapping?: {
columnName?: string | undefined;
mapping?: {
columnValue?: {
stringValue?: string | undefined;
} | undefined;
shardName?: string | undefined;
}[] | undefined;
} | undefined;
transferId?: {} | undefined;
roundRobin?: {} | undefined;
} | undefined;
clickhouseClusterName?: string | undefined;
securityGroups?: string[] | undefined;
} & {
connection?: ({
connectionOptions?: {
onPremise?: {
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
mdbClusterId?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
database?: string | undefined;
} | undefined;
} & {
connectionOptions?: ({
onPremise?: {
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
mdbClusterId?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
database?: string | undefined;
} & {
onPremise?: ({
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: {
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} | undefined;
} & {
shards?: ({
name?: string | undefined;
hosts?: string[] | undefined;
}[] & ({
name?: string | undefined;
hosts?: string[] | undefined;
} & {
name?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>)[] & Record, never>) | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
tlsMode?: ({
disabled?: {} | undefined;
enabled?: {
caCertificate?: string | undefined;
} | undefined;
} & {
disabled?: ({} & {} & Record, never>) | undefined;
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
} & Record