resources

package
v0.1.0-rc0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 21, 2022 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PhaseUploadConfigKubeadm kubeadmPhase = iota
	PhaseUploadConfigKubelet
	PhaseBootstrapToken
)
View Source 
const (
	AdminKubeConfigFileName             = kubeadmconstants.AdminKubeConfigFileName
	ControllerManagerKubeConfigFileName = kubeadmconstants.ControllerManagerKubeConfigFileName
	SchedulerKubeConfigFileName         = kubeadmconstants.SchedulerKubeConfigFileName
)

Variables

This section is empty.

Functions

func Handle 

func Handle(ctx context.Context, resource Resource, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

Handle handles the given resource and returns a boolean to say if the tenantControlPlane has been modified.

func HandleDeletion added in v0.1.0 

func HandleDeletion(ctx context.Context, resource DeleteableResource, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

HandleDeletion handles the deletion of the given resource.

func KubeadmPhaseCreate added in v0.1.0 

func KubeadmPhaseCreate(ctx context.Context, r KubeadmPhaseResource, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

Types

type APIServerCertificate 

type APIServerCertificate struct {
	Client       client.Client
	Log          logr.Logger
	Name         string
	TmpDirectory string
	// contains filtered or unexported fields
}

func (*APIServerCertificate) CleanUp 

func (r *APIServerCertificate) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*APIServerCertificate) CreateOrUpdate 

func (r *APIServerCertificate) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (res controllerutil.OperationResult, err error)

func (*APIServerCertificate) Define 

func (r *APIServerCertificate) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*APIServerCertificate) GetClient 

func (r *APIServerCertificate) GetClient() client.Client

func (*APIServerCertificate) GetName 

func (r *APIServerCertificate) GetName() string

func (*APIServerCertificate) GetTmpDirectory 

func (r *APIServerCertificate) GetTmpDirectory() string

func (*APIServerCertificate) ShouldCleanup 

func (r *APIServerCertificate) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*APIServerCertificate) ShouldStatusBeUpdated 

func (r *APIServerCertificate) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*APIServerCertificate) UpdateTenantControlPlaneStatus 

func (r *APIServerCertificate) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type APIServerKubeletClientCertificate 

type APIServerKubeletClientCertificate struct {
	Client       client.Client
	Log          logr.Logger
	Name         string
	TmpDirectory string
	// contains filtered or unexported fields
}

func (*APIServerKubeletClientCertificate) CleanUp 

func (r *APIServerKubeletClientCertificate) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*APIServerKubeletClientCertificate) CreateOrUpdate 

func (r *APIServerKubeletClientCertificate) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (res controllerutil.OperationResult, err error)

func (*APIServerKubeletClientCertificate) Define 

func (r *APIServerKubeletClientCertificate) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*APIServerKubeletClientCertificate) GetClient 

func (r *APIServerKubeletClientCertificate) GetClient() client.Client

func (*APIServerKubeletClientCertificate) GetName 

func (r *APIServerKubeletClientCertificate) GetName() string

func (*APIServerKubeletClientCertificate) GetTmpDirectory 

func (r *APIServerKubeletClientCertificate) GetTmpDirectory() string

func (*APIServerKubeletClientCertificate) ShouldCleanup 

func (r *APIServerKubeletClientCertificate) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*APIServerKubeletClientCertificate) ShouldStatusBeUpdated 

func (r *APIServerKubeletClientCertificate) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*APIServerKubeletClientCertificate) UpdateTenantControlPlaneStatus 

func (r *APIServerKubeletClientCertificate) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type CACertificate 

type CACertificate struct {
	Client       client.Client
	Log          logr.Logger
	Name         string
	TmpDirectory string
	// contains filtered or unexported fields
}

func (*CACertificate) CleanUp 

func (r *CACertificate) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*CACertificate) CreateOrUpdate 

func (r *CACertificate) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*CACertificate) Define 

func (r *CACertificate) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*CACertificate) GetClient 

func (r *CACertificate) GetClient() client.Client

func (*CACertificate) GetName 

func (r *CACertificate) GetName() string

func (*CACertificate) GetTmpDirectory 

func (r *CACertificate) GetTmpDirectory() string

func (*CACertificate) ShouldCleanup 

func (r *CACertificate) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*CACertificate) ShouldStatusBeUpdated 

