repository

package

Go to main page

Versions in this module

v0

v0.6.0

Oct 30, 2026

Changes in this version

type MemoryStackRepository

+ func (r *MemoryStackRepository) ListByCluster(_ context.Context, clusterID string) ([]*domain.Stack, error)

+ func (r *MemoryStackRepository) ListCompleted(_ context.Context) ([]*domain.Stack, error)

+ func (r *MemoryStackRepository) SetYAMLOverride(_ context.Context, stackID, key, yamlText string) error

+ type PostgresStackImageScanRepository struct

+ func NewPostgresStackImageScanRepository(pool *pgxpool.Pool) *PostgresStackImageScanRepository

+ func (r *PostgresStackImageScanRepository) ClaimCVENotices(ctx context.Context, stackID string, ids []string, at time.Time) ([]string, error)

+ func (r *PostgresStackImageScanRepository) ListByStack(ctx context.Context, stackID string) ([]domain.StackImageScan, error)

+ func (r *PostgresStackImageScanRepository) ListVulnerabilities(ctx context.Context, stackID, digest string) (domain.StackImageVulnerabilities, error)

+ func (r *PostgresStackImageScanRepository) NotifiedCVEIDs(ctx context.Context, stackID string) (map[string]bool, error)

+ func (r *PostgresStackImageScanRepository) ReleaseCVENotices(ctx context.Context, stackID string, ids []string) error

+ func (r *PostgresStackImageScanRepository) ReplaceForStack(ctx context.Context, stackID string, scans []domain.StackImageScan) error

+ func (r *PostgresStackImageScanRepository) VulnerabilityIDsByRelease(ctx context.Context, stackID, release string) (map[string]bool, bool, error)

type PostgresStackRepository

+ func (r *PostgresStackRepository) ListByCluster(ctx context.Context, clusterID string) ([]*domain.Stack, error)

+ func (r *PostgresStackRepository) ListCompleted(ctx context.Context) ([]*domain.Stack, error)

+ func (r *PostgresStackRepository) SetYAMLOverride(ctx context.Context, stackID, key, yamlText string) error

+ type PostgresUpgradeRepository struct

+ func NewPostgresUpgradeRepository(pool *pgxpool.Pool) *PostgresUpgradeRepository

+ func (r *PostgresUpgradeRepository) ActiveRun(ctx context.Context, stackID string) (*domain.UpgradeRun, error)

+ func (r *PostgresUpgradeRepository) CloseStaleRun(ctx context.Context, run *domain.UpgradeRun, staleBefore time.Time) (bool, error)

+ func (r *PostgresUpgradeRepository) CreateBundle(ctx context.Context, b *domain.UpgradeBundle) error

+ func (r *PostgresUpgradeRepository) CreateRun(ctx context.Context, run *domain.UpgradeRun) error

+ func (r *PostgresUpgradeRepository) FindRunByIdempotencyKey(ctx context.Context, stackID, key string) (*domain.UpgradeRun, error)

+ func (r *PostgresUpgradeRepository) GetBundle(ctx context.Context, id string) (*domain.UpgradeBundle, error)

+ func (r *PostgresUpgradeRepository) GetRun(ctx context.Context, stackID, runID string) (*domain.UpgradeRun, error)

+ func (r *PostgresUpgradeRepository) GetVerifiedBundle(ctx context.Context, id string) (*domain.UpgradeBundle, error)

+ func (r *PostgresUpgradeRepository) Heartbeat(ctx context.Context, runID string, at time.Time) error

+ func (r *PostgresUpgradeRepository) LatestRun(ctx context.Context, stackID, tool string) (*domain.UpgradeRun, error)

+ func (r *PostgresUpgradeRepository) ListBundles(ctx context.Context) ([]domain.UpgradeBundle, error)

+ func (r *PostgresUpgradeRepository) ListRuns(ctx context.Context, stackID string, limit int) ([]domain.UpgradeRun, error)

+ func (r *PostgresUpgradeRepository) ListVerifiedBundles(ctx context.Context, tool, source string) ([]domain.UpgradeBundle, error)

+ func (r *PostgresUpgradeRepository) UpdateBundleStatus(ctx context.Context, id, status string) error

+ func (r *PostgresUpgradeRepository) UpdateRun(ctx context.Context, run *domain.UpgradeRun) error

v0.5.0

Aug 31, 2026

Changes in this version

+ type MemoryCompatibilityRepository struct

+ func NewMemoryCompatibilityRepository() *MemoryCompatibilityRepository

+ func (r *MemoryCompatibilityRepository) Create(_ context.Context, m *domain.CompatibilityMatrix) error

+ func (r *MemoryCompatibilityRepository) Delete(_ context.Context, id string) error

+ func (r *MemoryCompatibilityRepository) GetAll(_ context.Context) ([]*domain.CompatibilityMatrix, error)

+ func (r *MemoryCompatibilityRepository) GetByID(_ context.Context, id string) (*domain.CompatibilityMatrix, error)

