/// import { ChannelCredentials, ChannelOptions, UntypedServiceImplementation, handleUnaryCall, Client, ClientUnaryCall, Metadata, CallOptions, ServiceError } from '@grpc/grpc-js'; import _m0 from 'protobufjs/minimal'; import { Job_Status, ApplicationInfo, SupportJob_Status, Job, SupportJob } from '../../../../../yandex/cloud/dataproc/manager/v1/job'; export declare const protobufPackage = "yandex.cloud.dataproc.manager.v1"; export interface ListJobsRequest { /** Required. ID of the cluster to list Yandex Data Processing jobs of. */ clusterId: string; /** * The maximum number of results per page that should be returned. If the number of available * results is larger than `page_size`, the service returns a `next_page_token` that can be used * to get the next page of results in subsequent ListJobs requests. * Acceptable values are 0 to 1000, inclusive. Default value: 100. */ pageSize: number; /** * Page token. Set `page_token` to the `next_page_token` returned by a previous ListJobs * request to get the next page of results. */ pageToken: string; /** String that describes a display filter. */ filter: string; } export interface ListJobsResponse { /** Requested list of Yandex Data Processing jobs. */ jobs: Job[]; /** * This token allows you to get the next page of results for ListJobs requests, * if the number of results is larger than `page_size` specified in the request. * To get the next page, specify the value of `next_page_token` as a value for * the `page_token` parameter in the next ListClusters request. Subsequent ListClusters * requests will have their own `next_page_token` to continue paging through the results. */ nextPageToken: string; } export interface UpdateJobStatusRequest { /** Required. ID of the Yandex Data Processing cluster. */ clusterId: string; /** Required. ID of the Yandex Data Processing job to update. */ jobId: string; /** Required. New status of the job. */ status: Job_Status; /** Attributes of YARN application. */ applicationInfo?: ApplicationInfo; } export interface UpdateJobStatusResponse { } export interface ListSupportJobsResponse { /** Requested list of Yandex Data Processing jobs. */ jobs: SupportJob[]; /** * This token allows you to get the next page of results for ListJobs requests, * if the number of results is larger than `page_size` specified in the request. * To get the next page, specify the value of `next_page_token` as a value for * the `page_token` parameter in the next ListClusters request. Subsequent ListClusters * requests will have their own `next_page_token` to continue paging through the results. */ nextPageToken: string; } export interface UpdateSupportJobStatusRequest { /** Required. ID of the Yandex Data Processing cluster. */ clusterId: string; /** Required. ID of the Yandex Data Processing job to update. */ jobId: string; /** Required. New status of the job. */ status: SupportJob_Status; } export interface SaveSupportJobLogRequest { /** ID of the cluster. */ clusterId: string; /** ID of the support job. */ jobId: string; /** Job output. */ output: string; } export interface SaveSupportJobLogResponse { } export declare const ListJobsRequest: { encode(message: ListJobsRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ListJobsRequest; fromJSON(object: any): ListJobsRequest; toJSON(message: ListJobsRequest): unknown; fromPartial, never>>(object: I): ListJobsRequest; }; export declare const ListJobsResponse: { encode(message: ListJobsResponse, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ListJobsResponse; fromJSON(object: any): ListJobsResponse; toJSON(message: ListJobsResponse): unknown; fromPartial, never>) | undefined; jarFileUris?: (string[] & string[] & Record, never>) | undefined; fileUris?: (string[] & string[] & Record, never>) | undefined; archiveUris?: (string[] & string[] & Record, never>) | undefined; properties?: ({ [x: string]: string | undefined; } & { [x: string]: string | undefined; } & Record, never>) | undefined; mainJarFileUri?: string | undefined; mainClass?: string | undefined; } & Record, never>) | undefined; sparkJob?: ({ args?: string[] | undefined; jarFileUris?: string[] | undefined; fileUris?: string[] | undefined; archiveUris?: string[] | undefined; properties?: { [x: string]: string | undefined; } | undefined; mainJarFileUri?: string | undefined; mainClass?: string | undefined; packages?: string[] | undefined; repositories?: string[] | undefined; excludePackages?: string[] | undefined; } & { args?: (string[] & string[] & Record, never>) | undefined; jarFileUris?: (string[] & string[] & Record, never>) | undefined; fileUris?: (string[] & string[] & Record, never>) | undefined; archiveUris?: (string[] & string[] & Record, never>) | undefined; properties?: ({ [x: string]: string | undefined; } & { [x: string]: string | undefined; } & Record, never>) | undefined; mainJarFileUri?: string | undefined; mainClass?: string | undefined; packages?: (string[] & string[] & Record, never>) | undefined; repositories?: (string[] & string[] & Record, never>) | undefined; excludePackages?: (string[] & string[] & Record, never>) | undefined; } & Record, never>) | undefined; pysparkJob?: ({ args?: string[] | undefined; jarFileUris?: string[] | undefined; fileUris?: string[] | undefined; archiveUris?: string[] | undefined; properties?: { [x: string]: string | undefined; } | undefined; mainPythonFileUri?: string | undefined; pythonFileUris?: string[] | undefined; packages?: string[] | undefined; repositories?: string[] | undefined; excludePackages?: string[] | undefined; } & { args?: (string[] & string[] & Record, never>) | undefined; jarFileUris?: (string[] & string[] & Record, never>) | undefined; fileUris?: (string[] & string[] & Record, never>) | undefined; archiveUris?: (string[] & string[] & Record, never>) | undefined; properties?: ({ [x: string]: string | undefined; } & { [x: string]: string | undefined; } & Record, never>) | undefined; mainPythonFileUri?: string | undefined; pythonFileUris?: (string[] & string[] & Record, never>) | undefined; packages?: (string[] & string[] & Record, never>) | undefined; repositories?: (string[] & string[] & Record, never>) | undefined; excludePackages?: (string[] & string[] & Record, never>) | undefined; } & Record, never>) | undefined; hiveJob?: ({ properties?: { [x: string]: string | undefined; } | undefined; continueOnFailure?: boolean | undefined; scriptVariables?: { [x: string]: string | undefined; } | undefined; jarFileUris?: string[] | undefined; queryFileUri?: string | undefined; queryList?: { queries?: string[] | undefined; } | undefined; } & { properties?: ({ [x: string]: string | undefined; } & { [x: string]: string | undefined; } & Record, never>) | undefined; continueOnFailure?: boolean | undefined; scriptVariables?: ({ [x: string]: string | undefined; } & { [x: string]: string | undefined; } & Record, never>) | undefined; jarFileUris?: (string[] & string[] & Record, never>) | undefined; queryFileUri?: string | undefined; queryList?: ({ queries?: string[] | undefined; } & { queries?: (string[] & string[] & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; applicationInfo?: ({ id?: string | undefined; applicationAttempts?: { id?: string | undefined; amContainerId?: string | undefined; }[] | undefined; } & { id?: string | undefined; applicationAttempts?: ({ id?: string | undefined; amContainerId?: string | undefined; }[] & ({ id?: string | undefined; amContainerId?: string | undefined; } & { id?: string | undefined; amContainerId?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>)[] & Record, never>) | undefined; nextPageToken?: string | undefined; } & Record, never>>(object: I): ListJobsResponse; }; export declare const UpdateJobStatusRequest: { encode(message: UpdateJobStatusRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): UpdateJobStatusRequest; fromJSON(object: any): UpdateJobStatusRequest; toJSON(message: UpdateJobStatusRequest): unknown; fromPartial, never>)[] & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): UpdateJobStatusRequest; }; export declare const UpdateJobStatusResponse: { encode(_: UpdateJobStatusResponse, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): UpdateJobStatusResponse; fromJSON(_: any): UpdateJobStatusResponse; toJSON(_: UpdateJobStatusResponse): unknown; fromPartial, never>>(_: I): UpdateJobStatusResponse; }; export declare const ListSupportJobsResponse: { encode(message: ListSupportJobsResponse, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ListSupportJobsResponse; fromJSON(object: any): ListSupportJobsResponse; toJSON(message: ListSupportJobsResponse): unknown; fromPartial, never>)[] & Record, never>) | undefined; nextPageToken?: string | undefined; } & Record, never>>(object: I): ListSupportJobsResponse; }; export declare const UpdateSupportJobStatusRequest: { encode(message: UpdateSupportJobStatusRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): UpdateSupportJobStatusRequest; fromJSON(object: any): UpdateSupportJobStatusRequest; toJSON(message: UpdateSupportJobStatusRequest): unknown; fromPartial, never>>(object: I): UpdateSupportJobStatusRequest; }; export declare const SaveSupportJobLogRequest: { encode(message: SaveSupportJobLogRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): SaveSupportJobLogRequest; fromJSON(object: any): SaveSupportJobLogRequest; toJSON(message: SaveSupportJobLogRequest): unknown; fromPartial, never>>(object: I): SaveSupportJobLogRequest; }; export declare const SaveSupportJobLogResponse: { encode(_: SaveSupportJobLogResponse, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): SaveSupportJobLogResponse; fromJSON(_: any): SaveSupportJobLogResponse; toJSON(_: SaveSupportJobLogResponse): unknown; fromPartial, never>>(_: I): SaveSupportJobLogResponse; }; export declare const JobServiceService: { /** Retrieves a list of jobs for Yandex Data Processing cluster. */ readonly listActive: { readonly path: "/yandex.cloud.dataproc.manager.v1.JobService/ListActive"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: ListJobsRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => ListJobsRequest; readonly responseSerialize: (value: ListJobsResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => ListJobsResponse; }; /** Currently used to update Job status. */ readonly updateStatus: { readonly path: "/yandex.cloud.dataproc.manager.v1.JobService/UpdateStatus"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: UpdateJobStatusRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => UpdateJobStatusRequest; readonly responseSerialize: (value: UpdateJobStatusResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => UpdateJobStatusResponse; }; /** Retrieves a list of support jobs for Yandex Data Processing cluster. */ readonly listSupportActive: { readonly path: "/yandex.cloud.dataproc.manager.v1.JobService/ListSupportActive"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: ListJobsRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => ListJobsRequest; readonly responseSerialize: (value: ListSupportJobsResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => ListSupportJobsResponse; }; /** Currently used to update support job status. */ readonly updateSupportStatus: { readonly path: "/yandex.cloud.dataproc.manager.v1.JobService/UpdateSupportStatus"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: UpdateSupportJobStatusRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => UpdateSupportJobStatusRequest; readonly responseSerialize: (value: UpdateJobStatusResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => UpdateJobStatusResponse; }; /** Save support job output. */ readonly saveSupportLog: { readonly path: "/yandex.cloud.dataproc.manager.v1.JobService/SaveSupportLog"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: SaveSupportJobLogRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => SaveSupportJobLogRequest; readonly responseSerialize: (value: SaveSupportJobLogResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => SaveSupportJobLogResponse; }; }; export interface JobServiceServer extends UntypedServiceImplementation { /** Retrieves a list of jobs for Yandex Data Processing cluster. */ listActive: handleUnaryCall; /** Currently used to update Job status. */ updateStatus: handleUnaryCall; /** Retrieves a list of support jobs for Yandex Data Processing cluster. */ listSupportActive: handleUnaryCall; /** Currently used to update support job status. */ updateSupportStatus: handleUnaryCall; /** Save support job output. */ saveSupportLog: handleUnaryCall; } export interface JobServiceClient extends Client { /** Retrieves a list of jobs for Yandex Data Processing cluster. */ listActive(request: ListJobsRequest, callback: (error: ServiceError | null, response: ListJobsResponse) => void): ClientUnaryCall; listActive(request: ListJobsRequest, metadata: Metadata, callback: (error: ServiceError | null, response: ListJobsResponse) => void): ClientUnaryCall; listActive(request: ListJobsRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: ListJobsResponse) => void): ClientUnaryCall; /** Currently used to update Job status. */ updateStatus(request: UpdateJobStatusRequest, callback: (error: ServiceError | null, response: UpdateJobStatusResponse) => void): ClientUnaryCall; updateStatus(request: UpdateJobStatusRequest, metadata: Metadata, callback: (error: ServiceError | null, response: UpdateJobStatusResponse) => void): ClientUnaryCall; updateStatus(request: UpdateJobStatusRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: UpdateJobStatusResponse) => void): ClientUnaryCall; /** Retrieves a list of support jobs for Yandex Data Processing cluster. */ listSupportActive(request: ListJobsRequest, callback: (error: ServiceError | null, response: ListSupportJobsResponse) => void): ClientUnaryCall; listSupportActive(request: ListJobsRequest, metadata: Metadata, callback: (error: ServiceError | null, response: ListSupportJobsResponse) => void): ClientUnaryCall; listSupportActive(request: ListJobsRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: ListSupportJobsResponse) => void): ClientUnaryCall; /** Currently used to update support job status. */ updateSupportStatus(request: UpdateSupportJobStatusRequest, callback: (error: ServiceError | null, response: UpdateJobStatusResponse) => void): ClientUnaryCall; updateSupportStatus(request: UpdateSupportJobStatusRequest, metadata: Metadata, callback: (error: ServiceError | null, response: UpdateJobStatusResponse) => void): ClientUnaryCall; updateSupportStatus(request: UpdateSupportJobStatusRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: UpdateJobStatusResponse) => void): ClientUnaryCall; /** Save support job output. */ saveSupportLog(request: SaveSupportJobLogRequest, callback: (error: ServiceError | null, response: SaveSupportJobLogResponse) => void): ClientUnaryCall; saveSupportLog(request: SaveSupportJobLogRequest, metadata: Metadata, callback: (error: ServiceError | null, response: SaveSupportJobLogResponse) => void): ClientUnaryCall; saveSupportLog(request: SaveSupportJobLogRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: SaveSupportJobLogResponse) => void): ClientUnaryCall; } export declare const JobServiceClient: { new (address: string, credentials: ChannelCredentials, options?: Partial): JobServiceClient; service: typeof JobServiceService; }; 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 {};
= P extends Builtin ? P : P & { [K in keyof P]: Exact
; } & Record>, never>; export {};