Class ScheduledExecution

Hierarchy (View Summary)

ModelShape<ScheduledExecutionsTable, this>
- ScheduledExecution

Constructors

constructor

new ScheduledExecution(
    attrs: {
        createdAt: Date;
        id: number;
        jobId: number;
        priority: number;
        queueName: string;
        scheduledAt: string;
    },
): ScheduledExecution
Parameters
- attrs: {
      createdAt: Date;
      id: number;
      jobId: number;
      priority: number;
      queueName: string;
      scheduledAt: string;
  }
Returns ScheduledExecution
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).constructor
- Defined in packages/core/src/models/base.ts:9

Properties

discard

discard: () => Promise<void>

dispatcher

dispatcher: Dispatcher = ...

`Static`dispatcher

dispatcher: typeof Dispatcher = ...

Methods

attr

attr<K extends NonNeverSelectKeys<ScheduledExecutionsTable>>(
    name: K,
): {
    createdAt: Date;
    id: number;
    jobId: number;
    priority: number;
    queueName: string;
    scheduledAt: string;
}[K]
Type Parameters
- K extends NonNeverSelectKeys<ScheduledExecutionsTable>
Parameters
- name: K
Returns {
    createdAt: Date;
    id: number;
    jobId: number;
    priority: number;
    queueName: string;
    scheduledAt: string;
}[K]
Inherited from ModelShape.attr
- Defined in packages/core/src/models/base.ts:35

attrs

attrs(): {
    createdAt: Date;
    id: number;
    jobId: number;
    priority: number;
    queueName: string;
    scheduledAt: string;
}
Returns {
    createdAt: Date;
    id: number;
    jobId: number;
    priority: number;
    queueName: string;
    scheduledAt: string;
}
Inherited from ModelShape.attrs
- Defined in packages/core/src/models/base.ts:34

destroy

destroy(): Promise<void>
Returns Promise<void>
Inherited from ModelShape.destroy
- Defined in packages/core/src/models/base.ts:37

reload

reload(): Promise<ScheduledExecution>
Returns Promise<ScheduledExecution>
Inherited from ModelShape.reload
- Defined in packages/core/src/models/base.ts:39

transaction

transaction(
cb: (tx: Transaction<Database>) => Promise<unknown>,
): Promise<unknown>
Parameters
- cb: (tx: Transaction<Database>) => Promise<unknown>
Returns Promise<unknown>
Inherited from ModelShape.transaction
- Defined in packages/core/src/models/base.ts:36

update

update(
    attrs: {
        createdAt?: Date;
        id?: number;
        jobId?: number;
        priority?: number;
        queueName?: string;
        scheduledAt?: string;
    },
): Promise<void>
Parameters
- attrs: {
      createdAt?: Date;
      id?: number;
      jobId?: number;
      priority?: number;
      queueName?: string;
      scheduledAt?: string;
  }
Returns Promise<void>
Inherited from ModelShape.update
- Defined in packages/core/src/models/base.ts:38

`Static`all

all(): Promise<ScheduledExecution[]>
Returns Promise<ScheduledExecution[]>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).all
- Defined in packages/core/src/models/base.ts:24

`Static`attributesFromJob

attributesFromJob(
job: Job,
): { jobId: number; priority: number; queueName: string; scheduledAt: Date }
Parameters
- job: Job
Returns { jobId: number; priority: number; queueName: string; scheduledAt: Date }
Overrides execution<ScheduledExecution, typeof TABLE>(TABLE).attributesFromJob
- Defined in packages/core/src/models/scheduled-execution.ts:41

`Static`count

count(): Promise<number>
Returns Promise<number>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).count
- Defined in packages/core/src/models/base.ts:30

`Static`create

create(
    attrs: { jobId: number; queueName: string; scheduledAt: string } & {
        createdAt?: Date;
        id?: number;
        priority?: number;
    },
    options?: {
        ignoreConflict:
            | NonNullableInsertKeys<ScheduledExecutionsTable>
            | NullableInsertKeys<ScheduledExecutionsTable>;
    },
): Promise<ScheduledExecution>
Parameters
- attrs: { jobId: number; queueName: string; scheduledAt: string } & {
      createdAt?: Date;
      id?: number;
      priority?: number;
  }
- Optionaloptions: {
      ignoreConflict:
          | NonNullableInsertKeys<ScheduledExecutionsTable>
          | NullableInsertKeys<ScheduledExecutionsTable>;
  }
Returns Promise<ScheduledExecution>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).create
- Defined in packages/core/src/models/base.ts:11

`Static`createAll

createAll(
    attrs: (
        { jobId: number; queueName: string; scheduledAt: string } & {
            createdAt?: Date;
            id?: number;
            priority?: number;
        }
    )[],
): Promise<ScheduledExecution[]>
Parameters
- attrs: (
      { jobId: number; queueName: string; scheduledAt: string } & {
          createdAt?: Date;
          id?: number;
          priority?: number;
      }
  )[]
Returns Promise<ScheduledExecution[]>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).createAll
- Defined in packages/core/src/models/base.ts:17

`Static`createAllFromJobs

createAllFromJobs(jobs: Job[]): Promise<void>
Parameters
- jobs: Job[]
Returns Promise<void>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).createAllFromJobs
- Defined in packages/core/src/models/execution.ts:8

`Static`createUnique

createUnique(
    attrs: { jobId: number; queueName: string; scheduledAt: string } & {
        createdAt?: Date;
        id?: number;
        priority?: number;
    },
    uniqueBy:
        | NonNullableInsertKeys<ScheduledExecutionsTable>
        | NullableInsertKeys<ScheduledExecutionsTable>,
): Promise<null | ScheduledExecution>
Parameters
- attrs: { jobId: number; queueName: string; scheduledAt: string } & {
      createdAt?: Date;
      id?: number;
      priority?: number;
  }
- uniqueBy:
  | NonNullableInsertKeys<ScheduledExecutionsTable>
  | NullableInsertKeys<ScheduledExecutionsTable>
Returns Promise<null | ScheduledExecution>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).createUnique
- Defined in packages/core/src/models/base.ts:18

`Static`destroy

destroy(cb: (db: Kysely<Database>) => CompiledQuery): Promise<number>
Parameters
- cb: (db: Kysely<Database>) => CompiledQuery
Returns Promise<number>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).destroy
- Defined in packages/core/src/models/base.ts:29

`Static`discardAllFromJobs

discardAllFromJobs(jobs: Job[]): Promise<void>
Parameters
- jobs: Job[]
Returns Promise<void>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).discardAllFromJobs
- Defined in packages/core/src/models/execution.ts:11

`Static`discardAllInBatches

discardAllInBatches(
opts?: { batchSize?: number; queue?: string },
): Promise<void>
Parameters
- Optionalopts: { batchSize?: number; queue?: string }
Returns Promise<void>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).discardAllInBatches
- Defined in packages/core/src/models/execution.ts:10

`Static`dispatchNextBatch

dispatchNextBatch(batchSize: number): Promise<number>
Parameters
- batchSize: number
Returns Promise<number>
- Defined in packages/core/src/models/scheduled-execution.ts:17

`Static`findAll

findAll(
cb: (db: Kysely<Database>) => CompiledQuery,
): Promise<ScheduledExecution[]>
Parameters
- cb: (db: Kysely<Database>) => CompiledQuery
Returns Promise<ScheduledExecution[]>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).findAll
- Defined in packages/core/src/models/base.ts:23

`Static`findById

findById(id: number): Promise<null | ScheduledExecution>
Parameters
- id: number
Returns Promise<null | ScheduledExecution>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).findById
- Defined in packages/core/src/models/base.ts:19

`Static`findByIdOrThrow

findByIdOrThrow(id: number): Promise<ScheduledExecution>
Parameters
- id: number
Returns Promise<ScheduledExecution>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).findByIdOrThrow
- Defined in packages/core/src/models/base.ts:20

`Static`findOne

findOne(
cb: (db: Kysely<Database>) => CompiledQuery,
): Promise<null | ScheduledExecution>
Parameters
- cb: (db: Kysely<Database>) => CompiledQuery
Returns Promise<null | ScheduledExecution>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).findOne
- Defined in packages/core/src/models/base.ts:21

`Static`findOneOrThrow

