Documentation ¶
Index ¶
- Constants
- func DeleteK8sResourcesWorkflow(ctx workflow.Context, input DeleteK8sResourcesWorkflowInput) error
- type ClientFactory
- type ClusterDNSRecordsDeleter
- type DeleteClusterDNSRecordsActivity
- type DeleteClusterDNSRecordsActivityInput
- type DeleteHelmDeploymentsActivity
- type DeleteHelmDeploymentsActivityInput
- type DeleteK8sResourcesWorkflowInput
- type DeleteNamespaceResourcesActivity
- type DeleteNamespaceResourcesActivityInput
- type DeleteNamespaceServicesActivity
- type DeleteNamespaceServicesActivityInput
- type DeleteUnusedClusterSecretsActivity
- type DeleteUnusedClusterSecretsActivityInput
- type DeleteUserNamespacesActivity
- type DeleteUserNamespacesActivityInput
- type DeleteUserNamespacesActivityOutput
- type HealthCheckActivity
- type HealthCheckActivityInput
- type HealthChecker
- type K8sConfigGetter
- type NamespaceResourcesDeleter
- type NamespaceServicesDeleter
- type SecretStore
- type UserNamespaceDeleter
- type WaitPersistentVolumesDeletionActivity
- type WaitPersistentVolumesDeletionActivityInput
Constants ¶
View Source
const DeleteClusterDNSRecordsActivityName = "delete-cluster-dns-records"
View Source
const DeleteHelmDeploymentsActivityName = "delete-helm-deployments"
View Source
const DeleteK8sResourcesWorkflowName = "delete-k8s-resources"
View Source
const DeleteNamespaceResourcesActivityName = "delete-namespace-resources"
View Source
const DeleteNamespaceServicesActivityName = "delete-namespace-services"
View Source
const DeleteUnusedClusterSecretsActivityName = "delete-unused-cluster-secrets"
View Source
const DeleteUserNamespacesActivityName = "delete-user-namespaces"
View Source
const HealthCheckActivityName = "k8s-health-check"
View Source
const WaitPersistentVolumesDeletionActivityName = "wait-persistent-volumes-deletion"
Variables ¶
This section is empty.
Functions ¶
func DeleteK8sResourcesWorkflow ¶
func DeleteK8sResourcesWorkflow(ctx workflow.Context, input DeleteK8sResourcesWorkflowInput) error
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 DeleteClusterDNSRecordsActivity ¶
type DeleteClusterDNSRecordsActivity struct {
// contains filtered or unexported fields
}
func MakeDeleteClusterDNSRecordsActivity ¶
func MakeDeleteClusterDNSRecordsActivity(deleter ClusterDNSRecordsDeleter) DeleteClusterDNSRecordsActivity
func (DeleteClusterDNSRecordsActivity) Execute ¶
func (a DeleteClusterDNSRecordsActivity) Execute(ctx context.Context, input DeleteClusterDNSRecordsActivityInput) error
type DeleteHelmDeploymentsActivity ¶
type DeleteHelmDeploymentsActivity struct {
// contains filtered or unexported fields
}
func MakeDeleteHelmDeploymentsActivity ¶
func MakeDeleteHelmDeploymentsActivity(k8sConfigGetter K8sConfigGetter, releaseDeleter helm.ReleaseDeleter, logger logrus.FieldLogger) DeleteHelmDeploymentsActivity
func (DeleteHelmDeploymentsActivity) Execute ¶
func (a DeleteHelmDeploymentsActivity) Execute(ctx context.Context, input DeleteHelmDeploymentsActivityInput) error
type DeleteNamespaceResourcesActivity ¶
type DeleteNamespaceResourcesActivity struct {
// contains filtered or unexported fields
}
func MakeDeleteNamespaceResourcesActivity ¶
func MakeDeleteNamespaceResourcesActivity(deleter NamespaceResourcesDeleter, k8sConfigGetter K8sConfigGetter) DeleteNamespaceResourcesActivity
func (DeleteNamespaceResourcesActivity) Execute ¶
func (a DeleteNamespaceResourcesActivity) Execute(ctx context.Context, input DeleteNamespaceResourcesActivityInput) error
type DeleteNamespaceServicesActivity ¶
type DeleteNamespaceServicesActivity struct {
// contains filtered or unexported fields
}
func MakeDeleteNamespaceServicesActivity ¶
func MakeDeleteNamespaceServicesActivity(deleter NamespaceServicesDeleter, k8sConfigGetter K8sConfigGetter) DeleteNamespaceServicesActivity
func (DeleteNamespaceServicesActivity) Execute ¶
func (a DeleteNamespaceServicesActivity) Execute(ctx context.Context, input DeleteNamespaceServicesActivityInput) error
type DeleteUnusedClusterSecretsActivity ¶
type DeleteUnusedClusterSecretsActivity struct {
// contains filtered or unexported fields
}
func MakeDeleteUnusedClusterSecretsActivity ¶
func MakeDeleteUnusedClusterSecretsActivity(secrets SecretStore) DeleteUnusedClusterSecretsActivity
func (DeleteUnusedClusterSecretsActivity) Execute ¶
func (a DeleteUnusedClusterSecretsActivity) Execute(_ context.Context, input DeleteUnusedClusterSecretsActivityInput) error
type DeleteUserNamespacesActivity ¶
type DeleteUserNamespacesActivity struct {
// contains filtered or unexported fields
}
func MakeDeleteUserNamespacesActivity ¶
func MakeDeleteUserNamespacesActivity(deleter UserNamespaceDeleter, k8sConfigGetter K8sConfigGetter) DeleteUserNamespacesActivity
func (DeleteUserNamespacesActivity) Execute ¶
func (a DeleteUserNamespacesActivity) Execute(ctx context.Context, input DeleteUserNamespacesActivityInput) (DeleteUserNamespacesActivityOutput, error)
type DeleteUserNamespacesActivityOutput ¶
type DeleteUserNamespacesActivityOutput struct {
NamespacesLeft []string
}
type HealthCheckActivity ¶
type HealthCheckActivity struct {
// contains filtered or unexported fields
}
func NewHealthCheckActivity ¶
func NewHealthCheckActivity( checker HealthChecker, clientFactory ClientFactory, ) HealthCheckActivity
NewHealthCheckActivity returns a new HealthCheckActivity.
func (HealthCheckActivity) Execute ¶
func (a HealthCheckActivity) Execute(ctx context.Context, input HealthCheckActivityInput) error
type HealthCheckActivityInput ¶
type HealthCheckActivityInput struct {
SecretID string
}
type HealthChecker ¶
type HealthChecker interface {
Check(ctx context.Context, client kubernetes.Interface) error
}
HealthChecker returns the result of the healthcheck
type K8sConfigGetter ¶
type SecretStore ¶
type UserNamespaceDeleter ¶
type WaitPersistentVolumesDeletionActivity ¶
type WaitPersistentVolumesDeletionActivity struct {
// contains filtered or unexported fields
}
WaitPersistentVolumesDeletionActivity collects the PVs that were created through PVCs and are expected to be deleted by Kubernetes upon cluster deletion.
func MakeWaitPersistentVolumesDeletionActivity ¶
func MakeWaitPersistentVolumesDeletionActivity(k8sConfigGetter K8sConfigGetter, logger logrus.FieldLogger) WaitPersistentVolumesDeletionActivity
func (WaitPersistentVolumesDeletionActivity) Execute ¶
func (a WaitPersistentVolumesDeletionActivity) Execute(ctx context.Context, input DeleteHelmDeploymentsActivityInput) (err error)
Source Files ¶
- client_factory.go
- common.go
- delete_cluster_dns_records_activity.go
- delete_helm_deployments_activity.go
- delete_k8s_resources.go
- delete_namespace_resources_activity.go
- delete_namespace_services_activity.go
- delete_unused_secrets_activity.go
- delete_user_namespaces_activity.go
- health_check_activity.go
- wait_pvs_deletion_activity.go
Click to show internal directories.
Click to hide internal directories.