func (r *CACertificate) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*CACertificate) UpdateTenantControlPlaneStatus 

func (r *CACertificate) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type DeleteableResource 

type DeleteableResource interface {
	Define(context.Context, *kamajiv1alpha1.TenantControlPlane) error
	Delete(context.Context, *kamajiv1alpha1.TenantControlPlane) error
}

type ETCDCACertificatesResource 

type ETCDCACertificatesResource struct {
	Client                client.Client
	Log                   logr.Logger
	Name                  string
	ETCDCASecretName      string
	ETCDCASecretNamespace string
	// contains filtered or unexported fields
}

func (*ETCDCACertificatesResource) CleanUp 

func (r *ETCDCACertificatesResource) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*ETCDCACertificatesResource) CreateOrUpdate 

func (r *ETCDCACertificatesResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*ETCDCACertificatesResource) Define 

func (r *ETCDCACertificatesResource) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*ETCDCACertificatesResource) GetName 

func (r *ETCDCACertificatesResource) GetName() string

func (*ETCDCACertificatesResource) ShouldCleanup 

func (r *ETCDCACertificatesResource) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*ETCDCACertificatesResource) ShouldStatusBeUpdated 

func (r *ETCDCACertificatesResource) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*ETCDCACertificatesResource) UpdateTenantControlPlaneStatus 

func (r *ETCDCACertificatesResource) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type ETCDCertificatesResource 

type ETCDCertificatesResource struct {
	Client client.Client
	Log    logr.Logger
	Name   string
	// contains filtered or unexported fields
}

func (*ETCDCertificatesResource) CleanUp 

func (r *ETCDCertificatesResource) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*ETCDCertificatesResource) CreateOrUpdate 

func (r *ETCDCertificatesResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*ETCDCertificatesResource) Define 

func (r *ETCDCertificatesResource) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*ETCDCertificatesResource) GetName 

func (r *ETCDCertificatesResource) GetName() string

func (*ETCDCertificatesResource) ShouldCleanup 

func (r *ETCDCertificatesResource) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*ETCDCertificatesResource) ShouldStatusBeUpdated 

func (r *ETCDCertificatesResource) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*ETCDCertificatesResource) UpdateTenantControlPlaneStatus 

func (r *ETCDCertificatesResource) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type ETCDSetupResource 

type ETCDSetupResource struct {
	Client                client.Client
	Log                   logr.Logger
	Name                  string
	Endpoints             []string
	ETCDClientCertsSecret k8stypes.NamespacedName
	ETCDCACertsSecret     k8stypes.NamespacedName
	// contains filtered or unexported fields
}

func (*ETCDSetupResource) CleanUp 

func (r *ETCDSetupResource) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*ETCDSetupResource) CreateOrUpdate 

func (r *ETCDSetupResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*ETCDSetupResource) Define 

func (r *ETCDSetupResource) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*ETCDSetupResource) Delete 

func (r *ETCDSetupResource) Delete(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*ETCDSetupResource) GetName 

func (r *ETCDSetupResource) GetName() string

func (*ETCDSetupResource) ShouldCleanup 

func (r *ETCDSetupResource) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*ETCDSetupResource) ShouldStatusBeUpdated 

func (r *ETCDSetupResource) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*ETCDSetupResource) UpdateTenantControlPlaneStatus 

func (r *ETCDSetupResource) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type FrontProxyCACertificate 

type FrontProxyCACertificate struct {
	Client       client.Client
	Log          logr.Logger
	Name         string
	TmpDirectory string
	// contains filtered or unexported fields
}

func (*FrontProxyCACertificate) CleanUp 

func (r *FrontProxyCACertificate) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*FrontProxyCACertificate) CreateOrUpdate 

func (r *FrontProxyCACertificate) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*FrontProxyCACertificate) Define 

func (r *FrontProxyCACertificate) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*FrontProxyCACertificate) GetClient 

func (r *FrontProxyCACertificate) GetClient() client.Client

func (*FrontProxyCACertificate) GetName 

func (r *FrontProxyCACertificate) GetName() string

func (*FrontProxyCACertificate) GetTmpDirectory 

func (r *FrontProxyCACertificate) GetTmpDirectory() string

func (*FrontProxyCACertificate) ShouldCleanup 

func (r *FrontProxyCACertificate) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*FrontProxyCACertificate) ShouldStatusBeUpdated 

