sqlstore

Jan 3, 2025

Changes in this version

+ func EnsureDBItems(t *testing.T, db sql.Database, content []rangesync.KeyBytes)

Nov 19, 2024

Changes in this version

+ func CreateDB(t *testing.T, keyLen int) sql.Database

+ func InsertDBItems(t *testing.T, db sql.Database, content []rangesync.KeyBytes)

+ func PopulateDB(t *testing.T, keyLen int, content []rangesync.KeyBytes) sql.Database

+ type Binder func(s *sql.Statement)

+ type IDStore interface

+ All func() rangesync.SeqResult

+ Clone func() IDStore

+ From func(from rangesync.KeyBytes, sizeHint int) rangesync.SeqResult

+ RegisterKey func(k rangesync.KeyBytes) error

+ Release func()

+ type SQLIDStore struct

+ func NewSQLIDStore(db sql.Executor, sts *SyncedTableSnapshot, keyLen int) *SQLIDStore

+ func (s *SQLIDStore) All() rangesync.SeqResult

+ func (s *SQLIDStore) Clone() IDStore

+ func (s *SQLIDStore) From(from rangesync.KeyBytes, sizeHint int) rangesync.SeqResult

+ func (s *SQLIDStore) RegisterKey(k rangesync.KeyBytes) error

+ func (s *SQLIDStore) Release()

+ func (s *SQLIDStore) SetSnapshot(sts *SyncedTableSnapshot)

+ func (s *SQLIDStore) Since(from rangesync.KeyBytes, since int64) (rangesync.SeqResult, int)

+ type SyncedTable struct

+ Binder Binder

+ Filter expr.Expr

+ IDColumn string

+ TableName string

+ TimestampColumn string

+ func (st *SyncedTable) Snapshot(db sql.Executor) (*SyncedTableSnapshot, error)

+ type SyncedTableSnapshot struct

+ func (sts *SyncedTableSnapshot) Load(db sql.Executor, dec func(stmt *sql.Statement) bool) error

+ func (sts *SyncedTableSnapshot) LoadCount(db sql.Executor) (int, error)

+ func (sts *SyncedTableSnapshot) LoadRange(db sql.Executor, fromID rangesync.KeyBytes, limit int, ...) error

+ func (sts *SyncedTableSnapshot) LoadRecent(db sql.Executor, fromID rangesync.KeyBytes, limit int, since int64, ...) error

+ func (sts *SyncedTableSnapshot) LoadRecentCount(db sql.Executor, since int64) (int, error)

+ func (sts *SyncedTableSnapshot) LoadSinceSnapshot(db sql.Executor, prev *SyncedTableSnapshot, dec func(stmt *sql.Statement) bool) error