From 1c8628d94bc17322a16dc29b748aac1d51eb5a38 Mon Sep 17 00:00:00 2001 From: Danilo Campana Fuchs Date: Fri, 23 Aug 2024 22:43:45 -0300 Subject: [PATCH] feat(Typescript): Generic getJobById (#471) --- types.d.ts | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/types.d.ts b/types.d.ts index 9e8c43e..2c3395e 100644 --- a/types.d.ts +++ b/types.d.ts @@ -1,7 +1,7 @@ import { EventEmitter } from 'events' declare namespace PgBoss { - + type JobStates = { created : 'created', retry: 'retry', @@ -107,13 +107,13 @@ declare namespace PgBoss { interface ConnectionOptions { db?: Db; } - + type InsertOptions = ConnectionOptions; - + type SendOptions = JobOptions & ExpirationOptions & RetentionOptions & RetryOptions & ConnectionOptions; - + type QueuePolicy = 'standard' | 'short' | 'singleton' | 'stately' - + type Queue = RetryOptions & ExpirationOptions & RetentionOptions & { name: string, policy?: QueuePolicy, deadLetter?: string } type QueueResult = Queue & { createdOn: Date, updatedOn: Date } type ScheduleOptions = SendOptions & { tz?: string } @@ -334,7 +334,7 @@ declare class PgBoss extends EventEmitter { deleteJob(name: string, id: string, options?: PgBoss.ConnectionOptions): Promise; deleteJob(name: string, ids: string[], options?: PgBoss.ConnectionOptions): Promise; - + complete(name: string, id: string, options?: PgBoss.ConnectionOptions): Promise; complete(name: string, id: string, data: object, options?: PgBoss.ConnectionOptions): Promise; complete(name: string, ids: string[], options?: PgBoss.ConnectionOptions): Promise; @@ -343,8 +343,8 @@ declare class PgBoss extends EventEmitter { fail(name: string, id: string, data: object, options?: PgBoss.ConnectionOptions): Promise; fail(name: string, ids: string[], options?: PgBoss.ConnectionOptions): Promise; - getJobById(name: string, id: string, options?: PgBoss.ConnectionOptions & { includeArchive: bool }): Promise; - + getJobById(name: string, id: string, options?: PgBoss.ConnectionOptions & { includeArchive: boolean }): Promise | null>; + createQueue(name: string, options?: PgBoss.Queue): Promise; updateQueue(name: string, options?: PgBoss.Queue): Promise; deleteQueue(name: string): Promise;