/// /** * Generated by the protoc-gen-ts. DO NOT EDIT! * compiler version: 0.0.0 * source: jetpack/proto/runtime/v1alpha1/remote.proto * git: https://github.com/thesayyn/protoc-gen-ts */ import * as dependency_1 from "./../../../../google/protobuf/timestamp"; import * as pb_1 from "google-protobuf"; import * as grpc_1 from "@grpc/grpc-js"; export declare namespace remote { export enum ErrorCode { UNKNOWN = 0, SYSTEM = 100, APPLICATION = 200 } export enum Unit { UNKNOWN_UNIT = 0, SECONDS = 1, MINUTES = 2, HOURS = 3, DAYS = 4, WEEKS = 5 } export enum DayOfWeek { UNKNOWN_DAY = 0, SUNDAY = 1, MONDAY = 2, TUESDAY = 3, WEDNESDAY = 4, THURSDAY = 5, FRIDAY = 6, SATURDAY = 7 } export class RemoteCallRequest extends pb_1.Message { #private; constructor(data?: any[] | { qualified_symbol?: string; json_args?: string; }); get qualified_symbol(): string; set qualified_symbol(value: string); get json_args(): string; set json_args(value: string); static fromObject(data: { qualified_symbol?: string; json_args?: string; }): RemoteCallRequest; toObject(): { qualified_symbol?: string | undefined; json_args?: string | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): RemoteCallRequest; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): RemoteCallRequest; } export class RemoteCallResponse extends pb_1.Message { #private; constructor(data?: any[] | { json_results?: string; }); get json_results(): string; set json_results(value: string); static fromObject(data: { json_results?: string; }): RemoteCallResponse; toObject(): { json_results?: string | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): RemoteCallResponse; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): RemoteCallResponse; } export class CreateTaskRequest extends pb_1.Message { #private; constructor(data?: any[] | { task?: Task; /** @deprecated*/ sdk_version?: string; }); get task(): Task; set task(value: Task); /** @deprecated*/ get sdk_version(): string; /** @deprecated*/ set sdk_version(value: string); static fromObject(data: { task?: ReturnType; sdk_version?: string; }): CreateTaskRequest; toObject(): { task?: { namespace?: string | undefined; hostname?: string | undefined; app_name?: string | undefined; project_id?: string | undefined; chart_revision?: string | undefined; qualified_symbol?: string | undefined; encoded_args?: Uint8Array | undefined; parent_task_id?: string | undefined; target_time?: { seconds?: number | undefined; nanos?: number | undefined; } | undefined; with_checkpointing?: boolean | undefined; task_id?: string | undefined; } | undefined; sdk_version?: string | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): CreateTaskRequest; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): CreateTaskRequest; } export class CreateTaskResponse extends pb_1.Message { #private; constructor(data?: any[] | { task_id?: string; }); get task_id(): string; set task_id(value: string); static fromObject(data: { task_id?: string; }): CreateTaskResponse; toObject(): { task_id?: string | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): CreateTaskResponse; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): CreateTaskResponse; } export class CancelTaskRequest extends pb_1.Message { #private; constructor(data?: any[] | { task_id?: string; }); get task_id(): string; set task_id(value: string); static fromObject(data: { task_id?: string; }): CancelTaskRequest; toObject(): { task_id?: string | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): CancelTaskRequest; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): CancelTaskRequest; } export class CancelTaskResponse extends pb_1.Message { #private; constructor(data?: any[] | { success?: boolean; }); get success(): boolean; set success(value: boolean); static fromObject(data: { success?: boolean; }): CancelTaskResponse; toObject(): { success?: boolean | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): CancelTaskResponse; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): CancelTaskResponse; } export class PostResultRequest extends pb_1.Message { #private; constructor(data?: any[] | { exec_id?: string; result?: Result; }); get exec_id(): string; set exec_id(value: string); get result(): Result; set result(value: Result); static fromObject(data: { exec_id?: string; result?: ReturnType; }): PostResultRequest; toObject(): { exec_id?: string | undefined; result?: { value?: { encoded_value?: Uint8Array | undefined; } | undefined; error?: { code?: ErrorCode | undefined; message?: string | undefined; encoded_error?: Uint8Array | undefined; } | undefined; } | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): PostResultRequest; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): PostResultRequest; } export class PostResultResponse extends pb_1.Message { #private; constructor(data?: any[] | {}); static fromObject(data: {}): PostResultResponse; toObject(): {}; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): PostResultResponse; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): PostResultResponse; } export class Task extends pb_1.Message { #private; constructor(data?: any[] | { namespace?: string; /** @deprecated*/ hostname?: string; app_name?: string; project_id?: string; chart_revision?: string; qualified_symbol?: string; encoded_args?: Uint8Array; parent_task_id?: string; target_time?: dependency_1.google.protobuf.Timestamp; with_checkpointing?: boolean; task_id?: string; }); get namespace(): string; set namespace(value: string); /** @deprecated*/ get hostname(): string; /** @deprecated*/ set hostname(value: string); get app_name(): string; set app_name(value: string); get project_id(): string; set project_id(value: string); get chart_revision(): string; set chart_revision(value: string); get qualified_symbol(): string; set qualified_symbol(value: string); get encoded_args(): Uint8Array; set encoded_args(value: Uint8Array); get parent_task_id(): string; set parent_task_id(value: string); get target_time(): dependency_1.google.protobuf.Timestamp; set target_time(value: dependency_1.google.protobuf.Timestamp); get with_checkpointing(): boolean; set with_checkpointing(value: boolean); get task_id(): string; set task_id(value: string); static fromObject(data: { namespace?: string; hostname?: string; app_name?: string; project_id?: string; chart_revision?: string; qualified_symbol?: string; encoded_args?: Uint8Array; parent_task_id?: string; target_time?: ReturnType; with_checkpointing?: boolean; task_id?: string; }): Task; toObject(): { namespace?: string | undefined; hostname?: string | undefined; app_name?: string | undefined; project_id?: string | undefined; chart_revision?: string | undefined; qualified_symbol?: string | undefined; encoded_args?: Uint8Array | undefined; parent_task_id?: string | undefined; target_time?: { seconds?: number | undefined; nanos?: number | undefined; } | undefined; with_checkpointing?: boolean | undefined; task_id?: string | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): Task; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): Task; } export class Result extends pb_1.Message { #private; constructor(data?: any[] | { value?: Value; error?: Error; }); get value(): Value; set value(value: Value); get error(): Error; set error(value: Error); static fromObject(data: { value?: ReturnType; error?: ReturnType; }): Result; toObject(): { value?: { encoded_value?: Uint8Array | undefined; } | undefined; error?: { code?: ErrorCode | undefined; message?: string | undefined; encoded_error?: Uint8Array | undefined; } | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): Result; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): Result; } export class Error extends pb_1.Message { #private; constructor(data?: any[] | { code?: ErrorCode; message?: string; encoded_error?: Uint8Array; }); get code(): ErrorCode; set code(value: ErrorCode); get message(): string; set message(value: string); get encoded_error(): Uint8Array; set encoded_error(value: Uint8Array); static fromObject(data: { code?: ErrorCode; message?: string; encoded_error?: Uint8Array; }): Error; toObject(): { code?: ErrorCode | undefined; message?: string | undefined; encoded_error?: Uint8Array | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): Error; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): Error; } export class Value extends pb_1.Message { #private; constructor(data?: any[] | { encoded_value?: Uint8Array; }); get encoded_value(): Uint8Array; set encoded_value(value: Uint8Array); static fromObject(data: { encoded_value?: Uint8Array; }): Value; toObject(): { encoded_value?: Uint8Array | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): Value; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): Value; } export class RegisterAppRequest extends pb_1.Message { #private; constructor(data?: any[] | { namespace?: string; hostname?: string; cron_jobs?: CronJob[]; qualified_symbols?: string[]; endpoints?: Map; }); get namespace(): string; set namespace(value: string); get hostname(): string; set hostname(value: string); get cron_jobs(): CronJob[]; set cron_jobs(value: CronJob[]); get qualified_symbols(): string[]; set qualified_symbols(value: string[]); get endpoints(): Map; set endpoints(value: Map); static fromObject(data: { namespace?: string; hostname?: string; cron_jobs?: ReturnType[]; qualified_symbols?: string[]; endpoints?: { [key: string]: string; }; }): RegisterAppRequest; toObject(): { namespace?: string | undefined; hostname?: string | undefined; cron_jobs?: { qualified_symbol?: string | undefined; target_time?: string | undefined; target_day_of_week?: DayOfWeek | undefined; unit?: Unit | undefined; interval?: number | undefined; schedule_rule?: string | undefined; }[] | undefined; qualified_symbols?: string[] | undefined; endpoints?: { [key: string]: string; } | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): RegisterAppRequest; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): RegisterAppRequest; } export class RegisterAppResponse extends pb_1.Message { #private; constructor(data?: any[] | {}); static fromObject(data: {}): RegisterAppResponse; toObject(): {}; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): RegisterAppResponse; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): RegisterAppResponse; } export class DeregisterAppRequest extends pb_1.Message { #private; constructor(data?: any[] | { namespace?: string; hostname?: string; }); get namespace(): string; set namespace(value: string); get hostname(): string; set hostname(value: string); static fromObject(data: { namespace?: string; hostname?: string; }): DeregisterAppRequest; toObject(): { namespace?: string | undefined; hostname?: string | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): DeregisterAppRequest; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): DeregisterAppRequest; } export class DeregisterAppResponse extends pb_1.Message { #private; constructor(data?: any[] | {}); static fromObject(data: {}): DeregisterAppResponse; toObject(): {}; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): DeregisterAppResponse; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): DeregisterAppResponse; } export class WaitForResultRequest extends pb_1.Message { #private; constructor(data?: any[] | { task_id?: string; }); get task_id(): string; set task_id(value: string); static fromObject(data: { task_id?: string; }): WaitForResultRequest; toObject(): { task_id?: string | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): WaitForResultRequest; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): WaitForResultRequest; } export class WaitForResultResponse extends pb_1.Message { #private; constructor(data?: any[] | { result?: Result; }); get result(): Result; set result(value: Result); static fromObject(data: { result?: ReturnType; }): WaitForResultResponse; toObject(): { result?: { value?: { encoded_value?: Uint8Array | undefined; } | undefined; error?: { code?: ErrorCode | undefined; message?: string | undefined; encoded_error?: Uint8Array | undefined; } | undefined; } | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): WaitForResultResponse; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): WaitForResultResponse; } export class GetSymbolFromEndpointRequest extends pb_1.Message { #private; constructor(data?: any[] | { endpoint?: string; }); get endpoint(): string; set endpoint(value: string); static fromObject(data: { endpoint?: string; }): GetSymbolFromEndpointRequest; toObject(): { endpoint?: string | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): GetSymbolFromEndpointRequest; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): GetSymbolFromEndpointRequest; } export class GetSymbolFromEndpointResponse extends pb_1.Message { #private; constructor(data?: any[] | { symbol?: string; }); get symbol(): string; set symbol(value: string); static fromObject(data: { symbol?: string; }): GetSymbolFromEndpointResponse; toObject(): { symbol?: string | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): GetSymbolFromEndpointResponse; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): GetSymbolFromEndpointResponse; } export class CronJob extends pb_1.Message { #private; constructor(data?: any[] | { qualified_symbol?: string; target_time?: string; target_day_of_week?: DayOfWeek; unit?: Unit; interval?: number; schedule_rule?: string; }); get qualified_symbol(): string; set qualified_symbol(value: string); get target_time(): string; set target_time(value: string); get target_day_of_week(): DayOfWeek; set target_day_of_week(value: DayOfWeek); get unit(): Unit; set unit(value: Unit); get interval(): number; set interval(value: number); get schedule_rule(): string; set schedule_rule(value: string); static fromObject(data: { qualified_symbol?: string; target_time?: string; target_day_of_week?: DayOfWeek; unit?: Unit; interval?: number; schedule_rule?: string; }): CronJob; toObject(): { qualified_symbol?: string | undefined; target_time?: string | undefined; target_day_of_week?: DayOfWeek | undefined; unit?: Unit | undefined; interval?: number | undefined; schedule_rule?: string | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): CronJob; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): CronJob; } export class GetTaskRequest extends pb_1.Message { #private; constructor(data?: any[] | { task_id?: string; }); get task_id(): string; set task_id(value: string); static fromObject(data: { task_id?: string; }): GetTaskRequest; toObject(): { task_id?: string | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): GetTaskRequest; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): GetTaskRequest; } export class GetTaskResponse extends pb_1.Message { #private; constructor(data?: any[] | { id?: string; encoded_args?: Uint8Array; }); get id(): string; set id(value: string); get encoded_args(): Uint8Array; set encoded_args(value: Uint8Array); static fromObject(data: { id?: string; encoded_args?: Uint8Array; }): GetTaskResponse; toObject(): { id?: string | undefined; encoded_args?: Uint8Array | undefined; }; serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; static deserialize(bytes: Uint8Array | pb_1.BinaryReader): GetTaskResponse; serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): GetTaskResponse; } interface GrpcPromiseServiceInterface { (message: P, metadata: grpc_1.Metadata, options?: grpc_1.CallOptions): Promise; (message: P, options?: grpc_1.CallOptions): Promise; } export abstract class UnimplementedRemoteExecutorService { static definition: { CreateTask: { path: string; requestStream: boolean; responseStream: boolean; requestSerialize: (message: CreateTaskRequest) => Buffer; requestDeserialize: (bytes: Buffer) => CreateTaskRequest; responseSerialize: (message: CreateTaskResponse) => Buffer; responseDeserialize: (bytes: Buffer) => CreateTaskResponse; }; CancelTask: { path: string; requestStream: boolean; responseStream: boolean; requestSerialize: (message: CancelTaskRequest) => Buffer; requestDeserialize: (bytes: Buffer) => CancelTaskRequest; responseSerialize: (message: CancelTaskResponse) => Buffer; responseDeserialize: (bytes: Buffer) => CancelTaskResponse; }; PostResult: { path: string; requestStream: boolean; responseStream: boolean; requestSerialize: (message: PostResultRequest) => Buffer; requestDeserialize: (bytes: Buffer) => PostResultRequest; responseSerialize: (message: PostResultResponse) => Buffer; responseDeserialize: (bytes: Buffer) => PostResultResponse; }; WaitForResult: { path: string; requestStream: boolean; responseStream: boolean; requestSerialize: (message: WaitForResultRequest) => Buffer; requestDeserialize: (bytes: Buffer) => WaitForResultRequest; responseSerialize: (message: WaitForResultResponse) => Buffer; responseDeserialize: (bytes: Buffer) => WaitForResultResponse; }; GetTask: { path: string; requestStream: boolean; responseStream: boolean; requestSerialize: (message: GetTaskRequest) => Buffer; requestDeserialize: (bytes: Buffer) => GetTaskRequest; responseSerialize: (message: GetTaskResponse) => Buffer; responseDeserialize: (bytes: Buffer) => GetTaskResponse; }; GetSymbolFromEndpoint: { path: string; requestStream: boolean; responseStream: boolean; requestSerialize: (message: GetSymbolFromEndpointRequest) => Buffer; requestDeserialize: (bytes: Buffer) => GetSymbolFromEndpointRequest; responseSerialize: (message: GetSymbolFromEndpointResponse) => Buffer; responseDeserialize: (bytes: Buffer) => GetSymbolFromEndpointResponse; }; RegisterApp: { path: string; requestStream: boolean; responseStream: boolean; requestSerialize: (message: RegisterAppRequest) => Buffer; requestDeserialize: (bytes: Buffer) => RegisterAppRequest; responseSerialize: (message: RegisterAppResponse) => Buffer; responseDeserialize: (bytes: Buffer) => RegisterAppResponse; }; DeregisterApp: { path: string; requestStream: boolean; responseStream: boolean; requestSerialize: (message: DeregisterAppRequest) => Buffer; requestDeserialize: (bytes: Buffer) => DeregisterAppRequest; responseSerialize: (message: DeregisterAppResponse) => Buffer; responseDeserialize: (bytes: Buffer) => DeregisterAppResponse; }; RemoteCall: { path: string; requestStream: boolean; responseStream: boolean; requestSerialize: (message: RemoteCallRequest) => Buffer; requestDeserialize: (bytes: Buffer) => RemoteCallRequest; responseSerialize: (message: RemoteCallResponse) => Buffer; responseDeserialize: (bytes: Buffer) => RemoteCallResponse; }; }; [method: string]: grpc_1.UntypedHandleCall; abstract CreateTask(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract CancelTask(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract PostResult(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract WaitForResult(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetTask(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract GetSymbolFromEndpoint(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract RegisterApp(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract DeregisterApp(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract RemoteCall(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; } const RemoteExecutorClient_base: grpc_1.ServiceClientConstructor; export class RemoteExecutorClient extends RemoteExecutorClient_base { constructor(address: string, credentials: grpc_1.ChannelCredentials, options?: Partial); CreateTask: GrpcPromiseServiceInterface; CancelTask: GrpcPromiseServiceInterface; PostResult: GrpcPromiseServiceInterface; WaitForResult: GrpcPromiseServiceInterface; GetTask: GrpcPromiseServiceInterface; GetSymbolFromEndpoint: GrpcPromiseServiceInterface; RegisterApp: GrpcPromiseServiceInterface; DeregisterApp: GrpcPromiseServiceInterface; RemoteCall: GrpcPromiseServiceInterface; } export {}; }