func (r *FrontProxyCACertificate) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*FrontProxyCACertificate) UpdateTenantControlPlaneStatus 

func (r *FrontProxyCACertificate) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type FrontProxyClientCertificate 

type FrontProxyClientCertificate struct {
	Client       client.Client
	Log          logr.Logger
	Name         string
	TmpDirectory string
	// contains filtered or unexported fields
}

func (*FrontProxyClientCertificate) CleanUp 

func (r *FrontProxyClientCertificate) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*FrontProxyClientCertificate) CreateOrUpdate 

func (r *FrontProxyClientCertificate) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*FrontProxyClientCertificate) Define 

func (r *FrontProxyClientCertificate) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*FrontProxyClientCertificate) GetClient 

func (r *FrontProxyClientCertificate) GetClient() client.Client

func (*FrontProxyClientCertificate) GetName 

func (r *FrontProxyClientCertificate) GetName() string

func (*FrontProxyClientCertificate) GetTmpDirectory 

func (r *FrontProxyClientCertificate) GetTmpDirectory() string

func (*FrontProxyClientCertificate) ShouldCleanup 

func (r *FrontProxyClientCertificate) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*FrontProxyClientCertificate) ShouldStatusBeUpdated 

func (r *FrontProxyClientCertificate) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*FrontProxyClientCertificate) UpdateTenantControlPlaneStatus 

func (r *FrontProxyClientCertificate) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type HandlerConfig 

type HandlerConfig struct {
	Resource           Resource
	TenantControlPlane *kamajiv1alpha1.TenantControlPlane
}

type KubeadmAddon added in v0.1.0 

type KubeadmAddon int
const (
	AddonCoreDNS KubeadmAddon = iota
	AddonKubeProxy
)

func (KubeadmAddon) String added in v0.1.0 

func (d KubeadmAddon) String() string

type KubeadmAddonResource added in v0.1.0 

type KubeadmAddonResource struct {
	Client       client.Client
	Log          logr.Logger
	Name         string
	KubeadmAddon KubeadmAddon
	// contains filtered or unexported fields
}

func (*KubeadmAddonResource) CleanUp added in v0.1.0 

func (r *KubeadmAddonResource) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*KubeadmAddonResource) CreateOrUpdate added in v0.1.0 

func (r *KubeadmAddonResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*KubeadmAddonResource) Define added in v0.1.0 

func (r *KubeadmAddonResource) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*KubeadmAddonResource) GetClient added in v0.1.0 

func (r *KubeadmAddonResource) GetClient() client.Client

func (*KubeadmAddonResource) GetKubeadmFunction added in v0.1.0 

func (r *KubeadmAddonResource) GetKubeadmFunction() (func(clientset.Interface, *kubeadm.Configuration) error, error)

func (*KubeadmAddonResource) GetName added in v0.1.0 

func (r *KubeadmAddonResource) GetName() string

func (*KubeadmAddonResource) GetStatus added in v0.1.0 

func (r *KubeadmAddonResource) GetStatus(tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (kamajiv1alpha1.KubeadmConfigChecksumDependant, error)

func (*KubeadmAddonResource) GetTmpDirectory added in v0.1.0 

func (r *KubeadmAddonResource) GetTmpDirectory() string

func (*KubeadmAddonResource) SetKubeadmConfigChecksum added in v0.1.0 

func (r *KubeadmAddonResource) SetKubeadmConfigChecksum(checksum string)

func (*KubeadmAddonResource) ShouldCleanup added in v0.1.0 

func (r *KubeadmAddonResource) ShouldCleanup(tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*KubeadmAddonResource) ShouldStatusBeUpdated added in v0.1.0 

func (r *KubeadmAddonResource) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*KubeadmAddonResource) UpdateTenantControlPlaneStatus added in v0.1.0 

func (r *KubeadmAddonResource) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type KubeadmConfigResource 

type KubeadmConfigResource struct {
	Client                 client.Client
	Name                   string
	ETCDs                  []string
	ETCDCompactionInterval string
	TmpDirectory           string
	// contains filtered or unexported fields
}

func (*KubeadmConfigResource) CleanUp 

func (r *KubeadmConfigResource) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*KubeadmConfigResource) CreateOrUpdate 

func (r *KubeadmConfigResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*KubeadmConfigResource) Define 

