;
}): 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 {};
}