api

package

Go to main page

Versions in this module

v0

v0.9.2

Nov 6, 2026

v0.9.0

Nov 2, 2026

v0.8.8

Oct 30, 2026

v0.8.7

Oct 29, 2026

v0.8.6

Oct 27, 2026

v0.8.5

Oct 26, 2026

v0.8.4

Oct 24, 2026

v0.8.3

Oct 24, 2026

v0.8.2

Oct 22, 2026

v0.8.1

Oct 22, 2026

v0.8.0

Oct 21, 2026

v0.7.0

Oct 20, 2026

v0.6.0

Oct 17, 2026

v0.5.1

Oct 16, 2026

v0.5.0

Oct 16, 2026

v0.4.0

Oct 15, 2026

v0.3.0

Oct 12, 2026

Changes in this version

+ const EnvAITurnTokenTTL

+ func PeerIsTrustedProxy(r *http.Request) bool

type NotificationChannelTester

+ SendChannelTest func(ctx context.Context, c alerting.NotificationChannel) error

type NotificationChannels

+ RevealNotificationChannel func(ctx context.Context, c alerting.NotificationChannel) (alerting.NotificationChannel, error)

type Option

+ func WithWebhookFailedDeliveryLimits(keep, bodyBytes int) Option

type WebhookDeliveryStore

+ PruneFailedWebhookDeliveries func(ctx context.Context, serviceName string, keep int) (int64, error)

v0.2.2

Oct 12, 2026

Changes in this version

+ type NodeHostReports interface

+ Get func(nodeID string) (agent.HostReport, bool)

type Router

+ func (rt *Router) SetNodeHostReports(src NodeHostReports)

type SSHProvisioner

+ ScanHostKeys func(ctx context.Context, host string, port int) ([]sshprovision.HostKey, error)

v0.2.1

Oct 12, 2026

v0.2.0

Oct 12, 2026

Changes in this version

+ const ACMEStagingDirectoryURL

+ const AIAssistantAgentName

+ const AIAssistantTokenName

+ const AbilitySecretsReveal

+ const AbilitySignInApprove

+ const AgentClientHeader

+ const ClientKindSystem

+ const EnvGateAllowHTTP

+ const EnvGateEventRetention

+ const EnvGateSessionTTL

+ const EnvGateTokenTTL

+ const EnvGitStatusEnabled

+ const ExperimentalDisabledCode

+ const HealthScoreStatusFail

+ const HealthScoreStatusPass

+ const HealthScoreStatusWarn

+ const OutcomeBlocked

+ const OutcomeCanceled

+ const OutcomeFailed

+ const OutcomeHealthy

+ const OutcomeInProgress

+ const OutcomeSuperseded

+ const SetupTokenFilename

+ const TopologyEdgeDatabaseBinding

+ const TopologyEdgeDependsOn

+ const TopologyEdgeEgressAllow

+ const TopologyEdgeVolume

+ const TopologyKindApp

+ const TopologyKindDatabase

+ const TopologyKindVolume

+ func AttentionResolvedWindow() time.Duration

+ func DeviceCodeTTL() time.Duration

+ func DeviceTokenTTL() time.Duration

+ func DockerGuardAuditEntry(d dockerguard.Decision) (store.AuditEntry, error)

+ func EnsureSetupToken(ctx context.Context, users UserCounter, dataDir string) (token string, created bool, err error)

+ func HostFirewallSSHPorts() []int

+ func LoadBetaFeatures(ctx context.Context, s BetaFeatureStore) error

+ func MintAIAssistantToken(ctx context.Context, tokens TokenStore) (string, error)

+ func MintAPIToken(ctx context.Context, tokens TokenStore, name string, abilities []string, ...) (string, store.APIToken, error)

+ func MintAgentAPIToken(ctx context.Context, tokens TokenStore, name string, abilities []string, ...) (string, store.APIToken, error)

+ func NewDeviceApprovalFromEnv() bool

+ func ReadSetupToken(dataDir string) (string, error)

+ func SetupTokenPath(dataDir string) string

+ type AIAssistantSecrets interface

+ DeleteAll func(ctx context.Context, serviceName string) error

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type AIAssistantSettingsStore interface

+ GetAIAssistantSettings func(ctx context.Context) (store.AIAssistantSettings, error)

+ UpdateAIAssistantSettings func(ctx context.Context, s store.AIAssistantSettings) error

+ type AIChatStore interface

+ CreateAIChatSession func(ctx context.Context, id string, now time.Time) (store.AIChatSession, error)

+ DeleteAIChatSession func(ctx context.Context, id string) error

+ GetAIChatConfirmation func(ctx context.Context, id string) (store.AIChatConfirmation, error)

+ GetAIChatSession func(ctx context.Context, id string) (store.AIChatSession, error)

+ ListAIChatMessages func(ctx context.Context, sessionID string) ([]store.AIChatMessage, error)

+ ListAIChatSessions func(ctx context.Context) ([]store.AIChatSession, error)

+ type AIControlStore interface

+ CountAgentTokens func(ctx context.Context, internalName, internalAgent string) (int, error)

+ EnvironmentOfApp func(ctx context.Context, appName string) (*store.EnvironmentRef, error)

+ EnvironmentOfDatabase func(ctx context.Context, databaseName string) (*store.EnvironmentRef, error)

+ GetAIControlSettings func(ctx context.Context) (store.AIControlSettings, error)

+ RevokeAgentTokens func(ctx context.Context, internalName, internalAgent string) (int, error)

+ UpdateAIControlSettings func(ctx context.Context, mode string, kinds []string, updatedBy string) error

+ type AIEngine interface

+ IsConfigured func(ctx context.Context) (bool, error)

+ ResolveConfirmation func(ctx context.Context, sessionID, confirmationID string, approve bool, ...) error

+ RunTurn func(ctx context.Context, sessionID, userContent string, sink ai.Sink) error

+ type AlertNoise interface

+ CreateSilence func(ctx context.Context, s alerting.Silence) error

+ DeleteMaintenanceWindow func(ctx context.Context, id string) error

+ ExpireSilence func(ctx context.Context, id string, now time.Time) (*alerting.Silence, error)

+ GetMaintenanceWindow func(ctx context.Context, id string) (*alerting.MaintenanceWindow, error)

+ GetSilence func(ctx context.Context, id string) (*alerting.Silence, error)

+ ListActiveSilences func(ctx context.Context, now time.Time) ([]alerting.Silence, error)

+ ListHistory func(ctx context.Context, f alerting.HistoryFilter) ([]alerting.HistoryEntry, error)

+ ListMaintenanceWindows func(ctx context.Context) ([]alerting.MaintenanceWindow, error)

+ ListSilences func(ctx context.Context, now time.Time, includeExpired bool, limit int) ([]alerting.Silence, error)

+ SaveMaintenanceWindow func(ctx context.Context, w alerting.MaintenanceWindow) error

+ type AppImportStore interface

+ CreateAppImportSession func(ctx context.Context, s store.AppImportSession, items []store.AppImportItem) error

+ DeleteAppImportSession func(ctx context.Context, id string) error

+ GetAppImportSession func(ctx context.Context, id string) (store.AppImportSession, error)

+ ListAppImportItems func(ctx context.Context, sessionID string) ([]store.AppImportItem, error)

+ ListAppImportSessions func(ctx context.Context) ([]store.AppImportSession, error)

+ SaveAppImportItem func(ctx context.Context, it store.AppImportItem, now time.Time) error

+ UpdateAppImportSession func(ctx context.Context, s store.AppImportSession, now time.Time) error

+ type AppIntegrationStore interface

+ DeleteAppIntegration func(ctx context.Context, id string) error

+ GetAppIntegration func(ctx context.Context, id string) (store.AppIntegration, error)

+ ListAppIntegrationsForService func(ctx context.Context, serviceName string) ([]store.AppIntegration, error)

+ SaveAppIntegration func(ctx context.Context, ai store.AppIntegration) error

+ type AppScheduleStore interface

+ ArmAppScheduleNextRun func(ctx context.Context, serviceName string, next time.Time) error

+ GetAppSchedule func(ctx context.Context, serviceName string) (*store.AppSchedule, error)

+ ListAppScheduleHistory func(ctx context.Context, serviceName string, limit int) ([]store.AppScheduleHistoryEntry, error)

+ SetAppSchedule func(ctx context.Context, serviceName, cron, branch, timezone string, enabled bool) error

+ type AppSleepStore interface

+ GetAppSleep func(ctx context.Context, serviceName string) (store.AppSleep, error)

+ ListAppSleep func(ctx context.Context) ([]store.AppSleep, error)

+ SetAppSleepHold func(ctx context.Context, serviceName string, hold bool, now time.Time) error

+ SetAppSleepIdle func(ctx context.Context, serviceName string, minutes int, now time.Time) error

+ SetAppSleeping func(ctx context.Context, serviceName string, sleeping bool, now time.Time) error

type AppStore

+ DeleteServiceBranchEnvOverride func(ctx context.Context, serviceName, id string) error

+ ListAppStreamsForService func(ctx context.Context, serviceName string) ([]store.AppStream, error)

+ ListDesiredServicesByEnvironment func(ctx context.Context, environmentID string) ([]store.DesiredService, error)

+ ListDesiredServicesByProject func(ctx context.Context, projectID string) ([]store.DesiredService, error)

+ ListServiceBranchEnvOverrides func(ctx context.Context, serviceName string) ([]store.ServiceBranchEnvOverride, error)

+ SetServiceAutoRollbackOnCrashloop func(ctx context.Context, name string, enabled bool) error

+ SetServiceAutoRollbackOnSLOBurn func(ctx context.Context, name, mode string) error

+ SetServiceBadgeEnabled func(ctx context.Context, name string, enabled bool) error

+ SetServiceBranchEnvOverride func(ctx context.Context, serviceName, branchPattern, key, value string, ...) (string, error)

+ SetServiceDatabaseEnvVar func(ctx context.Context, name, envVar string, ref *store.DatabaseEnvRef) error

+ SetServiceExecEnabled func(ctx context.Context, name string, enabled bool) error

+ SetServicePreviewEnvOverride func(ctx context.Context, name, envVar string, value *string) error

+ SetServiceVaultEnvVar func(ctx context.Context, name, envVar string, ref *store.VaultEnvRef) error

+ UpdateServiceEgressPolicy func(ctx context.Context, name string, policy *store.ServiceEgressPolicy) error

+ UpdateServiceHealth func(ctx context.Context, name string, health *store.ServiceHealth) error

+ UpdateServiceVolumes func(ctx context.Context, name string, volumes []store.ServiceVolume) error

+ type AppStreamStore interface

+ DeleteAppStream func(ctx context.Context, id string) error

+ GetAppStream func(ctx context.Context, id string) (store.AppStream, error)

+ ListAllAppStreams func(ctx context.Context) ([]store.AppStream, error)

+ ListAppStreamsForService func(ctx context.Context, serviceName string) ([]store.AppStream, error)

+ SaveAppStream func(ctx context.Context, s store.AppStream) error

+ type AppVolumeMoveStore interface

+ FinishAppVolumeMove func(ctx context.Context, id, status, errMsg, finishedAt string) error

+ GetAppVolumeMove func(ctx context.Context, id string) (store.AppVolumeMove, error)

+ ListAppVolumeMoves func(ctx context.Context, serviceName string) ([]store.AppVolumeMove, error)

+ StartAppVolumeMove func(ctx context.Context, m store.AppVolumeMove) error

+ UpdateAppVolumeMoveSteps func(ctx context.Context, id string, steps []store.AppVolumeMoveStep) error

+ type ApprovalChatNotifier interface

+ SendApprovalRequest func(ctx context.Context, c alerting.NotificationChannel, ...) error

+ type AuthLibOAuth interface

+ InvalidateProvider func(name string)

+ LinkOAuthIdentity func(ctx context.Context, legacyUserID, provider, providerUserID string) error

+ OAuthCallback func(r *http.Request, provider string) authengine.OAuthOutcome

+ OAuthEnabled func() bool

+ OAuthStart func(r *http.Request, provider string) authengine.OAuthOutcome

+ Prefix func() string

+ ResolveOAuthUser func(ctx context.Context, provider, providerUserID string) (string, error)

+ type BackupDeleter interface

+ DeleteBackup func(ctx context.Context, historyID string) error

type BackupHistoryStore

+ ListAllBackupHistory func(ctx context.Context, limit int, before *time.Time) ([]store.BackupHistory, error)

+ type BackupProtection interface

+ Encryption func() backup.EncryptionStatus

+ Health func(ctx context.Context) ([]backup.ResourceHealth, error)

+ RefreshProtection func(ctx context.Context, targetIDs []string) ([]store.BackupTargetProtection, error)

+ RestoreVolumeTo func(ctx context.Context, rtm docker.Runtime, ...) error

+ StartDrill func(ctx context.Context, backupID string) (string, error)

+ VolumeExists func(ctx context.Context, rtm docker.Runtime, name string) (exists, known bool, err error)

+ type BackupProtectionStore interface

+ GetBackupDrill func(ctx context.Context, id string) (store.BackupDrill, error)

+ GetVolumeBackupPolicy func(ctx context.Context, serviceName, volumeName string) (store.VolumeBackupPolicy, error)

+ ListBackupDrills func(ctx context.Context, serviceName, volumeName, databaseName string, limit int) ([]store.BackupDrill, error)

+ ListBackupTargetProtection func(ctx context.Context) ([]store.BackupTargetProtection, error)

+ SetVolumeBackupPolicy func(ctx context.Context, p store.VolumeBackupPolicy) error

+ type BaseBackupHistoryStore interface

+ ListBaseBackupHistory func(ctx context.Context, databaseName string) ([]store.BaseBackupHistory, error)

+ type BaseBackupRunner interface

+ RunBaseBackup func(ctx context.Context, historyID, databaseName, containerName, targetID string) error

+ type BetaFeatureStore interface

+ ListBetaFeatures func(ctx context.Context) (map[string]bool, error)

type BitbucketAppClient

+ CreateCommitBuildStatus func(ctx context.Context, accessToken, fullName, commit string, ...) error

+ CreatePullRequestComment func(ctx context.Context, accessToken, fullName string, prID int, body string) (int64, error)

+ ListPullRequestComments func(ctx context.Context, accessToken, fullName string, prID int) ([]gitprovider.Comment, error)

+ UpdatePullRequestComment func(ctx context.Context, accessToken, fullName string, prID int, commentID int64, ...) error

