Enum SyncOperation 

pub enum SyncOperation {
    GetDatabases(GenericCallback<BackendResult<Vec<DatabaseInfo>>>, ImmutableOrigin),
    UpgradeVersion(GenericSender<BackendResult<u64>>, ImmutableOrigin, String, u64, u64),
    GetObjectStore(GenericSender<BackendResult<IndexedDBObjectStore>>, ImmutableOrigin, String, String),
    Commit(GenericSender<BackendResult<()>>, ImmutableOrigin, String, u64),
    CreateIndex(ImmutableOrigin, String, String, String, KeyPath, bool, bool),
    DeleteIndex(ImmutableOrigin, String, String, String),
    CreateObjectStore(GenericSender<BackendResult<CreateObjectResult>>, ImmutableOrigin, String, String, Option<KeyPath>, bool),
    DeleteObjectStore(GenericSender<BackendResult<()>>, ImmutableOrigin, String, String),
    CloseDatabase(ImmutableOrigin, Uuid, String),
    OpenDatabase(GenericCallback<ConnectionMsg>, ImmutableOrigin, String, Option<u64>, Uuid),
    DeleteDatabase(GenericCallback<BackendResult<u64>>, ImmutableOrigin, String, Uuid),
    RegisterNewTxn(GenericSender<u64>, ImmutableOrigin, String),
    StartTransaction(GenericSender<BackendResult<()>>, ImmutableOrigin, String, u64),
    Version(GenericSender<BackendResult<u64>>, ImmutableOrigin, String),
    AbortPendingUpgrades {
        pending_upgrades: HashMap<String, HashSet<Uuid>>,
        origin: ImmutableOrigin,
    },
    AbortPendingUpgrade {
        name: String,
        id: Uuid,
        origin: ImmutableOrigin,
    },
    NotifyEndOfVersionChange {
        id: Uuid,
        name: String,
        old_version: u64,
        origin: ImmutableOrigin,
    },
    Exit(GenericSender<()>),
}

Variants

GetDatabases(GenericCallback<BackendResult<Vec<DatabaseInfo>>>, ImmutableOrigin)

Gets existing databases.

UpgradeVersion(GenericSender<BackendResult<u64>>, ImmutableOrigin, String, u64, u64)

Upgrades the version of the database

Tuple Fields

0: GenericSender<BackendResult<u64>>

Sender to send new version as the result of the operation

1: ImmutableOrigin

2: String

3: u64

4: u64

GetObjectStore(GenericSender<BackendResult<IndexedDBObjectStore>>, ImmutableOrigin, String, String)

Get object store info

Commit(GenericSender<BackendResult<()>>, ImmutableOrigin, String, u64)

Commits changes of a transaction to the database

CreateIndex(ImmutableOrigin, String, String, String, KeyPath, bool, bool)

Creates a new index for the database

DeleteIndex(ImmutableOrigin, String, String, String)

Delete an index

CreateObjectStore(GenericSender<BackendResult<CreateObjectResult>>, ImmutableOrigin, String, String, Option<KeyPath>, bool)

Creates a new store for the database

DeleteObjectStore(GenericSender<BackendResult<()>>, ImmutableOrigin, String, String)

CloseDatabase(ImmutableOrigin, Uuid, String)

OpenDatabase(GenericCallback<ConnectionMsg>, ImmutableOrigin, String, Option<u64>, Uuid)

DeleteDatabase(GenericCallback<BackendResult<u64>>, ImmutableOrigin, String, Uuid)

Deletes the database

RegisterNewTxn(GenericSender<u64>, ImmutableOrigin, String)

Returns an unique identifier that is used to be able to commit/abort transactions.

Tuple Fields

0: GenericSender<u64>

The unique identifier of the transaction

1: ImmutableOrigin

2: String

StartTransaction(GenericSender<BackendResult<()>>, ImmutableOrigin, String, u64)

Starts executing the requests of a transaction https://www.w3.org/TR/IndexedDB-2/#transaction-start

Version(GenericSender<BackendResult<u64>>, ImmutableOrigin, String)

Returns the version of the database

AbortPendingUpgrades

Abort pending database upgrades

Fields

pending_upgrades: HashMap<String, HashSet<Uuid>>

origin: ImmutableOrigin

AbortPendingUpgrade

Abort the current pending upgrade.

Fields

name: String

id: Uuid

origin: ImmutableOrigin

NotifyEndOfVersionChange

Fields

id: Uuid

name: String

old_version: u64

origin: ImmutableOrigin

Exit(GenericSender<()>)

Send a reply when done cleaning up thread resources and then shut it down

Trait Implementations

impl Debug for SyncOperation

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SyncOperation

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SyncOperation

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.