Class SqliteBucketStorage

Namespace

PowerSync.Common.Client.Sync.Bucket

Assembly

PowerSync.Common.dll

public class SqliteBucketStorage : IBucketStorageAdapter, ICloseable

Inheritance

object

SqliteBucketStorage

Implements

IBucketStorageAdapter

ICloseable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

BucketStorageAdapterExtensions.CurrentCheckpointRequestId(IBucketStorageAdapter)

BucketStorageAdapterExtensions.NextCheckpointRequestId(IBucketStorageAdapter)

BucketStorageAdapterExtensions.SeedCheckpointRequestId(IBucketStorageAdapter, string)

Constructors

SqliteBucketStorage(IDBAdapter, ILogger?)

Fields

MAX_OP_ID

Properties

Events

Methods

Close()

Control(string, object?)

Invokes the powersync_control function for the sync client.

GetClientId()

Get a unique client ID.

GetCrudBatch(int)

Get a batch of objects to send to the server. When the objects are successfully sent to the server, call .Complete().

HandleCrudCheckpoint(long, string?)

HasCrud()

NextCrudItem()

ReadOrUpdateCheckpoint(ITransaction, string, string?)

Reads or updates the stored checkpoint request id using the given transaction.

ReadOrUpdateCheckpoint(string, string?)

Reads or updates the stored checkpoint request id.

UpdateLocalTarget(Func<Task<string>>)