func (r *KubeadmConfigResource) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*KubeadmConfigResource) GetName 

func (r *KubeadmConfigResource) GetName() string

func (*KubeadmConfigResource) ShouldCleanup 

func (r *KubeadmConfigResource) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*KubeadmConfigResource) ShouldStatusBeUpdated 

func (r *KubeadmConfigResource) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*KubeadmConfigResource) UpdateTenantControlPlaneStatus 

func (r *KubeadmConfigResource) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type KubeadmPhase 

type KubeadmPhase struct {
	Client client.Client
	Log    logr.Logger
	Name   string
	Phase  kubeadmPhase
	// contains filtered or unexported fields
}

func (*KubeadmPhase) CleanUp added in v0.1.0 

func (r *KubeadmPhase) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*KubeadmPhase) CreateOrUpdate added in v0.1.0 

func (r *KubeadmPhase) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*KubeadmPhase) Define added in v0.1.0 

func (r *KubeadmPhase) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*KubeadmPhase) GetClient added in v0.1.0 

func (r *KubeadmPhase) GetClient() client.Client

func (*KubeadmPhase) GetKubeadmFunction added in v0.1.0 

func (r *KubeadmPhase) GetKubeadmFunction() (func(clientset.Interface, *kubeadm.Configuration) error, error)

func (*KubeadmPhase) GetName added in v0.1.0 

func (r *KubeadmPhase) GetName() string

func (*KubeadmPhase) GetStatus added in v0.1.0 

func (r *KubeadmPhase) GetStatus(tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (kamajiv1alpha1.KubeadmConfigChecksumDependant, error)

func (*KubeadmPhase) GetTmpDirectory added in v0.1.0 

func (r *KubeadmPhase) GetTmpDirectory() string

func (*KubeadmPhase) SetKubeadmConfigChecksum added in v0.1.0 

func (r *KubeadmPhase) SetKubeadmConfigChecksum(checksum string)

func (*KubeadmPhase) ShouldCleanup added in v0.1.0 

func (r *KubeadmPhase) ShouldCleanup(tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*KubeadmPhase) ShouldStatusBeUpdated added in v0.1.0 

func (r *KubeadmPhase) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*KubeadmPhase) UpdateTenantControlPlaneStatus added in v0.1.0 

func (r *KubeadmPhase) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type KubeadmPhaseResource 

type KubeadmPhaseResource interface {
	KubeadmResource
	GetClient() client.Client
	GetKubeadmFunction() (func(clientset.Interface, *kubeadm.Configuration) error, error)
	GetStatus(*kamajiv1alpha1.TenantControlPlane) (kamajiv1alpha1.KubeadmConfigChecksumDependant, error)
	SetKubeadmConfigChecksum(string)
}

type KubeadmResource 

type KubeadmResource interface {
	Resource
	GetClient() client.Client
	GetTmpDirectory() string
}

type KubeconfigResource 

type KubeconfigResource struct {
	Client             client.Client
	Log                logr.Logger
	Name               string
	KubeConfigFileName string
	TmpDirectory       string
	// contains filtered or unexported fields
}

func (*KubeconfigResource) CleanUp 

func (r *KubeconfigResource) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*KubeconfigResource) CreateOrUpdate 

func (r *KubeconfigResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*KubeconfigResource) Define 

func (r *KubeconfigResource) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*KubeconfigResource) GetClient 

func (r *KubeconfigResource) GetClient() client.Client

func (*KubeconfigResource) GetName 

func (r *KubeconfigResource) GetName() string

func (*KubeconfigResource) GetTmpDirectory 

func (r *KubeconfigResource) GetTmpDirectory() string

func (*KubeconfigResource) ShouldCleanup 

func (r *KubeconfigResource) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*KubeconfigResource) ShouldStatusBeUpdated 

func (r *KubeconfigResource) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*KubeconfigResource) UpdateTenantControlPlaneStatus 

func (r *KubeconfigResource) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type KubernetesDeploymentResource 

type KubernetesDeploymentResource struct {
	Client                 client.Client
	ETCDStorageType        types.ETCDStorageType
	ETCDEndpoints          []string
	ETCDCompactionInterval string
	Name                   string
	KineContainerImage     string
	// contains filtered or unexported fields
}

func (*KubernetesDeploymentResource) CleanUp 

