deckhouse

Documentation

Index

• Constants
• Variables
• func ConfigureReleaseChannel(kubeCl *client.KubernetesClient, cfg *config.DeckhouseInstaller) error
• func ConvergeDeckhouseConfiguration(ctx context.Context, kubeCl *client.KubernetesClient, clusterUUID string, ...) error
• func CreateDeckhouseDeployment(kubeCl *client.KubernetesClient, cfg *config.DeckhouseInstaller) error
• func CreateDeckhouseDeploymentManifest(cfg *config.DeckhouseInstaller) *appsv1.Deployment
• func CreateDeckhouseManifests(kubeCl *client.KubernetesClient, cfg *config.DeckhouseInstaller) error
• func DeleteCAPIMachineDeployments(kubeCl *client.KubernetesClient) error
• func DeleteDeckhouseDeployment(kubeCl *client.KubernetesClient) error
• func DeleteMCMMachineDeployments(kubeCl *client.KubernetesClient) error
• func DeleteMachinesIfResourcesExist(kubeCl *client.KubernetesClient) error
• func DeletePVC(kubeCl *client.KubernetesClient) error
• func DeletePods(kubeCl *client.KubernetesClient) error
• func DeleteServices(kubeCl *client.KubernetesClient) error
• func DeleteStorageClasses(kubeCl *client.KubernetesClient) error
• func GetPod(kubeCl *client.KubernetesClient, leaderElectionLeaseName types.NamespacedName) (*v1.Pod, error)
• func LockDeckhouseQueueBeforeCreatingModuleConfigs(kubeCl *client.KubernetesClient) (*actions.ManifestTask, error)
• func UnlockDeckhouseQueueAfterCreatingModuleConfigs(kubeCl *client.KubernetesClient) error
• func WaitForCAPIMachinesDeletion(kubeCl *client.KubernetesClient) error
• func WaitForDeckhouseDeploymentDeletion(kubeCl *client.KubernetesClient) error
• func WaitForKubernetesAPI(kubeCl *client.KubernetesClient) error
• func WaitForMCMMachinesDeletion(kubeCl *client.KubernetesClient) error
• func WaitForPVCDeletion(kubeCl *client.KubernetesClient) error
• func WaitForPVDeletion(kubeCl *client.KubernetesClient) error
• func WaitForReadiness(kubeCl *client.KubernetesClient) error
• func WaitForReadinessNotOnNode(kubeCl *client.KubernetesClient, excludeNode string) error
• func WaitForServicesDeletion(kubeCl *client.KubernetesClient) error
• type LogPrinter
  • func NewLogPrinter(kubeCl *client.KubernetesClient) *LogPrinter
  • func (d *LogPrinter) GetPod() error
  • func (d *LogPrinter) Print(ctx context.Context) (bool, error)
  • func (d *LogPrinter) WaitPodBecomeReady() *LogPrinter
  • func (d *LogPrinter) WithExcludeNode(nodeName string) *LogPrinter
  • func (d *LogPrinter) WithLeaderElectionAwarenessMode(leaderElectionLease types.NamespacedName) *LogPrinter

Constants

const (
	MCMGroup        = "machine.sapcloud.io"
	MCMGroupVersion = "v1alpha1"
)

mcm

const (
	CAPIGroup        = "cluster.x-k8s.io"
	CAPIGroupVersion = "v1beta1"
)

CAPI

Variables

var (
	ErrListPods      = errors.New("No Deckhouse pod found.")
	ErrReadLease     = errors.New("No Deckhouse leader election lease found.")
	ErrBadLease      = errors.New("Deckhouse leader election lease is malformed.")
	ErrTimedOut      = errors.New("Time is out waiting for Deckhouse readiness.")
	ErrRequestFailed = errors.New("Request failed. Probably pod was restarted during installation.")
	ErrIncorrectNode = errors.New("Deckhouse on wrong node")
)

Functions

func ConfigureReleaseChannel

func ConfigureReleaseChannel(kubeCl *client.KubernetesClient, cfg *config.DeckhouseInstaller) error

func ConvergeDeckhouseConfiguration

func ConvergeDeckhouseConfiguration(ctx context.Context, kubeCl *client.KubernetesClient, clusterUUID string, clusterConfig []byte, providerClusterConfig []byte) error

