db

Sep 24, 2026

Changes in this version

+ const AccessApproved

+ const AccessPending

+ const AccessRejected

+ const AccessRevoked

+ const EventAccessGranted

+ const EventAccessRejected

+ const EventAccessRequested

+ const EventAccessReset

+ const EventAccessRevoked

type PG

+ func (db *PG) DeleteUserAccess(ctx context.Context, email string) (bool, error)

+ func (db *PG) GetUserAccess(ctx context.Context, email string) (*UserAccess, error)

+ func (db *PG) InsertAccessRequest(ctx context.Context, u *UserAccess) (created bool, err error)

+ func (db *PG) ListUserAccess(ctx context.Context) ([]*UserAccess, error)

+ func (db *PG) SetUserAccessStatus(ctx context.Context, email, status, decidedBy string, decidedAt time.Time) (*UserAccess, error)

+ type UserAccess struct

+ DecidedAt *time.Time

+ DecidedBy string

+ Department string

+ Email string

+ Name string

+ Reason string

+ RequestedAt time.Time

+ Status string

Sep 23, 2026

Changes in this version

+ var ImportTables = []string

+ func LooksLikeMongoURI(uri string) bool

+ func MigratePG(ctx context.Context, pool *pgxpool.Pool) error

+ func MigrationsChecksum() (string, error)

+ type PG struct

+ func NewPG(ctx context.Context, uri string) (*PG, error)

+ func (db *PG) ActivityFor(ctx context.Context, owner, course, assignment string) ([]*ActivityEntry, error)

+ func (db *PG) AllActivityFor(ctx context.Context, owner string) ([]*ActivityEntry, error)

+ func (db *PG) CancelJob(ctx context.Context, owner, id string) (*ScheduledJob, error)

+ func (db *PG) ClaimDueJob(ctx context.Context, workerID string, now time.Time) (*ScheduledJob, error)

+ func (db *PG) CountsForImport(ctx context.Context) (map[string]int64, error)

+ func (db *PG) CourseActivityFor(ctx context.Context, owner, course string) ([]*ActivityEntry, error)

+ func (db *PG) CourseOf(ctx context.Context, owner, name string) (*StoredCourse, error)

+ func (db *PG) CoursesOf(ctx context.Context, owner string) ([]*StoredCourse, error)

+ func (db *PG) DBHost() string

+ func (db *PG) DeleteCourse(ctx context.Context, owner, name string) error

+ func (db *PG) DeleteUserGitLabToken(ctx context.Context, owner string) error

+ func (db *PG) Disconnect(_ context.Context) error

+ func (db *PG) EnsureSecretsRowForImport(ctx context.Context, owner string) error

+ func (db *PG) EventsBetween(ctx context.Context, since, until time.Time) ([]*Event, error)

+ func (db *PG) FinishJob(ctx context.Context, id, status, logText, errText string) error

+ func (db *PG) GetUserSecret(ctx context.Context, owner string) (*UserSecret, error)

+ func (db *PG) JobOf(ctx context.Context, owner, id string) (*ScheduledJob, error)

+ func (db *PG) JobsOf(ctx context.Context, owner string, statuses []string) ([]*ScheduledJob, error)

+ func (db *PG) MarkNotified(ctx context.Context, id string) error

+ func (db *PG) MigrateSchema(ctx context.Context) error

+ func (db *PG) ReapExpired(ctx context.Context, now time.Time) (jobs, events int64, err error)

+ func (db *PG) RecentEvents(ctx context.Context, since time.Time, limit int64) ([]*Event, error)

+ func (db *PG) RecordActivity(ctx context.Context, e *ActivityEntry) error

+ func (db *PG) RecordEvent(ctx context.Context, e *Event) error

+ func (db *PG) SaveCourse(ctx context.Context, course *StoredCourse) error

+ func (db *PG) SaveJob(ctx context.Context, job *ScheduledJob) error

+ func (db *PG) SaveUserGitLabToken(ctx context.Context, owner string, sealed secrets.SealedValue, ...) error

+ func (db *PG) SetSummarySentAt(ctx context.Context, at time.Time) error

+ func (db *PG) SystemState(ctx context.Context) (*SystemState, error)

+ func (db *PG) TruncateAllForImport(ctx context.Context) error

+ func (db *PG) UnnotifiedTerminalJobs(ctx context.Context) ([]*ScheduledJob, error)

Jul 21, 2026

Changes in this version

+ const EventCourseCreated

+ const EventCourseDeleted

+ const EventJobCancelled

+ const EventJobDone

+ const EventJobExpired

+ const EventJobFailed

+ const EventJobScheduled

+ const EventLogin

+ const EventLoginRejected