func (r *KubernetesDeploymentResource) CleanUp(context.Context, *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*KubernetesDeploymentResource) CreateOrUpdate 

func (r *KubernetesDeploymentResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*KubernetesDeploymentResource) Define 

func (r *KubernetesDeploymentResource) Define(_ context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*KubernetesDeploymentResource) GetName 

func (r *KubernetesDeploymentResource) GetName() string

func (*KubernetesDeploymentResource) ShouldCleanup 

func (r *KubernetesDeploymentResource) ShouldCleanup(*kamajiv1alpha1.TenantControlPlane) bool

func (*KubernetesDeploymentResource) ShouldStatusBeUpdated 

func (r *KubernetesDeploymentResource) ShouldStatusBeUpdated(_ context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*KubernetesDeploymentResource) UpdateTenantControlPlaneStatus 

func (r *KubernetesDeploymentResource) UpdateTenantControlPlaneStatus(_ context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type KubernetesIngressResource 

type KubernetesIngressResource struct {
	Client client.Client
	Name   string
	// contains filtered or unexported fields
}

func (*KubernetesIngressResource) CleanUp 

func (r *KubernetesIngressResource) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*KubernetesIngressResource) CreateOrUpdate 

func (r *KubernetesIngressResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*KubernetesIngressResource) Define 

func (r *KubernetesIngressResource) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*KubernetesIngressResource) GetName 

func (r *KubernetesIngressResource) GetName() string

func (*KubernetesIngressResource) ShouldCleanup 

func (r *KubernetesIngressResource) ShouldCleanup(tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*KubernetesIngressResource) ShouldStatusBeUpdated 

func (r *KubernetesIngressResource) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*KubernetesIngressResource) UpdateTenantControlPlaneStatus 

func (r *KubernetesIngressResource) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type KubernetesServiceResource 

type KubernetesServiceResource struct {
	Client client.Client
	Name   string
	// contains filtered or unexported fields
}

KubernetesServiceResource must be the first Resource processed by the TenantControlPlane: when a TenantControlPlan is expecting a dynamic IP address, the Service will get it from the controller-manager.

func (*KubernetesServiceResource) CleanUp 

func (r *KubernetesServiceResource) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*KubernetesServiceResource) CreateOrUpdate 

func (r *KubernetesServiceResource) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*KubernetesServiceResource) Define 

func (r *KubernetesServiceResource) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*KubernetesServiceResource) GetName 

func (r *KubernetesServiceResource) GetName() string

func (*KubernetesServiceResource) ShouldCleanup 

func (r *KubernetesServiceResource) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*KubernetesServiceResource) ShouldStatusBeUpdated 

func (r *KubernetesServiceResource) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*KubernetesServiceResource) UpdateTenantControlPlaneStatus 

func (r *KubernetesServiceResource) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type KubernetesUpgrade 

type KubernetesUpgrade struct {
	Name   string
	Client client.Client
	// contains filtered or unexported fields
}

func (*KubernetesUpgrade) CleanUp 

func (k *KubernetesUpgrade) CleanUp(context.Context, *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*KubernetesUpgrade) CreateOrUpdate 

func (k *KubernetesUpgrade) CreateOrUpdate(ctx context.Context, plane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*KubernetesUpgrade) Define 

func (k *KubernetesUpgrade) Define(_ context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*KubernetesUpgrade) GetName 

func (k *KubernetesUpgrade) GetName() string

func (*KubernetesUpgrade) ShouldCleanup 

func (k *KubernetesUpgrade) ShouldCleanup(*kamajiv1alpha1.TenantControlPlane) bool

func (*KubernetesUpgrade) ShouldStatusBeUpdated 

func (k *KubernetesUpgrade) ShouldStatusBeUpdated(context.Context, *kamajiv1alpha1.TenantControlPlane) bool

func (*KubernetesUpgrade) UpdateTenantControlPlaneStatus 

func (k *KubernetesUpgrade) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type Resource 

type Resource interface {
	Define(context.Context, *kamajiv1alpha1.TenantControlPlane) error
	ShouldCleanup(*kamajiv1alpha1.TenantControlPlane) bool
	CleanUp(context.Context, *kamajiv1alpha1.TenantControlPlane) (bool, error)
	CreateOrUpdate(context.Context, *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)
	GetName() string
	ShouldStatusBeUpdated(context.Context, *kamajiv1alpha1.TenantControlPlane) bool
	UpdateTenantControlPlaneStatus(context.Context, *kamajiv1alpha1.TenantControlPlane) error
}