+ func (r *MemoryCompatibilityRepository) Update(_ context.Context, m *domain.CompatibilityMatrix) error

+ func (r *MemoryCompatibilityRepository) Validate(_ context.Context, tools map[string]string) (*domain.CompatibilityMatrix, error)

+ type MemoryHelmStepMetadataRepository struct

+ func NewMemoryHelmStepMetadataRepository() *MemoryHelmStepMetadataRepository

+ func (r *MemoryHelmStepMetadataRepository) Create(_ context.Context, item *domain.HelmStepMetadata) error

+ func (r *MemoryHelmStepMetadataRepository) Delete(_ context.Context, stepName string) error

+ func (r *MemoryHelmStepMetadataRepository) GetByStep(_ context.Context, stepName string) (*domain.HelmStepMetadata, error)

+ func (r *MemoryHelmStepMetadataRepository) List(_ context.Context) ([]*domain.HelmStepMetadata, error)

+ func (r *MemoryHelmStepMetadataRepository) Seed(items ...*domain.HelmStepMetadata)

+ func (r *MemoryHelmStepMetadataRepository) Update(_ context.Context, item *domain.HelmStepMetadata) error

+ type MemoryHistoryRepository struct

+ func NewMemoryHistoryRepository() *MemoryHistoryRepository

+ func (r *MemoryHistoryRepository) GetDiff(_ context.Context, stackID, versionID string) ([]domain.ConfigDiff, error)

+ func (r *MemoryHistoryRepository) GetVersion(_ context.Context, stackID, versionID string) (*domain.StackVersion, error)

+ func (r *MemoryHistoryRepository) ListVersions(_ context.Context, stackID string) ([]*domain.StackVersion, error)

+ func (r *MemoryHistoryRepository) SaveVersion(_ context.Context, version *domain.StackVersion) error

+ type MemoryResourceDefaultRepository struct

+ func NewMemoryResourceDefaultRepository() *MemoryResourceDefaultRepository

+ func (r *MemoryResourceDefaultRepository) List(_ context.Context) ([]*domain.ResourceDefault, error)

+ func (r *MemoryResourceDefaultRepository) Upsert(_ context.Context, resource *domain.ResourceDefault) error

+ type MemoryStackRepository struct

+ func NewMemoryStackRepository() *MemoryStackRepository

+ func (r *MemoryStackRepository) Create(_ context.Context, stack *domain.Stack) error

+ func (r *MemoryStackRepository) Delete(_ context.Context, id string) error

+ func (r *MemoryStackRepository) FindByID(ctx context.Context, id string) (*domain.Stack, error)

+ func (r *MemoryStackRepository) GetByID(_ context.Context, id string) (*domain.Stack, error)

+ func (r *MemoryStackRepository) List(_ context.Context, orgID string, includeDeleted bool) ([]*domain.Stack, error)

+ func (r *MemoryStackRepository) ListInFlight(_ context.Context) ([]*domain.Stack, error)

+ func (r *MemoryStackRepository) TouchUpdatedAt(_ context.Context, stackID string) error

+ func (r *MemoryStackRepository) Update(_ context.Context, stack *domain.Stack) error

+ func (r *MemoryStackRepository) UpdateTools(ctx context.Context, stack *domain.Stack) error

+ type MemoryTemplateRepository struct

+ func NewMemoryTemplateRepository() *MemoryTemplateRepository

+ func (r *MemoryTemplateRepository) Create(_ context.Context, template *domain.Template) error

+ func (r *MemoryTemplateRepository) Delete(_ context.Context, id string) error

+ func (r *MemoryTemplateRepository) GetByID(_ context.Context, id string) (*domain.Template, error)

+ func (r *MemoryTemplateRepository) List(_ context.Context) ([]*domain.Template, error)

+ func (r *MemoryTemplateRepository) Update(_ context.Context, template *domain.Template) error

+ type PostgresClusterReader struct

+ func NewPostgresClusterReader(pool *pgxpool.Pool) *PostgresClusterReader

+ func (r *PostgresClusterReader) GetClusterSummary(ctx context.Context, clusterID string) (*port.ClusterSummary, error)

+ type PostgresCompatibilityRepository struct

+ func NewPostgresCompatibilityRepository(pool *pgxpool.Pool) *PostgresCompatibilityRepository

+ func (r *PostgresCompatibilityRepository) Create(ctx context.Context, m *domain.CompatibilityMatrix) error

+ func (r *PostgresCompatibilityRepository) Delete(ctx context.Context, id string) error

+ func (r *PostgresCompatibilityRepository) GetAll(ctx context.Context) ([]*domain.CompatibilityMatrix, error)

+ func (r *PostgresCompatibilityRepository) GetByID(ctx context.Context, id string) (*domain.CompatibilityMatrix, error)

+ func (r *PostgresCompatibilityRepository) Update(ctx context.Context, m *domain.CompatibilityMatrix) error

+ func (r *PostgresCompatibilityRepository) Validate(ctx context.Context, tools map[string]string) (*domain.CompatibilityMatrix, error)

