import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire"; import type { CallContext, CallOptions } from "nice-grpc-common"; import { Guid } from "./protobuf-net/bcl"; export declare const protobufPackage = "Cratis.Chronicle.Contracts.Jobs"; export declare enum JobStatus { None = 0, PreparingJob = 1, PreparingSteps = 2, StartingSteps = 3, JOB_STATUS_Running = 4, JOB_STATUS_CompletedSuccessfully = 5, CompletedWithFailures = 6, JOB_STATUS_Stopped = 7, JOB_STATUS_Failed = 8, JOB_STATUS_Removing = 9, UNRECOGNIZED = -1 } export declare function jobStatusFromJSON(object: any): JobStatus; export declare function jobStatusToJSON(object: JobStatus): string; export declare enum JobStepStatus { JOB_STEP_STATUS_Unknown = 0, Scheduled = 1, JOB_STEP_STATUS_Running = 2, JOB_STEP_STATUS_CompletedSuccessfully = 3, CompletedWithFailure = 4, JOB_STEP_STATUS_Stopped = 5, JOB_STEP_STATUS_Failed = 6, JOB_STEP_STATUS_Removing = 7, UNRECOGNIZED = -1 } export declare function jobStepStatusFromJSON(object: any): JobStepStatus; export declare function jobStepStatusToJSON(object: JobStepStatus): string; export declare enum ValidationResultSeverity { VALIDATION_RESULT_SEVERITY_Unknown = 0, Information = 1, Warning = 2, Error = 3, UNRECOGNIZED = -1 } export declare function validationResultSeverityFromJSON(object: any): ValidationResultSeverity; export declare function validationResultSeverityToJSON(object: ValidationResultSeverity): string; export interface AllJobsRequest { EventStore: string; Namespace: string; } export interface CommandResult { CorrelationId: Guid | undefined; IsAuthorized: boolean; ValidationResults: ValidationResult[]; ExceptionMessages: string[]; ExceptionStackTrace: string; AuthorizationFailureReason: string; } export interface DeleteJobRequest { EventStore: string; Namespace: string; JobId: Guid | undefined; } export interface GetJobStepsRequest { EventStore: string; Namespace: string; JobId: Guid | undefined; } export interface JobProgress { TotalSteps: number; SuccessfulSteps: number; FailedSteps: number; StoppedSteps: number; IsCompleted: boolean; IsStopped: boolean; Message: string; } export interface JobStatusChanged { Status: JobStatus; Occurred: SerializableDateTimeOffset | undefined; ExceptionMessages: string[]; ExceptionStackTrace: string; } export interface JobStepProgress { Percentage: number; Message: string; } export interface JobStepStatusChanged { Status: JobStepStatus; Occurred: SerializableDateTimeOffset | undefined; ExceptionMessages: string[]; ExceptionStackTrace: string; } export interface JobStepSummaryResponse { Id: Guid | undefined; Type: string; Name: string; Status: JobStepStatus; StatusChanges: JobStepStatusChanged[]; Progress: JobStepProgress | undefined; } export interface JobSummaryResponse { Id: Guid | undefined; Details: string; Type: string; Status: JobStatus; Created: SerializableDateTimeOffset | undefined; StatusChanges: JobStatusChanged[]; Progress: JobProgress | undefined; } export interface ObserveJobsRequest { EventStore: string; Namespace: string; } export interface QueryResultIEnumerableJobStepSummaryResponse { CorrelationId: Guid | undefined; IsAuthorized: boolean; ValidationResults: ValidationResult[]; ExceptionMessages: string[]; ExceptionStackTrace: string; Data: JobStepSummaryResponse[]; } export interface QueryResultIEnumerableJobSummaryResponse { CorrelationId: Guid | undefined; IsAuthorized: boolean; ValidationResults: ValidationResult[]; ExceptionMessages: string[]; ExceptionStackTrace: string; Data: JobSummaryResponse[]; } export interface ResumeJobRequest { EventStore: string; Namespace: string; JobId: Guid | undefined; } export interface SerializableDateTimeOffset { Value: string; } export interface StopJobRequest { EventStore: string; Namespace: string; JobId: Guid | undefined; } export interface ValidationResult { Severity: ValidationResultSeverity; Message: string; Members: string[]; } export declare const AllJobsRequest: MessageFns; export declare const CommandResult: MessageFns; export declare const DeleteJobRequest: MessageFns; export declare const GetJobStepsRequest: MessageFns; export declare const JobProgress: MessageFns; export declare const JobStatusChanged: MessageFns; export declare const JobStepProgress: MessageFns; export declare const JobStepStatusChanged: MessageFns; export declare const JobStepSummaryResponse: MessageFns; export declare const JobSummaryResponse: MessageFns; export declare const ObserveJobsRequest: MessageFns; export declare const QueryResultIEnumerableJobStepSummaryResponse: MessageFns; export declare const QueryResultIEnumerableJobSummaryResponse: MessageFns; export declare const ResumeJobRequest: MessageFns; export declare const SerializableDateTimeOffset: MessageFns; export declare const StopJobRequest: MessageFns; export declare const ValidationResult: MessageFns; export type JobsDefinition = typeof JobsDefinition; export declare const JobsDefinition: { readonly name: "Jobs"; readonly fullName: "Cratis.Chronicle.Contracts.Jobs.Jobs"; readonly methods: { readonly allJobs: { readonly name: "AllJobs"; readonly requestType: typeof AllJobsRequest; readonly requestStream: false; readonly responseType: typeof QueryResultIEnumerableJobSummaryResponse; readonly responseStream: false; readonly options: {}; }; readonly deleteJob: { readonly name: "DeleteJob"; readonly requestType: typeof DeleteJobRequest; readonly requestStream: false; readonly responseType: typeof CommandResult; readonly responseStream: false; readonly options: {}; }; readonly getJobSteps: { readonly name: "GetJobSteps"; readonly requestType: typeof GetJobStepsRequest; readonly requestStream: false; readonly responseType: typeof QueryResultIEnumerableJobStepSummaryResponse; readonly responseStream: false; readonly options: {}; }; readonly observeJobs: { readonly name: "ObserveJobs"; readonly requestType: typeof ObserveJobsRequest; readonly requestStream: false; readonly responseType: typeof QueryResultIEnumerableJobSummaryResponse; readonly responseStream: true; readonly options: {}; }; readonly resumeJob: { readonly name: "ResumeJob"; readonly requestType: typeof ResumeJobRequest; readonly requestStream: false; readonly responseType: typeof CommandResult; readonly responseStream: false; readonly options: {}; }; readonly stopJob: { readonly name: "StopJob"; readonly requestType: typeof StopJobRequest; readonly requestStream: false; readonly responseType: typeof CommandResult; readonly responseStream: false; readonly options: {}; }; }; }; export interface JobsServiceImplementation { allJobs(request: AllJobsRequest, context: CallContext & CallContextExt): Promise>; deleteJob(request: DeleteJobRequest, context: CallContext & CallContextExt): Promise>; getJobSteps(request: GetJobStepsRequest, context: CallContext & CallContextExt): Promise>; observeJobs(request: ObserveJobsRequest, context: CallContext & CallContextExt): ServerStreamingMethodResult>; resumeJob(request: ResumeJobRequest, context: CallContext & CallContextExt): Promise>; stopJob(request: StopJobRequest, context: CallContext & CallContextExt): Promise>; } export interface JobsClient { allJobs(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; deleteJob(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; getJobSteps(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; observeJobs(request: DeepPartial, options?: CallOptions & CallOptionsExt): AsyncIterable; resumeJob(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; stopJob(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; } type Builtin = Date | Function | Uint8Array | string | number | boolean | bigint | undefined; export type DeepPartial = T extends bigint ? string | number | bigint : T extends Builtin ? T : T extends globalThis.Array ? globalThis.Array> : T extends ReadonlyArray ? ReadonlyArray> : T extends {} ? { [K in keyof T]?: DeepPartial; } : Partial; export type ServerStreamingMethodResult = { [Symbol.asyncIterator](): AsyncIterator; }; export interface MessageFns { encode(message: T, writer?: BinaryWriter): BinaryWriter; decode(input: BinaryReader | Uint8Array, length?: number): T; fromJSON(object: any): T; toJSON(message: T): unknown; create(base?: DeepPartial): T; fromPartial(object: DeepPartial): T; } export {}; //# sourceMappingURL=jobs.d.ts.map