Skip to content

managementContract

const managementContract: object;

Defined in: orpc/contract.ts:54

oRPC contract for the versioned Monque management HTTP API.

The contract is REST-shaped under /api/v1 and is exported for consumers that want type-level route information or their own oRPC integration. Runtime support for mutation routes still depends on the methods available on ManagementOptions.monque.

cancelJob: ContractProcedureBuilderWithInputOutput<ZodObject<{
  body: ZodOptional<ZodUnknown>;
  headers: ZodOptional<ZodObject<{
  }, $loose>>;
  params: ZodObject<{
     id: ZodString;
  }, $strict>;
  query: ZodOptional<ZodObject<{
  }, $strict>>;
}, $strict>, ZodObject<{
  claimedBy: ZodNullable<ZodString>;
  createdAt: ZodISODateTime;
  failCount: ZodNumber;
  failureReason: ZodNullable<ZodString>;
  heartbeatInterval: ZodOptional<ZodNumber>;
  id: ZodString;
  lastHeartbeat: ZodNullable<ZodISODateTime>;
  lockedAt: ZodNullable<ZodISODateTime>;
  name: ZodString;
  nextRunAt: ZodISODateTime;
  payload: ZodNonOptional<ZodUnknown>;
  repeatInterval: ZodOptional<ZodString>;
  status: ZodEnum<{
     cancelled: "cancelled";
     completed: "completed";
     failed: "failed";
     pending: "pending";
     processing: "processing";
  }>;
  uniqueKey: ZodOptional<ZodString>;
  updatedAt: ZodISODateTime;
}, $strict>, MergedErrorMap<Record<never, never>, {
  BAD_REQUEST: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 400;
  };
  CONFLICT: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 409;
  };
  FORBIDDEN: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 403;
  };
  INTERNAL_SERVER_ERROR: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 500;
  };
  NOT_FOUND: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 404;
  };
}>, Record<never, never>>;
cancelJobs: ContractProcedureBuilderWithInputOutput<ZodObject<{
  name: ZodOptional<ZodString>;
  newerThan: ZodOptional<ZodISODateTime>;
  olderThan: ZodOptional<ZodISODateTime>;
  status: ZodOptional<ZodUnion<readonly [ZodEnum<{
     cancelled: "cancelled";
     completed: "completed";
     failed: "failed";
     pending: "pending";
     processing: "processing";
   }>, ZodArray<ZodEnum<{
     cancelled: "cancelled";
     completed: "completed";
     failed: "failed";
     pending: "pending";
     processing: "processing";
  }>>]>>;
}, $strict>, ZodObject<{
  count: ZodNumber;
  errors: ZodArray<ZodObject<{
     error: ZodString;
     jobId: ZodString;
  }, $strict>>;
}, $strict>, MergedErrorMap<Record<never, never>, {
  BAD_REQUEST: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 400;
  };
  CONFLICT: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 409;
  };
  FORBIDDEN: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 403;
  };
  INTERNAL_SERVER_ERROR: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 500;
  };
}>, Record<never, never>>;
capabilities: ContractProcedureBuilderWithOutput<Schema<unknown, unknown>, ZodObject<{
  actions: ZodObject<{
     cancel: ZodBoolean;
     cancelBulk: ZodBoolean;
     delete: ZodBoolean;
     deleteBulk: ZodBoolean;
     read: ZodBoolean;
     reschedule: ZodBoolean;
     retry: ZodBoolean;
     retryBulk: ZodBoolean;
  }, $strict>;
  readOnly: ZodBoolean;
}, $strict>, Record<never, never>, Record<never, never>>;
deleteJob: ContractProcedureBuilderWithInputOutput<ZodObject<{
  body: ZodOptional<ZodUnknown>;
  headers: ZodOptional<ZodObject<{
  }, $loose>>;
  params: ZodObject<{
     id: ZodString;
  }, $strict>;
  query: ZodOptional<ZodObject<{
  }, $strict>>;
}, $strict>, ZodObject<{
  deleted: ZodLiteral<true>;
}, $strict>, MergedErrorMap<Record<never, never>, {
  BAD_REQUEST: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 400;
  };
  CONFLICT: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 409;
  };
  FORBIDDEN: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 403;
  };
  INTERNAL_SERVER_ERROR: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 500;
  };
  NOT_FOUND: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 404;
  };
}>, Record<never, never>>;
deleteJobs: ContractProcedureBuilderWithInputOutput<ZodObject<{
  name: ZodOptional<ZodString>;
  newerThan: ZodOptional<ZodISODateTime>;
  olderThan: ZodOptional<ZodISODateTime>;
  status: ZodOptional<ZodUnion<readonly [ZodEnum<{
     cancelled: "cancelled";
     completed: "completed";
     failed: "failed";
     pending: "pending";
     processing: "processing";
   }>, ZodArray<ZodEnum<{
     cancelled: "cancelled";
     completed: "completed";
     failed: "failed";
     pending: "pending";
     processing: "processing";
  }>>]>>;
}, $strict>, ZodObject<{
  count: ZodNumber;
  errors: ZodArray<ZodObject<{
     error: ZodString;
     jobId: ZodString;
  }, $strict>>;
}, $strict>, MergedErrorMap<Record<never, never>, {
  BAD_REQUEST: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 400;
  };
  CONFLICT: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 409;
  };
  FORBIDDEN: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 403;
  };
  INTERNAL_SERVER_ERROR: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 500;
  };
}>, Record<never, never>>;
health: ContractProcedureBuilderWithOutput<Schema<unknown, unknown>, ZodObject<{
  scheduler: ZodObject<{
     healthy: ZodBoolean;
  }, $strict>;
  status: ZodEnum<{
     ok: "ok";
     unavailable: "unavailable";
  }>;
}, $strict>, Record<never, never>, Record<never, never>>;
job: ContractProcedureBuilderWithInputOutput<ZodObject<{
  body: ZodOptional<ZodUnknown>;
  headers: ZodOptional<ZodObject<{
  }, $loose>>;
  params: ZodObject<{
     id: ZodString;
  }, $strict>;
  query: ZodOptional<ZodObject<{
  }, $strict>>;
}, $strict>, ZodObject<{
  claimedBy: ZodNullable<ZodString>;
  createdAt: ZodISODateTime;
  failCount: ZodNumber;
  failureReason: ZodNullable<ZodString>;
  heartbeatInterval: ZodOptional<ZodNumber>;
  id: ZodString;
  lastHeartbeat: ZodNullable<ZodISODateTime>;
  lockedAt: ZodNullable<ZodISODateTime>;
  name: ZodString;
  nextRunAt: ZodISODateTime;
  payload: ZodNonOptional<ZodUnknown>;
  repeatInterval: ZodOptional<ZodString>;
  status: ZodEnum<{
     cancelled: "cancelled";
     completed: "completed";
     failed: "failed";
     pending: "pending";
     processing: "processing";
  }>;
  uniqueKey: ZodOptional<ZodString>;
  updatedAt: ZodISODateTime;
}, $strict>, Record<never, never>, Record<never, never>>;
jobs: ContractProcedureBuilderWithInputOutput<ZodObject<{
  cursor: ZodOptional<ZodString>;
  limit: ZodOptional<ZodString>;
  name: ZodOptional<ZodString>;
  status: ZodOptional<ZodUnion<readonly [ZodEnum<{
     cancelled: "cancelled";
     completed: "completed";
     failed: "failed";
     pending: "pending";
     processing: "processing";
   }>, ZodArray<ZodEnum<{
     cancelled: "cancelled";
     completed: "completed";
     failed: "failed";
     pending: "pending";
     processing: "processing";
  }>>]>>;
}, $strict>, ZodObject<{
  cursor: ZodNullable<ZodString>;
  hasNextPage: ZodBoolean;
  hasPreviousPage: ZodBoolean;
  jobs: ZodArray<ZodObject<{
     claimedBy: ZodNullable<ZodString>;
     createdAt: ZodISODateTime;
     failCount: ZodNumber;
     failureReason: ZodNullable<ZodString>;
     heartbeatInterval: ZodOptional<ZodNumber>;
     id: ZodString;
     lastHeartbeat: ZodNullable<ZodISODateTime>;
     lockedAt: ZodNullable<ZodISODateTime>;
     name: ZodString;
     nextRunAt: ZodISODateTime;
     payload: ZodNonOptional<ZodUnknown>;
     repeatInterval: ZodOptional<ZodString>;
     status: ZodEnum<{
        cancelled: "cancelled";
        completed: "completed";
        failed: "failed";
        pending: "pending";
        processing: "processing";
     }>;
     uniqueKey: ZodOptional<ZodString>;
     updatedAt: ZodISODateTime;
  }, $strict>>;
}, $strict>, Record<never, never>, Record<never, never>>;
jobStats: ContractProcedureBuilderWithInputOutput<ZodObject<{
  name: ZodOptional<ZodString>;
}, $strict>, ZodObject<{
  avgProcessingDurationMs: ZodOptional<ZodNumber>;
  cancelled: ZodNumber;
  completed: ZodNumber;
  failed: ZodNumber;
  pending: ZodNumber;
  processing: ZodNumber;
  total: ZodNumber;
}, $strict>, Record<never, never>, Record<never, never>>;
queueViews: ContractProcedureBuilderWithOutput<Schema<unknown, unknown>, ZodObject<{
  queueViews: ZodArray<ZodObject<{
     hasPersistedJobs: ZodBoolean;
     hasRegisteredWorker: ZodBoolean;
     name: ZodString;
     stats: ZodObject<{
        avgProcessingDurationMs: ZodOptional<ZodNumber>;
        cancelled: ZodNumber;
        completed: ZodNumber;
        failed: ZodNumber;
        pending: ZodNumber;
        processing: ZodNumber;
        total: ZodNumber;
     }, $strict>;
     worker: ZodNullable<ZodObject<{
        activeCount: ZodNumber;
        concurrency: ZodNumber;
     }, $strict>>;
  }, $strict>>;
}, $strict>, Record<never, never>, Record<never, never>>;
rescheduleJob: ContractProcedureBuilderWithInputOutput<ZodObject<{
  body: ZodObject<{
     nextRunAt: ZodISODateTime;
  }, $strict>;
  headers: ZodOptional<ZodObject<{
  }, $loose>>;
  params: ZodObject<{
     id: ZodString;
  }, $strict>;
  query: ZodOptional<ZodObject<{
  }, $strict>>;
}, $strict>, ZodObject<{
  claimedBy: ZodNullable<ZodString>;
  createdAt: ZodISODateTime;
  failCount: ZodNumber;
  failureReason: ZodNullable<ZodString>;
  heartbeatInterval: ZodOptional<ZodNumber>;
  id: ZodString;
  lastHeartbeat: ZodNullable<ZodISODateTime>;
  lockedAt: ZodNullable<ZodISODateTime>;
  name: ZodString;
  nextRunAt: ZodISODateTime;
  payload: ZodNonOptional<ZodUnknown>;
  repeatInterval: ZodOptional<ZodString>;
  status: ZodEnum<{
     cancelled: "cancelled";
     completed: "completed";
     failed: "failed";
     pending: "pending";
     processing: "processing";
  }>;
  uniqueKey: ZodOptional<ZodString>;
  updatedAt: ZodISODateTime;
}, $strict>, MergedErrorMap<Record<never, never>, {
  BAD_REQUEST: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 400;
  };
  CONFLICT: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 409;
  };
  FORBIDDEN: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 403;
  };
  INTERNAL_SERVER_ERROR: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 500;
  };
  NOT_FOUND: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 404;
  };
}>, Record<never, never>>;
retryJob: ContractProcedureBuilderWithInputOutput<ZodObject<{
  body: ZodOptional<ZodUnknown>;
  headers: ZodOptional<ZodObject<{
  }, $loose>>;
  params: ZodObject<{
     id: ZodString;
  }, $strict>;
  query: ZodOptional<ZodObject<{
  }, $strict>>;
}, $strict>, ZodObject<{
  claimedBy: ZodNullable<ZodString>;
  createdAt: ZodISODateTime;
  failCount: ZodNumber;
  failureReason: ZodNullable<ZodString>;
  heartbeatInterval: ZodOptional<ZodNumber>;
  id: ZodString;
  lastHeartbeat: ZodNullable<ZodISODateTime>;
  lockedAt: ZodNullable<ZodISODateTime>;
  name: ZodString;
  nextRunAt: ZodISODateTime;
  payload: ZodNonOptional<ZodUnknown>;
  repeatInterval: ZodOptional<ZodString>;
  status: ZodEnum<{
     cancelled: "cancelled";
     completed: "completed";
     failed: "failed";
     pending: "pending";
     processing: "processing";
  }>;
  uniqueKey: ZodOptional<ZodString>;
  updatedAt: ZodISODateTime;
}, $strict>, MergedErrorMap<Record<never, never>, {
  BAD_REQUEST: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 400;
  };
  CONFLICT: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 409;
  };
  FORBIDDEN: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 403;
  };
  INTERNAL_SERVER_ERROR: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 500;
  };
  NOT_FOUND: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 404;
  };
}>, Record<never, never>>;
retryJobs: ContractProcedureBuilderWithInputOutput<ZodObject<{
  name: ZodOptional<ZodString>;
  newerThan: ZodOptional<ZodISODateTime>;
  olderThan: ZodOptional<ZodISODateTime>;
  status: ZodOptional<ZodUnion<readonly [ZodEnum<{
     cancelled: "cancelled";
     completed: "completed";
     failed: "failed";
     pending: "pending";
     processing: "processing";
   }>, ZodArray<ZodEnum<{
     cancelled: "cancelled";
     completed: "completed";
     failed: "failed";
     pending: "pending";
     processing: "processing";
  }>>]>>;
}, $strict>, ZodObject<{
  count: ZodNumber;
  errors: ZodArray<ZodObject<{
     error: ZodString;
     jobId: ZodString;
  }, $strict>>;
}, $strict>, MergedErrorMap<Record<never, never>, {
  BAD_REQUEST: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 400;
  };
  CONFLICT: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 409;
  };
  FORBIDDEN: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 403;
  };
  INTERNAL_SERVER_ERROR: {
     data: ZodObject<{
        error: ZodString;
     }, $strict>;
     status: 500;
  };
}>, Record<never, never>>;