+ type BuildCacheService interface

+ Clear func(ctx context.Context, app string) (objectstore.ClearResult, error)

+ KeyPrefix func(app string) (string, error)

+ Stats func(ctx context.Context, app string) (objectstore.CacheStats, error)

+ type BuildCacheSettingsStore interface

+ DeleteBuildCacheSetting func(ctx context.Context, appName string) error

+ GetBuildCacheSetting func(ctx context.Context, appName string) (store.BuildCacheSetting, error)

+ ListBuildCacheSettings func(ctx context.Context) ([]store.BuildCacheSetting, error)

+ UpsertBuildCacheSetting func(ctx context.Context, s store.BuildCacheSetting) error

+ type CanaryStore interface

+ DeleteCanaryRelease func(ctx context.Context, serviceName string) error

+ GetCanaryRelease func(ctx context.Context, serviceName string) (store.CanaryRelease, bool, error)

+ ListCanaryReleases func(ctx context.Context) ([]store.CanaryRelease, error)

+ SetCanaryRelease func(ctx context.Context, c store.CanaryRelease) error

+ type CertObservationSource interface

+ ListAllCertExpiryObservations func(ctx context.Context) ([]alerting.CertExpiryObservation, error)

type CertStore

+ DeleteCertStorageValue func(ctx context.Context, key string) error

+ type CloudflareDNSTokenResolver interface

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ type ComposeRevisionStore interface

+ AddComposeRevision func(ctx context.Context, rev store.ComposeRevision) (int, error)

+ DeleteComposeRevisions func(ctx context.Context, appID string) error

+ GetComposeRevision func(ctx context.Context, appID string, revision int) (store.ComposeRevision, error)

+ ListComposeApps func(ctx context.Context) ([]string, error)

+ ListComposeRevisions func(ctx context.Context, appID string, limit int) ([]store.ComposeRevision, error)

+ type ControlPlaneBackupManager interface

+ Create func(ctx context.Context) (cpbackup.Info, error)

+ Delete func(name string) error

+ List func() ([]cpbackup.Info, error)

+ Open func(name string) (*os.File, cpbackup.Info, error)

+ Verify func(ctx context.Context, name string) (cpbackup.VerifyResult, error)

+ type ControlPlaneDR interface

+ AckEscrow func(ctx context.Context) error

+ BuildEscrow func(ctx context.Context, in cpbackup.EscrowInput) (cpbackup.EscrowBundle, error)

+ ListRemote func(ctx context.Context) ([]cpbackup.Remote, error)

+ StartBackup func() error

+ StartDrill func() error

+ Status func(ctx context.Context) (cpbackup.Status, error)

+ UpdateConfig func(ctx context.Context, u cpbackup.ConfigUpdate) error

+ type CustomTemplateStore interface

+ DeleteCustomTemplate func(ctx context.Context, id string) error

+ GetCustomTemplate func(ctx context.Context, id string) (store.CustomTemplate, error)

+ ListCustomTemplates func(ctx context.Context) ([]store.CustomTemplate, error)

+ SaveCustomTemplate func(ctx context.Context, t store.CustomTemplate) error

+ type DataExportService interface

+ Create func(ctx context.Context, in dataexport.Input) (store.ExportDestination, error)

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

+ Get func(ctx context.Context, id string) (store.ExportDestination, error)

+ List func(ctx context.Context) ([]store.ExportDestination, error)

+ Series func(ctx context.Context, allow dataexport.ResourceFilter) ([]dataexport.Series, error)

+ Status func(ctx context.Context, id string) (store.ExportStatus, error)

+ StreamAudit func(ctx context.Context, from, to time.Time, fn func(dataexport.AuditRecord) error) error

+ Test func(ctx context.Context, id string) error

+ Update func(ctx context.Context, id string, p dataexport.Patch) (store.ExportDestination, error)

+ type DataImportStore interface

+ ClaimDatabaseDataImport func(ctx context.Context, name, host string, port int, srcDB string, now time.Time, ...) error

+ FinishDatabaseDataImport func(ctx context.Context, name, status, reason string, checked, mismatched int, ...) error

+ GetDatabaseDataImport func(ctx context.Context, name string) (store.DatabaseDataImport, bool, error)

+ ListDatabaseDataImports func(ctx context.Context) ([]store.DatabaseDataImport, error)

+ type DatabaseAccessStore interface

+ EnvironmentOfApp func(ctx context.Context, appName string) (*store.EnvironmentRef, error)

+ EnvironmentOfDatabase func(ctx context.Context, databaseName string) (*store.EnvironmentRef, error)

+ GetDatabaseAccessSettings func(ctx context.Context, database string) (store.DatabaseAccessSettings, error)

+ GetDatabaseAccessUser func(ctx context.Context, database, role string) (*store.DatabaseAccessUser, error)

+ GetDatabaseAccessUserByID func(ctx context.Context, id string) (*store.DatabaseAccessUser, error)

+ ListDatabaseAccessUsers func(ctx context.Context, database, kind string) ([]store.DatabaseAccessUser, error)

+ ListDatabaseNetworkRuleNotes func(ctx context.Context, database string) (map[string]string, error)

+ MarkDatabaseAccessUserRevoked func(ctx context.Context, database, role string, now time.Time) error

+ RecordDatabaseAccessUser func(ctx context.Context, u store.DatabaseAccessUser) error

+ ReplaceDatabaseNetworkRuleNotes func(ctx context.Context, database string, notes map[string]string) error

+ SaveDatabaseAccessSettings func(ctx context.Context, s store.DatabaseAccessSettings) error

+ type DatabaseQueryStore interface

+ AddDatabaseQueryHistory func(ctx context.Context, h store.DatabaseQueryHistory, keep int) (store.DatabaseQueryHistory, error)

+ ClearDatabaseQueryHistory func(ctx context.Context, database, principalType, principalID string) error

+ DeleteDatabaseSavedQuery func(ctx context.Context, database, principalType, principalID, id string) error

+ ListDatabaseQueryHistory func(ctx context.Context, database, principalType, principalID string, limit int) ([]store.DatabaseQueryHistory, error)

+ ListDatabaseSavedQueries func(ctx context.Context, database, principalType, principalID string) ([]store.DatabaseSavedQuery, error)

+ SaveDatabaseQuery func(ctx context.Context, q store.DatabaseSavedQuery) (store.DatabaseSavedQuery, error)

type DatabaseStore

+ ListDesiredDatabasesByProject func(ctx context.Context, projectID string) ([]store.DesiredDatabase, error)

+ SetDatabasePITR func(ctx context.Context, name string, enabled bool, enabledAt string) error

+ UpdateDatabaseSuspended func(ctx context.Context, name string, suspended bool) error

+ type DatabaseUpgrader interface

+ EffectivePolicy func(ctx context.Context, name string) (dbupgrade.Policy, bool, error)

+ Overview func(ctx context.Context, name string) (dbupgrade.Overview, error)

+ SetPolicy func(ctx context.Context, name string, p dbupgrade.Policy, inherit bool, by string) error

+ Summary func(ctx context.Context, visible func(string) bool) ([]dbupgrade.SummaryItem, error)

+ UpgradeNow func(ctx context.Context, name, version, by string) (store.DBUpgradeRun, error)

+ type DeployApprovalStore interface

+ DecideDeployApproval func(ctx context.Context, ...) (bool, error)

+ GetDeployApproval func(ctx context.Context, id string) (store.DeployApproval, error)

+ ListDeployApprovals func(ctx context.Context, status, serviceName string) ([]store.DeployApproval, error)

+ SaveDeployApproval func(ctx context.Context, a store.DeployApproval) error

type DeployAttemptStore

+ ListFailedDeploysSince func(ctx context.Context, since time.Time) ([]store.FailedDeploy, error)

+ SetDeployAttemptCommit func(ctx context.Context, id, image, commitSHA string) error

+ type DeployGateStore interface

+ GetDeploySafetySettings func(ctx context.Context, serviceName string) (store.DeploySafetySettings, error)

+ GetRollbackPin func(ctx context.Context, serviceName, attemptID string) (*store.RollbackPin, error)

+ ListGateEvents func(ctx context.Context, attemptID string) ([]store.DeployGateEvent, error)

+ ListRollbackPins func(ctx context.Context, serviceName string) ([]store.RollbackPin, error)

+ SaveDeploySafetySettings func(ctx context.Context, s store.DeploySafetySettings) error

+ type DeployQueueStore interface

+ CancelDeployAttempt func(ctx context.Context, id, from, by string, now time.Time) (bool, error)

+ FinishRunningDeployAttempt func(ctx context.Context, id, status string, finishedAt time.Time, errMsg string) (bool, error)

+ GetServiceCancelSuperseded func(ctx context.Context, name string) (bool, error)

+ ListQueuedDeployAttempts func(ctx context.Context) ([]store.DeployAttempt, error)

+ ListRunningDeployAttempts func(ctx context.Context) ([]store.DeployAttempt, error)

+ SetServiceCancelSuperseded func(ctx context.Context, name string, enabled bool) error

+ StartQueuedDeployAttempt func(ctx context.Context, id string, now time.Time) (bool, error)

+ SupersedeQueuedDeployAttempt func(ctx context.Context, id, by string, now time.Time) (bool, error)

+ type DeploySafetyStore interface

+ ReplaceDeployFreezeWindows func(ctx context.Context, scope string, windows []store.DeployFreezeWindow) ([]store.DeployFreezeWindow, error)

+ SetDeployAttemptReason func(ctx context.Context, id, reason string) error

+ type DeviceLoginNotifier interface

+ SendNotice func(ctx context.Context, kind alerting.NotifyKind, notifyURL, text string) error

+ type DockerGuardController interface

+ SetMode func(mode dockerguard.Mode, actor string, now time.Time) (dockerguard.Status, error)

+ Status func() dockerguard.Status

+ type DockerHubClient interface

+ ListTags func(ctx context.Context, namespace, repository string, pageSize int) ([]dockerhub.Tag, error)

+ SearchRepositories func(ctx context.Context, query string, pageSize int) ([]dockerhub.Repository, error)

+ type DoctorIngressEdge struct

+ Hardening bool

+ MaxBodyBytes int64

+ RetryWindow time.Duration

+ SocketActivation bool

+ TrustedProxies int

+ type DomainAuthGateStore interface

+ DeleteDomainAuthGate func(ctx context.Context, domain string) error

+ GetDomainAuthGate func(ctx context.Context, domain string) (store.DomainAuthGate, bool, error)

+ ListDomainAuthGates func(ctx context.Context) ([]store.DomainAuthGate, error)

+ SetDomainAuthGate func(ctx context.Context, g store.DomainAuthGate) error

type DomainBasicAuthStore

+ ListDomainBasicAuth func(ctx context.Context) ([]store.DomainBasicAuth, error)

+ type DomainErrorPagesStore interface

+ DeleteDomainErrorPage func(ctx context.Context, domain string, statusCode int) error

+ DeleteDomainErrorPages func(ctx context.Context, domain string) error

+ ListDomainErrorPages func(ctx context.Context, domain string) ([]store.DomainErrorPage, error)

+ SetDomainErrorPage func(ctx context.Context, domain string, statusCode int, body string) error

type DomainMaintenanceStore

+ ListDomainMaintenance func(ctx context.Context) ([]string, error)

+ type DomainRedirectStore interface

+ DeleteDomainRedirect func(ctx context.Context, domain string) error

+ GetDomainRedirect func(ctx context.Context, domain string) (store.DomainRedirect, bool, error)

+ ListDomainRedirects func(ctx context.Context) ([]store.DomainRedirect, error)

+ SetDomainRedirect func(ctx context.Context, domain, targetURL string, statusCode int) error

+ type DomainSearchVisibilityStore interface

+ IsDomainHidden func(ctx context.Context, domain string) (bool, error)

+ SetDomainHidden func(ctx context.Context, domain string, hidden bool) error

type DomainTLSCertStore

+ ListDomainTLSCerts func(ctx context.Context) ([]store.DomainTLSCert, error)

+ type DomainTrafficPolicyStore interface

+ DeleteDomainTrafficPolicy func(ctx context.Context, domain, kind string) error

+ GetDomainTrafficPolicy func(ctx context.Context, domain, kind string) (store.DomainTrafficPolicy, bool, error)

+ ListDomainTrafficPoliciesFor func(ctx context.Context, domain string) ([]store.DomainTrafficPolicy, error)

+ SetDomainTrafficPolicy func(ctx context.Context, domain, kind string, spec []byte) error

+ type DomainWAFStore interface

+ DeleteDomainWAF func(ctx context.Context, domain string) error

+ GetDomainWAF func(ctx context.Context, domain string) (store.DomainWAF, bool, error)

+ ListDomainWAF func(ctx context.Context) ([]store.DomainWAF, error)

+ SetDomainWAF func(ctx context.Context, domain string, wafEnabled bool, mode string, ...) error

type EnvironmentStore

+ DeleteEnvironmentSecretEnvVar func(ctx context.Context, environmentID, key string) error

+ EnvironmentMemberCounts func(ctx context.Context, envID string) (apps, databases int, err error)

+ EnvironmentOfDatabase func(ctx context.Context, databaseName string) (*store.EnvironmentRef, error)

+ GetEnvironmentsByIDs func(ctx context.Context, ids []string) (map[string]store.Environment, error)

+ ListAllEnvironments func(ctx context.Context) ([]store.EnvironmentWithCounts, error)

+ ListEnvironmentEnvVarsDetailed func(ctx context.Context, environmentID string) ([]store.SharedEnvVar, error)

+ ListEnvironmentSecretEnvKeys func(ctx context.Context, environmentID string) ([]string, error)

+ MoveEnvironmentMembers func(ctx context.Context, fromID, toID string) error

+ SetEnvironmentSecretEnvVar func(ctx context.Context, environmentID, key string) error

+ UpdateEnvironment func(ctx context.Context, id string, patch store.EnvironmentPatch) error

+ type EscrowMaterialReader func() (cpbackup.EscrowMaterial, error)

+ type ExposureStore interface

+ DeleteExposureRestriction func(ctx context.Context, port int, protocol string) error

+ ListExposureRestrictions func(ctx context.Context) ([]store.ExposureRestriction, error)

+ SaveExposureRestriction func(ctx context.Context, r store.ExposureRestriction) error

+ type ExternalDatabaseStore interface

