deploy

Documentation

Index

• Constants
• func ApplyGivenInitManifests(ctx context.Context, vClient client.Client, vConfig *rest.Config, ...) error
• func ManifestStringToUnstructuredArray(out, defaultNamespace string) ([]*unstructured.Unstructured, error)
• func RegisterInitManifestsController(controllerCtx *synccontext.ControllerContext) error
• type ChartStatus
• type Deployer
  • func (r *Deployer) Apply(ctx context.Context, vConfig *config.VirtualClusterConfig) (result ctrl.Result, err error)
  • func (r *Deployer) ProcessHelmChart(ctx context.Context, vConfig *config.VirtualClusterConfig, ...) (bool, error)
  • func (r *Deployer) ProcessInitManifests(ctx context.Context, vConfig *config.VirtualClusterConfig, ...) (bool, error)
  • func (r *Deployer) UpdateConfigMap(ctx context.Context, lastError error, requeue bool, ...) error
• type InitObjectStatus
• type KObject
  • func UnstructuredToKObject(obj unstructured.Unstructured) KObject
  • func (k *KObject) Equals(obj unstructured.Unstructured) bool
• type ManifestsStatus
• type Status
  • func ParseStatus(cm *corev1.ConfigMap) *Status
• type UnstructuredMap

Constants

const (
	StatusFailed  InitObjectStatus = "Failed"
	StatusSuccess InitObjectStatus = "Success"
	StatusPending InitObjectStatus = "Pending"

	StatusKey = "vcluster.loft.sh/status"

	DefaultTimeOut = 180 * time.Second
	HelmWorkDir    = "/tmp"

	ChartPullError = "ChartPullFailed"
	InstallError   = "InstallFailed"
	UpgradeError   = "UpgradeFailed"
	UninstallError = "UninstallFailed"

	VClusterDeployConfigMap          = "vcluster-deploy"
	VClusterDeployConfigMapNamespace = "kube-system"
)

Functions

func ApplyGivenInitManifests

func ApplyGivenInitManifests(ctx context.Context, vClient client.Client, vConfig *rest.Config, rawManifests, lastAppliedManifests string) error

func ManifestStringToUnstructuredArray

func ManifestStringToUnstructuredArray(out, defaultNamespace string) ([]*unstructured.Unstructured, error)

func RegisterInitManifestsController

func RegisterInitManifestsController(controllerCtx *synccontext.ControllerContext) error

Types

type ChartStatus

type ChartStatus struct {
	Name                       string `json:"name,omitempty"`
	Namespace                  string `json:"namespace,omitempty"`
	Phase                      string `json:"phase,omitempty"`
	Reason                     string `json:"reason,omitempty"`
	Message                    string `json:"message,omitempty"`
	LastAppliedChartConfigHash string `json:"lastAppliedChartConfigHash,omitempty"`
}

type Deployer

type Deployer struct {
	Log loghelper.Logger

	VirtualManager ctrl.Manager
	HelmClient     helm.Client
}

func (*Deployer) Apply

func (r *Deployer) Apply(ctx context.Context, vConfig *config.VirtualClusterConfig) (result ctrl.Result, err error)

func (*Deployer) ProcessHelmChart

func (r *Deployer) ProcessHelmChart(ctx context.Context, vConfig *config.VirtualClusterConfig, configMap *corev1.ConfigMap) (bool, error)

func (*Deployer) ProcessInitManifests

func (r *Deployer) ProcessInitManifests(ctx context.Context, vConfig *config.VirtualClusterConfig, configMap *corev1.ConfigMap) (bool, error)

func (*Deployer) UpdateConfigMap

func (r *Deployer) UpdateConfigMap(ctx context.Context, lastError error, requeue bool, oldConfigMap *corev1.ConfigMap, newConfigMap *corev1.ConfigMap) error

type InitObjectStatus

type InitObjectStatus string

type KObject

type KObject struct {
	APIVersion string
	Kind       string
	Namespace  string
	Name       string
}

func UnstructuredToKObject

func UnstructuredToKObject(obj unstructured.Unstructured) KObject

func (*KObject) Equals

func (k *KObject) Equals(obj unstructured.Unstructured) bool

type ManifestsStatus

type ManifestsStatus struct {
	Phase                string `json:"phase,omitempty"`
	Reason               string `json:"reason,omitempty"`
	Message              string `json:"message,omitempty"`
	LastAppliedManifests string `json:"lastAppliedManifests,omitempty"`
}

type Status

type Status struct {
	Phase   string `json:"phase,omitempty"`
	Reason  string `json:"reason,omitempty"`
	Message string `json:"message,omitempty"`

	Charts    []ChartStatus   `json:"charts,omitempty"`
	Manifests ManifestsStatus `json:"manifests,omitempty"`
}

func ParseStatus

func ParseStatus(cm *corev1.ConfigMap) *Status

type UnstructuredMap

type UnstructuredMap map[KObject]*unstructured.Unstructured