cmd

Documentation

Index

• Constants
• func BuildConfig(master, kubeConfig string, f client.Factory) (*rest.Config, error)
• func CheckCSIInstalled(kubeClient kubernetes.Interface) (bool, bool, error)
• func CheckCSIVersion(containers []v1.Container) (bool, bool, error)
• func CheckError(err error)
• func CheckPluginImageRepo(kubeClient kubernetes.Interface, ns string, defaultImage string, ...) (string, error)
• func CheckVSphereCSIDriverVersion(kubeClient kubernetes.Interface) error
• func CheckVeleroVersion(kubeClient kubernetes.Interface, ns string) error
• func CompareVersion(currentVersion string, minVersion string) int
• func CreateFeatureStateConfigMap(kubeClient kubernetes.Interface, features []string, veleroNs string) error
• func Exit(msg string, args ...interface{})
• func GetCompatibleRepoAndTagFromPluginImage(kubeClient kubernetes.Interface, namespace string, targetContainer string) (string, error)
• func GetFeatureFlagsFromImage(containers []v1.Container, containerName string) ([]string, error)
• func GetVeleroFeatureFlags(kubeClient kubernetes.Interface, ns string) ([]string, error)
• func GetVeleroVersion(kubeClient kubernetes.Interface, ns string) (string, error)
• func GetVersionFromImage(containers []v1.Container, imageName string) string
• func GetVersionFromImageByContainerName(containers []v1.Container, containerName string) string

Constants

const (
	// the port where prometheus metrics are exposed
	DefaultMetricsAddress = ":8085"

	// server's client default qps and burst
	DefaultClientQPS   float32 = 20.0
	DefaultClientBurst int     = 30

	DefaultProfilerAddress         = "localhost:6060"
	DefaultInsecureFlag       bool = true
	DefaultVCConfigFromSecret bool = true

	DefaultBackupWorkers      = 1
	DefaultRetryIntervalStart = time.Second
	DefaultRetryIntervalMax   = 5 * time.Minute
)

Functions

func BuildConfig

func BuildConfig(master, kubeConfig string, f client.Factory) (*rest.Config, error)

func CheckCSIInstalled

func CheckCSIInstalled(kubeClient kubernetes.Interface) (bool, bool, error)

func CheckCSIVersion

func CheckCSIVersion(containers []v1.Container) (bool, bool, error)

func CheckError

func CheckError(err error)

CheckError prints err to stderr and exits with code 1 if err is not nil. Otherwise, it is a no-op.

func CheckPluginImageRepo

func CheckPluginImageRepo(kubeClient kubernetes.Interface, ns string, defaultImage string, serverType string) (string, error)

func CheckVSphereCSIDriverVersion

func CheckVSphereCSIDriverVersion(kubeClient kubernetes.Interface) error

func CheckVeleroVersion

func CheckVeleroVersion(kubeClient kubernetes.Interface, ns string) error

func CompareVersion

func CompareVersion(currentVersion string, minVersion string) int

If currentVersion < minVersion, return -1 If currentVersion == minVersion, return 0 If currentVersion > minVersion, return 1 Assume input versions are both valid

func CreateFeatureStateConfigMap

func CreateFeatureStateConfigMap(kubeClient kubernetes.Interface, features []string, veleroNs string) error

func Exit

func Exit(msg string, args ...interface{})

Exit prints msg (with optional args), plus a newline, to stderr and exits with code 1.

func GetCompatibleRepoAndTagFromPluginImage

func GetCompatibleRepoAndTagFromPluginImage(kubeClient kubernetes.Interface, namespace string, targetContainer string) (string, error)

func GetFeatureFlagsFromImage

func GetFeatureFlagsFromImage(containers []v1.Container, containerName string) ([]string, error)

func GetVeleroFeatureFlags

func GetVeleroFeatureFlags(kubeClient kubernetes.Interface, ns string) ([]string, error)

func GetVeleroVersion

func GetVeleroVersion(kubeClient kubernetes.Interface, ns string) (string, error)

func GetVersionFromImage

func GetVersionFromImage(containers []v1.Container, imageName string) string

Return version in the format: vX.Y.Z

func GetVersionFromImageByContainerName

func GetVersionFromImageByContainerName(containers []v1.Container, containerName string) string

Return version in the format: vX.Y.Z