+ CreateExternalDatabase func(ctx context.Context, d store.ExternalDatabase) error

+ DeleteExternalDatabase func(ctx context.Context, name string) error

+ GetExternalDatabase func(ctx context.Context, name string) (*store.ExternalDatabase, error)

+ ListExternalDatabases func(ctx context.Context) ([]store.ExternalDatabase, error)

+ SetExternalDatabaseHealth func(ctx context.Context, name, status, reason string, latencyMs int, ...) error

+ UpdateExternalDatabase func(ctx context.Context, d store.ExternalDatabase) error

+ type FirewallRuleStore interface

+ DeleteFirewallRule func(ctx context.Context, id string) error

+ ListFirewallRules func(ctx context.Context) ([]store.FirewallRule, error)

+ SaveFirewallRule func(ctx context.Context, r store.FirewallRule) error

+ type ForgeDeploymentStore interface

+ CreateForgeDeployment func(ctx context.Context, d store.ForgeDeployment) error

+ ListForgeDeploymentsByState func(ctx context.Context, app, environment, state, excludeID string) ([]store.ForgeDeployment, error)

+ SetForgeDeploymentState func(ctx context.Context, id, state, warning string, at time.Time) error

+ type GPUHostDiagnoser func(ctx context.Context) gpu.HostDiagnosis

+ type GateSettings struct

+ AllowHTTP bool

+ EventRetention time.Duration

+ SessionTTL time.Duration

+ TokenTTL time.Duration

+ func DefaultGateSettings() GateSettings

+ func GateSettingsFromEnv(getenv func(string) string) (GateSettings, error)

+ type GateStore interface

+ ConsumeGateToken func(ctx context.Context, tokenHash string) (store.GateToken, bool, error)

+ CountLiveGateSessions func(ctx context.Context, domain string) (int, error)

+ CreateGateSession func(ctx context.Context, s store.GateSession) error

+ CreateGateToken func(ctx context.Context, t store.GateToken) error

+ DashboardSessionLive func(ctx context.Context, sessionID string) (bool, error)

+ DomainEnvironmentID func(ctx context.Context, domain string) (string, error)

+ GetDomainAuthGate func(ctx context.Context, domain string) (store.DomainAuthGate, bool, error)

+ GetGateSession func(ctx context.Context, tokenHash string) (store.GateSession, bool, error)

+ GetOrganization func(ctx context.Context, id string) (store.Organization, error)

+ GetRole func(ctx context.Context, id string) (store.Role, error)

+ GetUserByEmail func(ctx context.Context, email string) (*store.User, error)

+ GetUserByID func(ctx context.Context, id string) (*store.User, error)

+ ListAuthGateEvents func(ctx context.Context, domain string, since time.Time, limit int) ([]store.GateEvent, error)

+ ListGateRules func(ctx context.Context, domain string) ([]store.GateRule, error)

+ ListOrganizations func(ctx context.Context) ([]store.Organization, error)

+ ListRoles func(ctx context.Context) ([]store.Role, error)

+ PruneGateData func(ctx context.Context, cutoff time.Time) (int64, error)

+ RecordAuthGateEvent func(ctx context.Context, e store.GateEvent) error

+ ReplaceGateRules func(ctx context.Context, domain string, rules []store.GateRule) error

+ RevokeGateSessions func(ctx context.Context, domain string) (int64, error)

+ UserRoleID func(ctx context.Context, userID string) (string, error)

+ UserTeamRoles func(ctx context.Context, userID string) (map[string]string, error)

+ UserVisibility func(ctx context.Context, userID string) (store.Visibility, error)

type GitHubAppClient

+ ListIssueComments func(ctx context.Context, instanceURL, token, owner, repo string, number int) ([]gitprovider.Comment, error)

+ UpdateIssueComment func(ctx context.Context, instanceURL, token, owner, repo string, commentID int64, ...) error

type GitHubAppStore

+ DeleteGitHubAppInstallation func(ctx context.Context, id int64) error

+ ListGitHubAppInstallations func(ctx context.Context) ([]store.GitHubAppInstallation, error)

+ UpsertGitHubAppInstallation func(ctx context.Context, installationID int64, accountLogin, accountType string) error

type GitLabAppClient

+ CreateCommitStatus func(ctx context.Context, instanceURL, accessToken, projectPath, sha string, ...) error

+ CreateMergeRequestNote func(ctx context.Context, instanceURL, accessToken, projectPath string, mrIID int, ...) (int64, error)

+ ListMergeRequestNotes func(ctx context.Context, instanceURL, accessToken, projectPath string, mrIID int) ([]gitprovider.Comment, error)

+ UpdateMergeRequestNote func(ctx context.Context, instanceURL, accessToken, projectPath string, mrIID int, ...) error

type GitSourceStore

+ ListGitSources func(ctx context.Context) ([]store.GitSourceSummary, error)

+ SetGitSourceBuild func(ctx context.Context, serviceName, buildType, buildPath, baseDirectory string) error

+ SetGitSourceDeploySettings func(ctx context.Context, serviceName string, paths, pathsIgnore []string, ...) error

+ type GiteaAppClient interface

+ CreateCommitStatus func(ctx context.Context, instanceURL, accessToken, fullName, sha string, ...) error

+ CreateIssueComment func(ctx context.Context, instanceURL, accessToken, fullName string, number int, ...) (int64, error)

+ CreateRepoWebhook func(ctx context.Context, ...) error

+ ExchangeCode func(ctx context.Context, ...) (giteaapp.Tokens, error)

+ GetRepo func(ctx context.Context, instanceURL, accessToken, fullName string) (giteaapp.Repo, error)

+ ListBranches func(ctx context.Context, instanceURL, accessToken, fullName string) ([]giteaapp.Branch, error)

+ ListIssueComments func(ctx context.Context, instanceURL, accessToken, fullName string, number int) ([]gitprovider.Comment, error)

+ ListRepos func(ctx context.Context, instanceURL, accessToken string) ([]giteaapp.Repo, error)

+ RefreshToken func(ctx context.Context, instanceURL, clientID, clientSecret, refreshToken string) (giteaapp.Tokens, error)

+ UpdateIssueComment func(ctx context.Context, instanceURL, accessToken, fullName string, ...) error

+ type GiteaAppSecrets interface

+ DeleteAll func(ctx context.Context, serviceName string) error

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type GiteaAppStore interface

+ DeleteGiteaAppConnection func(ctx context.Context) error

+ GetGiteaAppConnection func(ctx context.Context) (store.GiteaAppConnection, error)

+ SaveGiteaAppConnection func(ctx context.Context, c store.GiteaAppConnection) error

+ type ImageAutoUpdateStore interface

+ GetImageAutoUpdate func(ctx context.Context, serviceName string) (store.ImageAutoUpdate, error)

+ RecordImageAutoUpdateCheck func(ctx context.Context, serviceName, result string, at time.Time) error

+ SetImageAutoUpdate func(ctx context.Context, serviceName string, enabled bool) error

+ SetImageAutoUpdateWebhookHash func(ctx context.Context, serviceName, hash string) error

+ type IngressPortOwner interface

+ OwnsPort func(port int) bool

type IngressSettingsStore

+ GetDashboardURL func(ctx context.Context) (string, error)

+ SetDashboardURL func(ctx context.Context, u string) error

+ type LBAdminStateStore interface

+ ListLBUpstreamAdminStates func(ctx context.Context) (map[string]map[int]string, error)

+ SetLBUpstreamAdminState func(ctx context.Context, service string, replica int, state string) error

+ type LoadBalancerStore interface

+ DeleteServiceLoadBalancer func(ctx context.Context, service string) error

+ GetServiceLoadBalancer func(ctx context.Context, service string) (string, bool, error)

+ ListLoadBalancerRows func(ctx context.Context) ([]store.LoadBalancerRow, error)

+ SetServiceLoadBalancer func(ctx context.Context, service, configJSON string) error

+ type LocalContainerLister interface

+ ListLocalContainers func(ctx context.Context) ([]docker.LocalContainer, error)

+ type LogArchiveStore interface

+ CountLogArchivePoliciesForTarget func(ctx context.Context, targetID string) (int, error)

+ DeleteLogArchivePolicy func(ctx context.Context, appName string) error

+ GetLogArchivePolicy func(ctx context.Context, appName string) (store.LogArchivePolicy, error)

+ ListLogArchivePolicies func(ctx context.Context) ([]store.LogArchivePolicy, error)

+ ListLogArchiveRuns func(ctx context.Context, appName string, all bool, limit int) ([]store.LogArchiveRun, error)

+ UpsertLogArchivePolicy func(ctx context.Context, p store.LogArchivePolicy) error

+ type LogArchiver interface

+ StartDump func(ctx context.Context, req objectstore.DumpRequest) (store.LogArchiveRun, error)

+ type LoginCodeStore interface

+ ClaimLapsedLoginApprovals func(ctx context.Context, now time.Time, limit int) ([]store.LoginApproval, error)

+ ClaimLapsedLoginCodes func(ctx context.Context, now time.Time, limit int) ([]store.LoginCodeChallenge, error)

+ ConsumeLoginApproval func(ctx context.Context, id string, now time.Time) (bool, error)

+ CreateLoginApproval func(ctx context.Context, a store.LoginApproval) error

+ CreateLoginCodeChallenge func(ctx context.Context, c store.LoginCodeChallenge) error

+ CreateTrustedDevice func(ctx context.Context, d store.TrustedDevice) error

+ DecideLoginApproval func(ctx context.Context, id, userID string, approve bool, decidedBy string, ...) (bool, error)

+ ExpireLoginCode func(ctx context.Context, id string, now time.Time) (bool, error)

+ ExtendTrustedDevice func(ctx context.Context, id string, expiresAt, now time.Time) error

+ GetCodeLoginSettings func(ctx context.Context) (store.CodeLoginSettings, bool, error)

+ GetLiveLoginCodeByBrowser func(ctx context.Context, browserHash string, now time.Time) (store.LoginCodeChallenge, error)

+ GetLoginApproval func(ctx context.Context, id string) (store.LoginApproval, error)

+ GetLoginApprovalByBrowser func(ctx context.Context, browserHash string) (store.LoginApproval, error)

+ GetTrustedDeviceByHash func(ctx context.Context, tokenHash string, now time.Time) (store.TrustedDevice, error)

+ ListLiveLoginCodesForUser func(ctx context.Context, userID string, now time.Time) ([]store.LoginCodeChallenge, error)

+ ListPendingLoginApprovalsForUser func(ctx context.Context, userID string, now time.Time) ([]store.LoginApproval, error)

+ ListTrustedDevices func(ctx context.Context, userID string, now time.Time) ([]store.TrustedDevice, error)

+ LockLoginCode func(ctx context.Context, id string, now time.Time) (bool, error)

+ LockLoginCodesForUser func(ctx context.Context, userID string, now time.Time) ([]string, error)

+ PruneLoginCodes func(ctx context.Context, cutoff time.Time) error

+ PruneTrustedDevices func(ctx context.Context, cutoff time.Time) error

+ RedeemLoginCode func(ctx context.Context, id string, now time.Time) (bool, error)

+ ReplaceLoginApproval func(ctx context.Context, a store.LoginApproval) ([]store.LoginApproval, error)

+ ReserveLoginCodeAttempt func(ctx context.Context, id string, maxAttempts int) (int, bool, error)

+ RevokeAllTrustedDevices func(ctx context.Context, userID string, now time.Time) (int, error)

+ RevokeTrustedDevice func(ctx context.Context, userID, id string, now time.Time) (bool, error)

+ SaveCodeLoginSettings func(ctx context.Context, s store.CodeLoginSettings) error

+ SupersedeLoginApprovals func(ctx context.Context, userID string, now time.Time) ([]store.LoginApproval, error)

+ TouchTrustedDevice func(ctx context.Context, id string, now time.Time) error

+ type MajorUpgradeStore interface

+ GetMajorUpgrade func(ctx context.Context, id string) (store.MajorUpgrade, error)

+ ListMajorUpgradeSnapshots func(ctx context.Context) ([]store.MajorUpgrade, error)

+ ListMajorUpgrades func(ctx context.Context, databaseName string) ([]store.MajorUpgrade, error)

+ type MajorUpgrader interface

+ DiscardSnapshot func(ctx context.Context, upgradeID string) error

+ Rollback func(ctx context.Context, upgradeID string) error

+ RunMajorUpgrade func(ctx context.Context, historyID, databaseName, toVersion string) error

+ type MeshKeyRotator interface

+ RotateKey func(ctx context.Context, nodeID string) (network.RotationResult, error)

+ RotationStatusFor func(nodeID string) (network.RotationStatus, bool)

+ type MeshSettingsStore interface

+ GetMeshSetting func(ctx context.Context) (store.MeshSetting, error)

+ SetMeshSetting func(ctx context.Context, enabled bool, actor string, now time.Time) error

+ type MeshStatusProvider interface

+ Status func(ctx context.Context) (network.Status, error)

+ type MigrationHubStore interface

+ CreateMigrationSession func(ctx context.Context, s store.MigrationSession, items []store.MigrationItem) error

+ DeleteMigrationSession func(ctx context.Context, id string) error

+ GetMigrationSession func(ctx context.Context, id string) (store.MigrationSession, error)

+ ListMigrationItems func(ctx context.Context, sessionID string) ([]store.MigrationItem, error)

+ ListMigrationSessions func(ctx context.Context) ([]store.MigrationSession, error)

+ MarkMigrationItemTargetCreated func(ctx context.Context, sessionID, sourceDB, version string) error

+ SetMigrationItemPlan func(ctx context.Context, sessionID, sourceDB, targetName, targetVersion string, ...) error

+ SetMigrationItemStatus func(ctx context.Context, sessionID, sourceDB, status, reason string, ...) error

+ SetMigrationStep func(ctx context.Context, id, step string, now time.Time) error

+ type ModelPreflightService interface

+ CacheEnabled func() bool

+ CacheList func(ctx context.Context) (models.CacheReport, error)

+ CachePrune func(ctx context.Context, volumes []string, dryRun bool) (models.CachePruneResult, error)

+ Preflight func(ctx context.Context, in models.PreflightInput) (models.PreflightResult, error)

+ PreflightEnabled func() bool

+ type ModelService interface

+ Create func(ctx context.Context, in models.CreateInput) (models.Created, error)

+ CreateKey func(ctx context.Context, model string, in models.CreateKeyInput) (models.CreatedKey, error)

