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

Source Files

View all Source files

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.