sqlite

package

Go to main page

Versions in this module

v1

v1.5.0

Apr 8, 2026

v1.4.1

Apr 2, 2026

v1.4.0

Mar 30, 2026

Changes in this version

type DB

+ func (db *DB) BeginWriteTx(ctx context.Context) (*sql.Tx, error)

+ func (db *DB) IsSourceManaged(ctx context.Context, id models.SourceID) (bool, error)

+ func (db *DB) IsTeamManaged(ctx context.Context, id models.TeamID) (bool, error)

+ func (db *DB) IsUserManaged(ctx context.Context, id models.UserID) (bool, error)

+ func (db *DB) ListQueriesForUser(ctx context.Context, userID models.UserID) ([]*models.SavedTeamQuery, error)

+ func (db *DB) WriteQueriesWithTx(tx *sql.Tx) *sqlc.Queries

v1.3.0

Feb 5, 2026

Changes in this version

type DB

+ func (db *DB) GetUserPreferencesJSON(ctx context.Context, userID models.UserID) (string, error)

+ func (db *DB) UpsertUserPreferencesJSON(ctx context.Context, userID models.UserID, preferencesJSON string) error

v1.2.2

Jan 27, 2026

v1.2.1

Jan 21, 2026

v1.2.0

Jan 21, 2026

Changes in this version

type DB

+ func (db *DB) ListQueriesByTeam(ctx context.Context, teamID models.TeamID) ([]*models.SavedTeamQuery, error)

v1.1.0

Dec 29, 2025

Changes in this version

type DB

+ func (db *DB) ToggleQueryBookmark(ctx context.Context, teamID models.TeamID, sourceID models.SourceID, ...) (bool, error)

v1.0.0

Dec 20, 2025

v0

v0.6.0

Dec 4, 2025

Changes in this version

type DB

+ func (db *DB) CreateAlert(ctx context.Context, alert *models.Alert) error

+ func (db *DB) DeleteAlert(ctx context.Context, alertID models.AlertID) error

+ func (db *DB) DeleteSetting(ctx context.Context, key string) error

+ func (db *DB) GetAlert(ctx context.Context, alertID models.AlertID) (*models.Alert, error)

+ func (db *DB) GetAlertForTeamSource(ctx context.Context, teamID models.TeamID, sourceID models.SourceID, ...) (*models.Alert, error)

+ func (db *DB) GetBoolSetting(ctx context.Context, key string, defaultValue bool) bool

+ func (db *DB) GetDurationSetting(ctx context.Context, key string, defaultValue time.Duration) time.Duration

+ func (db *DB) GetFloat64Setting(ctx context.Context, key string, defaultValue float64) float64

+ func (db *DB) GetIntSetting(ctx context.Context, key string, defaultValue int) int

+ func (db *DB) GetLatestUnresolvedAlertHistory(ctx context.Context, alertID models.AlertID) (*models.AlertHistoryEntry, error)

+ func (db *DB) GetSetting(ctx context.Context, key string) (string, error)

+ func (db *DB) GetSettingWithDefault(ctx context.Context, key, defaultValue string) string

+ func (db *DB) InsertAlertHistory(ctx context.Context, alertID models.AlertID, status models.AlertStatus, ...) (*models.AlertHistoryEntry, error)

+ func (db *DB) ListActiveAlertsDue(ctx context.Context) ([]*models.Alert, error)

+ func (db *DB) ListAlertHistory(ctx context.Context, alertID models.AlertID, limit int) ([]*models.AlertHistoryEntry, error)

+ func (db *DB) ListAlertsByTeamAndSource(ctx context.Context, teamID models.TeamID, sourceID models.SourceID) ([]*models.Alert, error)

+ func (db *DB) ListSettings(ctx context.Context) ([]sqlc.SystemSetting, error)

+ func (db *DB) ListSettingsByCategory(ctx context.Context, category string) ([]sqlc.SystemSetting, error)

+ func (db *DB) MarkAlertEvaluated(ctx context.Context, alertID models.AlertID) error

+ func (db *DB) MarkAlertTriggered(ctx context.Context, alertID models.AlertID) error