+ Delete func(ctx context.Context, name string) error

+ EngineMetrics func(ctx context.Context, name string, window time.Duration) (models.EngineMetricsReport, error)

+ FitCheck func(ctx context.Context, req models.FitRequest) (models.FitReport, error)

+ GPUNodes func(ctx context.Context) ([]models.GPUNode, error)

+ Get func(ctx context.Context, name string) (models.View, error)

+ List func(ctx context.Context) ([]models.View, error)

+ ListKeys func(ctx context.Context, model string) ([]models.KeyView, error)

+ ModelFit func(ctx context.Context, name string) (models.FitReport, error)

+ NodeGPU func(ctx context.Context, nodeID string) (gpu.Info, bool, error)

+ Restart func(ctx context.Context, name string) error

+ RevokeKey func(ctx context.Context, model, id string) error

+ RotateKey func(ctx context.Context, name string) (string, error)

+ RotateKeyByID func(ctx context.Context, model, id, actor string, grace *time.Duration) (models.CreatedKey, error)

+ SetHFToken func(ctx context.Context, name, token string) error

+ SetLocalNodeID func(id string)

+ SetResidency func(ctx context.Context, name, residency string, idleTTL time.Duration) error

+ SetSwapGroup func(ctx context.Context, name, group string) error

+ Sleep func(ctx context.Context, name string) error

+ UnplacedWorkloads func(ctx context.Context) ([]models.Unplaced, error)

+ Usage func(ctx context.Context, model string, window time.Duration) (models.UsageReport, error)

+ Wake func(ctx context.Context, name string) error

+ type NetworkShareSecretsSetter interface

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type NetworkShareStore interface

+ DeleteNetworkShare func(ctx context.Context, id string) error

+ GetNetworkShare func(ctx context.Context, id string) (store.NetworkShare, error)

+ GetNetworkShareByName func(ctx context.Context, name string) (store.NetworkShare, error)

+ ListNetworkShares func(ctx context.Context) ([]store.NetworkShare, error)

+ SaveNetworkShare func(ctx context.Context, s store.NetworkShare) error

+ UpdateNetworkShare func(ctx context.Context, ...) error

+ type NodeMeshStatusSource interface

+ MeshStatus func(ctx context.Context, nodeID string) (network.Status, error)

+ type NodeProviderSecrets interface

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type NodeProvisionStore interface

+ GetNodeProvision func(ctx context.Context, id string) (store.NodeProvision, error)

+ ListNodeProvisions func(ctx context.Context) ([]store.NodeProvision, error)

+ SaveNodeProvision func(ctx context.Context, p store.NodeProvision) error

+ UpdateNodeProvisionStatus func(ctx context.Context, ...) error

+ type NodeProvisioner interface

+ CreateServer func(ctx context.Context, opts provision.CreateOpts) (serverID, ipAddr string, err error)

+ DeleteServer func(ctx context.Context, id string) error

+ GetServer func(ctx context.Context, id string) (status provision.ServerStatus, ipAddr string, err error)

+ ListRegions func(ctx context.Context) ([]provision.Region, error)

+ ListSizes func(ctx context.Context, region string) ([]provision.Size, error)

+ type NodeProvisionerFactory func(provider, token string) (NodeProvisioner, error)

+ type NodeSessionCloser interface

+ Disconnect func(nodeID string)

type NodeStore

+ RevokeNodeCert func(ctx context.Context, id string, now time.Time) error

+ UpdateNodeRegion func(ctx context.Context, id, region string) error

+ type OIDCJWKSProvider interface

+ JWKS func(ctx context.Context) (oidc.JWKS, error)

+ type OIDCKeyRotator interface

+ RotateKey func(ctx context.Context, retireAfter time.Duration) (oidc.RotationResult, error)

+ type ObjectClientResolver interface

+ Client func(ctx context.Context, targetID string) (*objectstore.Client, store.BackupTarget, error)

+ type ObservabilityStore interface

+ GetObservabilitySettings func(ctx context.Context) (store.ObservabilitySettings, error)

+ UpdateObservabilitySettings func(ctx context.Context, s store.ObservabilitySettings) error

type OnboardingStore

+ GetOnboardingState func(ctx context.Context) (store.OnboardingState, error)

+ SetOnboardingProgress func(ctx context.Context, currentStep string, steps map[string]string) error

type Option

+ func WithACMEDefaultDirectory(url string) Option

+ func WithAIAssistantSecrets(s AIAssistantSecrets) Option

+ func WithAIEngine(e AIEngine) Option

+ func WithAgentCAFingerprint(fp string) Option

+ func WithAlertNoise(a AlertNoise) Option

+ func WithAllowInsecureLogin(allow bool) Option

+ func WithAppTeardownOptions(opts ...application.Option) Option

+ func WithApprovalChatNotifier(n ApprovalChatNotifier) Option

+ func WithAuthEngine(e *authengine.Engine) Option

+ func WithAuthEngineMFA(m *authengine.MFA) Option

+ func WithAutoPlacement(enabled bool) Option

+ func WithBackupDeleter(d BackupDeleter) Option

+ func WithBackupProtection(p BackupProtection, st BackupProtectionStore) Option

+ func WithBaseBackupRunner(r BaseBackupRunner) Option

+ func WithCapacityForecastLookback(d time.Duration) Option

+ func WithCertRenewalTracking(src CertObservationSource, stalledThreshold time.Duration) Option

+ func WithChangelog(entries []changelog.Entry) Option

+ func WithCloudflareDNSTokenResolver(r CloudflareDNSTokenResolver) Option

+ func WithControlPlaneBackupScheduleDisabled(disabled bool) Option

+ func WithControlPlaneBackups(m ControlPlaneBackupManager) Option

+ func WithControlPlaneDR(dr ControlPlaneDR, material EscrowMaterialReader) Option

+ func WithDashboardCache(ttl, stale time.Duration) Option

+ func WithDashboardListenAddr(addr string) Option

+ func WithDashboardURL(u string) Option

+ func WithDatabaseAccess(s DatabaseAccessStore, ttl dbaccess.TTLLimits) Option

+ func WithDatabaseUpgrader(u DatabaseUpgrader) Option

+ func WithDeleteTeardownTimeout(d time.Duration) Option

+ func WithDeployApprovalTTL(d time.Duration) Option

+ func WithDeployGate(s DeployGateStore, defaults deploysafety.Effective) Option

+ func WithDeployMaxConcurrent(n int) Option

+ func WithDeploySafety(s DeploySafetyStore, resolver docker.ImageResolver) Option

+ func WithDeviceLoginNotifier(n DeviceLoginNotifier) Option

+ func WithDockerGuard(c DockerGuardController) Option

+ func WithDoctorAgentAdvertise(host string, port int) Option

+ func WithDoctorClockSkewWarnAge(d time.Duration) Option

+ func WithDoctorDiskIOWarnLatency(d time.Duration) Option

+ func WithDoctorIngressPorts(httpPort, httpsPort int) Option

+ func WithDoctorMinCPUCount(n int) Option

+ func WithDoctorMinRAMBytes(n int64) Option

+ func WithDoctorNetworkTimeout(d time.Duration) Option

+ func WithDoctorPublicIPEndpoint(url string) Option

+ func WithExposure(m *exposure.Manager, s ExposureStore) Option

+ func WithFirewallRequiredPorts(ports []int) Option

+ func WithGPUHostDiagnoser(d GPUHostDiagnoser) Option

+ func WithGiteaAppSecrets(s GiteaAppSecrets) Option

+ func WithHSTS(enabled bool) Option

+ func WithHTTPSEnableLimits(maxPerHour int, pendingTimeout time.Duration) Option

+ func WithHostFirewallRunner(run func(ctx context.Context, name string, args ...string) ([]byte, error), ...) Option

+ func WithIngressPortOwner(o IngressPortOwner) Option

+ func WithJobLimits(maxPerApp int) Option

+ func WithLoadBalancers(s LoadBalancerStore, registry *loadbalancer.Registry, ...) Option

+ func WithLoginCodeKey(key []byte) Option

+ func WithMajorUpgrader(u MajorUpgrader) Option

+ func WithMeshSettings(s MeshSettingsStore) Option

+ func WithMinAgentVersion(v string) Option

+ func WithModels(s ModelService) Option

+ func WithMultiNode(s PlacementStore, cfg nodemove.Config, meshPortMin, meshPortMax int) Option

+ func WithNetworkShareSecrets(s NetworkShareSecretsSetter) Option

+ func WithNewDeviceApproval(on bool) Option

+ func WithNodeCertThresholds(warning, critical time.Duration) Option

+ func WithNodeJoinTokenTTL(d time.Duration) Option

+ func WithNodeProviderSecrets(s NodeProviderSecrets) Option

+ func WithNodeProvisionerFactory(f NodeProvisionerFactory) Option

+ func WithNodeProvisions(s NodeProvisionStore) Option

+ func WithNodeSessionCloser(c NodeSessionCloser) Option

+ func WithOrphanedContainerManager(m OrphanedContainerManager) Option

+ func WithOrphanedVolumeManager(m OrphanedVolumeManager) Option

+ func WithPITRRestoreRunner(r PITRRestoreRunner) Option

+ func WithPipelines(st PipelineStore, runner PipelineRunner) Option

+ func WithPreviewLimits(l PreviewLimits) Option

+ func WithPreviewStuckAfter(d time.Duration) Option

+ func WithPublicHostSource(source string) Option

+ func WithPushVAPIDPublicKey(publicKey string) Option

+ func WithReadinessProbes(p ReadinessProbes) Option

+ func WithReconcileNudger(n ReconcileNudger) Option

+ func WithRegistryCatalogSecrets(s RegistryCatalogSecrets) Option

+ func WithRequestLogThresholds(slow, critical time.Duration) Option

+ func WithRequestSummaryWindow(d time.Duration) Option

+ func WithRoute53DNSCredentialResolver(r Route53DNSCredentialResolver) Option

+ func WithRoute53DNSSecrets(s Route53DNSSecrets) Option

+ func WithSSHNodeProvisions(s SSHNodeProvisionStore) Option

+ func WithSSHProvisioner(p SSHProvisioner) Option

+ func WithSecretBinding(b SecretBinder) Option

+ func WithSecretRotationWarnAge(d time.Duration) Option

+ func WithSelfUpgrade(s SelfUpgradeStore, launch SelfUpgradeLauncher) Option

+ func WithStaleSecretCounter(c StaleSecretCounter) Option

+ func WithStandaloneSafety(s StandaloneSafety) Option

+ func WithStatusPage(db StatusPageDB, cfg statuspage.Config, perMinute int) Option

+ func WithStatusPageViewer(st StatusPageStore, v StatusPageViewer, perMinute int) Option

+ func WithStorage(d StorageDeps) Option

+ func WithTokenRedeemRateLimit(perMinute int) Option

+ func WithUpgradeHistory(s UpgradeHistoryStore) Option

+ func WithUpgradeScheduling(s UpgradeScheduleStore, sender dbupgrade.NoticeSender, cfg upgradesched.Config) Option

+ func WithVaultSecrets(s VaultSecrets) Option

+ func WithWakeToken(token string) Option

+ func WithWebhookDeliveryRetention(d time.Duration) Option

+ func WithWebhookRateLimit(perMinute int) Option

type OrganizationStore

+ DeleteOrganizationSecretEnvVar func(ctx context.Context, orgID, key string) error

+ ListOrganizationEnvVarsDetailed func(ctx context.Context, orgID string) ([]store.SharedEnvVar, error)

+ ListOrganizationSecretEnvKeys func(ctx context.Context, orgID string) ([]string, error)

+ SetOrganizationSecretEnvVar func(ctx context.Context, orgID, key string) error

+ type OrphanSweepResult struct

+ OrphanedServices int

+ StuckDeploys int

+ type OrphanedContainerManager interface

+ Remove func(ctx context.Context, id string, force bool) error

+ Stop func(ctx context.Context, id string, timeout time.Duration) error

+ type OrphanedVolumeManager interface

+ ListNamedVolumes func(ctx context.Context) ([]docker.NamedVolume, error)

+ RemoveVolume func(ctx context.Context, name string) error

+ type PITRRestoreHistoryStore interface

+ ListPITRRestoreHistory func(ctx context.Context, databaseName string) ([]store.PITRRestoreHistory, error)

+ type PITRRestoreRunner interface

+ RunPITRRestore func(ctx context.Context, ...) error

+ ValidateTarget func(ctx context.Context, databaseName, containerName string, target time.Time) error

+ WindowBounds func(ctx context.Context, databaseName, containerName string) (hasBaseBackup bool, start, end time.Time, err error)

+ type PipelineEvents interface

+ TriggerEvent func(ctx context.Context, app string, ev pipeline.Event, ref, sha, actor string) []store.PipelineRun

+ type PipelineOverviewStore interface

+ ListPipelineRunRows func(ctx context.Context, f store.PipelineRunFilter) ([]store.PipelineRunRow, error)

+ PipelineAppCounts func(ctx context.Context, since time.Time) ([]store.PipelineAppCounts, error)

+ type PipelineRunner interface

+ Cancel func(ctx context.Context, runID string) error

+ DecideHold func(ctx context.Context, runID string, approved bool, by string) (bool, error)

+ Nudge func()

+ Rerun func(ctx context.Context, runID, actor string) (store.PipelineRun, error)

+ Start func(ctx context.Context, p store.Pipeline, opt pipeline.StartOptions) (store.PipelineRun, error)

+ type PipelineStore interface

+ DecidePipelineApproval func(ctx context.Context, id int64, decision, by, comment string, now time.Time) (bool, error)

+ DeletePipeline func(ctx context.Context, id string) error

+ GetPipelineByName func(ctx context.Context, app, name string) (store.Pipeline, error)

+ GetPipelineRun func(ctx context.Context, id string) (store.PipelineRun, error)

+ ListPipelineApprovals func(ctx context.Context, runID string) ([]store.PipelineApproval, error)

+ ListPipelineJobs func(ctx context.Context, runID string) ([]store.PipelineJob, error)

+ ListPipelineLogs func(ctx context.Context, runID, jobKey string, afterID int64, limit int) ([]store.PipelineLogLine, error)

+ ListPipelineRuns func(ctx context.Context, app, pipelineID string, limit int) ([]store.PipelineRun, error)

+ ListPipelineStepLogs func(ctx context.Context, runID, jobKey string, step *int, afterID int64, limit int) ([]store.PipelineLogLine, error)

