Versions in this module Expand all Collapse all v0 v0.0.9 Feb 16, 2024 v0.0.8 Nov 30, 2023 Changes in this version type SqlLdbWriter + ID string + Logger *events.Logger v0.0.7 Nov 1, 2023 v0.0.6 Oct 6, 2023 v0.0.5 Aug 11, 2023 v0.0.4 Aug 3, 2023 Changes in this version + type CheckpointType string + var Full CheckpointType = "FULL" + var Passive CheckpointType = "PASSIVE" + var Restart CheckpointType = "RESTART" + var Truncate CheckpointType = "TRUNCATE" + type PragmaWALResult struct + Busy int + Checkpointed int + Log int + Type CheckpointType + func (p *PragmaWALResult) String() string type SqlLdbWriter + func (writer *SqlLdbWriter) Checkpoint(checkpointingType CheckpointType) (*PragmaWALResult, error) v0.0.3 Oct 28, 2022 v0.0.2 Jul 11, 2022 v0.0.1 Nov 18, 2021 Changes in this version + type CallbackWriter struct + Callbacks []LDBWriteCallback + ChangeBuffer *sqlite.SQLChangeBuffer + DB *sql.DB + Delegate LDBWriter + func (w *CallbackWriter) ApplyDMLStatement(ctx context.Context, statement schema.DMLStatement) error + type ChangelogCallback struct + ChangelogWriter *changelog.ChangelogWriter + Seq int64 + func (c *ChangelogCallback) LDBWritten(ctx context.Context, data LDBWriteMetadata) + type LDBWriteCallback interface + LDBWritten func(ctx context.Context, data LDBWriteMetadata) + type LDBWriteMetadata struct + Changes []sqlite.SQLiteWatchChange + DB *sql.DB + Statement schema.DMLStatement + type LDBWriter interface + ApplyDMLStatement func(ctx context.Context, statement schema.DMLStatement) error + type LDBWriterWithChangelog struct + ChangeBuffer *sqlite.SQLChangeBuffer + ChangelogWriter *changelog.ChangelogWriter + DB *sql.DB + LdbWriter LDBWriter + Seq int64 + func (w *LDBWriterWithChangelog) ApplyDMLStatement(ctx context.Context, statement schema.DMLStatement) error + type SqlLdbWriter struct + Db *sql.DB + LedgerTx *sql.Tx + func (writer *SqlLdbWriter) ApplyDMLStatement(_ context.Context, statement schema.DMLStatement) error + func (writer *SqlLdbWriter) Close() error
Go to main page