ConvergeDeckhouseConfiguration – reconciles deckhouse in-cluster configmaps and secrets. This function used in commander-mode, which stores primary configuration in the storage outside of cluster, and periodically reconciles configuration inside cluster to match configuration stored outside of cluster.

func CreateDeckhouseDeployment

func CreateDeckhouseDeployment(kubeCl *client.KubernetesClient, cfg *config.DeckhouseInstaller) error

func CreateDeckhouseDeploymentManifest

func CreateDeckhouseDeploymentManifest(cfg *config.DeckhouseInstaller) *appsv1.Deployment

func CreateDeckhouseManifests

func CreateDeckhouseManifests(kubeCl *client.KubernetesClient, cfg *config.DeckhouseInstaller) error

func DeleteCAPIMachineDeployments

func DeleteCAPIMachineDeployments(kubeCl *client.KubernetesClient) error

func DeleteDeckhouseDeployment

func DeleteDeckhouseDeployment(kubeCl *client.KubernetesClient) error

func DeleteMCMMachineDeployments

func DeleteMCMMachineDeployments(kubeCl *client.KubernetesClient) error

func DeleteMachinesIfResourcesExist

func DeleteMachinesIfResourcesExist(kubeCl *client.KubernetesClient) error

func DeletePVC

func DeletePVC(kubeCl *client.KubernetesClient) error

func DeletePods

func DeletePods(kubeCl *client.KubernetesClient) error

func DeleteServices

func DeleteServices(kubeCl *client.KubernetesClient) error

func DeleteStorageClasses

func DeleteStorageClasses(kubeCl *client.KubernetesClient) error

func GetPod

func GetPod(kubeCl *client.KubernetesClient, leaderElectionLeaseName types.NamespacedName) (*v1.Pod, error)

func LockDeckhouseQueueBeforeCreatingModuleConfigs

func LockDeckhouseQueueBeforeCreatingModuleConfigs(kubeCl *client.KubernetesClient) (*actions.ManifestTask, error)

func UnlockDeckhouseQueueAfterCreatingModuleConfigs

func UnlockDeckhouseQueueAfterCreatingModuleConfigs(kubeCl *client.KubernetesClient) error

func WaitForCAPIMachinesDeletion

func WaitForCAPIMachinesDeletion(kubeCl *client.KubernetesClient) error

func WaitForDeckhouseDeploymentDeletion

func WaitForDeckhouseDeploymentDeletion(kubeCl *client.KubernetesClient) error

func WaitForKubernetesAPI

func WaitForKubernetesAPI(kubeCl *client.KubernetesClient) error

func WaitForMCMMachinesDeletion

func WaitForMCMMachinesDeletion(kubeCl *client.KubernetesClient) error

func WaitForPVCDeletion

func WaitForPVCDeletion(kubeCl *client.KubernetesClient) error

func WaitForPVDeletion

func WaitForPVDeletion(kubeCl *client.KubernetesClient) error

func WaitForReadiness

func WaitForReadiness(kubeCl *client.KubernetesClient) error

func WaitForReadinessNotOnNode

func WaitForReadinessNotOnNode(kubeCl *client.KubernetesClient, excludeNode string) error

func WaitForServicesDeletion

func WaitForServicesDeletion(kubeCl *client.KubernetesClient) error

Types

type LogPrinter

type LogPrinter struct {
	// contains filtered or unexported fields
}

func NewLogPrinter

func NewLogPrinter(kubeCl *client.KubernetesClient) *LogPrinter

func (*LogPrinter) GetPod

func (d *LogPrinter) GetPod() error

func (*LogPrinter) Print

func (d *LogPrinter) Print(ctx context.Context) (bool, error)

func (*LogPrinter) WaitPodBecomeReady

func (d *LogPrinter) WaitPodBecomeReady() *LogPrinter

func (*LogPrinter) WithExcludeNode

func (d *LogPrinter) WithExcludeNode(nodeName string) *LogPrinter

func (*LogPrinter) WithLeaderElectionAwarenessMode

func (d *LogPrinter) WithLeaderElectionAwarenessMode(leaderElectionLease types.NamespacedName) *LogPrinter