+ ListPipelineTriggerLog func(ctx context.Context, app string, limit int) ([]store.PipelineTriggerLog, error)

+ ListPipelines func(ctx context.Context, app string) ([]store.Pipeline, error)

+ SavePipeline func(ctx context.Context, p store.Pipeline) (store.Pipeline, error)

+ type PipelineSyncStore interface

+ GetPipelineSync func(ctx context.Context, app string) (store.PipelineSync, error)

+ SavePipelineSync func(ctx context.Context, s store.PipelineSync) error

+ type PipelineSyncer interface

+ Sync func(ctx context.Context, app string) (pipeline.SyncResult, error)

+ SyncOnPush func(ctx context.Context, app, ref, sha string) (pipeline.SyncResult, bool, error)

+ type PlacementStore interface

+ EnsureDatabaseMeshPort func(ctx context.Context, name string, minPort, maxPort int) (int, error)

+ GetNodeLabels func(ctx context.Context, nodeID string) (map[string]string, error)

+ GetPlacementSelector func(ctx context.Context, kind, resource string) (map[string]string, error)

+ ListNodeLabels func(ctx context.Context) (map[string]map[string]string, error)

+ SetNodeLabels func(ctx context.Context, nodeID string, labels map[string]string) error

+ SetPlacementSelector func(ctx context.Context, kind, resource string, selector map[string]string) error

type PreviewEnvironmentStore

+ DeletePreviewDatabaseIsolation func(ctx context.Context, id string) error

+ DeletePreviewEphemeralDatabase func(ctx context.Context, id string) error

+ GetPreviewAppSettings func(ctx context.Context, appName string) (store.PreviewAppSettings, error)

+ GetPreviewDatabaseIsolationByPreviewAndKey func(ctx context.Context, previewEnvironmentID, sourceKey string) (*store.PreviewDatabaseIsolation, error)

+ GetPreviewEphemeralDatabaseByPreviewAndKey func(ctx context.Context, previewEnvironmentID, sourceKey string) (*store.PreviewEphemeralDatabase, error)

+ ListPreviewAppSettings func(ctx context.Context) (map[string]store.PreviewAppSettings, error)

+ ListPreviewDatabaseIsolationsByPreview func(ctx context.Context, previewEnvironmentID string) ([]store.PreviewDatabaseIsolation, error)

+ ListPreviewEnvironments func(ctx context.Context) ([]store.PreviewEnvironment, error)

+ ListPreviewEphemeralDatabasesByPreview func(ctx context.Context, previewEnvironmentID string) ([]store.PreviewEphemeralDatabase, error)

+ SavePreviewAppSettings func(ctx context.Context, s store.PreviewAppSettings) error

+ SavePreviewDatabaseIsolation func(ctx context.Context, p store.PreviewDatabaseIsolation) error

+ SavePreviewEphemeralDatabase func(ctx context.Context, p store.PreviewEphemeralDatabase) error

+ SetPreviewEnvironmentCommentID func(ctx context.Context, id string, commentID int64) error

+ SetPreviewEnvironmentExtendedUntil func(ctx context.Context, id, until string) error

+ UpdatePreviewDatabaseIsolationStatus func(ctx context.Context, id, status, statusReason, updatedAt string) error

+ UpdatePreviewEphemeralDatabaseStatus func(ctx context.Context, id, status, statusReason, updatedAt string) error

+ type PreviewLimits struct

+ MaxPerApp int

+ MaxTotal int

+ type PreviewService interface

+ Capture func(ctx context.Context, app string) error

+ Config func() preview.Config

+ DeleteApp func(ctx context.Context, app string) error

+ List func(ctx context.Context, app string) ([]preview.Record, error)

+ OpenImage func(ctx context.Context, app, deploymentID string) (string, preview.Record, error)

+ Prune func(ctx context.Context, app string, all bool) (preview.PruneResult, error)

+ SaveSettings func(ctx context.Context, app string, patch preview.SettingsPatch) (preview.AppSettings, error)

+ Settings func(ctx context.Context, app string) (preview.AppSettings, error)

+ Status func(ctx context.Context, app string) (preview.Summary, error)

+ type ProbeAttemptStore interface

+ ListProbeAttempts func(ctx context.Context, deployID string) ([]store.ProbeAttempt, error)

type ProjectStore

+ DeleteProjectSecretEnvVar func(ctx context.Context, projectID, key string) error

+ ListProjectEnvVarsDetailed func(ctx context.Context, projectID string) ([]store.SharedEnvVar, error)

+ ListProjectSecretEnvKeys func(ctx context.Context, projectID string) ([]string, error)

+ SetProjectSecretEnvVar func(ctx context.Context, projectID, key string) error

+ type ProxyIntegrationStore interface

+ GetProxyIntegrationSettings func(ctx context.Context) (store.ProxyIntegrationSettings, error)

+ ListProxyRouteStatus func(ctx context.Context) ([]store.ProxyRouteStatus, error)

+ SaveProxyRouteVerification func(ctx context.Context, s store.ProxyRouteStatus) error

+ UpdateProxyIntegrationSettings func(ctx context.Context, s store.ProxyIntegrationSettings) error

+ type PushSubscriptions interface

+ DeletePushSubscription func(ctx context.Context, id, userID string) error

+ ListPushSubscriptionsForUser func(ctx context.Context, userID string) ([]store.PushSubscription, error)

+ SavePushSubscription func(ctx context.Context, s store.PushSubscription) error

+ type ReadinessProbes struct

+ Database func(ctx context.Context) error

+ EngineStarted func() bool

+ Migrations func(ctx context.Context) error

+ type ReconcileNudger interface

+ Nudge func()

+ type RegistryCatalogClient interface

+ ListRepositories func(ctx context.Context, baseURL, username, password string) ([]string, error)

+ ListTags func(ctx context.Context, baseURL, username, password, repository string) ([]string, error)

+ type RegistryCatalogSecrets interface

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ type Restarter struct

+ Supervised bool

+ Trigger func()

+ func (r Restarter) Supported() bool

type Role

+ Builtin bool

+ ID string

+ UserCount int

+ Visibility string

+ type RoleStore interface

+ CountRootUsersExcept func(ctx context.Context, userID string) (int, error)

+ CountRootUsersOutsideRole func(ctx context.Context, roleID string) (int, error)

+ CreateRole func(ctx context.Context, r store.Role) error

+ DeleteRole func(ctx context.Context, id string) error

+ GetRole func(ctx context.Context, id string) (store.Role, error)

+ ListRoles func(ctx context.Context) ([]store.Role, error)

+ ListUserEnvironmentGrants func(ctx context.Context, userID string) ([]string, error)

+ RoleUserCounts func(ctx context.Context) (map[string]int, error)

+ SetUserEnvironmentGrants func(ctx context.Context, userID string, environmentIDs []string) error

+ SetUserRole func(ctx context.Context, userID, roleID string) error

+ SyncRoleAbilities func(ctx context.Context, roleID string) error

+ UpdateRole func(ctx context.Context, r store.Role) error

+ UpdateRoleAndSync func(ctx context.Context, r store.Role) error

+ UserRoleID func(ctx context.Context, userID string) (string, error)

+ type Route53DNSCredentialResolver interface

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ type Route53DNSSecrets interface

+ DeleteAll func(ctx context.Context, serviceName string) error

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type Route53DNSStore interface

+ GetRoute53DNSSettings func(ctx context.Context) (store.Route53DNSSettings, error)

+ UpdateRoute53DNSSettings func(ctx context.Context, s store.Route53DNSSettings) error

type Router

+ func (rt *Router) BudgetStatuses(ctx context.Context) ([]usagecost.BudgetStatus, error)

+ func (rt *Router) CheckImageUpdate(ctx context.Context, serviceName string) (string, error)

+ func (rt *Router) DrainDeployQueue(ctx context.Context)

+ func (rt *Router) GitSourceCloneToken(ctx context.Context, name, repoURL string) string

+ func (rt *Router) PipelineRunEnv(ctx context.Context, run store.PipelineRun) map[string]string

+ func (rt *Router) PipelineStatusReporter() pipeline.StatusReporter

+ func (rt *Router) PurgeOldWebhookDeliveries(ctx context.Context) (int64, error)

+ func (rt *Router) RecordRevoked(ctx context.Context, c dbaccess.TempCredential)

+ func (rt *Router) ReleaseHandlers() map[string]deploy.ReleaseHandler

+ func (rt *Router) ResumeCutoverRuns(ctx context.Context)

+ func (rt *Router) RevokeTemp(ctx context.Context, name, role string) error

+ func (rt *Router) RunDeployApprovalExpirySweep(ctx context.Context, interval time.Duration) error

+ func (rt *Router) RunDeviceLoginExpirySweeper(ctx context.Context) error

+ func (rt *Router) RunGateSweeper(ctx context.Context, interval time.Duration) error

+ func (rt *Router) RunNodeMoves(ctx context.Context)

+ func (rt *Router) RunStatusPageSampler(ctx context.Context) error

+ func (rt *Router) RunWebhookDeliverySweeper(ctx context.Context, interval time.Duration) error

+ func (rt *Router) SetAppTeardownOptions(opts ...application.Option)

+ func (rt *Router) SetControlPlaneDR(dr ControlPlaneDR, material EscrowMaterialReader)

+ func (rt *Router) SetDataExport(s DataExportService)

+ func (rt *Router) SetDatabaseUpgrader(u DatabaseUpgrader)

+ func (rt *Router) SetDockerGuard(c DockerGuardController)

+ func (rt *Router) SetDoctorIngressEdge(edge DoctorIngressEdge)

+ func (rt *Router) SetForgeDeployments(s ForgeDeploymentStore)

+ func (rt *Router) SetGate(secret string, settings GateSettings)

+ func (rt *Router) SetLoadBalancers(s LoadBalancerStore, registry *loadbalancer.Registry, ...)

+ func (rt *Router) SetLocalNodeID(id string)

+ func (rt *Router) SetMesh(mesh MeshStatusProvider, rotator MeshKeyRotator)

+ func (rt *Router) SetMeshPaths(r meshpath.Resolver)

+ func (rt *Router) SetMeshPeerStatus(src NodeMeshStatusSource)

+ func (rt *Router) SetMeshStartError(err error)

+ func (rt *Router) SetMeshZone(zone string)

+ func (rt *Router) SetOIDCManager(m OIDCJWKSProvider, issuerURL string, ratePerMinute int)

+ func (rt *Router) SetOIDCRotator(r OIDCKeyRotator)

+ func (rt *Router) SetOrphanReaper(r *orphans.Reaper)

+ func (rt *Router) SetPipelineEvents(e PipelineEvents)

+ func (rt *Router) SetPipelineSync(syncer PipelineSyncer, st PipelineSyncStore)

+ func (rt *Router) SetPipelines(st PipelineStore, runner PipelineRunner)

+ func (rt *Router) SetPreview(p PreviewService)

+ func (rt *Router) SetProxyIntegration(syncer *proxyroutes.Syncer, st ProxyIntegrationStore, ...)

+ func (rt *Router) SetRestarter(r Restarter)

+ func (rt *Router) SetStorage(d StorageDeps)

+ func (rt *Router) SetSupplyChain(s SupplyChainService)

+ func (rt *Router) SetWALShipStatus(src WALShipStatusSource)

+ func (rt *Router) StatusHostHandler(next http.Handler) http.Handler

+ func (rt *Router) StatusPageAppStatus(ctx context.Context, name string) (string, error)

+ func (rt *Router) SweepDeviceLoginExpiry(ctx context.Context, now time.Time) (int, error)

+ func (rt *Router) SweepOrphanPreviews(ctx context.Context) (OrphanSweepResult, error)

+ func (rt *Router) SweepSignInExpiry(ctx context.Context, now time.Time) error

+ func (rt *Router) SweepTokenHygiene(ctx context.Context, now time.Time) error

+ func (rt *Router) TriggerScheduledDeploy(ctx context.Context, serviceName, branch string) (string, error)

+ func (rt *Router) UpgradeScheduler() *upgradesched.Scheduler

+ func (rt *Router) UsageRollupTick(ctx context.Context)

+ func (rt *Router) WithHSTS(next http.Handler) http.Handler

+ type SSHNodeProvisionStore interface

+ GetSSHNodeProvision func(ctx context.Context, id string) (store.SSHNodeProvision, error)

+ ListSSHNodeProvisions func(ctx context.Context) ([]store.SSHNodeProvision, error)

+ SaveSSHNodeProvision func(ctx context.Context, p store.SSHNodeProvision) error

+ UpdateSSHNodeProvisionProgress func(ctx context.Context, ...) error

+ type SSHProvisioner interface

+ Provision func(ctx context.Context, creds sshprovision.Credentials, ...) (sshprovision.DetectedHost, error)

+ type ScheduledTaskStarter interface

+ Start func(ctx context.Context, task store.ScheduledTask, trigger string) (runID string, err error)

type ScheduledTaskStore

+ CountScheduledTasksForService func(ctx context.Context, serviceName string) (int, error)

+ GetScheduledTaskRun func(ctx context.Context, id string) (store.ScheduledTaskRun, error)

+ ListScheduledTaskRuns func(ctx context.Context, f store.ScheduledTaskRunFilter) ([]store.ScheduledTaskRun, error)

+ UpdateScheduledTaskConfig func(ctx context.Context, t store.ScheduledTask, now time.Time) error

+ type SecretBinder interface

+ BindingStatus func(ctx context.Context) (secrets.BindingStatus, error)

+ Rebind func(ctx context.Context) (secrets.RebindResult, error)

type SecretSetter

+ DeleteAll func(ctx context.Context, serviceName string) error

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ ExistsForServices func(ctx context.Context, serviceNames []string, envKey string) (map[string]bool, error)

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ type SecurityStore interface

+ ClearUserResetFlag func(ctx context.Context, userID string, now time.Time) error

+ ConsumeSignInAlertToken func(ctx context.Context, id string, now time.Time) (store.SignInAlertToken, error)

+ CreateSignInAlertToken func(ctx context.Context, t store.SignInAlertToken) error

+ DeleteTokenHygieneNotice func(ctx context.Context, tokenID string) error

+ FlagUserForReset func(ctx context.Context, userID, reason string, now time.Time) error

+ ForgetBrowser func(ctx context.Context, userID, fingerprint string) error

+ GetSecurityPolicy func(ctx context.Context) (store.SecurityPolicy, bool, error)

+ GetUserSecuritySettings func(ctx context.Context, userID string) (store.UserSecuritySettings, error)

+ ListTokenHygieneNotices func(ctx context.Context) ([]store.TokenHygieneNotice, error)

+ ListUserSecuritySettings func(ctx context.Context) ([]store.UserSecuritySettings, error)

+ MarkTokenHygieneDisabled func(ctx context.Context, tokenID string, now time.Time) error

+ PruneKnownBrowsers func(ctx context.Context, cutoff time.Time) error

+ PruneSignInAlertTokens func(ctx context.Context, cutoff time.Time) error

+ RememberBrowser func(ctx context.Context, userID, fingerprint string, now time.Time) (bool, bool, error)

+ SaveSecurityPolicy func(ctx context.Context, p store.SecurityPolicy) error

+ SaveTokenHygieneNotice func(ctx context.Context, n store.TokenHygieneNotice) error

+ SetRequireNewDeviceApproval func(ctx context.Context, userID string, on bool, now time.Time) error

+ type SelfUpgradeLauncher func(ctx context.Context, args []string) error

+ type SelfUpgradeStore interface

+ ListSelfUpgradeAttempts func(ctx context.Context, limit int) ([]store.SelfUpgradeAttempt, error)

+ UpsertSelfUpgradeAttempt func(ctx context.Context, a store.SelfUpgradeAttempt) error

+ type SessionLinkTokenStore interface

+ ClaimSessionLinkToken func(ctx context.Context, id string) error

+ GetSessionLinkTokenByHash func(ctx context.Context, hash string) (*store.SessionLinkToken, error)

+ SaveSessionLinkToken func(ctx context.Context, t store.SessionLinkToken) error

+ type SetupGuideStore interface

+ GetSetupGuideState func(ctx context.Context) (store.SetupGuideState, error)

+ ResetSetupGuide func(ctx context.Context) error

+ SetSetupGuideHidden func(ctx context.Context, hidden bool, by string) error

+ SetSetupGuideOverride func(ctx context.Context, stepID, state, by string) error

+ type StaleSecretCounter interface

+ CountStaleSecrets func(ctx context.Context, cutoff time.Time) (int, error)

+ type StandaloneSafety struct

+ ControlPorts []standalone.ControlPort

+ IngressPorts []int

+ type StatusPageDB interface

+ type StatusPageStore interface

+ AddStatusIncidentUpdate func(ctx context.Context, u store.StatusIncidentUpdate) error

+ DeleteStatusComponent func(ctx context.Context, id string) error

+ DeleteStatusIncident func(ctx context.Context, id string) error

+ GetStatusComponent func(ctx context.Context, id string) (store.StatusComponent, error)

+ GetStatusIncident func(ctx context.Context, id string) (store.StatusIncident, error)

+ GetStatusPageSettings func(ctx context.Context) (store.StatusPageSettings, error)

+ ListStatusComponents func(ctx context.Context) ([]store.StatusComponent, error)

+ ListStatusIncidentUpdates func(ctx context.Context) ([]store.StatusIncidentUpdate, error)

+ ListStatusIncidents func(ctx context.Context, limit int) ([]store.StatusIncident, error)

+ SaveStatusComponent func(ctx context.Context, c store.StatusComponent) error

+ SaveStatusIncident func(ctx context.Context, i store.StatusIncident) error

+ SaveStatusPageSettings func(ctx context.Context, s store.StatusPageSettings) error

+ type StatusPageViewer interface

+ Enabled func(ctx context.Context) (bool, error)

+ Invalidate func()

+ PreviewView func(ctx context.Context) (statuspage.View, error)

+ View func(ctx context.Context) (statuspage.View, error)

+ type StorageDeps struct

+ Archive LogArchiveStore

+ ArchiveRoot string

+ Archiver LogArchiver

+ BuildCache BuildCacheService

+ BuildCacheSettings BuildCacheSettingsStore

+ Clients ObjectClientResolver

+ Options StorageOptionsStore

+ type StorageOptionsStore interface

+ GetStorageOptions func(ctx context.Context, targetID string) (store.StorageOptions, bool, error)

+ ListStorageOptions func(ctx context.Context) (map[string]store.StorageOptions, error)

+ SaveStorageOptions func(ctx context.Context, o store.StorageOptions) error

+ type SupplyChainService interface

+ ArmOverride func(ctx context.Context, app, reason string) (supplychain.Settings, error)

+ Config func() supplychain.Config

+ DeleteApp func(ctx context.Context, app string) error

+ Get func(ctx context.Context, app, attemptID string) (supplychain.Record, error)

+ Lookup func(ctx context.Context, ids []string) (map[string]supplychain.Record, error)

+ OpenSBOM func(ctx context.Context, app, attemptID string) ([]byte, supplychain.Record, error)

+ SaveSettings func(ctx context.Context, app string, patch supplychain.SettingsPatch) (supplychain.Settings, error)

+ ScanNow func(ctx context.Context, app, attemptID string) (supplychain.Record, error)

+ Settings func(ctx context.Context, app string) (supplychain.Settings, error)

+ type TagStore interface

+ AttachAppTag func(ctx context.Context, tagID, appName string) error

+ DeleteTag func(ctx context.Context, id string) error

+ DetachAppTag func(ctx context.Context, tagID, appName string) error

+ GetTag func(ctx context.Context, id string) (store.Tag, error)

+ GetTagByName func(ctx context.Context, name string) (store.Tag, error)

+ ListAppNamesByTag func(ctx context.Context, tagID string) ([]string, error)

+ ListTags func(ctx context.Context) ([]store.Tag, error)

+ ListTagsForApp func(ctx context.Context, appName string) ([]store.Tag, error)

+ ListTagsForApps func(ctx context.Context, appNames []string) (map[string][]store.Tag, error)

+ SaveTag func(ctx context.Context, t store.Tag) error

type TelemetryQuerier

+ LatestByMetric func(ctx context.Context, metric string) ([]telemetry.Sample, error)

type TokenStore

+ GetAPITokenByID func(ctx context.Context, id string) (*store.APIToken, error)

+ type UpdateSettingsStore interface

+ GetUpdateSettings func(ctx context.Context) (store.UpdateSettings, error)

+ UpdateUpdateSettings func(ctx context.Context, s store.UpdateSettings) error

+ type UpgradeHistoryStore interface

+ AcknowledgeUpgrade func(ctx context.Context, id, byType, byID, byName string, now time.Time) (e store.UpgradeHistoryEntry, changed bool, err error)

+ ListNodeAgentVersionChanges func(ctx context.Context, limit int) ([]store.NodeAgentVersionChange, error)

+ ListUpgradeHistory func(ctx context.Context, limit int) ([]store.UpgradeHistoryEntry, error)

+ type UpgradeScheduleStore interface

+ UpdateUpgradePolicy func(ctx context.Context, p store.UpgradePolicy) error

+ type UserCounter interface

+ CountUsers func(ctx context.Context) (int, error)

+ type VaultSecrets interface

+ DeleteAll func(ctx context.Context, serviceName string) error

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type VaultSettingsStore interface

+ GetVaultSettings func(ctx context.Context) (store.VaultSettings, error)

+ UpdateVaultSettings func(ctx context.Context, s store.VaultSettings) error

+ type WALShipStatusSource interface

+ WALShipStatus func(databaseName string) (backup.WALShipStatus, bool)

type WebhookDeliveryStore

+ DeleteWebhookDeliveriesOlderThan func(ctx context.Context, cutoff time.Time) (int64, error)

v0.2.0-beta.20

Oct 11, 2026

v0.2.0-beta.19

Oct 11, 2026

v0.2.0-beta.18

Oct 5, 2026

v0.2.0-beta.17

Oct 5, 2026

v0.2.0-beta.16

Oct 5, 2026

v0.2.0-beta.15

Oct 5, 2026

v0.2.0-beta.14

Sep 23, 2026

v0.2.0-beta.13

Sep 23, 2026

v0.2.0-beta.12

Sep 23, 2026

v0.2.0-beta.11

Sep 23, 2026

v0.2.0-beta.10

Sep 23, 2026

v0.2.0-beta.9

Sep 23, 2026

v0.2.0-beta.8

Sep 23, 2026

v0.2.0-beta.7

Sep 23, 2026

v0.2.0-beta.6

Sep 23, 2026

v0.2.0-beta.5

Sep 21, 2026

v0.2.0-beta.4

Sep 20, 2026

v0.2.0-beta.3

Sep 20, 2026

v0.2.0-beta.2

Sep 18, 2026

v0.2.0-beta.1

Sep 13, 2026

v0.2.0-beta

Sep 12, 2026

v0.1.0

Sep 9, 2026

Changes in this version

+ const AbilityDeploy

+ const AbilityRead

+ const AbilityReadSensitive

+ const AbilityRoot

+ const AbilityWrite

+ const AbilityWriteSensitive

+ const ClientKindAPI

+ const ClientKindCLI

+ const ClientKindDashboard

+ const ClientKindMCP

+ const RoleAdmin

+ const RoleOperator

+ const RoleViewer

+ func BootstrapAdmin(ctx context.Context, s AuthStore, username, password string) error

+ func MaybeBootstrapDevAdmin(ctx context.Context, s AuthStore, logger *slog.Logger) error

+ func MaybeSeedDevFixturesFromFile(ctx context.Context, s TokenStore, logger *slog.Logger, path string) error

+ type AlertRules interface

+ DeleteRule func(ctx context.Context, id string) error

+ GetRule func(ctx context.Context, id string) (*alerting.Rule, error)

+ ListRulesForResource func(ctx context.Context, resourceID string) ([]alerting.Rule, error)

+ SaveRule func(ctx context.Context, r alerting.Rule) error

+ type AppComposeStore interface

+ GetAppByName func(ctx context.Context, name string) (store.App, error)

+ SaveApp func(ctx context.Context, a store.App) error

+ SaveDesiredService func(ctx context.Context, svc store.DesiredService) error

+ type AppGroupLister interface

+ DeleteApp func(ctx context.Context, id string) error

+ GetAppByName func(ctx context.Context, name string) (store.App, error)

+ ListServicesByApp func(ctx context.Context, appID string) ([]store.DesiredService, error)

+ SaveApp func(ctx context.Context, a store.App) error

+ type AppStore interface

+ DeleteDesiredService func(ctx context.Context, name string) error

+ GetDesiredService func(ctx context.Context, name string) (*store.DesiredService, error)

+ ListDesiredServices func(ctx context.Context) ([]store.DesiredService, error)

+ ListDesiredServicesByNode func(ctx context.Context, nodeID string) ([]store.DesiredService, error)

+ RestartService func(ctx context.Context, name string) error

+ SaveDesiredService func(ctx context.Context, svc store.DesiredService) error

+ UpdateServiceApp func(ctx context.Context, name, appID string) error

+ UpdateServiceDatabaseAttachment func(ctx context.Context, name string, att *store.DatabaseAttachment) error

+ UpdateServiceLogDrain func(ctx context.Context, name string, drain *store.LogDrain) error

+ UpdateServiceNode func(ctx context.Context, name, nodeID string) error

+ UpdateServiceProject func(ctx context.Context, name, projectID string) error

+ UpdateServiceStorageTarget func(ctx context.Context, name, storageTargetID string) error

+ UpdateServiceSuspended func(ctx context.Context, name string, suspended bool) error

+ type AuditStore interface

+ DeleteAuditEntriesOlderThan func(ctx context.Context, cutoff time.Time) (int64, error)

+ ListAuditEntries func(ctx context.Context, limit int, before *time.Time, ...) ([]store.AuditEntry, error)

+ SaveAuditEntry func(ctx context.Context, e store.AuditEntry) error

+ type AuthStore interface

+ CountUsers func(ctx context.Context) (int, error)

+ CreateUser func(ctx context.Context, u store.User) error

+ DeleteUser func(ctx context.Context, id string) error

+ DisableUserTOTP func(ctx context.Context, id string) error

+ EnableUserTOTP func(ctx context.Context, id string, confirmedAt time.Time) error

+ GetUserByEmail func(ctx context.Context, email string) (*store.User, error)

+ GetUserByID func(ctx context.Context, id string) (*store.User, error)

+ ListUsers func(ctx context.Context) ([]store.User, error)

+ UpdateUserAbilities func(ctx context.Context, id string, abilities []string) error

+ UpdateUserLastLogin func(ctx context.Context, id string, when time.Time) error

+ UpdateUserPasswordHash func(ctx context.Context, id string, hash *string) error

+ type BackupDownloader interface

+ Download func(ctx context.Context, historyID string) (io.ReadCloser, error)

+ type BackupHistoryStore interface

+ GetBackupHistory func(ctx context.Context, id string) (store.BackupHistory, error)

+ ListBackupHistory func(ctx context.Context, databaseName string, limit int, before *time.Time) ([]store.BackupHistory, error)

+ type BackupRunner interface

+ RunBackup func(ctx context.Context, ...) error

+ type BackupSecretsSetter interface

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type BackupTargetStore interface

+ DeleteBackupTarget func(ctx context.Context, id string) error

+ GetBackupTarget func(ctx context.Context, id string) (store.BackupTarget, error)

+ ListBackupTargets func(ctx context.Context) ([]store.BackupTarget, error)

+ SaveBackupTarget func(ctx context.Context, t store.BackupTarget) error

+ UpdateBackupTarget func(ctx context.Context, id, name, provider, endpoint, region, bucket string) error

+ type BackupTargetTester interface

+ TestTarget func(ctx context.Context, targetID string) error

+ type BackupVerificationStore interface

+ ListBackupVerifications func(ctx context.Context, backupHistoryID string, limit int) ([]store.BackupVerification, error)

+ type BackupVerifier interface

+ VerifyBackup func(ctx context.Context, verificationID, backupHistoryID, engine, checkedBy string) error

+ type BitbucketAppClient interface

+ CreateRepoWebhook func(ctx context.Context, accessToken, fullName, hookURL, secret string) error

+ ExchangeCode func(ctx context.Context, key, secret, code string) (bitbucketapp.Tokens, error)

+ GetRepo func(ctx context.Context, accessToken, fullName string) (bitbucketapp.Repo, error)

+ ListBranches func(ctx context.Context, accessToken, fullName string) ([]bitbucketapp.Branch, error)

+ ListRepos func(ctx context.Context, accessToken string) ([]bitbucketapp.Repo, error)

