import _m0 from 'protobufjs/minimal'; import { Health, Resources } from '../../../../yandex/cloud/airflow/v1/common'; import { MaintenanceWindow, MaintenanceOperation } from '../../../../yandex/cloud/airflow/v1/maintenance'; import { LogLevel_Level } from '../../../../yandex/cloud/logging/v1/log_entry'; export declare const protobufPackage = "yandex.cloud.airflow.v1"; /** Apache Airflow cluster. */ export interface Cluster { /** * Unique ID of the Apache Airflow cluster. * This ID is assigned by Cloud during cluster creation. */ id: string; /** ID of the folder that the Apache Airflow cluster belongs to. */ folderId: string; /** The time when the Apache Airflow cluster was created. */ createdAt?: Date; /** * Name of the Apache Airflow cluster. * The name is unique within the folder. 1-64 characters long. */ name: string; /** Description of the Apache Airflow cluster. 0-256 characters long. */ description: string; /** Resource labels as `key:value` pairs. Maximum of 64 per resource. */ labels: { [key: string]: string; }; /** Monitoring systems relevant to the Apache Airflow cluster. */ monitoring: Monitoring[]; /** Configuration of Apache Airflow components. */ config?: ClusterConfig; /** Aggregated cluster health. */ health: Health; /** Cluster status. */ status: Cluster_Status; /** Network related configuration options. */ network?: NetworkConfig; /** Parameters of the location and access to the code that will be executed in the cluster. */ codeSync?: CodeSyncConfig; /** Deletion Protection inhibits deletion of the cluster. */ deletionProtection: boolean; /** Address of Apache Airflow web UI. */ webserverUrl: string; /** * Service account used to access Cloud resources. * For more information, see [documentation](/docs/managed-airflow/concepts/impersonation). */ serviceAccountId: string; /** Cloud Logging configuration. */ logging?: LoggingConfig; /** Window of maintenance operations. */ maintenanceWindow?: MaintenanceWindow; /** Maintenance operation planned at nearest maintenance_window. */ plannedOperation?: MaintenanceOperation; } export declare enum Cluster_Status { /** STATUS_UNKNOWN - Cluster state is unknown. */ STATUS_UNKNOWN = 0, /** CREATING - Cluster is being created. */ CREATING = 1, /** RUNNING - Cluster is running normally. */ RUNNING = 2, /** ERROR - Cluster encountered a problem and cannot operate. */ ERROR = 3, /** STOPPING - Cluster is stopping. */ STOPPING = 4, /** STOPPED - Cluster is stopped. */ STOPPED = 5, /** STARTING - Cluster is starting. */ STARTING = 6, /** UPDATING - Cluster is being updated. */ UPDATING = 7, UNRECOGNIZED = -1 } export declare function cluster_StatusFromJSON(object: any): Cluster_Status; export declare function cluster_StatusToJSON(object: Cluster_Status): string; export interface Cluster_LabelsEntry { key: string; value: string; } /** Monitoring system. */ export interface Monitoring { /** Name of the monitoring system. */ name: string; /** Description of the monitoring system. */ description: string; /** Link to the monitoring system. */ link: string; } export interface ClusterConfig { /** * Version of Apache Airflow that runs on the cluster. * Use `airlow_version` instead. * * @deprecated */ versionId: string; /** Configuration of the Apache Airflow application itself. */ airflow?: AirflowConfig; /** Configuration of webserver instances. */ webserver?: WebserverConfig; /** Configuration of scheduler instances. */ scheduler?: SchedulerConfig; /** Configuration of triggerer instances. */ triggerer?: TriggererConfig; /** Configuration of worker instances. */ worker?: WorkerConfig; /** The list of additional packages installed in the cluster. */ dependencies?: Dependencies; /** Configuration of Lockbox Secret Backend. */ lockbox?: LockboxConfig; /** Apache Airflow version. Format: "Major.Minor" */ airflowVersion: string; /** Python version. Format: "Major.Minor" */ pythonVersion: string; } export interface AirflowConfig { /** Properties to be passed to Apache Airflow configuration file. */ config: { [key: string]: string; }; } export interface AirflowConfig_ConfigEntry { key: string; value: string; } export interface WebserverConfig { /** The number of webserver instances in the cluster. */ count: number; /** Resources allocated to webserver instances. */ resources?: Resources; } export interface SchedulerConfig { /** The number of scheduler instances in the cluster. */ count: number; /** Resources allocated to scheduler instances. */ resources?: Resources; } export interface TriggererConfig { /** The number of triggerer instances in the cluster. */ count: number; /** Resources allocated to triggerer instances. */ resources?: Resources; } export interface WorkerConfig { /** The minimum number of worker instances in the cluster. */ minCount: number; /** The maximum number of worker instances in the cluster. */ maxCount: number; /** Resources allocated to worker instances. */ resources?: Resources; } export interface Dependencies { /** Python packages that are installed in the cluster. */ pipPackages: string[]; /** System packages that are installed in the cluster. */ debPackages: string[]; } export interface NetworkConfig { /** IDs of VPC network subnets where instances of the cluster are attached. */ subnetIds: string[]; /** User security groups. */ securityGroupIds: string[]; } export interface S3Config { /** The name of the Object Storage bucket that stores DAG files used in the cluster. */ bucket: string; } export interface CodeSyncConfig { s3?: S3Config | undefined; } export interface LoggingConfig { /** Logs generated by the Airflow components are delivered to Cloud Logging. */ enabled: boolean; /** Logs should be written to default log group for specified folder. */ folderId: string | undefined; /** Logs should be written to log group resolved by ID. */ logGroupId: string | undefined; /** * Minimum log entry level. * * See [LogLevel.Level] for details. */ minLevel: LogLevel_Level; } export interface LockboxConfig { /** The setting allows to enable Lockbox Secret Backend. */ enabled: boolean; } export declare const Cluster: { encode(message: Cluster, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): Cluster; fromJSON(object: any): Cluster; toJSON(message: Cluster): unknown; fromPartial, never>) | undefined; monitoring?: ({ name?: string | undefined; description?: string | undefined; link?: string | undefined; }[] & ({ name?: string | undefined; description?: string | undefined; link?: string | undefined; } & { name?: string | undefined; description?: string | undefined; link?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; config?: ({ versionId?: string | undefined; airflow?: { config?: { [x: string]: string | undefined; } | undefined; } | undefined; webserver?: { count?: number | undefined; resources?: { resourcePresetId?: string | undefined; } | undefined; } | undefined; scheduler?: { count?: number | undefined; resources?: { resourcePresetId?: string | undefined; } | undefined; } | undefined; triggerer?: { count?: number | undefined; resources?: { resourcePresetId?: string | undefined; } | undefined; } | undefined; worker?: { minCount?: number | undefined; maxCount?: number | undefined; resources?: { resourcePresetId?: string | undefined; } | undefined; } | undefined; dependencies?: { pipPackages?: string[] | undefined; debPackages?: string[] | undefined; } | undefined; lockbox?: { enabled?: boolean | undefined; } | undefined; airflowVersion?: string | undefined; pythonVersion?: string | undefined; } & { versionId?: string | undefined; airflow?: ({ config?: { [x: string]: string | undefined; } | undefined; } & { config?: ({ [x: string]: string | undefined; } & { [x: string]: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; webserver?: ({ count?: number | undefined; resources?: { resourcePresetId?: string | undefined; } | undefined; } & { count?: number | undefined; resources?: ({ resourcePresetId?: string | undefined; } & { resourcePresetId?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; scheduler?: ({ count?: number | undefined; resources?: { resourcePresetId?: string | undefined; } | undefined; } & { count?: number | undefined; resources?: ({ resourcePresetId?: string | undefined; } & { resourcePresetId?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; triggerer?: ({ count?: number | undefined; resources?: { resourcePresetId?: string | undefined; } | undefined; } & { count?: number | undefined; resources?: ({ resourcePresetId?: string | undefined; } & { resourcePresetId?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; worker?: ({ minCount?: number | undefined; maxCount?: number | undefined; resources?: { resourcePresetId?: string | undefined; } | undefined; } & { minCount?: number | undefined; maxCount?: number | undefined; resources?: ({ resourcePresetId?: string | undefined; } & { resourcePresetId?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; dependencies?: ({ pipPackages?: string[] | undefined; debPackages?: string[] | undefined; } & { pipPackages?: (string[] & string[] & Record, never>) | undefined; debPackages?: (string[] & string[] & Record, never>) | undefined; } & Record, never>) | undefined; lockbox?: ({ enabled?: boolean | undefined; } & { enabled?: boolean | undefined; } & Record, never>) | undefined; airflowVersion?: string | undefined; pythonVersion?: string | undefined; } & Record, never>) | undefined; health?: Health | undefined; status?: Cluster_Status | undefined; network?: ({ subnetIds?: string[] | undefined; securityGroupIds?: string[] | undefined; } & { subnetIds?: (string[] & string[] & Record, never>) | undefined; securityGroupIds?: (string[] & string[] & Record, never>) | undefined; } & Record, never>) | undefined; codeSync?: ({ s3?: { bucket?: string | undefined; } | undefined; } & { s3?: ({ bucket?: string | undefined; } & { bucket?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; deletionProtection?: boolean | undefined; webserverUrl?: string | undefined; serviceAccountId?: string | undefined; logging?: ({ enabled?: boolean | undefined; folderId?: string | undefined; logGroupId?: string | undefined; minLevel?: LogLevel_Level | undefined; } & { enabled?: boolean | undefined; folderId?: string | undefined; logGroupId?: string | undefined; minLevel?: LogLevel_Level | undefined; } & Record, never>) | undefined; maintenanceWindow?: ({ anytime?: {} | undefined; weeklyMaintenanceWindow?: { day?: import("../../../../yandex/cloud/airflow/v1/maintenance").WeeklyMaintenanceWindow_WeekDay | undefined; hour?: number | undefined; } | undefined; } & { anytime?: ({} & {} & Record, never>) | undefined; weeklyMaintenanceWindow?: ({ day?: import("../../../../yandex/cloud/airflow/v1/maintenance").WeeklyMaintenanceWindow_WeekDay | undefined; hour?: number | undefined; } & { day?: import("../../../../yandex/cloud/airflow/v1/maintenance").WeeklyMaintenanceWindow_WeekDay | undefined; hour?: number | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; plannedOperation?: ({ info?: string | undefined; delayedUntil?: Date | undefined; latestMaintenanceTime?: Date | undefined; nextMaintenanceWindowTime?: Date | undefined; } & { info?: string | undefined; delayedUntil?: Date | undefined; latestMaintenanceTime?: Date | undefined; nextMaintenanceWindowTime?: Date | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): Cluster; }; export declare const Cluster_LabelsEntry: { encode(message: Cluster_LabelsEntry, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): Cluster_LabelsEntry; fromJSON(object: any): Cluster_LabelsEntry; toJSON(message: Cluster_LabelsEntry): unknown; fromPartial, never>>(object: I): Cluster_LabelsEntry; }; export declare const Monitoring: { encode(message: Monitoring, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): Monitoring; fromJSON(object: any): Monitoring; toJSON(message: Monitoring): unknown; fromPartial, never>>(object: I): Monitoring; }; export declare const ClusterConfig: { encode(message: ClusterConfig, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ClusterConfig; fromJSON(object: any): ClusterConfig; toJSON(message: ClusterConfig): unknown; fromPartial, never>) | undefined; } & Record, never>) | undefined; webserver?: ({ count?: number | undefined; resources?: { resourcePresetId?: string | undefined; } | undefined; } & { count?: number | undefined; resources?: ({ resourcePresetId?: string | undefined; } & { resourcePresetId?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; scheduler?: ({ count?: number | undefined; resources?: { resourcePresetId?: string | undefined; } | undefined; } & { count?: number | undefined; resources?: ({ resourcePresetId?: string | undefined; } & { resourcePresetId?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; triggerer?: ({ count?: number | undefined; resources?: { resourcePresetId?: string | undefined; } | undefined; } & { count?: number | undefined; resources?: ({ resourcePresetId?: string | undefined; } & { resourcePresetId?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; worker?: ({ minCount?: number | undefined; maxCount?: number | undefined; resources?: { resourcePresetId?: string | undefined; } | undefined; } & { minCount?: number | undefined; maxCount?: number | undefined; resources?: ({ resourcePresetId?: string | undefined; } & { resourcePresetId?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; dependencies?: ({ pipPackages?: string[] | undefined; debPackages?: string[] | undefined; } & { pipPackages?: (string[] & string[] & Record, never>) | undefined; debPackages?: (string[] & string[] & Record, never>) | undefined; } & Record, never>) | undefined; lockbox?: ({ enabled?: boolean | undefined; } & { enabled?: boolean | undefined; } & Record, never>) | undefined; airflowVersion?: string | undefined; pythonVersion?: string | undefined; } & Record, never>>(object: I): ClusterConfig; }; export declare const AirflowConfig: { encode(message: AirflowConfig, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): AirflowConfig; fromJSON(object: any): AirflowConfig; toJSON(message: AirflowConfig): unknown; fromPartial, never>) | undefined; } & Record, never>>(object: I): AirflowConfig; }; export declare const AirflowConfig_ConfigEntry: { encode(message: AirflowConfig_ConfigEntry, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): AirflowConfig_ConfigEntry; fromJSON(object: any): AirflowConfig_ConfigEntry; toJSON(message: AirflowConfig_ConfigEntry): unknown; fromPartial, never>>(object: I): AirflowConfig_ConfigEntry; }; export declare const WebserverConfig: { encode(message: WebserverConfig, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): WebserverConfig; fromJSON(object: any): WebserverConfig; toJSON(message: WebserverConfig): unknown; fromPartial, never>) | undefined; } & Record, never>>(object: I): WebserverConfig; }; export declare const SchedulerConfig: { encode(message: SchedulerConfig, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): SchedulerConfig; fromJSON(object: any): SchedulerConfig; toJSON(message: SchedulerConfig): unknown; fromPartial, never>) | undefined; } & Record, never>>(object: I): SchedulerConfig; }; export declare const TriggererConfig: { encode(message: TriggererConfig, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): TriggererConfig; fromJSON(object: any): TriggererConfig; toJSON(message: TriggererConfig): unknown; fromPartial, never>) | undefined; } & Record, never>>(object: I): TriggererConfig; }; export declare const WorkerConfig: { encode(message: WorkerConfig, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): WorkerConfig; fromJSON(object: any): WorkerConfig; toJSON(message: WorkerConfig): unknown; fromPartial, never>) | undefined; } & Record, never>>(object: I): WorkerConfig; }; export declare const Dependencies: { encode(message: Dependencies, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): Dependencies; fromJSON(object: any): Dependencies; toJSON(message: Dependencies): unknown; fromPartial, never>) | undefined; debPackages?: (string[] & string[] & Record, never>) | undefined; } & Record, never>>(object: I): Dependencies; }; export declare const NetworkConfig: { encode(message: NetworkConfig, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): NetworkConfig; fromJSON(object: any): NetworkConfig; toJSON(message: NetworkConfig): unknown; fromPartial, never>) | undefined; securityGroupIds?: (string[] & string[] & Record, never>) | undefined; } & Record, never>>(object: I): NetworkConfig; }; export declare const S3Config: { encode(message: S3Config, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): S3Config; fromJSON(object: any): S3Config; toJSON(message: S3Config): unknown; fromPartial, never>>(object: I): S3Config; }; export declare const CodeSyncConfig: { encode(message: CodeSyncConfig, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): CodeSyncConfig; fromJSON(object: any): CodeSyncConfig; toJSON(message: CodeSyncConfig): unknown; fromPartial, never>) | undefined; } & Record, never>>(object: I): CodeSyncConfig; }; export declare const LoggingConfig: { encode(message: LoggingConfig, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): LoggingConfig; fromJSON(object: any): LoggingConfig; toJSON(message: LoggingConfig): unknown; fromPartial, never>>(object: I): LoggingConfig; }; export declare const LockboxConfig: { encode(message: LockboxConfig, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): LockboxConfig; fromJSON(object: any): LockboxConfig; toJSON(message: LockboxConfig): unknown; fromPartial, never>>(object: I): LockboxConfig; }; 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 {};