db

Aug 28, 2023

Changes in this version

type ChangeLogEvent

+ func (e ChangeLogEvent) Unwrap() (ChangeLogEvent, error)

+ func (e ChangeLogEvent) Wrap() (ChangeLogEvent, error)

Jul 24, 2023

Changes in this version

+ var ErrEndOfWatch = errors.New("watching event finished")

type SqliteStreamDB

+ func (conn *SqliteStreamDB) WithReadTx(cb func(tx *sql.Tx) error) error

Jun 27, 2023

Changes in this version

type ColumnInfo

+ PrimaryKeyIndex int

Oct 18, 2022

Changes in this version

+ var PoolSize = 4

+ func RestoreFrom(destPath, bkFilePath string) error

Sep 25, 2022

Changes in this version

type SqliteStreamDB

+ func (conn *SqliteStreamDB) DeleteChangeLog(event *ChangeLogEvent) (bool, error)

Sep 19, 2022

Changes in this version

+ const ScanLimit

+ var ErrLogNotReadyToPublish = errors.New("not ready to publish changes")

Sep 18, 2022

Changes in this version

type SqliteStreamDB

+ func (conn *SqliteStreamDB) InstallCDC() error

Sep 12, 2022

Changes in this version

+ var MarmotPrefix = "__marmot__"

+ func GetAllDBTables(path string) ([]string, error)

Sep 11, 2022

Changes in this version

+ var ErrNoTableMapping = errors.New("no table mapping found")

+ func OpenRaw(dns string) (*sql.DB, *sqlite3.SQLiteConn, error)

+ type ChangeLogEvent struct

+ Id int64

+ Row map[string]any

+ TableName string

+ Type string

+ func (e *ChangeLogEvent) Hash() (uint64, error)

+ func (e *ChangeLogEvent) Marshal() ([]byte, error)

+ func (e *ChangeLogEvent) Unmarshal(data []byte) error

+ type ChangeLogState = int16

+ const Failed

+ const Pending

+ const Published

+ type ColumnInfo struct

+ DefaultValue any

+ IsPrimaryKey bool

+ Name string

+ NotNull bool

+ Type string

+ type EnhancedRows struct

+ func (rs *EnhancedRows) Finalize()

+ type EnhancedStatement struct

+ func (stmt *EnhancedStatement) Finalize()

+ type SqliteDriverConnector struct

+ func (t SqliteDriverConnector) Connect(_ context.Context) (driver.Conn, error)

+ func (t SqliteDriverConnector) Driver() driver.Driver

+ type SqliteStreamDB struct

+ OnChange func(event *ChangeLogEvent) error

+ func OpenStreamDB(path string, tables []string) (*SqliteStreamDB, error)

+ func (conn *SqliteStreamDB) BackupTo(bkFilePath string) error

+ func (conn *SqliteStreamDB) CleanupChangeLogs() error

+ func (conn *SqliteStreamDB) Execute(query string) error

+ func (conn *SqliteStreamDB) GetPath() string

+ func (conn *SqliteStreamDB) GetRawConnection() *sqlite3.SQLiteConn

+ func (conn *SqliteStreamDB) GetTableInfo(table string) ([]*ColumnInfo, error)

+ func (conn *SqliteStreamDB) RemoveCDC() error

+ func (conn *SqliteStreamDB) Replicate(event *ChangeLogEvent) error

+ func (conn *SqliteStreamDB) RestoreFrom(bkFilePath string) error

+ func (conn *SqliteStreamDB) StartWatching() error