db

type ChangeLogEvent struct {
	Id        int64
	Type      string
	TableName string
	Row       map[string]any
	// contains filtered or unexported fields
}

type ChangeLogState = int16

type ColumnInfo struct {
	Name            string `db:"name"`
	Type            string `db:"type"`
	NotNull         bool   `db:"notnull"`
	DefaultValue    any    `db:"dflt_value"`
	PrimaryKeyIndex int    `db:"pk"`
	IsPrimaryKey    bool
}

type EnhancedRows struct {
	*sql.Rows
}

type EnhancedStatement struct {
	*sql.Stmt
}

type SqliteStreamDB struct {
	OnChange func(event *ChangeLogEvent) error
	// contains filtered or unexported fields
}