+ func (db *DB) PruneAlertHistory(ctx context.Context, alertID models.AlertID, keep int) error

+ func (db *DB) ResolveAlertHistory(ctx context.Context, historyID int64, message string) error

+ func (db *DB) UpdateAlert(ctx context.Context, alert *models.Alert) error

+ func (db *DB) UpdateAlertHistoryPayload(ctx context.Context, historyID int64, payload map[string]any) error

+ func (db *DB) UpsertSetting(ctx context.Context, key, value, valueType, category, description string, ...) error

v0.5.0

Oct 3, 2025

v0.4.0

Aug 12, 2025

v0.3.0

Jun 13, 2025

v0.2.2

Jun 12, 2025

Changes in this version

type DB

+ func (db *DB) CreateAPIToken(ctx context.Context, params sqlc.CreateAPITokenParams) (int64, error)

+ func (db *DB) DeleteAPIToken(ctx context.Context, params sqlc.DeleteAPITokenParams) error

+ func (db *DB) DeleteExpiredAPITokens(ctx context.Context) error

+ func (db *DB) GetAPIToken(ctx context.Context, id int64) (sqlc.ApiToken, error)

+ func (db *DB) GetAPITokenByHash(ctx context.Context, tokenHash string) (sqlc.ApiToken, error)

+ func (db *DB) ListAPITokensForUser(ctx context.Context, userID int64) ([]sqlc.ApiToken, error)

+ func (db *DB) UpdateAPITokenLastUsed(ctx context.Context, id int64) error

v0.2.1

Apr 27, 2025

v0.2.1-rc.1

Apr 27, 2025

v0.2.0

Apr 27, 2025

Changes in this version

+ var ErrNotFound = errors.New("resource not found")

+ var ErrQueryNotFound = fmt.Errorf("%w: query", ErrNotFound)

+ var ErrSessionNotFound = fmt.Errorf("%w: session", ErrNotFound)

+ var ErrSourceExists = fmt.Errorf("%w: source with this database/table already exists", ErrUniqueConstraint)

+ var ErrSourceNotFound = fmt.Errorf("%w: source", ErrNotFound)

+ var ErrTeamExists = fmt.Errorf("%w: team with this name already exists", ErrUniqueConstraint)

+ var ErrTeamNotFound = fmt.Errorf("%w: team", ErrNotFound)

+ var ErrUniqueConstraint = errors.New("unique constraint violation")

+ var ErrUserExists = fmt.Errorf("%w: user with this email already exists", ErrUniqueConstraint)

+ var ErrUserNotFound = fmt.Errorf("%w: user", ErrNotFound)

+ func IsNotFoundError(err error) bool

+ func IsSourceNotFoundError(err error) bool

+ func IsTeamNotFoundError(err error) bool

+ func IsUniqueConstraintError(err error) bool

+ func IsUserNotFoundError(err error) bool

+ type DB struct

+ func New(opts Options) (*DB, error)

+ func (db *DB) AddTeamMember(ctx context.Context, teamID models.TeamID, userID models.UserID, ...) error

+ func (db *DB) AddTeamSource(ctx context.Context, teamID models.TeamID, sourceID models.SourceID) error

+ func (db *DB) Close() error

+ func (db *DB) CountAdminUsers(ctx context.Context) (int, error)

+ func (db *DB) CountUserSessions(ctx context.Context, userID models.UserID) (int, error)

+ func (db *DB) CreateSession(ctx context.Context, session *models.Session) error

+ func (db *DB) CreateSource(ctx context.Context, source *models.Source) error

+ func (db *DB) CreateTeam(ctx context.Context, team *models.Team) error

+ func (db *DB) CreateTeamSourceQuery(ctx context.Context, query *models.TeamQuery) error

+ func (db *DB) CreateUser(ctx context.Context, user *models.User) error

+ func (db *DB) DeleteSession(ctx context.Context, sessionID models.SessionID) error

+ func (db *DB) DeleteSource(ctx context.Context, id models.SourceID) error

+ func (db *DB) DeleteTeam(ctx context.Context, teamID models.TeamID) error

+ func (db *DB) DeleteTeamSourceQuery(ctx context.Context, teamID models.TeamID, sourceID models.SourceID, ...) error

