Class BlockedExecution

Hierarchy (View Summary)

ModelShape<BlockedExecutionsTable, this>
- BlockedExecution

Constructors

constructor

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

Properties

discard

discard: () => Promise<void>

Methods

attr

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

attrs

attrs(): {
    concurrencyKey: string;
    createdAt: Date;
    expiresAt: Date;
    id: number;
    jobId: number;
    priority: number;
    queueName: string;
}
Returns {
    concurrencyKey: string;
    createdAt: Date;
    expiresAt: Date;
    id: number;
    jobId: number;
    priority: number;
    queueName: 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

release

release(): Promise<void>
Returns Promise<void>
- Defined in packages/core/src/models/blocked-execution.ts:30

reload

reload(): Promise<BlockedExecution>
Returns Promise<BlockedExecution>
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: {
        concurrencyKey?: string;
        expiresAt?: string;
        id?: number;
        jobId?: number;
        priority?: number;
        queueName?: string;
    },
): Promise<void>
Parameters
- attrs: {
      concurrencyKey?: string;
      expiresAt?: string;
      id?: number;
      jobId?: number;
      priority?: number;
      queueName?: string;
  }
Returns Promise<void>
Inherited from ModelShape.update
- Defined in packages/core/src/models/base.ts:38

`Static`all

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

`Static`attributesFromJob

attributesFromJob(
job: Job,
): { jobId: number; priority: number; queueName: string }
Parameters
- job: Job
Returns { jobId: number; priority: number; queueName: string }
Inherited from execution<BlockedExecution, typeof TABLE>(TABLE).attributesFromJob
- Defined in packages/core/src/models/execution.ts:9

`Static`count

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

`Static`create

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

`Static`createAll

createAll(
    attrs: (
        { concurrencyKey: string; jobId: number; queueName: string } & {
            createdAt?: string;
            expiresAt?: string;
            id?: number;
            priority?: number;
        }
    )[],
): Promise<BlockedExecution[]>
Parameters
- attrs: (
      { concurrencyKey: string; jobId: number; queueName: string } & {
          createdAt?: string;
          expiresAt?: string;
          id?: number;
          priority?: number;
      }
  )[]
Returns Promise<BlockedExecution[]>
Inherited from execution<BlockedExecution, 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<BlockedExecution, typeof TABLE>(TABLE).createAllFromJobs
- Defined in packages/core/src/models/execution.ts:8

`Static`createUnique

createUnique(
    attrs: { concurrencyKey: string; jobId: number; queueName: string } & {
        createdAt?: string;
        expiresAt?: string;
        id?: number;
        priority?: number;
    },
    uniqueBy:
        | NonNullableInsertKeys<BlockedExecutionsTable>
        | NullableInsertKeys<BlockedExecutionsTable>,
): Promise<null | BlockedExecution>
Parameters
- attrs: { concurrencyKey: string; jobId: number; queueName: string } & {
      createdAt?: string;
      expiresAt?: string;
      id?: number;
      priority?: number;
  }
- uniqueBy:
  | NonNullableInsertKeys<BlockedExecutionsTable>
  | NullableInsertKeys<BlockedExecutionsTable>
Returns Promise<null | BlockedExecution>
Inherited from execution<BlockedExecution, 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<BlockedExecution, 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<BlockedExecution, 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<BlockedExecution, typeof TABLE>(TABLE).discardAllInBatches
- Defined in packages/core/src/models/execution.ts:10

`Static`findAll

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

`Static`findById

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

`Static`findByIdOrThrow

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

`Static`findOne

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

`Static`findOneOrThrow

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

`Static`last

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

`Static`releaseOne

releaseOne(concurrencyKey: string): Promise<void>
Parameters
- concurrencyKey: string
Returns Promise<void>
- Defined in packages/core/src/models/blocked-execution.ts:11

`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<BlockedExecution, 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<BlockedExecution, typeof TABLE>(TABLE).updateAll
- Defined in packages/core/src/models/base.ts:28

Class BlockedExecution

Hierarchy (View Summary)

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

Returns BlockedExecution

Properties

discard

Methods

attr

Type Parameters

Parameters

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

attrs

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

destroy

Returns Promise<void>

release

Returns Promise<void>

reload

Returns Promise<BlockedExecution>

transaction

Parameters

Returns Promise<unknown>

update

Parameters

Returns Promise<void>

Staticall

Returns Promise<BlockedExecution[]>

StaticattributesFromJob

Parameters

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

Staticcount

Returns Promise<number>

Staticcreate

Parameters

Returns Promise<BlockedExecution>

StaticcreateAll

Parameters

Returns Promise<BlockedExecution[]>

StaticcreateAllFromJobs

Parameters

Returns Promise<void>

StaticcreateUnique

Parameters

Returns Promise<null | BlockedExecution>

Staticdestroy

Parameters

Returns Promise<number>

StaticdiscardAllFromJobs

Parameters

Returns Promise<void>

StaticdiscardAllInBatches

Parameters

Returns Promise<void>

StaticfindAll

Parameters

Returns Promise<BlockedExecution[]>

StaticfindById

Parameters

Returns Promise<null | BlockedExecution>

StaticfindByIdOrThrow

Parameters

Returns Promise<BlockedExecution>

StaticfindOne

Parameters

Returns Promise<null | BlockedExecution>

StaticfindOneOrThrow

Parameters

Returns Promise<BlockedExecution>

Staticlast

Returns Promise<null | BlockedExecution>

Parameters

Returns Promise<null | BlockedExecution>

Parameters

Returns Promise<BlockedExecution[]>

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

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

`Static`all

`Static`attributesFromJob

`Static`count

`Static`create

`Static`createAll

`Static`createAllFromJobs

`Static`createUnique

`Static`destroy

`Static`discardAllFromJobs

`Static`discardAllInBatches

`Static`findAll

`Static`findById

`Static`findByIdOrThrow

`Static`findOne

`Static`findOneOrThrow

`Static`last

`Static`releaseOne

`Static`transaction

`Static`updateAll