+ RefreshToken func(ctx context.Context, key, secret, refreshToken string) (bitbucketapp.Tokens, error)

+ type BitbucketAppSecrets interface

+ DeleteAll func(ctx context.Context, serviceName string) error

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type BitbucketAppStore interface

+ DeleteBitbucketAppConnection func(ctx context.Context) error

+ GetBitbucketAppConnection func(ctx context.Context) (store.BitbucketAppConnection, error)

+ SaveBitbucketAppConnection func(ctx context.Context, c store.BitbucketAppConnection) error

+ type Builder interface

+ Deploy func(ctx context.Context, req deploy.Request, progress func(build.ProgressEvent)) (string, error)

+ DeploySpec func(ctx context.Context, req deploy.MultiRequest, ...) ([]deploy.ServiceOutcome, error)

+ type CertStore interface

+ GetCertStorageValue func(ctx context.Context, key string) (*store.CertStorageValue, error)

+ ListCertStorageKeys func(ctx context.Context, prefix string, recursive bool) ([]string, error)

+ type CloneRestoreHistoryStore interface

+ ListCloneRestores func(ctx context.Context, sourceDatabaseName string) ([]store.CloneRestore, error)

+ type CloneRestoreRunner interface

+ RunCloneRestore func(ctx context.Context, ...) error

+ type CloudflareDNSSecrets interface

+ DeleteAll func(ctx context.Context, serviceName string) error

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type CloudflareDNSStore interface

+ GetCloudflareDNSSettings func(ctx context.Context) (store.CloudflareDNSSettings, error)

+ UpdateCloudflareDNSSettings func(ctx context.Context, s store.CloudflareDNSSettings) error

+ type CloudflareTunnelSecrets interface

+ DeleteAll func(ctx context.Context, serviceName string) error

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type CloudflareTunnelStore interface

+ GetCloudflareTunnelSettings func(ctx context.Context) (store.CloudflareTunnelSettings, error)

+ UpdateCloudflareTunnelSettings func(ctx context.Context, s store.CloudflareTunnelSettings) error

+ type ComposeSecretStore interface

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type ContainerLister interface

+ ListByPrefix func(ctx context.Context, prefix string) ([]docker.ContainerState, error)

+ type DBPinger interface

+ PingContext func(ctx context.Context) error

+ type DatabaseStore interface

+ DeleteDesiredDatabase func(ctx context.Context, name string) error

+ GetDesiredDatabase func(ctx context.Context, name string) (*store.DesiredDatabase, error)

+ ListDesiredDatabases func(ctx context.Context) ([]store.DesiredDatabase, error)

+ ListDesiredDatabasesByNode func(ctx context.Context, nodeID string) ([]store.DesiredDatabase, error)

+ SaveDesiredDatabase func(ctx context.Context, d store.DesiredDatabase) error

+ SetDatabaseBackupSchedule func(ctx context.Context, name, targetID, schedule string, retain, retainDays int) error

+ SetDatabasePublicAccess func(ctx context.Context, name string, enabled bool, requestedPort int) (int, error)

+ UpdateDatabaseNode func(ctx context.Context, name, nodeID string) error

+ UpdateDatabaseProject func(ctx context.Context, name, projectID string) error

+ type DeployAttemptStore interface

+ FinishDeployAttempt func(ctx context.Context, id, status string, finishedAt time.Time, errMsg string) error

+ GetDeployAttempt func(ctx context.Context, id string) (*store.DeployAttempt, error)

+ ListDeployAttempts func(ctx context.Context, serviceName string) ([]store.DeployAttempt, error)

+ SaveDeployAttempt func(ctx context.Context, a store.DeployAttempt) error

+ type DeployLogQuerier interface

+ QueryDeployLog func(ctx context.Context, attemptID string) ([]telemetry.DeployLogEntry, error)

+ type DeployNotifier interface

+ Dispatch func(ctx context.Context, resourceID string, ev alerting.DeployOutcome)

+ type DeployNotifyTargets interface

+ DeleteDeployTarget func(ctx context.Context, id string) error

+ GetDeployTarget func(ctx context.Context, id string) (*alerting.DeployTarget, error)

+ ListDeployTargetsForResource func(ctx context.Context, resourceID string) ([]alerting.DeployTarget, error)

+ SaveDeployTarget func(ctx context.Context, t alerting.DeployTarget) error

+ type DeployStore interface

+ GetConditions func(ctx context.Context, controllerName string) ([]reconcile.Condition, error)

+ GetConditionsForControllers func(ctx context.Context, controllerNames []string) (map[string][]reconcile.Condition, error)

+ type DevFixtureToken struct

+ Abilities []string

+ Name string

+ Plaintext string

+ type DevFixtures struct

+ Tokens []DevFixtureToken

+ func ParseDevFixtures(data []byte) (*DevFixtures, error)

+ type DeviceAuthStore interface

+ GetDeviceAuthRequestByDeviceCode func(ctx context.Context, deviceCode string) (*store.DeviceAuthRequest, error)

+ GetDeviceAuthRequestByUserCode func(ctx context.Context, userCode string) (*store.DeviceAuthRequest, error)

+ ListPendingDeviceAuthRequests func(ctx context.Context, now time.Time) ([]store.DeviceAuthRequest, error)

+ RedeemDeviceAuthRequest func(ctx context.Context, deviceCode, tokenID string, redeemedAt time.Time) error

+ SaveDeviceAuthRequest func(ctx context.Context, r store.DeviceAuthRequest) error

+ SetDeviceAuthRequestStatus func(ctx context.Context, userCode, status, approvedByUserID string) (int64, error)

+ type DockerDiskUsager interface

+ DiskUsage func(ctx context.Context) (docker.DiskUsage, error)

+ type DockerPinger interface

+ Ping func(ctx context.Context) error

+ type DockerPruner interface

+ Prune func(ctx context.Context, keep []string) docker.PruneResult

+ type Document struct

+ Statement []Statement

+ func ParseDocument(raw string) (*Document, error)

+ type DomainBasicAuthSecrets interface

+ DeleteAll func(ctx context.Context, serviceName string) error

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type DomainBasicAuthStore interface

+ DeleteDomainBasicAuth func(ctx context.Context, domain string) error

+ GetDomainBasicAuth func(ctx context.Context, domain string) (store.DomainBasicAuth, bool, error)

+ SetDomainBasicAuth func(ctx context.Context, domain, username string) error

+ type DomainMaintenanceStore interface

+ DeleteDomainMaintenance func(ctx context.Context, domain string) error

+ GetDomainMaintenance func(ctx context.Context, domain string) (bool, error)

+ SetDomainMaintenance func(ctx context.Context, domain string) error

+ type DomainStore interface

+ ListServiceDomains func(ctx context.Context) ([]store.ServiceDomain, error)

+ type DomainTLSCertSecrets interface

+ DeleteAll func(ctx context.Context, serviceName string) error

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type DomainTLSCertStore interface

+ DeleteDomainTLSCert func(ctx context.Context, domain string) error

+ GetDomainTLSCert func(ctx context.Context, domain string) (store.DomainTLSCert, bool, error)

+ SetDomainTLSCert func(ctx context.Context, domain string, uploadedAt, expiresAt time.Time) error

+ type Effect string

+ const EffectAllow

+ const EffectDeny

+ type EmailSecretsStore interface

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type EmailSettingsStore interface

+ GetEmailSettings func(ctx context.Context) (store.EmailSettings, error)

+ UpdateEmailSettings func(ctx context.Context, s store.EmailSettings) error

+ type EnvironmentStore interface

+ DeleteEnvironment func(ctx context.Context, id string) error

+ GetEnvironment func(ctx context.Context, id string) (store.Environment, error)

+ ListEnvironmentEnvVars func(ctx context.Context, environmentID string) (map[string]string, error)

+ ListEnvironmentsByProject func(ctx context.Context, projectID string) ([]store.Environment, error)

+ SaveEnvironment func(ctx context.Context, e store.Environment) error

+ SetEnvironmentEnvVars func(ctx context.Context, environmentID string, vars map[string]string) error

+ SetEnvironmentProtected func(ctx context.Context, id string, protected bool) error

+ SetServiceEnvironment func(ctx context.Context, serviceName, envID string) error

+ type FeatureFlagStore interface

+ DeleteFeatureFlag func(ctx context.Context, id string) error

+ GetFeatureFlag func(ctx context.Context, id string) (store.FeatureFlag, error)

+ GetFeatureFlagByKey func(ctx context.Context, key string) (store.FeatureFlag, error)

+ ListFeatureFlagsForService func(ctx context.Context, serviceName string) ([]store.FeatureFlag, error)

+ SaveFeatureFlag func(ctx context.Context, f store.FeatureFlag) error

+ UpdateFeatureFlag func(ctx context.Context, id, name, description string, enabled bool, ...) error

+ type GitHubAppClient interface

+ CheckInstanceReachable func(ctx context.Context, instanceURL string) error

+ CreateCommitStatus func(ctx context.Context, instanceURL, token, owner, repo, sha string, ...) error

+ CreateIssueComment func(ctx context.Context, instanceURL, token, owner, repo string, number int, ...) error

+ CreateRepoWebhook func(ctx context.Context, instanceURL, token, owner, repo, hookURL, secret string) error

+ ExchangeManifestCode func(ctx context.Context, instanceURL, code string) (githubapp.Credentials, error)

+ GetInstallation func(ctx context.Context, instanceURL, appJWT string, installationID int64) (githubapp.InstallationInfo, error)

+ GetRepo func(ctx context.Context, instanceURL, token, owner, repo string) (githubapp.Repo, error)

+ ListBranches func(ctx context.Context, instanceURL, token, owner, repo string) ([]githubapp.Branch, error)

+ ListInstallationRepos func(ctx context.Context, instanceURL, token string) ([]githubapp.Repo, error)

+ MintInstallationToken func(ctx context.Context, instanceURL, appJWT string, installationID int64) (githubapp.InstallationToken, error)

+ type GitHubAppSecrets interface

+ DeleteAll func(ctx context.Context, serviceName string) error

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type GitHubAppStore interface

+ DeleteGitHubAppConnection func(ctx context.Context) error

+ GetGitHubAppConnection func(ctx context.Context) (store.GitHubAppConnection, error)

+ SaveGitHubAppConnection func(ctx context.Context, c store.GitHubAppConnection) error

+ UpdateGitHubAppInstallation func(ctx context.Context, installationID int64, accountLogin string) error

+ type GitLabAppClient interface

+ CreateProjectWebhook func(ctx context.Context, instanceURL, accessToken string, projectID int64, ...) error

+ ExchangeCode func(ctx context.Context, ...) (gitlabapp.Tokens, error)

+ GetProject func(ctx context.Context, instanceURL, accessToken string, projectID int64) (gitlabapp.Project, error)

+ ListBranches func(ctx context.Context, instanceURL, accessToken string, projectID int64) ([]gitlabapp.Branch, error)

+ ListProjects func(ctx context.Context, instanceURL, accessToken string) ([]gitlabapp.Project, error)

+ RefreshToken func(ctx context.Context, instanceURL, clientID, clientSecret, refreshToken string) (gitlabapp.Tokens, error)

+ type GitLabAppSecrets interface

+ DeleteAll func(ctx context.Context, serviceName string) error

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type GitLabAppStore interface

+ DeleteGitLabAppConnection func(ctx context.Context) error

+ GetGitLabAppConnection func(ctx context.Context) (store.GitLabAppConnection, error)

+ SaveGitLabAppConnection func(ctx context.Context, c store.GitLabAppConnection) error

+ type GitSourceSecrets interface

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type GitSourceStore interface

+ DeleteGitSource func(ctx context.Context, serviceName string) error

+ GetGitSource func(ctx context.Context, serviceName string) (*store.GitSource, error)

+ SaveGitSource func(ctx context.Context, g store.GitSource) error

+ SetGitSourcePostPRComments func(ctx context.Context, serviceName string, enabled bool) error

+ SetGitSourcePreviewEnabled func(ctx context.Context, serviceName string, enabled bool) error

+ type HookRunStore interface

+ GetHookRuns func(ctx context.Context, serviceName string) ([]store.HookRun, error)

+ type ImageLister interface

+ ListImages func(ctx context.Context, repo string) ([]docker.ImageInfo, error)

+ type IngressSettingsStore interface

+ GetIngressSettings func(ctx context.Context) (store.IngressSettings, error)

+ UpdateIngressSettings func(ctx context.Context, s store.IngressSettings) error

+ type InviteStore interface

+ ClaimInvite func(ctx context.Context, id string) error

+ GetInviteByHash func(ctx context.Context, hash string) (*store.Invite, error)

+ GetInviteByID func(ctx context.Context, id string) (*store.Invite, error)

+ ListPendingInvites func(ctx context.Context) ([]store.Invite, error)

+ RevokeInvite func(ctx context.Context, id string) error

+ SaveInvite func(ctx context.Context, inv store.Invite) error

+ type MasterKeyRotator interface

+ GetMasterKeyRotatedAt func(ctx context.Context) (rotatedAt time.Time, ok bool, err error)

+ RotateMasterKey func(ctx context.Context, newMasterKey string) (rotatedAt time.Time, err error)

+ type NodeRuntimeResolver func(nodeID string) (docker.Runtime, error)

+ type NodeStore interface

+ DeleteNode func(ctx context.Context, id string) error

+ GetNode func(ctx context.Context, id string) (*store.Node, error)

+ ListNodes func(ctx context.Context) ([]store.Node, error)

+ SaveNodeJoinToken func(ctx context.Context, t store.NodeJoinToken) error

+ SetNodeSchedulable func(ctx context.Context, id string, schedulable bool) error

+ UpdateNodeWorkloads func(ctx context.Context, id string, acceptsApp, acceptsBuild bool) error

+ type NotificationChannelTester interface

+ SendTest func(ctx context.Context, kind alerting.NotifyKind, notifyURL string) error

+ type NotificationChannels interface

+ DeleteNotificationChannel func(ctx context.Context, id string) error

+ GetNotificationChannel func(ctx context.Context, id string) (*alerting.NotificationChannel, error)

+ ListNotificationChannels func(ctx context.Context) ([]alerting.NotificationChannel, error)

+ SaveNotificationChannel func(ctx context.Context, c alerting.NotificationChannel) error

+ type NotificationDeliveryStore interface

+ ListNotificationDeliveries func(ctx context.Context, channelID string, limit int, before *time.Time) ([]alerting.NotificationDelivery, error)

+ RecordNotificationDelivery func(ctx context.Context, d alerting.NotificationDelivery) error

+ type OAuthIdentityStore interface

+ GetOAuthIdentity func(ctx context.Context, provider, providerUserID string) (*store.OAuthIdentity, error)

+ ListOAuthIdentitiesForUser func(ctx context.Context, userID string) ([]store.OAuthIdentity, error)

+ SaveOAuthIdentity func(ctx context.Context, i store.OAuthIdentity) error

+ type OAuthSecrets interface

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type OAuthSettingsStore interface

+ GetOAuthProviderSettings func(ctx context.Context, provider string) (store.OAuthProviderSettings, error)

+ ListOAuthProviderSettings func(ctx context.Context) ([]store.OAuthProviderSettings, error)

+ UpdateOAuthProviderSettings func(ctx context.Context, s store.OAuthProviderSettings) error

+ type OnboardingStore interface

+ GetOnboardingCompleted func(ctx context.Context) (bool, error)

+ MarkOnboardingCompleted func(ctx context.Context) error

+ type Option func(*Router)

+ func WithAPIRateLimit(readPerMinute, writePerMinute int) Option

+ func WithAlertRules(a AlertRules) Option

+ func WithAuditLogRetention(d time.Duration) Option

+ func WithBackupDownloader(d BackupDownloader) Option

+ func WithBackupRunner(r BackupRunner) Option

+ func WithBackupSecrets(s BackupSecretsSetter) Option

+ func WithBackupTargetTester(t BackupTargetTester) Option

+ func WithBackupVerifier(v BackupVerifier) Option

+ func WithBitbucketAppSecrets(s BitbucketAppSecrets) Option

+ func WithBuilder(b Builder) Option

+ func WithCertExpiryWarningWindow(d time.Duration) Option

+ func WithCloneRestoreRunner(r CloneRestoreRunner) Option

+ func WithCloudflareDNSSecrets(s CloudflareDNSSecrets) Option

+ func WithCloudflareTunnelSecrets(s CloudflareTunnelSecrets) Option

+ func WithComposeSecrets(s ComposeSecretStore) Option

+ func WithContainerLister(l ContainerLister) Option

+ func WithDBPinger(p DBPinger) Option

+ func WithDataDir(path string) Option

+ func WithDeployLogQuerier(s DeployLogQuerier) Option

+ func WithDeployNotifier(n DeployNotifier) Option

+ func WithDeployNotifyTargets(t DeployNotifyTargets) Option

+ func WithDeployRecorder(r *deploylog.Recorder) Option

+ func WithDockerDiskUsager(u DockerDiskUsager) Option

+ func WithDockerPinger(p DockerPinger) Option

+ func WithDockerPruner(p DockerPruner) Option

+ func WithDoctorDiskWarningBytes(n int64) Option

+ func WithDoctorMasterKeyRotationWarnAge(d time.Duration) Option

+ func WithDomainBasicAuthSecrets(s DomainBasicAuthSecrets) Option

+ func WithDomainTLSCertSecrets(s DomainTLSCertSecrets) Option

+ func WithEmailSecrets(s EmailSecretsStore) Option

+ func WithEmailSender(s email.Sender) Option

+ func WithExecRuntime(r NodeRuntimeResolver) Option

+ func WithGitHubAppManifestConfig(cfg githubapp.ManifestConfig) Option

+ func WithGitHubAppSecrets(s GitHubAppSecrets) Option

+ func WithGitLabAppSecrets(s GitLabAppSecrets) Option

+ func WithGitSourceSecrets(s GitSourceSecrets) Option

+ func WithImageLister(l ImageLister) Option

+ func WithInviteTTL(d time.Duration) Option

+ func WithLogBroadcaster(b *telemetry.LogBroadcaster) Option

+ func WithMasterKeyRotation(r MasterKeyRotator, masterKeyFilePath string) Option

+ func WithNodeAlertThresholds(patchStatus, nodeDiskSpace, nodeCPU, nodeMemory float64) Option

+ func WithNotificationChannelTester(t NotificationChannelTester) Option

+ func WithNotificationChannels(c NotificationChannels) Option

+ func WithNotificationDeliveries(d NotificationDeliveryStore) Option

+ func WithOAuthSecrets(s OAuthSecrets) Option

+ func WithPreviewTTL(d time.Duration) Option

+ func WithPublicHost(host string) Option

+ func WithRegistryAuthTester(t RegistryAuthTester) Option

+ func WithRegistryCredentialSecrets(s RegistryCredentialSecretsSetter) Option

+ func WithRegistrySecrets(s RegistrySecrets) Option

+ func WithResourceRecommendationLookback(d time.Duration) Option

+ func WithRestoreRunner(r RestoreRunner) Option

+ func WithScheduledTaskRunner(r ScheduledTaskRunner) Option

+ func WithSecretSetter(s SecretSetter) Option

+ func WithServiceVolumeBackupRunner(r ServiceVolumeBackupRunner) Option

+ func WithServiceVolumeRestoreRunner(r ServiceVolumeRestoreRunner) Option

+ func WithSessionTTL(d time.Duration) Option

+ func WithTelemetryQuerier(q TelemetryQuerier) Option

+ func WithTwoFactorSecrets(s TwoFactorSecrets) Option

+ func WithVolumeCloneRestoreRunner(r VolumeCloneRestoreRunner) Option

+ type OrganizationStore interface

+ DeleteOrganization func(ctx context.Context, id string) error

+ GetOrganization func(ctx context.Context, id string) (store.Organization, error)

+ ListOrganizationEnvVars func(ctx context.Context, orgID string) (map[string]string, error)

+ ListOrganizations func(ctx context.Context) ([]store.Organization, error)

+ SaveOrganization func(ctx context.Context, o store.Organization) error

+ SetOrganizationEnvVars func(ctx context.Context, orgID string, vars map[string]string) error

+ SetProjectOrganization func(ctx context.Context, projectID, orgID string) error

+ type PasswordResetTokenStore interface

+ ClaimPasswordResetToken func(ctx context.Context, id string) error

+ GetPasswordResetTokenByHash func(ctx context.Context, hash string) (*store.PasswordResetToken, error)

+ SavePasswordResetToken func(ctx context.Context, t store.PasswordResetToken) error

+ type PolicyStore interface

+ AttachPolicy func(ctx context.Context, id, policyID, principalType, principalID string) error

+ DeletePolicy func(ctx context.Context, id string) error

+ DetachPolicy func(ctx context.Context, policyID, principalType, principalID string) error

+ GetPolicy func(ctx context.Context, id string) (*store.Policy, error)

+ ListAttachmentsForPolicy func(ctx context.Context, policyID string) ([]store.PolicyAttachment, error)

+ ListPolicies func(ctx context.Context) ([]store.Policy, error)

+ ListPoliciesForPrincipal func(ctx context.Context, principalType, principalID string) ([]store.Policy, error)

+ SavePolicy func(ctx context.Context, p store.Policy) error

+ UpdatePolicy func(ctx context.Context, id, name, description, document string) error

+ type PreviewEnvironmentStore interface

+ DeletePreviewEnvironment func(ctx context.Context, id string) error

+ GetPreviewEnvironmentByAppAndPR func(ctx context.Context, appName string, prNumber int) (*store.PreviewEnvironment, error)

+ ListPreviewEnvironmentsByApp func(ctx context.Context, appName string) ([]store.PreviewEnvironment, error)

+ ListStalePreviewEnvironments func(ctx context.Context, cutoff time.Time) ([]store.PreviewEnvironment, error)

+ SavePreviewEnvironment func(ctx context.Context, p store.PreviewEnvironment) error

+ UpdatePreviewEnvironment func(ctx context.Context, p store.PreviewEnvironment) error

+ type ProjectStore interface

+ DeleteProject func(ctx context.Context, id string) error

+ GetProject func(ctx context.Context, id string) (store.Project, error)

+ ListProjectEnvVars func(ctx context.Context, projectID string) (map[string]string, error)

+ ListProjects func(ctx context.Context) ([]store.Project, error)

+ SaveProject func(ctx context.Context, p store.Project) error

+ SetProjectEnvVars func(ctx context.Context, projectID string, vars map[string]string) error

+ type RecoveryCodeStore interface

+ ConsumeUserRecoveryCode func(ctx context.Context, userID, hash string) (bool, error)

+ CountUnusedUserRecoveryCodes func(ctx context.Context, userID string) (int, error)

+ DeleteUserRecoveryCodes func(ctx context.Context, userID string) error

+ ReplaceUserRecoveryCodes func(ctx context.Context, userID string, hashes []string) error

+ type RegistryAuthTester interface

+ TestRegistryAuth func(ctx context.Context, host, username, password string) error

+ type RegistryCredentialSecretsSetter interface

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type RegistryCredentialStore interface

+ DeleteRegistryCredential func(ctx context.Context, id string) error

+ GetRegistryCredential func(ctx context.Context, id string) (store.RegistryCredential, error)

+ GetRegistryCredentialByName func(ctx context.Context, name string) (store.RegistryCredential, error)

+ ListRegistryCredentials func(ctx context.Context) ([]store.RegistryCredential, error)

+ SaveRegistryCredential func(ctx context.Context, c store.RegistryCredential) error

+ UpdateRegistryCredential func(ctx context.Context, id, name, registryHost, username string, ...) error

+ type RegistrySecrets interface

+ DeleteAll func(ctx context.Context, serviceName string) error

+ Exists func(ctx context.Context, serviceName, envKey string) (bool, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type RegistryStore interface

+ GetRegistrySettings func(ctx context.Context) (store.RegistrySettings, error)

+ UpdateRegistrySettings func(ctx context.Context, s store.RegistrySettings) error

+ type RestoreHistoryStore interface

+ ListRestoreHistory func(ctx context.Context, databaseName string) ([]store.RestoreHistory, error)

+ type RestoreRunner interface

+ RunRestore func(ctx context.Context, ...) error

+ type Role struct

+ Abilities []string

+ Description string

+ Name string

+ type Router struct

+ func NewRouter(logger *slog.Logger, b *brand.Brand, s Store, opts ...Option) *Router

+ func (rt *Router) CheckDomainStatus(ctx context.Context, domain string) (string, error)

+ func (rt *Router) Handler() http.Handler

+ func (rt *Router) PurgeOldAuditEntries(ctx context.Context) (int64, error)

+ func (rt *Router) RunAuditLogSweeper(ctx context.Context, interval time.Duration) error

+ func (rt *Router) RunPreviewSweeper(ctx context.Context, interval time.Duration) error

+ func (rt *Router) SweepStalePreviewEnvironments(ctx context.Context) (swept int, err error)

+ type ScheduledTaskRunner interface

+ Run func(ctx context.Context, task store.ScheduledTask) error

+ type ScheduledTaskStore interface

+ DeleteScheduledTask func(ctx context.Context, id string) error

+ GetScheduledTask func(ctx context.Context, id string) (store.ScheduledTask, error)

+ ListScheduledTasksForService func(ctx context.Context, serviceName string) ([]store.ScheduledTask, error)

+ SaveScheduledTask func(ctx context.Context, t store.ScheduledTask) error

+ UpdateScheduledTask func(ctx context.Context, id string, command []string, schedule string, ...) error

+ type SecretSetter interface

+ ListKeys func(ctx context.Context, serviceName string) ([]store.SecretKeyInfo, error)

+ SetLocked func(ctx context.Context, serviceName, envKey string, locked bool) error

+ SetValueGuarded func(ctx context.Context, serviceName, envKey, plaintext string, ...) error

+ type ServiceVolumeBackupHistoryStore interface

+ ListServiceVolumeBackupHistory func(ctx context.Context, serviceName, volumeName string, limit int, ...) ([]store.BackupHistory, error)

+ type ServiceVolumeBackupRunner interface

+ RunVolumeBackup func(ctx context.Context, ...) error

+ type ServiceVolumeBackupScheduleStore interface

+ GetServiceVolumeBackupSchedule func(ctx context.Context, serviceName, volumeName string) (store.ServiceVolumeBackupConfig, error)

+ SetServiceVolumeBackupSchedule func(ctx context.Context, serviceName, volumeName, targetID, schedule string, ...) error

+ type ServiceVolumeRestoreHistoryStore interface

+ ListServiceVolumeRestoreHistory func(ctx context.Context, serviceName, volumeName string) ([]store.RestoreHistory, error)

+ type ServiceVolumeRestoreRunner interface

+ RunVolumeRestore func(ctx context.Context, ...) error

+ type Statement struct

+ Action []string

+ Effect Effect

+ Resource []string

+ type StaticSiteStore interface

+ ListStaticSites func(ctx context.Context) ([]store.StaticSite, error)

+ type Store interface

+ type TelemetryQuerier interface

+ QueryLogs func(ctx context.Context, resourceID string, from, to time.Time, query string) ([]telemetry.LogEntry, error)

+ QueryMetrics func(ctx context.Context, resourceID, metric string, from, to time.Time) ([]telemetry.Sample, error)

+ type TokenStore interface

+ GetAPITokenByHash func(ctx context.Context, hash string) (*store.APIToken, error)

+ ListAPITokens func(ctx context.Context) ([]store.APIToken, error)

+ RevokeAPIToken func(ctx context.Context, id string) error

+ SaveAPIToken func(ctx context.Context, t store.APIToken) error

+ TouchAPITokenLastUsed func(ctx context.Context, id string) error

+ type TwoFactorSecrets interface

+ DeleteAll func(ctx context.Context, serviceName string) error

+ Resolve func(ctx context.Context, serviceName, envKey string) (string, error)

+ SetValue func(ctx context.Context, serviceName, envKey, plaintext string) error

+ type VolumeCloneRestoreHistoryStore interface

+ ListVolumeCloneRestores func(ctx context.Context, serviceName, volumeName string) ([]store.VolumeCloneRestore, error)

+ type VolumeCloneRestoreRunner interface

+ RunVolumeCloneRestore func(ctx context.Context, ...) error

+ type WebhookDeliveryStore interface

+ GetWebhookDelivery func(ctx context.Context, id string) (*store.WebhookDelivery, error)

+ ListWebhookDeliveries func(ctx context.Context, serviceName string, limit int, before *time.Time) ([]store.WebhookDelivery, error)

+ SaveWebhookDelivery func(ctx context.Context, d store.WebhookDelivery) error

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