sqlite

package

v0.4.0 Latest Latest Go to latest Published: Jan 6, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func NewInterpreter() common.Interpreter

func NewUnversionedNotifier(opts common.Opts, table string) (*notifier.UnversionedPersistenceNotifier[*UnversionedPersistence], error)

func NewVersionedNotifier(opts common.Opts, table string) (*notifier.VersionedPersistenceNotifier[*VersionedPersistence], error)

func OpenDB(dataSourceName string, maxOpenConns, maxIdleConns int, maxIdleTime time.Duration, skipPragmas bool) (*sql.DB, error)

type BasePersistence[V any, R any] struct {
	*common.BasePersistence[V, R]
}

func (db *BasePersistence[V, R]) SetStates(ns driver.Namespace, kvs map[driver.PKey]V) map[driver.PKey]error

type TestDriver struct {
	Name    string
	TempDir string
}

func (t *TestDriver) NewTransactionalUnversioned(dataSourceName string, config driver.Config) (driver.TransactionalUnversionedPersistence, error)

func (t *TestDriver) NewTransactionalVersioned(dataSourceName string, config driver.Config) (driver.TransactionalVersionedPersistence, error)

func (t *TestDriver) NewUnversioned(dataSourceName string, config driver.Config) (driver.UnversionedPersistence, error)

func (t *TestDriver) NewVersioned(dataSourceName string, config driver.Config) (driver.VersionedPersistence, error)

type UnversionedPersistence struct {
	*common.UnversionedPersistence
}

func NewUnversioned(opts common.Opts, table string) (*UnversionedPersistence, error)

type VersionedPersistence struct {
	*common.VersionedPersistence
}

func NewVersioned(opts common.Opts, table string) (*VersionedPersistence, error)