findOneOrThrow(
cb: (db: Kysely<Database>) => CompiledQuery,
): Promise<ScheduledExecution>
Parameters
- cb: (db: Kysely<Database>) => CompiledQuery
Returns Promise<ScheduledExecution>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).findOneOrThrow
- Defined in packages/core/src/models/base.ts:22

`Static`last

last(): Promise<null | ScheduledExecution>
Returns Promise<null | ScheduledExecution>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).last
- Defined in packages/core/src/models/base.ts:25
last(limit: 1): Promise<null | ScheduledExecution>
Parameters
- limit: 1
Returns Promise<null | ScheduledExecution>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).last
- Defined in packages/core/src/models/base.ts:26
last(limit: number): Promise<ScheduledExecution[]>
Parameters
- limit: number
Returns Promise<ScheduledExecution[]>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).last
- Defined in packages/core/src/models/base.ts:27

`Static`transaction

transaction<T>(cb: (tx: Transaction<Database>) => Promise<T>): Promise<T>
Type Parameters
- T
Parameters
- cb: (tx: Transaction<Database>) => Promise<T>
Returns Promise<T>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).transaction
- Defined in packages/core/src/models/base.ts:10

`Static`updateAll

updateAll(cb: (db: Kysely<Database>) => CompiledQuery): Promise<number>
Parameters
- cb: (db: Kysely<Database>) => CompiledQuery
Returns Promise<number>
Inherited from execution<ScheduledExecution, typeof TABLE>(TABLE).updateAll
- Defined in packages/core/src/models/base.ts:28

Class ScheduledExecution

Hierarchy (View Summary)

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

Returns ScheduledExecution

Properties

discard

dispatcher

Staticdispatcher

Methods

attr

Type Parameters

Parameters

Returns { createdAt: Date; id: number; jobId: number; priority: number; queueName: string; scheduledAt: string;}[K]

attrs

Returns { createdAt: Date; id: number; jobId: number; priority: number; queueName: string; scheduledAt: string;}

destroy

Returns Promise<void>

reload

Returns Promise<ScheduledExecution>

transaction

Parameters

Returns Promise<unknown>

update

Parameters

Returns Promise<void>

Staticall

Returns Promise<ScheduledExecution[]>

StaticattributesFromJob

Parameters

Returns { jobId: number; priority: number; queueName: string; scheduledAt: Date }

Staticcount

Returns Promise<number>

Staticcreate

Parameters

Returns Promise<ScheduledExecution>

StaticcreateAll

Parameters

Returns Promise<ScheduledExecution[]>

StaticcreateAllFromJobs

Parameters

Returns Promise<void>

StaticcreateUnique

Parameters

Returns Promise<null | ScheduledExecution>

Staticdestroy

Parameters

Returns Promise<number>

StaticdiscardAllFromJobs

Parameters

Returns Promise<void>

StaticdiscardAllInBatches

Parameters

Returns Promise<void>

StaticdispatchNextBatch

Parameters

Returns Promise<number>

StaticfindAll

Parameters

Returns Promise<ScheduledExecution[]>

StaticfindById

Parameters

Returns Promise<null | ScheduledExecution>

StaticfindByIdOrThrow

Parameters

Returns Promise<ScheduledExecution>

StaticfindOne

Parameters

Returns Promise<null | ScheduledExecution>

StaticfindOneOrThrow

Parameters

Returns Promise<ScheduledExecution>

Staticlast

Returns Promise<null | ScheduledExecution>

Parameters

`Static`dispatcher

Returns {
createdAt: Date;
id: number;
jobId: number;
priority: number;
queueName: string;
scheduledAt: string;
}[K]

Returns {
createdAt: Date;
id: number;
jobId: number;
priority: number;
queueName: string;
scheduledAt: string;
}

`Static`all

`Static`attributesFromJob

`Static`count

`Static`create

`Static`createAll

`Static`createAllFromJobs

`Static`createUnique

`Static`destroy

`Static`discardAllFromJobs

`Static`discardAllInBatches

`Static`dispatchNextBatch

`Static`findAll

`Static`findById

`Static`findByIdOrThrow

`Static`findOne

`Static`findOneOrThrow

`Static`last

`Static`transaction

`Static`updateAll