sqlitestore

package

v1.13.0 Latest Latest Go to latest Published: May 4, 2026 License: GPL-3.0 Imports: 30 Imported by: 0

Details

This section is empty.

View Source

var ErrLocked = errors.New("sqlite db is locked")

This section is empty.

type SqliteStore struct {
	// contains filtered or unexported fields
}

func NewMemorySqliteStore(t testing.TB) (*SqliteStore, error)

func NewSqliteStore(db string) (*SqliteStore, error)

func (m *SqliteStore) Add(op ...*v1.Operation) error

func (m *SqliteStore) Close() error

func (m *SqliteStore) Delete(opID ...int64) ([]*v1.Operation, error)

func (m *SqliteStore) Get(opID int64) (*v1.Operation, error)

func (m *SqliteStore) GetHighestOpIDAndModno(q oplog.Query) (int64, int64, error)

func (m *SqliteStore) Query(q oplog.Query, f func(*v1.Operation) error) error

func (m *SqliteStore) QueryMetadata(q oplog.Query, f func(oplog.OpMetadata) error) error

func (m *SqliteStore) ResetForTest(t *testing.T) error

func (m *SqliteStore) Set(opts oplog.SetOptions, op ...*v1.Operation) error

func (m *SqliteStore) SetVersion(version int64) error

func (m *SqliteStore) Transform(q oplog.Query, f func(*v1.Operation) (*v1.Operation, error)) error

func (m *SqliteStore) Update(op ...*v1.Operation) error

func (m *SqliteStore) Version() (int64, error)