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:122

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:161

---

clear()

clear(): Promise<void>

Returns

Promise<void>

Implementation of

SchedulerStorage.clear

Defined in

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

---

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:175

---

deleteExecution()

deleteExecution(params): Promise<void>

Parameters

params

account

String0x

chainId

IntegerString

slot

string

Returns

Promise<void>

Implementation of

SchedulerStorage.deleteExecution

Defined in

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

---

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:232

---

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:222

---

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:215

---

getQueuedExecution()

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

Parameters

params

account

String0x

chainId

IntegerString

slot

string

Returns

Promise<undefined | ScheduledExecutionQueued<TransactionDataType>>

Implementation of

SchedulerStorage.getQueuedExecution

Defined in

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

---

getQueuedExecutionsForAccount()

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

Parameters

params

account

String0x

chainId

IntegerString

limit

number

Returns

Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Implementation of

SchedulerStorage.getQueuedExecutionsForAccount

Defined in

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

---

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:186

---

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:193

---

getUnFinalizedScheduledExecutionsPerBroadcaster()

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

Parameters

params

broadcaster

String0x

chainId

IntegerString

limit

number

Returns

Promise<ScheduledExecutionQueued<TransactionDataType>[]>

Implementation of

SchedulerStorage.getUnFinalizedScheduledExecutionsPerBroadcaster

Defined in

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

---

setup()

setup(): Promise<void>

Returns

Promise<void>

Implementation of

SchedulerStorage.setup

Defined in

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