Documentation
¶
Index ¶
- Constants
- Variables
- type KOTSStore
- func (s *KOTSStore) AddAppToAllDownstreams(appID string) error
- func (s *KOTSStore) ClearTaskStatus(id string) error
- func (s *KOTSStore) CreateApp(name string, upstreamURI string, licenseData string, isAirgapEnabled bool, ...) (*apptypes.App, error)
- func (s *KOTSStore) CreateAppVersion(appID string, currentSequence *int64, filesInDir string, source string, ...) (int64, error)
- func (s *KOTSStore) CreateAppVersionArchive(appID string, sequence int64, archivePath string) error
- func (s *KOTSStore) CreateNewCluster(userID string, isAllUsers bool, title string, token string) (string, error)
- func (s *KOTSStore) CreatePendingSupportBundle(id string, appID string, clusterID string) error
- func (s *KOTSStore) CreateScheduledInstanceSnapshot(id string, clusterID string, timestamp time.Time) error
- func (s *KOTSStore) CreateScheduledSnapshot(id string, appID string, timestamp time.Time) error
- func (s *KOTSStore) CreateSession(forUser *usertypes.User, issuedAt time.Time, expiresAt time.Time, ...) (*sessiontypes.Session, error)
- func (s *KOTSStore) CreateSupportBundle(id string, appID string, archivePath string, marshalledTree []byte) (*types.SupportBundle, error)
- func (s *KOTSStore) DeletePendingScheduledInstanceSnapshots(clusterID string) error
- func (s *KOTSStore) DeletePendingScheduledSnapshots(appID string) error
- func (s *KOTSStore) DeletePendingSupportBundle(id string) error
- func (s *KOTSStore) DeleteSession(id string) error
- func (s *KOTSStore) GetAirgapInstallStatus(appID string) (*airgaptypes.InstallStatus, error)
- func (s *KOTSStore) GetAllAppLicenses() ([]*kotsv1beta1.License, error)
- func (s *KOTSStore) GetApp(id string) (*apptypes.App, error)
- func (s *KOTSStore) GetAppFromSlug(slug string) (*apptypes.App, error)
- func (s *KOTSStore) GetAppIDFromSlug(slug string) (string, error)
- func (s *KOTSStore) GetAppStatus(appID string) (*appstatustypes.AppStatus, error)
- func (s *KOTSStore) GetAppVersion(appID string, sequence int64) (*versiontypes.AppVersion, error)
- func (s *KOTSStore) GetAppVersionArchive(appID string, sequence int64, dstPath string) error
- func (s *KOTSStore) GetAppVersionsAfter(appID string, sequence int64) ([]*versiontypes.AppVersion, error)
- func (s *KOTSStore) GetClusterIDFromDeployToken(deployToken string) (string, error)
- func (s *KOTSStore) GetClusterIDFromSlug(slug string) (string, error)
- func (s *KOTSStore) GetDownstream(clusterID string) (*downstreamtypes.Downstream, error)
- func (s *KOTSStore) GetLatestLicenseForApp(appID string) (*kotsv1beta1.License, error)
- func (s *KOTSStore) GetLicenseForAppVersion(appID string, sequence int64) (*kotsv1beta1.License, error)
- func (s *KOTSStore) GetPendingAirgapUploadApp() (*airgaptypes.PendingApp, error)
- func (s *KOTSStore) GetPendingInstallationStatus() (*installationtypes.InstallStatus, error)
- func (s *KOTSStore) GetPreflightProgress(appID string, sequence int64) (string, error)
- func (s *KOTSStore) GetPreflightResults(appID string, sequence int64) (*preflighttypes.PreflightResult, error)
- func (s *KOTSStore) GetPrometheusAddress() (string, error)
- func (s *KOTSStore) GetRedactions(id string) (troubleshootredact.RedactionList, error)
- func (s *KOTSStore) GetRegistryDetailsForApp(appID string) (*registrytypes.RegistrySettings, error)
- func (s *KOTSStore) GetSession(id string) (*sessiontypes.Session, error)
- func (s *KOTSStore) GetSupportBundle(id string) (*types.SupportBundle, error)
- func (s *KOTSStore) GetSupportBundleAnalysis(id string) (*types.SupportBundleAnalysis, error)
- func (s *KOTSStore) GetSupportBundleArchive(bundleID string) (string, error)
- func (s *KOTSStore) GetSupportBundleSpecForApp(id string) (string, error)
- func (s *KOTSStore) GetTaskStatus(id string) (string, string, error)
- func (s *KOTSStore) Init() error
- func (s *KOTSStore) IsGitOpsEnabledForApp(appID string) (bool, error)
- func (s *KOTSStore) IsIdentityServiceSupportedForVersion(appID string, sequence int64) (bool, error)
- func (s *KOTSStore) IsKotsadmIDGenerated() (bool, error)
- func (s *KOTSStore) IsNotFound(err error) bool
- func (s *KOTSStore) IsRollbackSupportedForVersion(appID string, sequence int64) (bool, error)
- func (s *KOTSStore) IsSnapshotsSupportedForVersion(a *apptypes.App, sequence int64, renderer rendertypes.Renderer) (bool, error)
- func (s *KOTSStore) ListAppsForDownstream(clusterID string) ([]*apptypes.App, error)
- func (s *KOTSStore) ListClusters() ([]*downstreamtypes.Downstream, error)
- func (s *KOTSStore) ListDownstreamsForApp(appID string) ([]downstreamtypes.Downstream, error)
- func (s *KOTSStore) ListInstalledAppSlugs() ([]string, error)
- func (s *KOTSStore) ListInstalledApps() ([]*apptypes.App, error)
- func (s *KOTSStore) ListPendingScheduledInstanceSnapshots(clusterID string) ([]snapshottypes.ScheduledInstanceSnapshot, error)
- func (s *KOTSStore) ListPendingScheduledSnapshots(appID string) ([]snapshottypes.ScheduledSnapshot, error)
- func (s *KOTSStore) ListPendingSupportBundlesForApp(appID string) ([]*types.PendingSupportBundle, error)
- func (s *KOTSStore) ListSupportBundles(appID string) ([]*types.SupportBundle, error)
- func (s *KOTSStore) RemoveApp(appID string) error
- func (s *KOTSStore) ResetAirgapInstallInProgress(appID string) error
- func (s *KOTSStore) ResetPreflightResults(appID string, sequence int64) error
- func (s *KOTSStore) RunMigrations()
- func (s *KOTSStore) SetAppInstallState(appID string, state string) error
- func (s *KOTSStore) SetAppIsAirgap(appID string, isAirgap bool) error
- func (s *KOTSStore) SetAppStatus(appID string, resourceStates []appstatustypes.ResourceState, ...) error
- func (s *KOTSStore) SetIgnorePreflightPermissionErrors(appID string, sequence int64) error
- func (s *KOTSStore) SetInstanceSnapshotSchedule(clusterID string, snapshotSchedule string) error
- func (s *KOTSStore) SetInstanceSnapshotTTL(clusterID string, snapshotTTL string) error
- func (s *KOTSStore) SetIsKotsadmIDGenerated() error
- func (s *KOTSStore) SetPreflightProgress(appID string, sequence int64, progress string) error
- func (s *KOTSStore) SetPreflightResults(appID string, sequence int64, results []byte) error
- func (s *KOTSStore) SetPrometheusAddress(address string) error
- func (s *KOTSStore) SetRedactions(id string, redacts troubleshootredact.RedactionList) error
- func (s *KOTSStore) SetSnapshotSchedule(appID string, snapshotSchedule string) error
- func (s *KOTSStore) SetSnapshotTTL(appID string, snapshotTTL string) error
- func (s *KOTSStore) SetSupportBundleAnalysis(id string, results []byte) error
- func (s *KOTSStore) SetTaskStatus(id string, message string, status string) error
- func (s *KOTSStore) SetUpdateCheckerSpec(appID string, updateCheckerSpec string) error
- func (s *KOTSStore) UpdateAppLicense(appID string, sequence int64, archiveDir string, ...) (int64, error)
- func (s *KOTSStore) UpdateRegistry(appID string, hostname string, username string, password string, ...) error
- func (s *KOTSStore) UpdateScheduledInstanceSnapshot(snapshotID string, backupName string) error
- func (s *KOTSStore) UpdateScheduledSnapshot(snapshotID string, backupName string) error
- func (s *KOTSStore) UpdateTaskStatusTimestamp(id string) error
- func (s *KOTSStore) WaitForReady(ctx context.Context) error
- type SessionMetadata
Constants ¶
View Source
const (
SessionSecretName = "kotsadm-sessions"
)
View Source
const (
TaskStatusConfigMapName = `kotsadm-tasks`
)
Variables ¶
View Source
var (
ErrNotFound = errors.New("not found")
)
Functions ¶
This section is empty.
Types ¶
type KOTSStore ¶
type KOTSStore struct {
// contains filtered or unexported fields
}
func StoreFromEnv ¶
func StoreFromEnv() *KOTSStore
func (*KOTSStore) AddAppToAllDownstreams ¶
func (*KOTSStore) ClearTaskStatus ¶
func (*KOTSStore) CreateAppVersion ¶
func (s *KOTSStore) CreateAppVersion(appID string, currentSequence *int64, filesInDir string, source string, skipPreflights bool, gitops gitopstypes.DownstreamGitOps) (int64, error)
func (*KOTSStore) CreateAppVersionArchive ¶
CreateAppVersion takes an unarchived app, makes an archive and then uploads it to s3 with the appID and sequence specified
func (*KOTSStore) CreateNewCluster ¶
func (*KOTSStore) CreatePendingSupportBundle ¶ added in v1.31.0
func (*KOTSStore) CreateScheduledInstanceSnapshot ¶
func (*KOTSStore) CreateScheduledSnapshot ¶
func (*KOTSStore) CreateSession ¶
func (*KOTSStore) CreateSupportBundle ¶
func (*KOTSStore) DeletePendingScheduledInstanceSnapshots ¶
func (*KOTSStore) DeletePendingScheduledSnapshots ¶
func (*KOTSStore) DeletePendingSupportBundle ¶ added in v1.32.0
func (*KOTSStore) DeleteSession ¶
func (*KOTSStore) GetAirgapInstallStatus ¶
func (s *KOTSStore) GetAirgapInstallStatus(appID string) (*airgaptypes.InstallStatus, error)
func (*KOTSStore) GetAllAppLicenses ¶
func (s *KOTSStore) GetAllAppLicenses() ([]*kotsv1beta1.License, error)
func (*KOTSStore) GetAppFromSlug ¶
func (*KOTSStore) GetAppIDFromSlug ¶
func (*KOTSStore) GetAppStatus ¶
func (s *KOTSStore) GetAppStatus(appID string) (*appstatustypes.AppStatus, error)
func (*KOTSStore) GetAppVersion ¶
func (s *KOTSStore) GetAppVersion(appID string, sequence int64) (*versiontypes.AppVersion, error)
func (*KOTSStore) GetAppVersionArchive ¶
GetAppVersionArchive will fetch the archive and return a string that contains a directory name where it's extracted into
func (*KOTSStore) GetAppVersionsAfter ¶ added in v1.31.0
func (s *KOTSStore) GetAppVersionsAfter(appID string, sequence int64) ([]*versiontypes.AppVersion, error)
func (*KOTSStore) GetClusterIDFromDeployToken ¶
func (*KOTSStore) GetClusterIDFromSlug ¶
func (*KOTSStore) GetDownstream ¶
func (s *KOTSStore) GetDownstream(clusterID string) (*downstreamtypes.Downstream, error)
func (*KOTSStore) GetLatestLicenseForApp ¶
func (s *KOTSStore) GetLatestLicenseForApp(appID string) (*kotsv1beta1.License, error)
func (*KOTSStore) GetLicenseForAppVersion ¶
func (*KOTSStore) GetPendingAirgapUploadApp ¶
func (s *KOTSStore) GetPendingAirgapUploadApp() (*airgaptypes.PendingApp, error)
func (*KOTSStore) GetPendingInstallationStatus ¶
func (s *KOTSStore) GetPendingInstallationStatus() (*installationtypes.InstallStatus, error)
func (*KOTSStore) GetPreflightProgress ¶
func (*KOTSStore) GetPreflightResults ¶
func (s *KOTSStore) GetPreflightResults(appID string, sequence int64) (*preflighttypes.PreflightResult, error)
func (*KOTSStore) GetPrometheusAddress ¶
func (*KOTSStore) GetRedactions ¶
func (s *KOTSStore) GetRedactions(id string) (troubleshootredact.RedactionList, error)
func (*KOTSStore) GetRegistryDetailsForApp ¶
func (s *KOTSStore) GetRegistryDetailsForApp(appID string) (*registrytypes.RegistrySettings, error)
func (*KOTSStore) GetSession ¶
func (s *KOTSStore) GetSession(id string) (*sessiontypes.Session, error)
func (*KOTSStore) GetSupportBundle ¶
func (s *KOTSStore) GetSupportBundle(id string) (*types.SupportBundle, error)
func (*KOTSStore) GetSupportBundleAnalysis ¶
func (s *KOTSStore) GetSupportBundleAnalysis(id string) (*types.SupportBundleAnalysis, error)
func (*KOTSStore) GetSupportBundleArchive ¶
GetSupportBundle will fetch the bundle archive and return a path to where it is stored. The caller is responsible for deleting.
func (*KOTSStore) GetSupportBundleSpecForApp ¶ added in v1.31.0
func (*KOTSStore) GetTaskStatus ¶
func (*KOTSStore) IsGitOpsEnabledForApp ¶
func (*KOTSStore) IsIdentityServiceSupportedForVersion ¶
func (*KOTSStore) IsKotsadmIDGenerated ¶
IsKotsadmIDGenerated retrieves the id of kotsadm if the pod is already
func (*KOTSStore) IsNotFound ¶
func (*KOTSStore) IsRollbackSupportedForVersion ¶
func (*KOTSStore) IsSnapshotsSupportedForVersion ¶
func (*KOTSStore) ListAppsForDownstream ¶
func (*KOTSStore) ListClusters ¶
func (s *KOTSStore) ListClusters() ([]*downstreamtypes.Downstream, error)
func (*KOTSStore) ListDownstreamsForApp ¶
func (s *KOTSStore) ListDownstreamsForApp(appID string) ([]downstreamtypes.Downstream, error)
func (*KOTSStore) ListInstalledAppSlugs ¶
func (*KOTSStore) ListInstalledApps ¶
func (*KOTSStore) ListPendingScheduledInstanceSnapshots ¶
func (s *KOTSStore) ListPendingScheduledInstanceSnapshots(clusterID string) ([]snapshottypes.ScheduledInstanceSnapshot, error)
func (*KOTSStore) ListPendingScheduledSnapshots ¶
func (s *KOTSStore) ListPendingScheduledSnapshots(appID string) ([]snapshottypes.ScheduledSnapshot, error)
func (*KOTSStore) ListPendingSupportBundlesForApp ¶ added in v1.31.0
func (s *KOTSStore) ListPendingSupportBundlesForApp(appID string) ([]*types.PendingSupportBundle, error)
func (*KOTSStore) ListSupportBundles ¶
func (s *KOTSStore) ListSupportBundles(appID string) ([]*types.SupportBundle, error)
func (*KOTSStore) ResetAirgapInstallInProgress ¶
func (*KOTSStore) ResetPreflightResults ¶
func (*KOTSStore) RunMigrations ¶
func (s *KOTSStore) RunMigrations()
func (*KOTSStore) SetAppInstallState ¶
func (*KOTSStore) SetAppIsAirgap ¶
func (*KOTSStore) SetAppStatus ¶
func (s *KOTSStore) SetAppStatus(appID string, resourceStates []appstatustypes.ResourceState, updatedAt time.Time) error
func (*KOTSStore) SetIgnorePreflightPermissionErrors ¶
func (*KOTSStore) SetInstanceSnapshotSchedule ¶
func (*KOTSStore) SetInstanceSnapshotTTL ¶
func (*KOTSStore) SetIsKotsadmIDGenerated ¶
SetIsKotsadmIDGenerated sets the status to true if the pod is starting for the first time
func (*KOTSStore) SetPreflightProgress ¶
func (*KOTSStore) SetPreflightResults ¶
func (*KOTSStore) SetPrometheusAddress ¶
func (*KOTSStore) SetRedactions ¶
func (s *KOTSStore) SetRedactions(id string, redacts troubleshootredact.RedactionList) error
func (*KOTSStore) SetSnapshotSchedule ¶
func (*KOTSStore) SetSnapshotTTL ¶
func (*KOTSStore) SetSupportBundleAnalysis ¶
func (*KOTSStore) SetTaskStatus ¶
func (*KOTSStore) SetUpdateCheckerSpec ¶
func (*KOTSStore) UpdateAppLicense ¶
func (s *KOTSStore) UpdateAppLicense(appID string, sequence int64, archiveDir string, newLicense *kotsv1beta1.License, originalLicenseData string, failOnVersionCreate bool, gitops gitopstypes.DownstreamGitOps, renderer rendertypes.Renderer) (int64, error)
func (*KOTSStore) UpdateRegistry ¶
func (*KOTSStore) UpdateScheduledInstanceSnapshot ¶
func (*KOTSStore) UpdateScheduledSnapshot ¶
func (*KOTSStore) UpdateTaskStatusTimestamp ¶
type SessionMetadata ¶
type SessionMetadata struct {
Roles []string
}
Source Files
¶
- airgap_store.go
- app_store.go
- appstatus_store.go
- cluster_store.go
- installation_store.go
- kots_store.go
- kotsadm_params_store.go
- license_store.go
- migrations.go
- preflight_store.go
- prometheus_store.go
- registry_store.go
- session_store.go
- snapshot_store.go
- sql.go
- supportbundle_store.go
- task_store.go
- version_store.go
Click to show internal directories.
Click to hide internal directories.