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

account

String0x

chainId

String0x

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

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

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

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

account

String0x

chainId

String0x

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

account

String0x

chainId

String0x

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

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

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

account

String0x

chainId

String0x

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