+ func (db *DB) DeleteUser(ctx context.Context, id models.UserID) error

+ func (db *DB) DeleteUserSessions(ctx context.Context, userID models.UserID) error

+ func (db *DB) GetSession(ctx context.Context, sessionID models.SessionID) (*models.Session, error)

+ func (db *DB) GetSource(ctx context.Context, id models.SourceID) (*models.Source, error)

+ func (db *DB) GetSourceByName(ctx context.Context, database, tableName string) (*models.Source, error)

+ func (db *DB) GetTeam(ctx context.Context, teamID models.TeamID) (*models.Team, error)

+ func (db *DB) GetTeamByName(ctx context.Context, name string) (*models.Team, error)

+ func (db *DB) GetTeamMember(ctx context.Context, teamID models.TeamID, userID models.UserID) (*models.TeamMember, error)

+ func (db *DB) GetTeamSourceQuery(ctx context.Context, teamID models.TeamID, sourceID models.SourceID, ...) (*models.SavedTeamQuery, error)

+ func (db *DB) GetUser(ctx context.Context, id models.UserID) (*models.User, error)

+ func (db *DB) GetUserByEmail(ctx context.Context, email string) (*models.User, error)

+ func (db *DB) ListQueriesByTeamAndSource(ctx context.Context, teamID models.TeamID, sourceID models.SourceID) ([]*models.SavedTeamQuery, error)

+ func (db *DB) ListSourceTeams(ctx context.Context, sourceID models.SourceID) ([]*models.Team, error)

+ func (db *DB) ListSources(ctx context.Context) ([]*models.Source, error)

+ func (db *DB) ListSourcesForUser(ctx context.Context, userID models.UserID) ([]*models.Source, error)

+ func (db *DB) ListTeamMembers(ctx context.Context, teamID models.TeamID) ([]*models.TeamMember, error)

+ func (db *DB) ListTeamMembersWithDetails(ctx context.Context, teamID models.TeamID) ([]*models.TeamMember, error)

+ func (db *DB) ListTeamSources(ctx context.Context, teamID models.TeamID) ([]*models.Source, error)

+ func (db *DB) ListTeams(ctx context.Context) ([]*models.Team, error)

+ func (db *DB) ListTeamsForUser(ctx context.Context, userID models.UserID) ([]*models.Team, error)

+ func (db *DB) ListUserTeams(ctx context.Context, userID models.UserID) ([]*models.Team, error)

+ func (db *DB) ListUsers(ctx context.Context) ([]*models.User, error)

+ func (db *DB) RemoveTeamMember(ctx context.Context, teamID models.TeamID, userID models.UserID) error

+ func (db *DB) RemoveTeamSource(ctx context.Context, teamID models.TeamID, sourceID models.SourceID) error

+ func (db *DB) TeamHasSource(ctx context.Context, teamID models.TeamID, sourceID models.SourceID) (bool, error)

+ func (db *DB) UpdateSource(ctx context.Context, source *models.Source) error

+ func (db *DB) UpdateTeam(ctx context.Context, team *models.Team) error

+ func (db *DB) UpdateTeamMemberRole(ctx context.Context, teamID models.TeamID, userID models.UserID, ...) error

+ func (db *DB) UpdateTeamSourceQuery(ctx context.Context, teamID models.TeamID, sourceID models.SourceID, ...) error

+ func (db *DB) UpdateUser(ctx context.Context, user *models.User) error

+ func (db *DB) UserHasSourceAccess(ctx context.Context, userID models.UserID, sourceID models.SourceID) (bool, error)

+ type Options struct

+ Config config.SQLiteConfig

+ Logger *slog.Logger

v0.2.0-rc.4

Apr 26, 2025

v0.2.0-rc.3

Apr 26, 2025

v0.2.0-rc.2

Apr 26, 2025

v0.2.0-rc.1

Apr 26, 2025

v0.1.0-alpha.4

Apr 25, 2025

v0.1.0-alpha.3

Apr 24, 2025

v0.1.0-alpha.2

Apr 23, 2025

v0.1.0-alpha.1

Apr 22, 2025

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL