FUZD / fuzd-server / RemoteSQLSchedulerStorage

Class: RemoteSQLSchedulerStorage<TransactionDataType>

Type Parameters

• TransactionDataType

Implements

• SchedulerStorage<TransactionDataType>

Constructors

new RemoteSQLSchedulerStorage()

new RemoteSQLSchedulerStorage<TransactionDataType>(db): RemoteSQLSchedulerStorage<TransactionDataType>

Parameters

• db: RemoteSQL

Returns

RemoteSQLSchedulerStorage<TransactionDataType>

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:106

Methods

archiveExecution()

archiveExecution(executionToStore): Promise<void>

Parameters

• executionToStore: ScheduledExecutionQueued<TransactionDataType>

Returns

Promise<void>

Implementation of

SchedulerStorage.archiveExecution

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:145

---

clear()

clear(): Promise<void>

Returns

Promise<void>

Implementation of

SchedulerStorage.clear

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:224

---

createOrUpdateQueuedExecution()

createOrUpdateQueuedExecution(executionToStore): Promise<ScheduledExecutionQueued<TransactionDataType>>

Parameters

• executionToStore: ScheduledExecutionQueued<TransactionDataType>

Returns

Promise<ScheduledExecutionQueued<TransactionDataType>>

Implementation of

SchedulerStorage.createOrUpdateQueuedExecution

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:159

---

deleteExecution()

deleteExecution(params): Promise<void>

Parameters

• params

• params.account: String0x

• params.chainId: String0x

• params.slot: string

Returns

Promise<void>

Implementation of

SchedulerStorage.deleteExecution

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:136

---

getAccountArchivedSubmissions()

getAccountArchivedSubmissions(account, params): Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Parameters

• account: String0x

• params

• params.limit: number

Returns

Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Implementation of

SchedulerStorage.getAccountArchivedSubmissions

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:214

---

getAccountSubmissions()

getAccountSubmissions(account, params): Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Parameters

• account: String0x

• params

• params.limit: number

Returns

Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Implementation of

SchedulerStorage.getAccountSubmissions

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:204

---

getAllExecutions()

getAllExecutions(params): Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Parameters

• params

• params.limit: number

Returns

Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Implementation of

SchedulerStorage.getAllExecutions

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:197

---

getQueuedExecution()

getQueuedExecution(params): Promise<undefined | ScheduledExecutionQueued<TransactionDataType>>

Parameters

• params

• params.account: String0x

• params.chainId: String0x

• params.slot: string

Returns

Promise<undefined | ScheduledExecutionQueued<TransactionDataType>>

Implementation of

SchedulerStorage.getQueuedExecution

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:108

---

getQueuedExecutionsForAccount()

getQueuedExecutionsForAccount(params): Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Parameters

• params

• params.account: String0x

• params.chainId: String0x

• params.limit: number

Returns

Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Implementation of

SchedulerStorage.getQueuedExecutionsForAccount

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:123

---

getQueueTopMostExecutions()

getQueueTopMostExecutions(params): Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Parameters

• params

• params.limit: number

Returns

Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Implementation of

SchedulerStorage.getQueueTopMostExecutions

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:170

---

getUnFinalizedBroadcastedScheduledExecutions()

getUnFinalizedBroadcastedScheduledExecutions(params): Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Parameters

• params

• params.limit: number

Returns

Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Implementation of

SchedulerStorage.getUnFinalizedBroadcastedScheduledExecutions

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:177

---

getUnFinalizedScheduledExecutionsPerAccount()

getUnFinalizedScheduledExecutionsPerAccount(params): Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Parameters

• params

• params.account: String0x

• params.chainId: String0x

• params.limit: number

Returns

Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Implementation of

SchedulerStorage.getUnFinalizedScheduledExecutionsPerAccount

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:186

---

setup()

setup(): Promise<void>

Returns

Promise<void>

Implementation of

SchedulerStorage.setup

Defined in

packages/server/src/storage/RemoteSQLSchedulerStorage.ts:230