/// import { ChannelCredentials, ChannelOptions, UntypedServiceImplementation, handleUnaryCall, Client, ClientUnaryCall, Metadata, CallOptions, ServiceError } from '@grpc/grpc-js'; import _m0 from 'protobufjs/minimal'; export declare const protobufPackage = "yandex.cloud.dataproc.manager.v1"; export declare enum InitActsState { /** INIT_ACTS_STATE_UNSPECIFIED - No init acts on cluster */ INIT_ACTS_STATE_UNSPECIFIED = 0, /** FAILED - At least one failed init act */ FAILED = 1, /** SUCCESSFUL - All init acts succeeded */ SUCCESSFUL = 2, /** IN_PROGRESS - Some init acts not finished */ IN_PROGRESS = 3, UNRECOGNIZED = -1 } export declare function initActsStateFromJSON(object: any): InitActsState; export declare function initActsStateToJSON(object: InitActsState): string; export interface HbaseNodeInfo { name: string; requests: number; heapSizeMb: number; maxHeapSizeMb: number; } export interface HbaseInfo { available: boolean; regions: number; requests: number; averageLoad: number; liveNodes: HbaseNodeInfo[]; deadNodes: HbaseNodeInfo[]; } export interface HDFSNodeInfo { name: string; used: number; remaining: number; capacity: number; numBlocks: number; state: string; } export interface HDFSInfo { available: boolean; percentRemaining: number; used: number; free: number; totalBlocks: number; missingBlocks: number; missingBlocksReplicaOne: number; liveNodes: HDFSNodeInfo[]; deadNodes: HDFSNodeInfo[]; safemode: string; decommissioningNodes: HDFSNodeInfo[]; decommissionedNodes: HDFSNodeInfo[]; /** Actual list of decommission hosts in HDFS namenode memory */ requestedDecommissionHosts: string[]; } export interface HiveInfo { available: boolean; queriesSucceeded: number; queriesFailed: number; queriesExecuting: number; sessionsOpen: number; sessionsActive: number; } export interface YarnNodeInfo { name: string; state: string; numContainers: number; usedMemoryMb: number; availableMemoryMb: number; updateTime: number; } export interface YarnInfo { available: boolean; liveNodes: YarnNodeInfo[]; /** Actual list of decommission hosts in Yarn resource manager memory */ requestedDecommissionHosts: string[]; } export interface ZookeeperInfo { alive: boolean; } export interface OozieInfo { alive: boolean; } export interface LivyInfo { alive: boolean; } export interface InitActs { state: InitActsState; /** fqdns of nodes for error message */ fqdns: string[]; } export interface Info { hdfs?: HDFSInfo; yarn?: YarnInfo; hive?: HiveInfo; zookeeper?: ZookeeperInfo; hbase?: HbaseInfo; oozie?: OozieInfo; /** * Report count is incremented every time report is sent by Yandex Data Processing Agent. * So Worker can use this property to make sure that Yandex Data Processing Agent got data sent by Worker through Yandex Data Processing Manager * for synchronization purposes */ reportCount: number; livy?: LivyInfo; initActs?: InitActs; } /** The request message containing the host status report. */ export interface ReportRequest { cid: string; topologyRevision: number; info?: Info; collectedAt?: Date; } /** The response message containing the agent commands to apply on host. */ export interface ReportReply { decommissionTimeout: number; yarnHostsToDecommission: string[]; hdfsHostsToDecommission: string[]; } export declare const HbaseNodeInfo: { encode(message: HbaseNodeInfo, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): HbaseNodeInfo; fromJSON(object: any): HbaseNodeInfo; toJSON(message: HbaseNodeInfo): unknown; fromPartial, never>>(object: I): HbaseNodeInfo; }; export declare const HbaseInfo: { encode(message: HbaseInfo, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): HbaseInfo; fromJSON(object: any): HbaseInfo; toJSON(message: HbaseInfo): unknown; fromPartial, never>)[] & Record, never>) | undefined; deadNodes?: ({ name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; }[] & ({ name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; } & { name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; } & Record, never>)[] & Record, never>) | undefined; } & Record, never>>(object: I): HbaseInfo; }; export declare const HDFSNodeInfo: { encode(message: HDFSNodeInfo, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): HDFSNodeInfo; fromJSON(object: any): HDFSNodeInfo; toJSON(message: HDFSNodeInfo): unknown; fromPartial, never>>(object: I): HDFSNodeInfo; }; export declare const HDFSInfo: { encode(message: HDFSInfo, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): HDFSInfo; fromJSON(object: any): HDFSInfo; toJSON(message: HDFSInfo): unknown; fromPartial, never>)[] & Record, never>) | undefined; deadNodes?: ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; }[] & ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & { name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; safemode?: string | undefined; decommissioningNodes?: ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; }[] & ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & { name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; decommissionedNodes?: ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; }[] & ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & { name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; requestedDecommissionHosts?: (string[] & string[] & Record, never>) | undefined; } & Record, never>>(object: I): HDFSInfo; }; export declare const HiveInfo: { encode(message: HiveInfo, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): HiveInfo; fromJSON(object: any): HiveInfo; toJSON(message: HiveInfo): unknown; fromPartial, never>>(object: I): HiveInfo; }; export declare const YarnNodeInfo: { encode(message: YarnNodeInfo, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): YarnNodeInfo; fromJSON(object: any): YarnNodeInfo; toJSON(message: YarnNodeInfo): unknown; fromPartial, never>>(object: I): YarnNodeInfo; }; export declare const YarnInfo: { encode(message: YarnInfo, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): YarnInfo; fromJSON(object: any): YarnInfo; toJSON(message: YarnInfo): unknown; fromPartial, never>)[] & Record, never>) | undefined; requestedDecommissionHosts?: (string[] & string[] & Record, never>) | undefined; } & Record, never>>(object: I): YarnInfo; }; export declare const ZookeeperInfo: { encode(message: ZookeeperInfo, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ZookeeperInfo; fromJSON(object: any): ZookeeperInfo; toJSON(message: ZookeeperInfo): unknown; fromPartial, never>>(object: I): ZookeeperInfo; }; export declare const OozieInfo: { encode(message: OozieInfo, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): OozieInfo; fromJSON(object: any): OozieInfo; toJSON(message: OozieInfo): unknown; fromPartial, never>>(object: I): OozieInfo; }; export declare const LivyInfo: { encode(message: LivyInfo, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): LivyInfo; fromJSON(object: any): LivyInfo; toJSON(message: LivyInfo): unknown; fromPartial, never>>(object: I): LivyInfo; }; export declare const InitActs: { encode(message: InitActs, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): InitActs; fromJSON(object: any): InitActs; toJSON(message: InitActs): unknown; fromPartial, never>) | undefined; } & Record, never>>(object: I): InitActs; }; export declare const Info: { encode(message: Info, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): Info; fromJSON(object: any): Info; toJSON(message: Info): unknown; fromPartial, never>)[] & Record, never>) | undefined; deadNodes?: ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; }[] & ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & { name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; safemode?: string | undefined; decommissioningNodes?: ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; }[] & ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & { name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; decommissionedNodes?: ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; }[] & ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & { name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; requestedDecommissionHosts?: (string[] & string[] & Record, never>) | undefined; } & Record, never>) | undefined; yarn?: ({ available?: boolean | undefined; liveNodes?: { name?: string | undefined; state?: string | undefined; numContainers?: number | undefined; usedMemoryMb?: number | undefined; availableMemoryMb?: number | undefined; updateTime?: number | undefined; }[] | undefined; requestedDecommissionHosts?: string[] | undefined; } & { available?: boolean | undefined; liveNodes?: ({ name?: string | undefined; state?: string | undefined; numContainers?: number | undefined; usedMemoryMb?: number | undefined; availableMemoryMb?: number | undefined; updateTime?: number | undefined; }[] & ({ name?: string | undefined; state?: string | undefined; numContainers?: number | undefined; usedMemoryMb?: number | undefined; availableMemoryMb?: number | undefined; updateTime?: number | undefined; } & { name?: string | undefined; state?: string | undefined; numContainers?: number | undefined; usedMemoryMb?: number | undefined; availableMemoryMb?: number | undefined; updateTime?: number | undefined; } & Record, never>)[] & Record, never>) | undefined; requestedDecommissionHosts?: (string[] & string[] & Record, never>) | undefined; } & Record, never>) | undefined; hive?: ({ available?: boolean | undefined; queriesSucceeded?: number | undefined; queriesFailed?: number | undefined; queriesExecuting?: number | undefined; sessionsOpen?: number | undefined; sessionsActive?: number | undefined; } & { available?: boolean | undefined; queriesSucceeded?: number | undefined; queriesFailed?: number | undefined; queriesExecuting?: number | undefined; sessionsOpen?: number | undefined; sessionsActive?: number | undefined; } & Record, never>) | undefined; zookeeper?: ({ alive?: boolean | undefined; } & { alive?: boolean | undefined; } & Record, never>) | undefined; hbase?: ({ available?: boolean | undefined; regions?: number | undefined; requests?: number | undefined; averageLoad?: number | undefined; liveNodes?: { name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; }[] | undefined; deadNodes?: { name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; }[] | undefined; } & { available?: boolean | undefined; regions?: number | undefined; requests?: number | undefined; averageLoad?: number | undefined; liveNodes?: ({ name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; }[] & ({ name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; } & { name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; } & Record, never>)[] & Record, never>) | undefined; deadNodes?: ({ name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; }[] & ({ name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; } & { name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; } & Record, never>)[] & Record, never>) | undefined; } & Record, never>) | undefined; oozie?: ({ alive?: boolean | undefined; } & { alive?: boolean | undefined; } & Record, never>) | undefined; reportCount?: number | undefined; livy?: ({ alive?: boolean | undefined; } & { alive?: boolean | undefined; } & Record, never>) | undefined; initActs?: ({ state?: InitActsState | undefined; fqdns?: string[] | undefined; } & { state?: InitActsState | undefined; fqdns?: (string[] & string[] & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): Info; }; export declare const ReportRequest: { encode(message: ReportRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ReportRequest; fromJSON(object: any): ReportRequest; toJSON(message: ReportRequest): unknown; fromPartial, never>)[] & Record, never>) | undefined; deadNodes?: ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; }[] & ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & { name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; safemode?: string | undefined; decommissioningNodes?: ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; }[] & ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & { name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; decommissionedNodes?: ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; }[] & ({ name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & { name?: string | undefined; used?: number | undefined; remaining?: number | undefined; capacity?: number | undefined; numBlocks?: number | undefined; state?: string | undefined; } & Record, never>)[] & Record, never>) | undefined; requestedDecommissionHosts?: (string[] & string[] & Record, never>) | undefined; } & Record, never>) | undefined; yarn?: ({ available?: boolean | undefined; liveNodes?: { name?: string | undefined; state?: string | undefined; numContainers?: number | undefined; usedMemoryMb?: number | undefined; availableMemoryMb?: number | undefined; updateTime?: number | undefined; }[] | undefined; requestedDecommissionHosts?: string[] | undefined; } & { available?: boolean | undefined; liveNodes?: ({ name?: string | undefined; state?: string | undefined; numContainers?: number | undefined; usedMemoryMb?: number | undefined; availableMemoryMb?: number | undefined; updateTime?: number | undefined; }[] & ({ name?: string | undefined; state?: string | undefined; numContainers?: number | undefined; usedMemoryMb?: number | undefined; availableMemoryMb?: number | undefined; updateTime?: number | undefined; } & { name?: string | undefined; state?: string | undefined; numContainers?: number | undefined; usedMemoryMb?: number | undefined; availableMemoryMb?: number | undefined; updateTime?: number | undefined; } & Record, never>)[] & Record, never>) | undefined; requestedDecommissionHosts?: (string[] & string[] & Record, never>) | undefined; } & Record, never>) | undefined; hive?: ({ available?: boolean | undefined; queriesSucceeded?: number | undefined; queriesFailed?: number | undefined; queriesExecuting?: number | undefined; sessionsOpen?: number | undefined; sessionsActive?: number | undefined; } & { available?: boolean | undefined; queriesSucceeded?: number | undefined; queriesFailed?: number | undefined; queriesExecuting?: number | undefined; sessionsOpen?: number | undefined; sessionsActive?: number | undefined; } & Record, never>) | undefined; zookeeper?: ({ alive?: boolean | undefined; } & { alive?: boolean | undefined; } & Record, never>) | undefined; hbase?: ({ available?: boolean | undefined; regions?: number | undefined; requests?: number | undefined; averageLoad?: number | undefined; liveNodes?: { name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; }[] | undefined; deadNodes?: { name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; }[] | undefined; } & { available?: boolean | undefined; regions?: number | undefined; requests?: number | undefined; averageLoad?: number | undefined; liveNodes?: ({ name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; }[] & ({ name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; } & { name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; } & Record, never>)[] & Record, never>) | undefined; deadNodes?: ({ name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; }[] & ({ name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; } & { name?: string | undefined; requests?: number | undefined; heapSizeMb?: number | undefined; maxHeapSizeMb?: number | undefined; } & Record, never>)[] & Record, never>) | undefined; } & Record, never>) | undefined; oozie?: ({ alive?: boolean | undefined; } & { alive?: boolean | undefined; } & Record, never>) | undefined; reportCount?: number | undefined; livy?: ({ alive?: boolean | undefined; } & { alive?: boolean | undefined; } & Record, never>) | undefined; initActs?: ({ state?: InitActsState | undefined; fqdns?: string[] | undefined; } & { state?: InitActsState | undefined; fqdns?: (string[] & string[] & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; collectedAt?: Date | undefined; } & Record, never>>(object: I): ReportRequest; }; export declare const ReportReply: { encode(message: ReportReply, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ReportReply; fromJSON(object: any): ReportReply; toJSON(message: ReportReply): unknown; fromPartial, never>) | undefined; hdfsHostsToDecommission?: (string[] & string[] & Record, never>) | undefined; } & Record, never>>(object: I): ReportReply; }; /** Yandex Data Processing manager service definition. */ export declare const DataprocManagerServiceService: { /** Sends a status report from a host. */ readonly report: { readonly path: "/yandex.cloud.dataproc.manager.v1.DataprocManagerService/Report"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: ReportRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => ReportRequest; readonly responseSerialize: (value: ReportReply) => Buffer; readonly responseDeserialize: (value: Buffer) => ReportReply; }; }; export interface DataprocManagerServiceServer extends UntypedServiceImplementation { /** Sends a status report from a host. */ report: handleUnaryCall; } export interface DataprocManagerServiceClient extends Client { /** Sends a status report from a host. */ report(request: ReportRequest, callback: (error: ServiceError | null, response: ReportReply) => void): ClientUnaryCall; report(request: ReportRequest, metadata: Metadata, callback: (error: ServiceError | null, response: ReportReply) => void): ClientUnaryCall; report(request: ReportRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: ReportReply) => void): ClientUnaryCall; } export declare const DataprocManagerServiceClient: { new (address: string, credentials: ChannelCredentials, options?: Partial): DataprocManagerServiceClient; service: typeof DataprocManagerServiceService; }; 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 {};