import _m0 from 'protobufjs/minimal'; import { Parser } from '../../../../../yandex/cloud/datatransfer/v1/endpoint/parsers'; import { Serializer } from '../../../../../yandex/cloud/datatransfer/v1/endpoint/serializers'; export declare const protobufPackage = "yandex.cloud.datatransfer.v1.endpoint"; export declare enum YdsCompressionCodec { YDS_COMPRESSION_CODEC_UNSPECIFIED = 0, YDS_COMPRESSION_CODEC_RAW = 1, YDS_COMPRESSION_CODEC_GZIP = 2, YDS_COMPRESSION_CODEC_ZSTD = 4, UNRECOGNIZED = -1 } export declare function ydsCompressionCodecFromJSON(object: any): YdsCompressionCodec; export declare function ydsCompressionCodecToJSON(object: YdsCompressionCodec): string; export interface YDSSource { /** Database */ database: string; /** Stream */ stream: string; /** SA which has read access to the stream. */ serviceAccountId: string; /** Compression codec */ supportedCodecs: YdsCompressionCodec[]; /** Data parsing rules */ parser?: Parser; /** * Should continue working, if consumer read lag exceed TTL of topic * False: stop the transfer in error state, if detected lost data. True: continue * working with losing part of data */ allowTtlRewind: boolean; /** for dedicated db */ endpoint: string; /** Network interface for endpoint. If none will assume public ipv4 */ subnetId: string; /** Security groups */ securityGroups: string[]; /** for important streams */ consumer: string; } export interface YDSTarget { /** Database */ database: string; /** Stream */ stream: string; /** SA which has read access to the stream. */ serviceAccountId: string; /** * Save transaction order * Not to split events queue into separate per-table queues. * Incompatible with setting Topic prefix, only with Topic full name. */ saveTxOrder: boolean; compressionCodec: YdsCompressionCodec; /** Data serialization format */ serializer?: Serializer; /** for dedicated db */ endpoint: string; /** Network interface for endpoint. If none will assume public ipv4 */ subnetId: string; /** Security groups */ securityGroups: string[]; } export declare const YDSSource: { encode(message: YDSSource, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): YDSSource; fromJSON(object: any): YDSSource; toJSON(message: YDSSource): unknown; fromPartial, never>) | undefined; parser?: ({ jsonParser?: { dataSchema?: { jsonFields?: string | undefined; fields?: { fields?: { name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; }[] | undefined; } | undefined; } | undefined; nullKeysAllowed?: boolean | undefined; addRestColumn?: boolean | undefined; unescapeStringValues?: boolean | undefined; } | undefined; auditTrailsV1Parser?: {} | undefined; cloudLoggingParser?: {} | undefined; tskvParser?: { dataSchema?: { jsonFields?: string | undefined; fields?: { fields?: { name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; }[] | undefined; } | undefined; } | undefined; nullKeysAllowed?: boolean | undefined; addRestColumn?: boolean | undefined; unescapeStringValues?: boolean | undefined; } | undefined; } & { jsonParser?: ({ dataSchema?: { jsonFields?: string | undefined; fields?: { fields?: { name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; }[] | undefined; } | undefined; } | undefined; nullKeysAllowed?: boolean | undefined; addRestColumn?: boolean | undefined; unescapeStringValues?: boolean | undefined; } & { dataSchema?: ({ jsonFields?: string | undefined; fields?: { fields?: { name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; }[] | undefined; } | undefined; } & { jsonFields?: string | undefined; fields?: ({ fields?: { name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; }[] | undefined; } & { fields?: ({ name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; }[] & ({ name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; } & { name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; nullKeysAllowed?: boolean | undefined; addRestColumn?: boolean | undefined; unescapeStringValues?: boolean | undefined; } & Record, never>) | undefined; auditTrailsV1Parser?: ({} & {} & Record, never>) | undefined; cloudLoggingParser?: ({} & {} & Record, never>) | undefined; tskvParser?: ({ dataSchema?: { jsonFields?: string | undefined; fields?: { fields?: { name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; }[] | undefined; } | undefined; } | undefined; nullKeysAllowed?: boolean | undefined; addRestColumn?: boolean | undefined; unescapeStringValues?: boolean | undefined; } & { dataSchema?: ({ jsonFields?: string | undefined; fields?: { fields?: { name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; }[] | undefined; } | undefined; } & { jsonFields?: string | undefined; fields?: ({ fields?: { name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; }[] | undefined; } & { fields?: ({ name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; }[] & ({ name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; } & { name?: string | undefined; type?: import("./common").ColumnType | undefined; key?: boolean | undefined; required?: boolean | undefined; path?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; nullKeysAllowed?: boolean | undefined; addRestColumn?: boolean | undefined; unescapeStringValues?: boolean | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; allowTtlRewind?: boolean | undefined; endpoint?: string | undefined; subnetId?: string | undefined; securityGroups?: (string[] & string[] & Record, never>) | undefined; consumer?: string | undefined; } & Record, never>>(object: I): YDSSource; }; export declare const YDSTarget: { encode(message: YDSTarget, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): YDSTarget; fromJSON(object: any): YDSTarget; toJSON(message: YDSTarget): unknown; fromPartial, never>) | undefined; serializerJson?: ({} & {} & Record, never>) | undefined; serializerDebezium?: ({ serializerParameters?: { key?: string | undefined; value?: string | undefined; }[] | undefined; } & { serializerParameters?: ({ key?: string | undefined; value?: string | undefined; }[] & ({ key?: string | undefined; value?: string | undefined; } & { key?: string | undefined; value?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; endpoint?: string | undefined; subnetId?: string | undefined; securityGroups?: (string[] & string[] & Record, never>) | undefined; } & Record, never>>(object: I): YDSTarget; }; type Builtin = Date | Function | Uint8Array | string | number | boolean | undefined; export type DeepPartial = T extends Builtin ? T : T extends Array ? Array> : T extends ReadonlyArray ? ReadonlyArray> : T extends {} ? { [K in keyof T]?: DeepPartial; } : Partial; type KeysOfUnion = T extends T ? keyof T : never; export type Exact = P extends Builtin ? P : P & { [K in keyof P]: Exact; } & Record>, never>; export {};