Documentation ¶
Index ¶
- Variables
- func GetAllDBTables(path string) ([]string, error)
- func RestoreFrom(destPath, bkFilePath string) error
- type ChangeLogEvent
- type ChangeLogState
- type ColumnInfo
- type EnhancedRows
- type EnhancedStatement
- type SqliteStreamDB
- func (conn *SqliteStreamDB) BackupTo(bkFilePath string) error
- func (conn *SqliteStreamDB) CleanupChangeLogs(beforeTime time.Time) (int64, error)
- func (conn *SqliteStreamDB) GetPath() string
- func (conn *SqliteStreamDB) GetRawConnection() *sqlite3.SQLiteConn
- func (conn *SqliteStreamDB) InstallCDC(tables []string) error
- func (conn *SqliteStreamDB) RemoveCDC(tables bool) error
- func (conn *SqliteStreamDB) Replicate(event *ChangeLogEvent) error
- func (conn *SqliteStreamDB) WithReadTx(cb func(tx *sql.Tx) error) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrEndOfWatch = errors.New("watching event finished")
View Source
var ErrLogNotReadyToPublish = errors.New("not ready to publish changes")
View Source
var ErrNoTableMapping = errors.New("no table mapping found")
View Source
var MarmotPrefix = "__marmot__"
View Source
var PoolSize = 4
Functions ¶
func GetAllDBTables ¶ added in v0.3.13
func RestoreFrom ¶ added in v0.6.0
Types ¶
type ChangeLogEvent ¶
type ChangeLogEvent struct { Id int64 Type string TableName string Row map[string]any // contains filtered or unexported fields }
func (ChangeLogEvent) Hash ¶
func (e ChangeLogEvent) Hash() (uint64, error)
func (ChangeLogEvent) Unwrap ¶ added in v0.8.6
func (e ChangeLogEvent) Unwrap() (ChangeLogEvent, error)
func (ChangeLogEvent) Wrap ¶ added in v0.8.6
func (e ChangeLogEvent) Wrap() (ChangeLogEvent, error)
type ChangeLogState ¶
type ChangeLogState = int16
const ( Pending ChangeLogState = 0 Published ChangeLogState = 1 Failed ChangeLogState = -1 )
type ColumnInfo ¶
type EnhancedRows ¶
func (*EnhancedRows) Finalize ¶
func (rs *EnhancedRows) Finalize()
type EnhancedStatement ¶
func (*EnhancedStatement) Finalize ¶
func (stmt *EnhancedStatement) Finalize()
type SqliteStreamDB ¶
type SqliteStreamDB struct { OnChange func(event *ChangeLogEvent) error // contains filtered or unexported fields }
func OpenStreamDB ¶
func OpenStreamDB(path string) (*SqliteStreamDB, error)
func (*SqliteStreamDB) BackupTo ¶
func (conn *SqliteStreamDB) BackupTo(bkFilePath string) error
func (*SqliteStreamDB) CleanupChangeLogs ¶
func (conn *SqliteStreamDB) CleanupChangeLogs(beforeTime time.Time) (int64, error)
func (*SqliteStreamDB) GetPath ¶
func (conn *SqliteStreamDB) GetPath() string
func (*SqliteStreamDB) GetRawConnection ¶
func (conn *SqliteStreamDB) GetRawConnection() *sqlite3.SQLiteConn
func (*SqliteStreamDB) InstallCDC ¶ added in v0.3.17
func (conn *SqliteStreamDB) InstallCDC(tables []string) error
func (*SqliteStreamDB) RemoveCDC ¶
func (conn *SqliteStreamDB) RemoveCDC(tables bool) error
func (*SqliteStreamDB) Replicate ¶
func (conn *SqliteStreamDB) Replicate(event *ChangeLogEvent) error
func (*SqliteStreamDB) WithReadTx ¶ added in v0.8.4
func (conn *SqliteStreamDB) WithReadTx(cb func(tx *sql.Tx) error) error
Click to show internal directories.
Click to hide internal directories.