///
import { ChannelCredentials, ChannelOptions, UntypedServiceImplementation, handleUnaryCall, Client, ClientUnaryCall, Metadata, CallOptions, ServiceError } from "@grpc/grpc-js";
import _m0 from "protobufjs/minimal";
import { EndpointSettings, Endpoint } from "../../../../yandex/cloud/datatransfer/v1/endpoint";
import { FieldMask } from "../../../../google/protobuf/field_mask";
import { Operation } from "../../../../yandex/cloud/operation/operation";
export declare const protobufPackage = "yandex.cloud.datatransfer.v1";
export interface GetEndpointRequest {
$type: "yandex.cloud.datatransfer.v1.GetEndpointRequest";
endpointId: string;
}
export interface ListEndpointsRequest {
$type: "yandex.cloud.datatransfer.v1.ListEndpointsRequest";
/** Identifier of the folder containing the endpoints to be listed. */
folderId: string;
/**
* The maximum number of endpoints to be sent in the response message. If the
* folder contains more endpoints than `page_size`, `next_page_token` will be
* included
* in the response message. Include it into the subsequent `ListEndpointRequest` 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 endpoints page to be fetched. Should be empty in
* the first `ListEndpointsRequest`. Subsequent requests should have this field
* filled
* with the `next_page_token` from the previous `ListEndpointsResponse`.
*/
pageToken: string;
}
export interface ListEndpointsResponse {
$type: "yandex.cloud.datatransfer.v1.ListEndpointsResponse";
/**
* The list of endpoints. If there are more endpoints in the folder, then
* `next_page_token` is a non-empty string to be included into the subsequent
* `ListEndpointsRequest` to fetch the next endpoints page.
*/
endpoints: Endpoint[];
/**
* Opaque value identifying the next endpoints page. This field is empty if there
* are no more endpoints in the folder. Otherwise, it is non-empty and should be
* included in the subsequent `ListEndpointsRequest` to fetch the next endpoints
* page.
*/
nextPageToken: string;
}
export interface CreateEndpointRequest {
$type: "yandex.cloud.datatransfer.v1.CreateEndpointRequest";
folderId: string;
name: string;
description: string;
labels: {
[key: string]: string;
};
settings?: EndpointSettings;
}
export interface CreateEndpointRequest_LabelsEntry {
$type: "yandex.cloud.datatransfer.v1.CreateEndpointRequest.LabelsEntry";
key: string;
value: string;
}
export interface CreateEndpointMetadata {
$type: "yandex.cloud.datatransfer.v1.CreateEndpointMetadata";
endpointId: string;
}
export interface UpdateEndpointRequest {
$type: "yandex.cloud.datatransfer.v1.UpdateEndpointRequest";
/** Identifier of the endpoint to be updated. */
endpointId: string;
/** The new endpoint name. Must be unique within the folder. */
name: string;
/** The new description for the endpoint. */
description: string;
labels: {
[key: string]: string;
};
/** The new endpoint name. Must be unique within the folder. */
settings?: EndpointSettings;
/**
* Field mask specifying endpoint 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;
}
export interface UpdateEndpointRequest_LabelsEntry {
$type: "yandex.cloud.datatransfer.v1.UpdateEndpointRequest.LabelsEntry";
key: string;
value: string;
}
export interface UpdateEndpointMetadata {
$type: "yandex.cloud.datatransfer.v1.UpdateEndpointMetadata";
endpointId: string;
}
export interface DeleteEndpointRequest {
$type: "yandex.cloud.datatransfer.v1.DeleteEndpointRequest";
endpointId: string;
}
export interface DeleteEndpointMetadata {
$type: "yandex.cloud.datatransfer.v1.DeleteEndpointMetadata";
endpointId: string;
}
export declare const GetEndpointRequest: {
$type: "yandex.cloud.datatransfer.v1.GetEndpointRequest";
encode(message: GetEndpointRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number | undefined): GetEndpointRequest;
fromJSON(object: any): GetEndpointRequest;
toJSON(message: GetEndpointRequest): unknown;
fromPartial, never>>(object: I): GetEndpointRequest;
};
export declare const ListEndpointsRequest: {
$type: "yandex.cloud.datatransfer.v1.ListEndpointsRequest";
encode(message: ListEndpointsRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number | undefined): ListEndpointsRequest;
fromJSON(object: any): ListEndpointsRequest;
toJSON(message: ListEndpointsRequest): unknown;
fromPartial, never>>(object: I): ListEndpointsRequest;
};
export declare const ListEndpointsResponse: {
$type: "yandex.cloud.datatransfer.v1.ListEndpointsResponse";
encode(message: ListEndpointsResponse, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number | undefined): ListEndpointsResponse;
fromJSON(object: any): ListEndpointsResponse;
toJSON(message: ListEndpointsResponse): unknown;
fromPartial, never>) | undefined;
settings?: ({
mysqlSource?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
serviceDatabase?: string | undefined;
user?: string | undefined;
includeTablesRegex?: string[] | undefined;
excludeTablesRegex?: string[] | undefined;
timezone?: string | undefined;
password?: {
raw?: string | undefined;
} | 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;
} | undefined;
postgresSource?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
objectTransferSettings?: {
function?: import("./endpoint/common").ObjectTransferStage | undefined;
type?: import("./endpoint/common").ObjectTransferStage | undefined;
view?: import("./endpoint/common").ObjectTransferStage | undefined;
index?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
sequence?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceOwnedBy?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceSet?: 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;
materializedView?: 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;
} | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
slotByteLagLimit?: number | undefined;
serviceSchema?: string | undefined;
} | undefined;
ydbSource?: {
paths?: string[] | undefined;
subnetId?: string | undefined;
serviceAccountId?: string | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
instance?: string | undefined;
saKeyContent?: string | undefined;
} | undefined;
kafkaSource?: {
connection?: {
clusterId?: string | undefined;
onPremise?: {
subnetId?: string | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
brokerUrls?: string[] | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
topicName?: string | undefined;
auth?: {
sasl?: {
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} | undefined;
noAuth?: {} | undefined;
} | undefined;
transformer?: {
serviceAccountId?: string | undefined;
cloudFunction?: string | undefined;
numberOfRetries?: number | undefined;
bufferSize?: string | undefined;
bufferFlushInterval?: string | undefined;
invocationTimeout?: string | undefined;
} | undefined;
parser?: {
jsonParser?: {
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} | undefined;
} | undefined;
} | undefined;
mongoSource?: {
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
secondaryPreferredMode?: boolean | undefined;
collections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
excludedCollections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
} | undefined;
clickhouseSource?: {
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
mysqlTarget?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
serviceDatabase?: string | undefined;
user?: string | undefined;
timezone?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
sqlMode?: string | undefined;
skipConstraintChecks?: boolean | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} | undefined;
postgresTarget?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} | undefined;
clickhouseTarget?: {
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
cleanupPolicy?: import("./endpoint/clickhouse").ClickhouseCleanupPolicy | undefined;
clickhouseClusterName?: string | undefined;
altNames?: {
fromName?: string | undefined;
toName?: string | undefined;
}[] | undefined;
sharding?: {
columnValueHash?: {
columnName?: string | undefined;
} | undefined;
customMapping?: {
columnName?: string | undefined;
mapping?: {
columnValue?: {
stringValue?: string | undefined;
} | undefined;
shardName?: string | undefined;
}[] | undefined;
} | undefined;
transferId?: {} | undefined;
} | undefined;
} | undefined;
ydbTarget?: {
path?: string | undefined;
subnetId?: string | undefined;
serviceAccountId?: string | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
cleanupPolicy?: import("./endpoint/ydb").YdbCleanupPolicy | undefined;
instance?: string | undefined;
saKeyContent?: string | undefined;
} | undefined;
kafkaTarget?: {
connection?: {
clusterId?: string | undefined;
onPremise?: {
subnetId?: string | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
brokerUrls?: string[] | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
auth?: {
sasl?: {
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} | undefined;
noAuth?: {} | undefined;
} | undefined;
topicSettings?: {
topic?: {
topicName?: string | undefined;
saveTxOrder?: boolean | undefined;
} | undefined;
topicPrefix?: string | undefined;
} | undefined;
serializer?: {
serializerAuto?: {} | undefined;
serializerJson?: {} | undefined;
serializerDebezium?: {
serializerParameters?: {
value?: string | undefined;
key?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
} | undefined;
mongoTarget?: {
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} | undefined;
} & {
mysqlSource?: ({
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
serviceDatabase?: string | undefined;
user?: string | undefined;
includeTablesRegex?: string[] | undefined;
excludeTablesRegex?: string[] | undefined;
timezone?: string | undefined;
password?: {
raw?: string | undefined;
} | 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;
} & {
connection?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} & {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
database?: string | undefined;
serviceDatabase?: string | undefined;
user?: string | undefined;
includeTablesRegex?: (string[] & string[] & Record, never>) | undefined;
excludeTablesRegex?: (string[] & string[] & Record, never>) | undefined;
timezone?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | 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;
} & Record, never>) | undefined;
postgresSource?: ({
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
objectTransferSettings?: {
function?: import("./endpoint/common").ObjectTransferStage | undefined;
type?: import("./endpoint/common").ObjectTransferStage | undefined;
view?: import("./endpoint/common").ObjectTransferStage | undefined;
index?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
sequence?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceOwnedBy?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceSet?: 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;
materializedView?: 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;
} | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
slotByteLagLimit?: number | undefined;
serviceSchema?: string | undefined;
} & {
connection?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} & {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
database?: string | undefined;
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
objectTransferSettings?: ({
function?: import("./endpoint/common").ObjectTransferStage | undefined;
type?: import("./endpoint/common").ObjectTransferStage | undefined;
view?: import("./endpoint/common").ObjectTransferStage | undefined;
index?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
sequence?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceOwnedBy?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceSet?: 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;
materializedView?: 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;
} & {
function?: import("./endpoint/common").ObjectTransferStage | undefined;
type?: import("./endpoint/common").ObjectTransferStage | undefined;
view?: import("./endpoint/common").ObjectTransferStage | undefined;
index?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
sequence?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceOwnedBy?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceSet?: 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;
materializedView?: 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;
} & Record, never>) | undefined;
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
slotByteLagLimit?: number | undefined;
serviceSchema?: string | undefined;
} & Record, never>) | undefined;
ydbSource?: ({
paths?: string[] | undefined;
subnetId?: string | undefined;
serviceAccountId?: string | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
instance?: string | undefined;
saKeyContent?: string | undefined;
} & {
paths?: (string[] & string[] & Record, never>) | undefined;
subnetId?: string | undefined;
serviceAccountId?: string | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
database?: string | undefined;
instance?: string | undefined;
saKeyContent?: string | undefined;
} & Record, never>) | undefined;
kafkaSource?: ({
connection?: {
clusterId?: string | undefined;
onPremise?: {
subnetId?: string | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
brokerUrls?: string[] | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
topicName?: string | undefined;
auth?: {
sasl?: {
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} | undefined;
noAuth?: {} | undefined;
} | undefined;
transformer?: {
serviceAccountId?: string | undefined;
cloudFunction?: string | undefined;
numberOfRetries?: number | undefined;
bufferSize?: string | undefined;
bufferFlushInterval?: string | undefined;
invocationTimeout?: string | undefined;
} | undefined;
parser?: {
jsonParser?: {
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} | undefined;
} | undefined;
} & {
connection?: ({
clusterId?: string | undefined;
onPremise?: {
subnetId?: string | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
brokerUrls?: string[] | undefined;
} | undefined;
} & {
clusterId?: string | undefined;
onPremise?: ({
subnetId?: string | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
brokerUrls?: string[] | undefined;
} & {
subnetId?: string | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
brokerUrls?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
topicName?: string | undefined;
auth?: ({
sasl?: {
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} | undefined;
noAuth?: {} | undefined;
} & {
sasl?: ({
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} & {
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} & Record, never>) | undefined;
noAuth?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
transformer?: ({
serviceAccountId?: string | undefined;
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;
} & Record, never>) | undefined;
parser?: ({
jsonParser?: {
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} | undefined;
} & {
jsonParser?: ({
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} & {
dataSchema?: ({
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} & {
fields?: ({
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} & {
fields?: ({
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] & ({
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
} & {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
jsonFields?: string | undefined;
} & Record, never>) | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} & Record, never>) | undefined;
auditTrailsV1Parser?: ({} & {} & Record, never>) | undefined;
cloudLoggingParser?: ({} & {} & Record, never>) | undefined;
tskvParser?: ({
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} & {
dataSchema?: ({
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} & {
fields?: ({
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} & {
fields?: ({
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] & ({
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
} & {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
jsonFields?: string | undefined;
} & Record, never>) | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
mongoSource?: ({
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
secondaryPreferredMode?: boolean | undefined;
collections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
excludedCollections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
} & {
connection?: ({
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} & {
connectionOptions?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} & {
port?: number | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
replicaSet?: string | 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;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
secondaryPreferredMode?: boolean | 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;
} & Record, never>) | undefined;
clickhouseSource?: ({
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
connection?: ({
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
} & {
connectionOptions?: ({
mdbClusterId?: string | undefined;
onPremise?: {
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} & {
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
httpPort?: number | undefined;
nativePort?: number | 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;
} & Record, never>) | undefined;
database?: string | undefined;
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
subnetId?: string | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
mysqlTarget?: ({
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
serviceDatabase?: string | undefined;
user?: string | undefined;
timezone?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
sqlMode?: string | undefined;
skipConstraintChecks?: boolean | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} & {
connection?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} & {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
database?: string | undefined;
serviceDatabase?: string | undefined;
user?: string | undefined;
timezone?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
sqlMode?: string | undefined;
skipConstraintChecks?: boolean | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} & Record, never>) | undefined;
postgresTarget?: ({
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} & {
connection?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} & {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
securityGroups?: (string[] & string[] & 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;
} & Record, never>) | undefined;
clickhouseTarget?: ({
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
cleanupPolicy?: import("./endpoint/clickhouse").ClickhouseCleanupPolicy | undefined;
clickhouseClusterName?: string | undefined;
altNames?: {
fromName?: string | undefined;
toName?: string | undefined;
}[] | undefined;
sharding?: {
columnValueHash?: {
columnName?: string | undefined;
} | undefined;
customMapping?: {
columnName?: string | undefined;
mapping?: {
columnValue?: {
stringValue?: string | undefined;
} | undefined;
shardName?: string | undefined;
}[] | undefined;
} | undefined;
transferId?: {} | undefined;
} | undefined;
} & {
connection?: ({
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
} & {
connectionOptions?: ({
mdbClusterId?: string | undefined;
onPremise?: {
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} & {
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
httpPort?: number | undefined;
nativePort?: number | 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;
} & Record, never>) | undefined;
database?: string | undefined;
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
subnetId?: string | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
cleanupPolicy?: import("./endpoint/clickhouse").ClickhouseCleanupPolicy | undefined;
clickhouseClusterName?: string | undefined;
altNames?: ({
fromName?: string | undefined;
toName?: string | undefined;
}[] & ({
fromName?: string | undefined;
toName?: string | undefined;
} & {
fromName?: string | undefined;
toName?: string | undefined;
} & Record, never>)[] & Record, never>) | undefined;
sharding?: ({
columnValueHash?: {
columnName?: string | undefined;
} | undefined;
customMapping?: {
columnName?: string | undefined;
mapping?: {
columnValue?: {
stringValue?: string | undefined;
} | undefined;
shardName?: string | undefined;
}[] | undefined;
} | undefined;
transferId?: {} | undefined;
} & {
columnValueHash?: ({
columnName?: string | undefined;
} & {
columnName?: string | undefined;
} & Record, never>) | undefined;
customMapping?: ({
columnName?: string | undefined;
mapping?: {
columnValue?: {
stringValue?: string | undefined;
} | undefined;
shardName?: string | undefined;
}[] | undefined;
} & {
columnName?: string | undefined;
mapping?: ({
columnValue?: {
stringValue?: string | undefined;
} | undefined;
shardName?: string | undefined;
}[] & ({
columnValue?: {
stringValue?: string | undefined;
} | undefined;
shardName?: string | undefined;
} & {
columnValue?: ({
stringValue?: string | undefined;
} & {
stringValue?: string | undefined;
} & Record, never>) | undefined;
shardName?: string | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
transferId?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
ydbTarget?: ({
path?: string | undefined;
subnetId?: string | undefined;
serviceAccountId?: string | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
cleanupPolicy?: import("./endpoint/ydb").YdbCleanupPolicy | undefined;
instance?: string | undefined;
saKeyContent?: string | undefined;
} & {
path?: string | undefined;
subnetId?: string | undefined;
serviceAccountId?: string | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
database?: string | undefined;
cleanupPolicy?: import("./endpoint/ydb").YdbCleanupPolicy | undefined;
instance?: string | undefined;
saKeyContent?: string | undefined;
} & Record, never>) | undefined;
kafkaTarget?: ({
connection?: {
clusterId?: string | undefined;
onPremise?: {
subnetId?: string | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
brokerUrls?: string[] | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
auth?: {
sasl?: {
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} | undefined;
noAuth?: {} | undefined;
} | undefined;
topicSettings?: {
topic?: {
topicName?: string | undefined;
saveTxOrder?: boolean | undefined;
} | undefined;
topicPrefix?: string | undefined;
} | undefined;
serializer?: {
serializerAuto?: {} | undefined;
serializerJson?: {} | undefined;
serializerDebezium?: {
serializerParameters?: {
value?: string | undefined;
key?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
} & {
connection?: ({
clusterId?: string | undefined;
onPremise?: {
subnetId?: string | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
brokerUrls?: string[] | undefined;
} | undefined;
} & {
clusterId?: string | undefined;
onPremise?: ({
subnetId?: string | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
brokerUrls?: string[] | undefined;
} & {
subnetId?: string | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
brokerUrls?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
auth?: ({
sasl?: {
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} | undefined;
noAuth?: {} | undefined;
} & {
sasl?: ({
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} & {
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} & Record, never>) | undefined;
noAuth?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
topicSettings?: ({
topic?: {
topicName?: string | undefined;
saveTxOrder?: boolean | undefined;
} | undefined;
topicPrefix?: string | undefined;
} & {
topic?: ({
topicName?: string | undefined;
saveTxOrder?: boolean | undefined;
} & {
topicName?: string | undefined;
saveTxOrder?: boolean | undefined;
} & Record, never>) | undefined;
topicPrefix?: string | undefined;
} & Record, never>) | undefined;
serializer?: ({
serializerAuto?: {} | undefined;
serializerJson?: {} | undefined;
serializerDebezium?: {
serializerParameters?: {
value?: string | undefined;
key?: string | undefined;
}[] | undefined;
} | undefined;
} & {
serializerAuto?: ({} & {} & Record, never>) | undefined;
serializerJson?: ({} & {} & Record, never>) | undefined;
serializerDebezium?: ({
serializerParameters?: {
value?: string | undefined;
key?: string | undefined;
}[] | undefined;
} & {
serializerParameters?: ({
value?: string | undefined;
key?: string | undefined;
}[] & ({
value?: string | undefined;
key?: string | undefined;
} & {
value?: string | undefined;
key?: string | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
mongoTarget?: ({
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} & {
connection?: ({
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} & {
connectionOptions?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} & {
port?: number | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
replicaSet?: string | 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;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
database?: string | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>>(object: I): ListEndpointsResponse;
};
export declare const CreateEndpointRequest: {
$type: "yandex.cloud.datatransfer.v1.CreateEndpointRequest";
encode(message: CreateEndpointRequest, writer?: _m0.Writer): _m0.Writer;
decode(input: _m0.Reader | Uint8Array, length?: number | undefined): CreateEndpointRequest;
fromJSON(object: any): CreateEndpointRequest;
toJSON(message: CreateEndpointRequest): unknown;
fromPartial, never>) | undefined;
settings?: ({
mysqlSource?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
serviceDatabase?: string | undefined;
user?: string | undefined;
includeTablesRegex?: string[] | undefined;
excludeTablesRegex?: string[] | undefined;
timezone?: string | undefined;
password?: {
raw?: string | undefined;
} | 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;
} | undefined;
postgresSource?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
objectTransferSettings?: {
function?: import("./endpoint/common").ObjectTransferStage | undefined;
type?: import("./endpoint/common").ObjectTransferStage | undefined;
view?: import("./endpoint/common").ObjectTransferStage | undefined;
index?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
sequence?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceOwnedBy?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceSet?: 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;
materializedView?: 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;
} | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
slotByteLagLimit?: number | undefined;
serviceSchema?: string | undefined;
} | undefined;
ydbSource?: {
paths?: string[] | undefined;
subnetId?: string | undefined;
serviceAccountId?: string | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
instance?: string | undefined;
saKeyContent?: string | undefined;
} | undefined;
kafkaSource?: {
connection?: {
clusterId?: string | undefined;
onPremise?: {
subnetId?: string | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
brokerUrls?: string[] | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
topicName?: string | undefined;
auth?: {
sasl?: {
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} | undefined;
noAuth?: {} | undefined;
} | undefined;
transformer?: {
serviceAccountId?: string | undefined;
cloudFunction?: string | undefined;
numberOfRetries?: number | undefined;
bufferSize?: string | undefined;
bufferFlushInterval?: string | undefined;
invocationTimeout?: string | undefined;
} | undefined;
parser?: {
jsonParser?: {
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} | undefined;
} | undefined;
} | undefined;
mongoSource?: {
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
secondaryPreferredMode?: boolean | undefined;
collections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
excludedCollections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
} | undefined;
clickhouseSource?: {
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} | undefined;
mysqlTarget?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
serviceDatabase?: string | undefined;
user?: string | undefined;
timezone?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
sqlMode?: string | undefined;
skipConstraintChecks?: boolean | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} | undefined;
postgresTarget?: {
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} | undefined;
clickhouseTarget?: {
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
cleanupPolicy?: import("./endpoint/clickhouse").ClickhouseCleanupPolicy | undefined;
clickhouseClusterName?: string | undefined;
altNames?: {
fromName?: string | undefined;
toName?: string | undefined;
}[] | undefined;
sharding?: {
columnValueHash?: {
columnName?: string | undefined;
} | undefined;
customMapping?: {
columnName?: string | undefined;
mapping?: {
columnValue?: {
stringValue?: string | undefined;
} | undefined;
shardName?: string | undefined;
}[] | undefined;
} | undefined;
transferId?: {} | undefined;
} | undefined;
} | undefined;
ydbTarget?: {
path?: string | undefined;
subnetId?: string | undefined;
serviceAccountId?: string | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
cleanupPolicy?: import("./endpoint/ydb").YdbCleanupPolicy | undefined;
instance?: string | undefined;
saKeyContent?: string | undefined;
} | undefined;
kafkaTarget?: {
connection?: {
clusterId?: string | undefined;
onPremise?: {
subnetId?: string | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
brokerUrls?: string[] | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
auth?: {
sasl?: {
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} | undefined;
noAuth?: {} | undefined;
} | undefined;
topicSettings?: {
topic?: {
topicName?: string | undefined;
saveTxOrder?: boolean | undefined;
} | undefined;
topicPrefix?: string | undefined;
} | undefined;
serializer?: {
serializerAuto?: {} | undefined;
serializerJson?: {} | undefined;
serializerDebezium?: {
serializerParameters?: {
value?: string | undefined;
key?: string | undefined;
}[] | undefined;
} | undefined;
} | undefined;
} | undefined;
mongoTarget?: {
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} | undefined;
} & {
mysqlSource?: ({
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
serviceDatabase?: string | undefined;
user?: string | undefined;
includeTablesRegex?: string[] | undefined;
excludeTablesRegex?: string[] | undefined;
timezone?: string | undefined;
password?: {
raw?: string | undefined;
} | 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;
} & {
connection?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} & {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
database?: string | undefined;
serviceDatabase?: string | undefined;
user?: string | undefined;
includeTablesRegex?: (string[] & string[] & Record, never>) | undefined;
excludeTablesRegex?: (string[] & string[] & Record, never>) | undefined;
timezone?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | 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;
} & Record, never>) | undefined;
postgresSource?: ({
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
objectTransferSettings?: {
function?: import("./endpoint/common").ObjectTransferStage | undefined;
type?: import("./endpoint/common").ObjectTransferStage | undefined;
view?: import("./endpoint/common").ObjectTransferStage | undefined;
index?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
sequence?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceOwnedBy?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceSet?: 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;
materializedView?: 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;
} | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
slotByteLagLimit?: number | undefined;
serviceSchema?: string | undefined;
} & {
connection?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} & {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
database?: string | undefined;
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
objectTransferSettings?: ({
function?: import("./endpoint/common").ObjectTransferStage | undefined;
type?: import("./endpoint/common").ObjectTransferStage | undefined;
view?: import("./endpoint/common").ObjectTransferStage | undefined;
index?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
sequence?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceOwnedBy?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceSet?: 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;
materializedView?: 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;
} & {
function?: import("./endpoint/common").ObjectTransferStage | undefined;
type?: import("./endpoint/common").ObjectTransferStage | undefined;
view?: import("./endpoint/common").ObjectTransferStage | undefined;
index?: import("./endpoint/common").ObjectTransferStage | undefined;
trigger?: import("./endpoint/common").ObjectTransferStage | undefined;
sequence?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceOwnedBy?: import("./endpoint/common").ObjectTransferStage | undefined;
sequenceSet?: 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;
materializedView?: 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;
} & Record, never>) | undefined;
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
slotByteLagLimit?: number | undefined;
serviceSchema?: string | undefined;
} & Record, never>) | undefined;
ydbSource?: ({
paths?: string[] | undefined;
subnetId?: string | undefined;
serviceAccountId?: string | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
instance?: string | undefined;
saKeyContent?: string | undefined;
} & {
paths?: (string[] & string[] & Record, never>) | undefined;
subnetId?: string | undefined;
serviceAccountId?: string | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
database?: string | undefined;
instance?: string | undefined;
saKeyContent?: string | undefined;
} & Record, never>) | undefined;
kafkaSource?: ({
connection?: {
clusterId?: string | undefined;
onPremise?: {
subnetId?: string | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
brokerUrls?: string[] | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
topicName?: string | undefined;
auth?: {
sasl?: {
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} | undefined;
noAuth?: {} | undefined;
} | undefined;
transformer?: {
serviceAccountId?: string | undefined;
cloudFunction?: string | undefined;
numberOfRetries?: number | undefined;
bufferSize?: string | undefined;
bufferFlushInterval?: string | undefined;
invocationTimeout?: string | undefined;
} | undefined;
parser?: {
jsonParser?: {
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} | undefined;
} | undefined;
} & {
connection?: ({
clusterId?: string | undefined;
onPremise?: {
subnetId?: string | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
brokerUrls?: string[] | undefined;
} | undefined;
} & {
clusterId?: string | undefined;
onPremise?: ({
subnetId?: string | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
brokerUrls?: string[] | undefined;
} & {
subnetId?: string | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
brokerUrls?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
topicName?: string | undefined;
auth?: ({
sasl?: {
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} | undefined;
noAuth?: {} | undefined;
} & {
sasl?: ({
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} & {
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
mechanism?: import("./endpoint/kafka").KafkaMechanism | undefined;
} & Record, never>) | undefined;
noAuth?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
transformer?: ({
serviceAccountId?: string | undefined;
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;
} & Record, never>) | undefined;
parser?: ({
jsonParser?: {
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} | undefined;
auditTrailsV1Parser?: {} | undefined;
cloudLoggingParser?: {} | undefined;
tskvParser?: {
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} | undefined;
} & {
jsonParser?: ({
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} & {
dataSchema?: ({
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} & {
fields?: ({
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} & {
fields?: ({
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] & ({
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
} & {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
jsonFields?: string | undefined;
} & Record, never>) | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} & Record, never>) | undefined;
auditTrailsV1Parser?: ({} & {} & Record, never>) | undefined;
cloudLoggingParser?: ({} & {} & Record, never>) | undefined;
tskvParser?: ({
dataSchema?: {
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} & {
dataSchema?: ({
fields?: {
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} | undefined;
jsonFields?: string | undefined;
} & {
fields?: ({
fields?: {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] | undefined;
} & {
fields?: ({
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
}[] & ({
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
} & {
type?: import("./endpoint/common").ColumnType | undefined;
name?: string | undefined;
key?: boolean | undefined;
path?: string | undefined;
required?: boolean | undefined;
} & Record, never>)[] & Record, never>) | undefined;
} & Record, never>) | undefined;
jsonFields?: string | undefined;
} & Record, never>) | undefined;
nullKeysAllowed?: boolean | undefined;
addRestColumn?: boolean | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
mongoSource?: ({
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
secondaryPreferredMode?: boolean | undefined;
collections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
excludedCollections?: {
databaseName?: string | undefined;
collectionName?: string | undefined;
}[] | undefined;
} & {
connection?: ({
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} | undefined;
} & {
connectionOptions?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
authSource?: string | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
replicaSet?: string | undefined;
} & {
port?: number | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
replicaSet?: string | 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;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
secondaryPreferredMode?: boolean | 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;
} & Record, never>) | undefined;
clickhouseSource?: ({
connection?: {
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
} | undefined;
subnetId?: string | undefined;
securityGroups?: string[] | undefined;
includeTables?: string[] | undefined;
excludeTables?: string[] | undefined;
} & {
connection?: ({
connectionOptions?: {
mdbClusterId?: string | undefined;
onPremise?: {
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} | undefined;
} & {
connectionOptions?: ({
mdbClusterId?: string | undefined;
onPremise?: {
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
httpPort?: number | undefined;
nativePort?: number | undefined;
shards?: {
name?: string | undefined;
hosts?: string[] | undefined;
}[] | undefined;
} & {
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
httpPort?: number | undefined;
nativePort?: number | 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;
} & Record, never>) | undefined;
database?: string | undefined;
user?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
subnetId?: string | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
includeTables?: (string[] & string[] & Record, never>) | undefined;
excludeTables?: (string[] & string[] & Record, never>) | undefined;
} & Record, never>) | undefined;
mysqlTarget?: ({
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
serviceDatabase?: string | undefined;
user?: string | undefined;
timezone?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
sqlMode?: string | undefined;
skipConstraintChecks?: boolean | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} & {
connection?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} & {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
} & Record, never>) | undefined;
securityGroups?: (string[] & string[] & Record, never>) | undefined;
database?: string | undefined;
serviceDatabase?: string | undefined;
user?: string | undefined;
timezone?: string | undefined;
password?: ({
raw?: string | undefined;
} & {
raw?: string | undefined;
} & Record, never>) | undefined;
sqlMode?: string | undefined;
skipConstraintChecks?: boolean | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} & Record, never>) | undefined;
postgresTarget?: ({
connection?: {
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} | undefined;
securityGroups?: string[] | undefined;
database?: string | undefined;
user?: string | undefined;
password?: {
raw?: string | undefined;
} | undefined;
cleanupPolicy?: import("./endpoint/common").CleanupPolicy | undefined;
} & {
connection?: ({
mdbClusterId?: string | undefined;
onPremise?: {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} | undefined;
} & {
mdbClusterId?: string | undefined;
onPremise?: ({
port?: number | undefined;
subnetId?: string | undefined;
hosts?: string[] | undefined;
tlsMode?: {
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} | undefined;
} & {
port?: number | undefined;
subnetId?: string | undefined;
hosts?: (string[] & string[] & Record, never>) | undefined;
tlsMode?: ({
enabled?: {
caCertificate?: string | undefined;
} | undefined;
disabled?: {} | undefined;
} & {
enabled?: ({
caCertificate?: string | undefined;
} & {
caCertificate?: string | undefined;
} & Record, never>) | undefined;
disabled?: ({} & {} & Record