db

Feb 9, 2026

Changes in this version

+ var ErrDatabaseCorrupt = fmt.Errorf("database corrupt")

+ func CompleteBatch(ctx context.Context, db sqlite.DB, lastEntryID int64, checkpoint string) error

+ func GetClientID(ctx context.Context, db sqlite.DB) (string, error)

+ type CrudEntry struct

+ Data map[string]any

+ ID int64

+ Metadata *string

+ Old map[string]any

+ Op Op

+ RowID string

+ Table sqlite.Table

+ TxID *int64

+ type CrudQueue struct

+ func NewCrudQueue(db sqlite.DB) *CrudQueue

+ func (q *CrudQueue) CheckHealth(ctx context.Context) error

+ func (q *CrudQueue) GetAllEntries(ctx context.Context) ([]*CrudEntry, error)

+ func (q *CrudQueue) GetNextEntry(ctx context.Context) (*CrudEntry, error)

+ func (q *CrudQueue) GetNextTransaction(ctx context.Context) ([]CrudEntry, error)

+ func (q *CrudQueue) HasPendingUploads(ctx context.Context) (bool, error)

+ type Op string

+ const OpDelete

+ const OpPatch

+ const OpPut