Documentation
¶
Index ¶
- Constants
- Variables
- func CreateKotsadmIDConfigMap(kotsadmID string) error
- func IsKotsadmIDConfigMapPresent() (bool, error)
- func UpdateKotsadmIDConfigMap(kotsadmID string) error
- 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 (c KOTSStore) GetClientset() (*kubernetes.Clientset, 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) GetLatestPreflightResultsForSequenceZero() (*preflighttypes.PreflightResult, 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) 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) GetReportingInfo(appID string) *upstreamtypes.ReportingInfo
- 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) 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) 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 ¶
const (
SessionSecretName = "kotsadm-sessions"
)
const (
TaskStatusConfigMapName = `kotsadm-tasks`
)
Variables ¶
var (
ErrNotFound = errors.New("not found")
)
var (
KotsadmIDConfigMapName = "kotsadm-id"
)
Functions ¶
func CreateKotsadmIDConfigMap ¶ added in v1.31.0
CreateKotsadmIDConfigMap creates an id for an kotsadm instance and stores in configmap
func IsKotsadmIDConfigMapPresent ¶ added in v1.31.0
IsKotsadmIDConfigMapPresent checks if the configmap for kotsadm-id exists
func UpdateKotsadmIDConfigMap ¶ added in v1.31.0
UpdateKotsadmIDConfigMap creates an id for an kotsadm instance and stores in configmap
Types ¶
type KOTSStore ¶
type KOTSStore struct { }
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) GetClientset ¶ added in v1.31.0
func (c KOTSStore) GetClientset() (*kubernetes.Clientset, 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) GetLatestPreflightResultsForSequenceZero ¶ added in v1.31.0
func (s KOTSStore) GetLatestPreflightResultsForSequenceZero() (*preflighttypes.PreflightResult, 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) 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) GetReportingInfo ¶ added in v1.31.0
func (s KOTSStore) GetReportingInfo(appID string) *upstreamtypes.ReportingInfo
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) 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) 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
- reporting_store.go
- session_store.go
- snapshot_store.go
- sql.go
- supportbundle_store.go
- task_store.go
- version_store.go