+ type PostgresDeployLogStore struct

+ func NewPostgresDeployLogStore(pool *pgxpool.Pool) *PostgresDeployLogStore

+ func (r *PostgresDeployLogStore) Append(ctx context.Context, deploymentID string, entry port.LogEntry) error

+ func (r *PostgresDeployLogStore) Delete(ctx context.Context, deploymentID string) error

+ func (r *PostgresDeployLogStore) List(ctx context.Context, deploymentID string, limit int) ([]port.LogEntry, error)

+ type PostgresHelmStepMetadataRepository struct

+ func NewPostgresHelmStepMetadataRepository(pool *pgxpool.Pool) *PostgresHelmStepMetadataRepository

+ func (r *PostgresHelmStepMetadataRepository) Create(ctx context.Context, item *domain.HelmStepMetadata) error

+ func (r *PostgresHelmStepMetadataRepository) Delete(ctx context.Context, stepName string) error

+ func (r *PostgresHelmStepMetadataRepository) GetByStep(ctx context.Context, stepName string) (*domain.HelmStepMetadata, error)

+ func (r *PostgresHelmStepMetadataRepository) List(ctx context.Context) ([]*domain.HelmStepMetadata, error)

+ func (r *PostgresHelmStepMetadataRepository) Update(ctx context.Context, item *domain.HelmStepMetadata) error

+ type PostgresHistoryRepository struct

+ func NewPostgresHistoryRepository(pool *pgxpool.Pool) *PostgresHistoryRepository

+ func (r *PostgresHistoryRepository) GetDiff(ctx context.Context, stackID, versionID string) ([]domain.ConfigDiff, error)

+ func (r *PostgresHistoryRepository) GetVersion(ctx context.Context, stackID, versionID string) (*domain.StackVersion, error)

+ func (r *PostgresHistoryRepository) ListVersions(ctx context.Context, stackID string) ([]*domain.StackVersion, error)

+ func (r *PostgresHistoryRepository) SaveVersion(ctx context.Context, version *domain.StackVersion) error

+ type PostgresKubeconfigProvider struct

+ func NewPostgresKubeconfigProvider(pool *pgxpool.Pool, encryptionKey []byte) *PostgresKubeconfigProvider

+ func (p *PostgresKubeconfigProvider) GetKubeconfig(ctx context.Context, clusterID string) ([]byte, error)

+ type PostgresResourceDefaultRepository struct

+ func NewPostgresResourceDefaultRepository(pool *pgxpool.Pool) *PostgresResourceDefaultRepository

+ func (r *PostgresResourceDefaultRepository) List(ctx context.Context) ([]*domain.ResourceDefault, error)

+ func (r *PostgresResourceDefaultRepository) Upsert(ctx context.Context, resource *domain.ResourceDefault) error

+ type PostgresStackRepository struct

+ func NewPostgresStackRepository(pool *pgxpool.Pool) *PostgresStackRepository

+ func (r *PostgresStackRepository) Create(ctx context.Context, stack *domain.Stack) error

+ func (r *PostgresStackRepository) Delete(ctx context.Context, id string) error

+ func (r *PostgresStackRepository) FindByID(ctx context.Context, id string) (*domain.Stack, error)

+ func (r *PostgresStackRepository) GetByID(ctx context.Context, id string) (*domain.Stack, error)

+ func (r *PostgresStackRepository) List(ctx context.Context, orgID string, includeDeleted bool) ([]*domain.Stack, error)

+ func (r *PostgresStackRepository) ListInFlight(ctx context.Context) ([]*domain.Stack, error)

+ func (r *PostgresStackRepository) TouchUpdatedAt(ctx context.Context, stackID string) error

+ func (r *PostgresStackRepository) Update(ctx context.Context, stack *domain.Stack) error

+ func (r *PostgresStackRepository) UpdateTools(ctx context.Context, stack *domain.Stack) error

+ type PostgresTemplateRepository struct

+ func NewPostgresTemplateRepository(pool *pgxpool.Pool) *PostgresTemplateRepository

+ func (r *PostgresTemplateRepository) Create(ctx context.Context, template *domain.Template) error

+ func (r *PostgresTemplateRepository) Delete(ctx context.Context, id string) error

+ func (r *PostgresTemplateRepository) GetByID(ctx context.Context, id string) (*domain.Template, error)

+ func (r *PostgresTemplateRepository) List(ctx context.Context) ([]*domain.Template, error)

+ func (r *PostgresTemplateRepository) Update(ctx context.Context, template *domain.Template) error

+ type PostgresTokenSourceRegistry struct

+ func NewPostgresTokenSourceRegistry(pool *pgxpool.Pool, secret *secrets.Router) *PostgresTokenSourceRegistry

+ func (r *PostgresTokenSourceRegistry) Upsert(ctx context.Context, input port.TokenSourceInput) error

v0.4.1

Aug 9, 2026

v0.4.0-alpha

Aug 9, 2026

v0.3.0-alpha

Jul 27, 2026

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