type SACertificate 

type SACertificate struct {
	Client       client.Client
	Log          logr.Logger
	Name         string
	TmpDirectory string
	// contains filtered or unexported fields
}

func (*SACertificate) CleanUp 

func (r *SACertificate) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*SACertificate) CreateOrUpdate 

func (r *SACertificate) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*SACertificate) Define 

func (r *SACertificate) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*SACertificate) GetClient 

func (r *SACertificate) GetClient() client.Client

func (*SACertificate) GetName 

func (r *SACertificate) GetName() string

func (*SACertificate) GetTmpDirectory 

func (r *SACertificate) GetTmpDirectory() string

func (*SACertificate) ShouldCleanup 

func (r *SACertificate) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*SACertificate) ShouldStatusBeUpdated 

func (r *SACertificate) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*SACertificate) UpdateTenantControlPlaneStatus 

func (r *SACertificate) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type SQLCertificate 

type SQLCertificate struct {
	Client                   client.Client
	Name                     string
	StorageType              types.ETCDStorageType
	SQLConfigSecretName      string
	SQLConfigSecretNamespace string
	// contains filtered or unexported fields
}

func (*SQLCertificate) CleanUp 

func (r *SQLCertificate) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*SQLCertificate) CreateOrUpdate 

func (r *SQLCertificate) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*SQLCertificate) Define 

func (r *SQLCertificate) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*SQLCertificate) GetClient 

func (r *SQLCertificate) GetClient() client.Client

func (*SQLCertificate) GetName 

func (r *SQLCertificate) GetName() string

func (*SQLCertificate) ShouldCleanup 

func (r *SQLCertificate) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*SQLCertificate) ShouldStatusBeUpdated 

func (r *SQLCertificate) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*SQLCertificate) UpdateTenantControlPlaneStatus 

func (r *SQLCertificate) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type SQLSetup 

type SQLSetup struct {
	Client       client.Client
	DBConnection sql.DBConnection
	Name         string
	// contains filtered or unexported fields
}

func (*SQLSetup) CleanUp 

func (r *SQLSetup) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*SQLSetup) CreateOrUpdate 

func (r *SQLSetup) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*SQLSetup) Define 

func (r *SQLSetup) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*SQLSetup) Delete 

func (r *SQLSetup) Delete(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*SQLSetup) GetClient 

func (r *SQLSetup) GetClient() client.Client

func (*SQLSetup) GetName 

func (r *SQLSetup) GetName() string

func (*SQLSetup) ShouldCleanup 

func (r *SQLSetup) ShouldCleanup(tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*SQLSetup) ShouldStatusBeUpdated 

func (r *SQLSetup) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*SQLSetup) UpdateTenantControlPlaneStatus 

func (r *SQLSetup) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

type SQLStorageConfig 

type SQLStorageConfig struct {
	Client client.Client
	Name   string
	Host   string
	Port   int
	// contains filtered or unexported fields
}

func (*SQLStorageConfig) CleanUp 

func (r *SQLStorageConfig) CleanUp(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (bool, error)

func (*SQLStorageConfig) CreateOrUpdate 

func (r *SQLStorageConfig) CreateOrUpdate(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) (controllerutil.OperationResult, error)

func (*SQLStorageConfig) Define 

func (r *SQLStorageConfig) Define(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

func (*SQLStorageConfig) GetClient 

func (r *SQLStorageConfig) GetClient() client.Client

func (*SQLStorageConfig) GetName 

func (r *SQLStorageConfig) GetName() string

func (*SQLStorageConfig) ShouldCleanup 

func (r *SQLStorageConfig) ShouldCleanup(plane *kamajiv1alpha1.TenantControlPlane) bool

func (*SQLStorageConfig) ShouldStatusBeUpdated 

func (r *SQLStorageConfig) ShouldStatusBeUpdated(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) bool

func (*SQLStorageConfig) UpdateTenantControlPlaneStatus 

func (r *SQLStorageConfig) UpdateTenantControlPlaneStatus(ctx context.Context, tenantControlPlane *kamajiv1alpha1.TenantControlPlane) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.