+ const EventOpDone

+ const EventOpFailed

+ const EventTokenDeleted

+ const EventTokenSaved

+ const SeverityError

+ const SeverityInfo

+ const SeverityWarning

type DB

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

+ func (db *DB) EventsBetween(ctx context.Context, since, until time.Time) ([]*Event, error)

+ func (db *DB) RecentEvents(ctx context.Context, since time.Time, limit int64) ([]*Event, error)

+ func (db *DB) RecordEvent(ctx context.Context, e *Event) error

+ func (db *DB) SetSummarySentAt(ctx context.Context, at time.Time) error

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

+ type Event struct

+ Actor string

+ ActorName string

+ Assignment string

+ At time.Time

+ Course string

+ Department string

+ Detail string

+ JobID string

+ Op string

+ Severity string

+ Type string

+ type SystemState struct

+ ID string

+ SummarySentAt *time.Time

Jul 20, 2026

Changes in this version

type DB

+ func (db *DB) AllActivityFor(ctx context.Context, owner string) ([]*ActivityEntry, error)

Jul 19, 2026

Changes in this version

type DB

+ func (db *DB) UnnotifiedTerminalJobs(ctx context.Context) ([]*ScheduledJob, error)

Jul 19, 2026

Changes in this version

+ const JobCancelled

+ const JobDone

+ const JobExpired

+ const JobFailed

+ const JobPending

+ const JobRunning

+ var ErrJobNotFound = errors.New("scheduled job not found")

+ var ErrNoDueJob = errors.New("no due job")

type DB

+ func (db *DB) CancelJob(ctx context.Context, owner, id string) (*ScheduledJob, error)

+ func (db *DB) ClaimDueJob(ctx context.Context, workerID string, now time.Time) (*ScheduledJob, error)

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

+ func (db *DB) FinishJob(ctx context.Context, id, status, logText, errText string) error

+ func (db *DB) JobOf(ctx context.Context, owner, id string) (*ScheduledJob, error)

+ func (db *DB) JobsOf(ctx context.Context, owner string, statuses []string) ([]*ScheduledJob, error)

+ func (db *DB) MarkNotified(ctx context.Context, id string) error

+ func (db *DB) SaveJob(ctx context.Context, job *ScheduledJob) error

+ type ScheduledJob struct

+ Assignment string

+ ConfigHash string

+ Course string

+ CreatedAt time.Time

+ Err string

+ FinishedAt *time.Time

+ GraceMin int

+ ID string

+ Log string

+ Notified bool

+ OnlyFor []string

+ Op string

+ Owner string

+ Params map[string]string

+ RunAt time.Time

+ StartedAt *time.Time

+ Status string

+ WorkerID string

Jul 19, 2026

Changes in this version

+ type ActivityEntry struct

+ Assignment string

+ At time.Time

+ Course string

+ Detail string

+ Op string

+ Owner string

+ Params map[string]string

+ Status string

type DB

+ func (db *DB) ActivityFor(ctx context.Context, owner, course, assignment string) ([]*ActivityEntry, error)

+ func (db *DB) CourseActivityFor(ctx context.Context, owner, course string) ([]*ActivityEntry, error)

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

+ func (db *DB) RecordActivity(ctx context.Context, e *ActivityEntry) error

Jul 17, 2026

Changes in this version

type DB

+ func (db *DB) DeleteUserGitLabToken(ctx context.Context, owner string) error

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

+ func (db *DB) GetUserSecret(ctx context.Context, owner string) (*UserSecret, error)

+ func (db *DB) SaveUserGitLabToken(ctx context.Context, owner string, sealed secrets.SealedValue, ...) error

+ type UserSecret struct

+ GitLab *secrets.SealedValue

+ GitLabUpdatedAt *time.Time

+ Owner string

Jul 17, 2026

Changes in this version

+ var ErrCourseNotFound = errors.New("course not found")

type DB

+ func (db *DB) CourseOf(ctx context.Context, owner, name string) (*StoredCourse, error)

+ func (db *DB) CoursesOf(ctx context.Context, owner string) ([]*StoredCourse, error)

+ func (db *DB) DeleteCourse(ctx context.Context, owner, name string) error

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

+ func (db *DB) SaveCourse(ctx context.Context, course *StoredCourse) error

+ type StoredCourse struct

+ ImportedAt time.Time

+ Name string

+ Owner string

+ RawYAML []byte

+ Source *config.CourseSource

+ UpdatedAt time.Time

Jul 17, 2026

Changes in this version

+ type DB struct

+ func Connect(ctx context.Context, uri, database string) (*DB, error)

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

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

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

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

+ func (db *DB) SaveUser(ctx context.Context, user *model.User) error