Documentation
¶
Index ¶
- Constants
- type ClientFactory
- type Cluster
- type ConfigureNodePoolLabelsActivity
- type ConfigureNodePoolLabelsActivityInput
- type CreatePipelineNamespaceActivity
- type CreatePipelineNamespaceActivityInput
- type DeployAWSEBSCSIDriverActivity
- type DeployAWSEBSCSIDriverActivityInput
- type DeployClusterAutoscalerActivityInput
- type DeployIngressControllerActivity
- type DeployIngressControllerActivityInput
- type DeployInstanceTerminationHandlerActivity
- type DeployInstanceTerminationHandlerActivityInput
- type DynamicClientFactory
- type DynamicFileClientFactory
- type HelmChartInstallParams
- type HelmInstallActivity
- type HelmInstallActivityInput
- type HelmService
- type InitManifestActivity
- type InitManifestActivityInput
- type InstallNodePoolLabelSetOperatorActivity
- type InstallNodePoolLabelSetOperatorActivityInput
- type LabelKubeSystemNamespaceActivity
- type LabelKubeSystemNamespaceActivityInput
- type Organization
- type RestoreBackupActivityInput
- type Workflow
- type WorkflowInput
Constants ¶
const ( DeployClusterAutoscalerActivityName = "deploy-cluster-autoscaler" RestoreBackupActivityName = "restore-backup" ErrReasonRestoreFailed = "BACKUP_RESTORE_FAILED" )
const ConfigureNodePoolLabelsActivityName = "configure-nodepool-labels"
const CreatePipelineNamespaceActivityName = "create-pipeline-namespace"
const DeployAWSEBSCSIDriverActivityName = "deploy-aws-ebs-csi-driver"
const DeployIngressControllerActivityName = "deploy-ingress-controller"
const DeployInstanceTerminationHandlerActivityName = "deploy-instance-termination-handler"
const HelmInstallActivityName = "cluster-setup-helm-install"
const InitManifestActivityName = "init-manifest"
const InstallNodePoolLabelSetOperatorActivityName = "install-nodepool-labelset-operator"
const LabelKubeSystemNamespaceActivityName = "label-kube-system-namespace"
const WorkflowName = "cluster-setup"
WorkflowName can be used to reference the cluster setup workflow.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientFactory ¶
type ClientFactory interface { // FromSecret creates a Kubernetes client for a cluster from a secret. FromSecret(ctx context.Context, secretID string) (kubernetes.Interface, error) }
ClientFactory returns a Kubernetes client.
type ConfigureNodePoolLabelsActivity ¶
type ConfigureNodePoolLabelsActivity struct {
// contains filtered or unexported fields
}
func NewConfigureNodePoolLabelsActivity ¶
func NewConfigureNodePoolLabelsActivity( namespace string, clientFactory DynamicClientFactory, ) ConfigureNodePoolLabelsActivity
NewConfigureNodePoolLabelsActivity returns a new ConfigureNodePoolLabelsActivity.
func (ConfigureNodePoolLabelsActivity) Execute ¶
func (a ConfigureNodePoolLabelsActivity) Execute(ctx context.Context, input ConfigureNodePoolLabelsActivityInput) error
type CreatePipelineNamespaceActivity ¶
type CreatePipelineNamespaceActivity struct {
// contains filtered or unexported fields
}
func NewCreatePipelineNamespaceActivity ¶
func NewCreatePipelineNamespaceActivity( namespace string, clientFactory ClientFactory, ) CreatePipelineNamespaceActivity
NewCreatePipelineNamespaceActivity returns a new CreatePipelineNamespaceActivity.
func (CreatePipelineNamespaceActivity) Execute ¶
func (a CreatePipelineNamespaceActivity) Execute(ctx context.Context, input CreatePipelineNamespaceActivityInput) error
type CreatePipelineNamespaceActivityInput ¶
type CreatePipelineNamespaceActivityInput struct { // Kubernetes cluster config secret ID. ConfigSecretID string }
type DeployAWSEBSCSIDriverActivity ¶
type DeployAWSEBSCSIDriverActivity struct {
// contains filtered or unexported fields
}
func NewDeployAWSEBSCSIDriverActivity ¶
func NewDeployAWSEBSCSIDriverActivity( config clusterconfig.LabelConfig, helmService HelmService, ) DeployAWSEBSCSIDriverActivity
NewDeployAWSEBSCSIDriverActivity returns a new DeployAWSEBSCSIDriverActivity.
func (DeployAWSEBSCSIDriverActivity) Execute ¶
func (a DeployAWSEBSCSIDriverActivity) Execute(ctx context.Context, input DeployAWSEBSCSIDriverActivityInput) error
type DeployClusterAutoscalerActivityInput ¶
type DeployClusterAutoscalerActivityInput struct {
ClusterID uint
}
type DeployIngressControllerActivity ¶
type DeployIngressControllerActivity struct {
// contains filtered or unexported fields
}
func NewDeployIngressControllerActivity ¶
func NewDeployIngressControllerActivity( config clusterconfig.LabelConfig, helmService HelmService, ) DeployIngressControllerActivity
NewDeployIngressControllerActivity returns a new DeployIngressControllerActivity.
func (DeployIngressControllerActivity) Execute ¶
func (a DeployIngressControllerActivity) Execute(ctx context.Context, input DeployIngressControllerActivityInput) error
type DeployInstanceTerminationHandlerActivity ¶
type DeployInstanceTerminationHandlerActivity struct {
// contains filtered or unexported fields
}
func NewDeployInstanceTerminationHandlerActivity ¶
func NewDeployInstanceTerminationHandlerActivity( config clusterconfig.LabelConfig, helmService HelmService, ) DeployInstanceTerminationHandlerActivity
NewDeployInstanceTerminationHandlerActivity returns a new DeployInstanceTerminationHandlerActivity.
func (DeployInstanceTerminationHandlerActivity) Execute ¶
func (a DeployInstanceTerminationHandlerActivity) Execute(ctx context.Context, input DeployInstanceTerminationHandlerActivityInput) error
type DynamicClientFactory ¶
type DynamicClientFactory interface { // FromSecret creates a Kubernetes client for a cluster from a secret. FromSecret(ctx context.Context, secretID string) (dynamic.Interface, error) }
DynamicClientFactory returns a dynamic Kubernetes client.
type DynamicFileClientFactory ¶
type DynamicFileClientFactory interface { // FromSecret creates a DynamicFileClient for a cluster from a secret. FromSecret(ctx context.Context, secretID string) (k8s.DynamicFileClient, error) }
DynamicFileClientFactory returns a DynamicFileClient.
type HelmChartInstallParams ¶
type HelmInstallActivity ¶
type HelmInstallActivity struct {
// contains filtered or unexported fields
}
func NewHelmInstallActivity ¶
func NewHelmInstallActivity(helmService HelmService) HelmInstallActivity
NewHelmInstallActivity returns a new HelmInstallActivity.
func (HelmInstallActivity) Execute ¶
func (a HelmInstallActivity) Execute(ctx context.Context, input HelmInstallActivityInput) error
type HelmService ¶
type HelmService interface { InstallDeployment( ctx context.Context, clusterID uint, namespace string, chartName string, releaseName string, values []byte, chartVersion string, wait bool, ) error ApplyDeployment( ctx context.Context, clusterID uint, namespace string, chartName string, releaseName string, values []byte, chartVersion string, ) error ApplyDeploymentReuseValues( ctx context.Context, clusterID uint, namespace string, chartName string, releaseName string, values []byte, chartVersion string, reuseValues bool, ) error }
type InitManifestActivity ¶
type InitManifestActivity struct {
// contains filtered or unexported fields
}
func NewInitManifestActivity ¶
func NewInitManifestActivity( manifest *template.Template, clientFactory DynamicFileClientFactory, ) InitManifestActivity
NewInitManifestActivity returns a new InitManifestActivity.
func (InitManifestActivity) Execute ¶
func (a InitManifestActivity) Execute(ctx context.Context, input InitManifestActivityInput) error
type InitManifestActivityInput ¶
type InitManifestActivityInput struct { // Kubernetes cluster config secret ID. ConfigSecretID string // Cluster information Cluster Cluster Organization Organization }
type InstallNodePoolLabelSetOperatorActivity ¶
type InstallNodePoolLabelSetOperatorActivity struct {
// contains filtered or unexported fields
}
func NewInstallNodePoolLabelSetOperatorActivity ¶
func NewInstallNodePoolLabelSetOperatorActivity( config clusterconfig.LabelConfig, helmService HelmService, ) InstallNodePoolLabelSetOperatorActivity
NewInstallNodePoolLabelSetOperatorActivity returns a new InstallNodePoolLabelSetOperatorActivity.
func (InstallNodePoolLabelSetOperatorActivity) Execute ¶
func (a InstallNodePoolLabelSetOperatorActivity) Execute(ctx context.Context, input InstallNodePoolLabelSetOperatorActivityInput) error
type InstallNodePoolLabelSetOperatorActivityInput ¶
type InstallNodePoolLabelSetOperatorActivityInput struct {
ClusterID uint
}
type LabelKubeSystemNamespaceActivity ¶
type LabelKubeSystemNamespaceActivity struct {
// contains filtered or unexported fields
}
func NewLabelKubeSystemNamespaceActivity ¶
func NewLabelKubeSystemNamespaceActivity( clientFactory ClientFactory, ) LabelKubeSystemNamespaceActivity
NewLabelKubeSystemNamespaceActivity returns a new LabelKubeSystemNamespaceActivity.
func (LabelKubeSystemNamespaceActivity) Execute ¶
func (a LabelKubeSystemNamespaceActivity) Execute(ctx context.Context, input LabelKubeSystemNamespaceActivityInput) error
type LabelKubeSystemNamespaceActivityInput ¶
type LabelKubeSystemNamespaceActivityInput struct { // Kubernetes cluster config secret ID. ConfigSecretID string }
type Organization ¶
Organization contains information about the organization a cluster belongs to.
type RestoreBackupActivityInput ¶
type RestoreBackupActivityInput struct { ClusterID uint RestoreBackupParams pkgCluster.RestoreFromBackupParams }
type Workflow ¶
type Workflow struct { // InstallInit InstallInitManifest bool // Drives installation IsIntegratedServicesV2 bool // Install additional Pipeline components here PipelineNamespace string InstallHelmCharts []HelmChartInstallParams }
Workflow orchestrates the post-creation cluster setup flow.
type WorkflowInput ¶
type WorkflowInput struct { // Kubernetes cluster config secret ID. ConfigSecretID string // Cluster information Cluster Cluster Organization Organization NodePoolLabels map[string]map[string]string RestoreBackupParams *pkgCluster.RestoreFromBackupParams }
WorkflowInput is the input for a cluster setup workflow.
Source Files
¶
- activity_configure_nodepool_labels.go
- activity_create_pipeline_namespace.go
- activity_deploy_aws_ebs_csi_driver.go
- activity_deploy_ingress_controller.go
- activity_deploy_instance_termination_handler.go
- activity_helm_install.go
- activity_install_nodepool_labelset_operator.go
- activity_label_kube_system_namespace.go
- activity_manifest.go
- client_factory.go
- helm.go
- workflow.go