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"`
	IsPrimaryKey bool   `db:"pk"`
}

type EnhancedRows struct {
	*sql.Rows
}

type EnhancedStatement struct {
	*sql.Stmt
}

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