cluster

package
v1.9.2 Latest Latest
Warning

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

Go to latest
Published: May 30, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 8 more Imports: 89 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CalcNodeCidrSize added in v1.6.0

func CalcNodeCidrSize(podSubnet string) (int32, bool)

func GetAPIServerCertSANs added in v1.3.1

func GetAPIServerCertSANs(c *platformv1.Cluster) []string

GetAPIServerCertSANs returns extra APIServer's certSANs need to pass kubeadm

func GetIndexedIP added in v1.2.5

func GetIndexedIP(subnet string, index int) (net.IP, error)

func GetNodeCIDRMaskSize added in v1.2.5

func GetNodeCIDRMaskSize(clusterCIDR string, maxNodePodNum int32) (int32, error)

func GetServiceCIDRAndNodeCIDRMaskSize

func GetServiceCIDRAndNodeCIDRMaskSize(clusterCIDR string, maxClusterServiceNum int32, maxNodePodNum int32) (string, int32, error)

func RegisterProvider added in v1.9.0

func RegisterProvider()

Types

type Provider

type Provider struct {
	*clusterprovider.DelegateProvider

	Config *config.Config
}

func NewProvider

func NewProvider() (*Provider, error)

func (*Provider) EnsureAPIServerCert added in v1.3.1

func (p *Provider) EnsureAPIServerCert(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureAnywhereAddons added in v1.9.1

func (p *Provider) EnsureAnywhereAddons(ctx context.Context, c *v1.Cluster) error

Ensure anywhere addon applications

func (*Provider) EnsureAnywhereEdtion added in v1.9.1

func (p *Provider) EnsureAnywhereEdtion(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureAuditConfig added in v1.9.1

func (p *Provider) EnsureAuditConfig(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureAuthzWebhook added in v1.3.1

func (p *Provider) EnsureAuthzWebhook(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureCNIPlugins

func (p *Provider) EnsureCNIPlugins(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureCSIOperator added in v1.3.1

func (p *Provider) EnsureCSIOperator(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureCheckAnywhereSubscription added in v1.9.1

func (p *Provider) EnsureCheckAnywhereSubscription(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureCilium added in v1.7.0

func (p *Provider) EnsureCilium(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureCleanClusterMark added in v1.3.1

func (p *Provider) EnsureCleanClusterMark(ctx context.Context, c *typesv1.Cluster) error

func (*Provider) EnsureCleanup added in v1.2.5

func (p *Provider) EnsureCleanup(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureClusterAddressReal added in v1.9.1

func (p *Provider) EnsureClusterAddressReal(ctx context.Context, c *v1.Cluster) error

update cluster to connect remote cluster apiserver

func (*Provider) EnsureClusterComplete

func (p *Provider) EnsureClusterComplete(ctx context.Context, cluster *v1.Cluster) error

因为validate那里没法更新对象(不能存储) PreCrete,在api中错误只能panic,响应不会有报错提示,所以只能挪到这里处理

func (*Provider) EnsureClusternetRegistration added in v1.9.1

func (p *Provider) EnsureClusternetRegistration(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureConntrackTools added in v1.3.1

func (p *Provider) EnsureConntrackTools(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureContainerRuntime added in v1.8.0

func (p *Provider) EnsureContainerRuntime(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureContainerd added in v1.8.0

func (p *Provider) EnsureContainerd(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureCopyFiles

func (p *Provider) EnsureCopyFiles(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureCreateClusterMark added in v1.3.1

func (p *Provider) EnsureCreateClusterMark(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureDisableSwap

func (p *Provider) EnsureDisableSwap(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureDocker

func (p *Provider) EnsureDocker(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureGPUManager added in v1.3.1

func (p *Provider) EnsureGPUManager(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureGalaxy

func (p *Provider) EnsureGalaxy(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureInitAPIServerHost added in v1.6.0

func (p *Provider) EnsureInitAPIServerHost(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureJoinPhaseControlPlaneJoinETCD added in v1.3.1

func (p *Provider) EnsureJoinPhaseControlPlaneJoinETCD(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureJoinPhaseControlPlaneJoinUpdateStatus added in v1.3.1

func (p *Provider) EnsureJoinPhaseControlPlaneJoinUpdateStatus(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureJoinPhaseControlPlanePrepare added in v1.3.1

func (p *Provider) EnsureJoinPhaseControlPlanePrepare(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureJoinPhaseKubeletStart added in v1.3.1

func (p *Provider) EnsureJoinPhaseKubeletStart(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureJoinPhasePreflight added in v1.3.1

func (p *Provider) EnsureJoinPhasePreflight(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKeepalivedInit added in v1.3.1

func (p *Provider) EnsureKeepalivedInit(ctx context.Context, c *v1.Cluster) error

EnsureKeepalivedInit make sure all master node has cleaning iptable table so in kubeadm join time apiserver may not join it self. keepalived only installs in master node 0 before kubeadm init phase to prevet from vip failover in kubeadm join(etcd phase)

func (*Provider) EnsureKeepalivedWithLBOption added in v1.4.0

func (p *Provider) EnsureKeepalivedWithLBOption(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKernelModule

func (p *Provider) EnsureKernelModule(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubeAPIServerRestart added in v1.9.1

func (p *Provider) EnsureKubeAPIServerRestart(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubeadm

func (p *Provider) EnsureKubeadm(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubeadmInitPhaseAddon added in v1.3.1

func (p *Provider) EnsureKubeadmInitPhaseAddon(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubeadmInitPhaseBootstrapToken added in v1.3.1

func (p *Provider) EnsureKubeadmInitPhaseBootstrapToken(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubeadmInitPhaseCerts added in v1.3.1

func (p *Provider) EnsureKubeadmInitPhaseCerts(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubeadmInitPhaseControlPlane added in v1.3.1

func (p *Provider) EnsureKubeadmInitPhaseControlPlane(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubeadmInitPhaseETCD added in v1.3.1

func (p *Provider) EnsureKubeadmInitPhaseETCD(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubeadmInitPhaseKubeConfig added in v1.3.1

func (p *Provider) EnsureKubeadmInitPhaseKubeConfig(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubeadmInitPhaseKubeletStart added in v1.3.1

func (p *Provider) EnsureKubeadmInitPhaseKubeletStart(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubeadmInitPhaseUploadCerts added in v1.3.1

func (p *Provider) EnsureKubeadmInitPhaseUploadCerts(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubeadmInitPhaseUploadConfig added in v1.3.1

func (p *Provider) EnsureKubeadmInitPhaseUploadConfig(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubeadmInitPhaseWaitControlPlane added in v1.3.1

func (p *Provider) EnsureKubeadmInitPhaseWaitControlPlane(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubeconfig

func (p *Provider) EnsureKubeconfig(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubelet

func (p *Provider) EnsureKubelet(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureKubernetesImages added in v1.3.1

func (p *Provider) EnsureKubernetesImages(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureMarkControlPlane

func (p *Provider) EnsureMarkControlPlane(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureMetricsServer added in v1.3.1

func (p *Provider) EnsureMetricsServer(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureModifyAPIServerHost added in v1.6.0

func (p *Provider) EnsureModifyAPIServerHost(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureModifyClusterCredential added in v1.9.1

func (p *Provider) EnsureModifyClusterCredential(ctx context.Context, c *v1.Cluster) error

update cluster credential to connect remote cluster apiserver

func (*Provider) EnsureNvidiaContainerRuntime

func (p *Provider) EnsureNvidiaContainerRuntime(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureNvidiaDevicePlugin

func (p *Provider) EnsureNvidiaDevicePlugin(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureNvidiaDriver

func (p *Provider) EnsureNvidiaDriver(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsurePatchAnnotation

func (p *Provider) EnsurePatchAnnotation(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsurePostClusterInstallHook added in v1.4.0

func (p *Provider) EnsurePostClusterInstallHook(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsurePostClusterUpgradeHook added in v1.4.0

func (p *Provider) EnsurePostClusterUpgradeHook(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsurePostInstallHook

func (p *Provider) EnsurePostInstallHook(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsurePreClusterInstallHook added in v1.4.0

func (p *Provider) EnsurePreClusterInstallHook(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsurePreClusterUpgradeHook added in v1.4.0

func (p *Provider) EnsurePreClusterUpgradeHook(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsurePreInstallHook

func (p *Provider) EnsurePreInstallHook(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsurePreflight

func (p *Provider) EnsurePreflight(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsurePrepareForControlplane

func (p *Provider) EnsurePrepareForControlplane(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureRegisterGlobalCluster added in v1.9.1

func (p *Provider) EnsureRegisterGlobalCluster(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureRegistryHosts

func (p *Provider) EnsureRegistryHosts(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureRemoveETCDMember added in v1.6.0

func (p *Provider) EnsureRemoveETCDMember(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureRemoveMachine added in v1.8.0

func (p *Provider) EnsureRemoveMachine(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureRemoveNode added in v1.6.0

func (p *Provider) EnsureRemoveNode(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureRenewCerts added in v1.3.1

func (p *Provider) EnsureRenewCerts(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureStoreCredential

func (p *Provider) EnsureStoreCredential(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureSysctl

func (p *Provider) EnsureSysctl(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureThirdPartyHA added in v1.3.1

func (p *Provider) EnsureThirdPartyHA(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureThirdPartyHAInit added in v1.3.1

func (p *Provider) EnsureThirdPartyHAInit(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureUpgradeControlPlaneNode added in v1.3.1

func (p *Provider) EnsureUpgradeControlPlaneNode(ctx context.Context, c *v1.Cluster) error

func (*Provider) EnsureUpgradeCoreDNS added in v1.6.0

func (p *Provider) EnsureUpgradeCoreDNS(ctx context.Context, c *v1.Cluster) error

func (*Provider) PreCreate

func (p *Provider) PreCreate(cluster *types.Cluster) error

func (*Provider) RegisterHandler added in v1.3.1

func (p *Provider) RegisterHandler(mux *mux.PathRecorderMux)

func (*Provider) Validate

func (p *Provider) Validate(cluster *types.Cluster) field.ErrorList

func (*Provider) ValidateUpdate

func (p *Provider) ValidateUpdate(cluster *types.Cluster, oldCluster *types.Cluster) field.ErrorList

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL