kotsadm

Documentation

Index

• func CopyImages(sourceEndpoint string, options types.PushImagesOptions, kotsNamespace string) error
• func DeleteIngress(ctx context.Context, namespace string, clientset *kubernetes.Clientset) error
• func Deploy(deployOptions types.DeployOptions, log *logger.CLILogger) error
• func EnsureConfigMaps(deployOptions types.DeployOptions, clientset *kubernetes.Clientset) error
• func EnsureIngress(ctx context.Context, namespace string, clientset *kubernetes.Clientset, ...) error
• func ExtractAppAirgapArchive(archive string, destDir string, excludeImages bool, progressWriter io.Writer) error
• func GetImagesFromBundle(airgapBundle string, options types.PushImagesOptions) ([]kustomizetypes.Image, error)
• func GetMetadata() types.Metadata
• func GetRegistryConfigFromCluster(namespace string, clientset kubernetes.Interface) (types.RegistryConfig, error)
• func IsAirgap() bool
• func MigrateExistingMinioFilesystemDeployments(log *logger.CLILogger, deployOptions *types.DeployOptions) error
• func PushImages(airgapArchive string, options types.PushImagesOptions) error
• func ReadDeployOptionsFromCluster(namespace string, clientset *kubernetes.Clientset) (*types.DeployOptions, error)
• func TagAndPushAppImagesFromBundle(airgapBundle string, options types.PushImagesOptions) ([]kustomizetypes.Image, error)
• func TagAndPushAppImagesFromPath(imagesDir string, options types.PushImagesOptions) ([]kustomizetypes.Image, error)
• func UpdateToVersion(newVersion string) error
• func Upgrade(clientset *kubernetes.Clientset, upgradeOptions types.UpgradeOptions) error
• func YAML(deployOptions types.DeployOptions) (map[string][]byte, error)
• type ProgressImage
• type ProgressReport
• type UpdateStatus
  • func GetKotsUpdateStatus() (UpdateStatus, string, error)

Functions

func CopyImages

func CopyImages(sourceEndpoint string, options types.PushImagesOptions, kotsNamespace string) error

Copies Admin Console images from public registry to private registry

func DeleteIngress

func DeleteIngress(ctx context.Context, namespace string, clientset *kubernetes.Clientset) error

func Deploy

func Deploy(deployOptions types.DeployOptions, log *logger.CLILogger) error

func EnsureConfigMaps

func EnsureConfigMaps(deployOptions types.DeployOptions, clientset *kubernetes.Clientset) error

func EnsureIngress

func EnsureIngress(ctx context.Context, namespace string, clientset *kubernetes.Clientset, ingressSpec kotsv1beta1.IngressConfigSpec) error

func ExtractAppAirgapArchive

func ExtractAppAirgapArchive(archive string, destDir string, excludeImages bool, progressWriter io.Writer) error

func GetImagesFromBundle

func GetImagesFromBundle(airgapBundle string, options types.PushImagesOptions) ([]kustomizetypes.Image, error)

func GetMetadata

func GetMetadata() types.Metadata

func GetRegistryConfigFromCluster

func GetRegistryConfigFromCluster(namespace string, clientset kubernetes.Interface) (types.RegistryConfig, error)

func IsAirgap

func IsAirgap() bool

func MigrateExistingMinioFilesystemDeployments

func MigrateExistingMinioFilesystemDeployments(log *logger.CLILogger, deployOptions *types.DeployOptions) error

MigrateExistingMinioFilesystemDeployments excutes a migration of minio snapshots deployment to the local-volume-provider plugin and validates the backups are still accessible. The plugin must already be installed on the cluster with velero accessible. This function will configure the plugin and update the default backup storage location. If the backup storage location cannot be updated or the plugin fails, the

func PushImages

func PushImages(airgapArchive string, options types.PushImagesOptions) error

Pushes Admin Console images from airgap bundle to private registry

func ReadDeployOptionsFromCluster

func ReadDeployOptionsFromCluster(namespace string, clientset *kubernetes.Clientset) (*types.DeployOptions, error)

func TagAndPushAppImagesFromBundle

func TagAndPushAppImagesFromBundle(airgapBundle string, options types.PushImagesOptions) ([]kustomizetypes.Image, error)

func TagAndPushAppImagesFromPath

func TagAndPushAppImagesFromPath(imagesDir string, options types.PushImagesOptions) ([]kustomizetypes.Image, error)

func UpdateToVersion

func UpdateToVersion(newVersion string) error

func Upgrade

func Upgrade(clientset *kubernetes.Clientset, upgradeOptions types.UpgradeOptions) error

func YAML

func YAML(deployOptions types.DeployOptions) (map[string][]byte, error)

YAML will return a map containing the YAML needed to run the admin console

Types

type ProgressImage

type ProgressImage struct {
	// image name and tag, "nginx:latest"
	DisplayName string `json:"displayName"`
	// image upload status: queued, uploading, uploaded, failed
	Status string `json:"status"`
	// error string set when status is failed
	Error string `json:"error"`
	// amount currently uploaded (currently number of layers)
	Current int64 `json:"current"`
	// total amount that needs to be uploaded (currently number of layers)
	Total int64 `json:"total"`
	// time when image started uploading
	StartTime time.Time `json:"startTime"`
	// time when image finished uploading
	EndTime time.Time `json:"endTime"`
}

type ProgressReport

type ProgressReport struct {
	// set to "progressReport"
	Type string `json:"type"`
	// the same progress text that used to be sent in unstructured message
	CompatibilityMessage string `json:"compatibilityMessage"`
	// all images found in archive
	Images []ProgressImage `json:"images"`
}

type UpdateStatus

type UpdateStatus string

const (
	UpdateRunning    UpdateStatus = "running"
	UpdateNotFound   UpdateStatus = "not-found"
	UpdateFailed     UpdateStatus = "failed"
	UpdateSuccessful UpdateStatus = "successful"
	UpdateUnknown    UpdateStatus = "unknown"
)

func GetKotsUpdateStatus

func GetKotsUpdateStatus() (UpdateStatus, string, error)