postgres

Jan 20, 2026

Changes in this version

type InstanceRepository

+ func (r *InstanceRepository) Delete(ctx context.Context, id domain.InstanceID) error

Dec 21, 2025

Changes in this version

+ type ApplicationRepository struct

+ func NewApplicationRepository(db *sql.DB) *ApplicationRepository

+ func (r *ApplicationRepository) FindByID(ctx context.Context, id domain.ApplicationID) (*domain.Application, error)

+ func (r *ApplicationRepository) FindBySlug(ctx context.Context, slug domain.AppSlug) (*domain.Application, error)

+ func (r *ApplicationRepository) List(ctx context.Context, limit int) ([]*domain.Application, error)

+ func (r *ApplicationRepository) Save(ctx context.Context, app *domain.Application) error

+ func (r *ApplicationRepository) UpdateStars(ctx context.Context, id domain.ApplicationID, stars int) error

type DashboardReader

+ func (r *DashboardReader) GetActiveInstancesCount(ctx context.Context, appSlug string) (int, error)

+ func (r *DashboardReader) GetAggregatedMetric(ctx context.Context, appSlug, metricName string) (float64, error)

+ func (r *DashboardReader) GetCombinedStats(ctx context.Context, appSlug, metricName string) (float64, int, error)

+ func (r *DashboardReader) GetMostUsedVersion(ctx context.Context, appSlug string) (string, error)

type Store

+ func (s *Store) ApplicationRepository() *ApplicationRepository

Dec 17, 2025

Changes in this version

+ type DashboardReader struct

+ func NewDashboardReader(db *sql.DB) *DashboardReader

+ func (r *DashboardReader) GetMetricsTimeSeries(ctx context.Context, appName string, since time.Time) (ports.MetricsTimeSeries, error)

+ func (r *DashboardReader) GetStats(ctx context.Context) (ports.DashboardStats, error)

+ func (r *DashboardReader) ListInstances(ctx context.Context, limit int) ([]ports.InstanceSummary, error)

+ type InstanceRepository struct

+ func NewInstanceRepository(db *sql.DB) *InstanceRepository

+ func (r *InstanceRepository) FindByID(ctx context.Context, id domain.InstanceID) (*domain.Instance, error)

+ func (r *InstanceRepository) GetPublicKey(ctx context.Context, id domain.InstanceID) (domain.PublicKey, error)

+ func (r *InstanceRepository) Save(ctx context.Context, instance *domain.Instance) error

+ func (r *InstanceRepository) UpdateStatus(ctx context.Context, id domain.InstanceID, status domain.InstanceStatus) error

+ type SnapshotRepository struct

+ func NewSnapshotRepository(db *sql.DB) *SnapshotRepository

+ func (r *SnapshotRepository) FindByInstanceID(ctx context.Context, id domain.InstanceID, limit int) ([]*domain.Snapshot, error)

+ func (r *SnapshotRepository) GetLatestByInstanceID(ctx context.Context, id domain.InstanceID) (*domain.Snapshot, error)

+ func (r *SnapshotRepository) Save(ctx context.Context, snapshot *domain.Snapshot) error

+ type Store struct

+ func NewStore(connStr string) (*Store, error)

+ func (s *Store) Close() error

+ func (s *Store) DB() *sql.DB

+ func (s *Store) DashboardReader() *DashboardReader

+ func (s *Store) InstanceRepository() *InstanceRepository

+ func (s *Store) SnapshotRepository() *SnapshotRepository