cluster

Documentation

Index

• Constants
• func GetIndexedIP(subnet string, index int) (net.IP, error)
• func GetNodeCIDRMaskSize(clusterCIDR string, maxNodePodNum int32) (int32, error)
• func GetServiceCIDRAndNodeCIDRMaskSize(clusterCIDR string, maxClusterServiceNum int32, maxNodePodNum int32) (string, int32, error)
• type Address
  • func (ca *Address) String() string
• type Cluster
  • func NewCluster(c clusterprovider.Cluster, cfg *config.Config) (*Cluster, error)
  • func (c *Cluster) AddAddress(addrType platformv1.AddressType, host string, port int32)
  • func (c *Cluster) Address(addrType platformv1.AddressType) *Address
  • func (c *Cluster) Clientset() (*kubernetes.Clientset, error)
  • func (c *Cluster) RemoveAddress(addrType platformv1.AddressType)
  • func (c *Cluster) SetCondition(newCondition platformv1.ClusterCondition)
• type Handler
• type Provider
  • func NewProvider() (*Provider, error)
  • func (p *Provider) AfterCreate(cluster platform.Cluster) ([]interface{}, error)
  • func (p *Provider) EnsureCNIPlugins(c *Cluster) error
  • func (p *Provider) EnsureCleanup(c *Cluster) error
  • func (p *Provider) EnsureClusterComplete(cluster *Cluster) error
  • func (p *Provider) EnsureCopyFiles(c *Cluster) error
  • func (p *Provider) EnsureDisableSwap(c *Cluster) error
  • func (p *Provider) EnsureDocker(c *Cluster) error
  • func (p *Provider) EnsureGalaxy(c *Cluster) error
  • func (p *Provider) EnsureJoinControlePlane(c *Cluster) error
  • func (p *Provider) EnsureKernelModule(c *Cluster) error
  • func (p *Provider) EnsureKubeadm(c *Cluster) error
  • func (p *Provider) EnsureKubeadmInitAddonPhase(c *Cluster) error
  • func (p *Provider) EnsureKubeadmInitBootstrapTokenPhase(c *Cluster) error
  • func (p *Provider) EnsureKubeadmInitCertsPhase(c *Cluster) error
  • func (p *Provider) EnsureKubeadmInitControlPlanePhase(c *Cluster) error
  • func (p *Provider) EnsureKubeadmInitEtcdPhase(c *Cluster) error
  • func (p *Provider) EnsureKubeadmInitKubeConfigPhase(c *Cluster) error
  • func (p *Provider) EnsureKubeadmInitKubeletStartPhase(c *Cluster) error
  • func (p *Provider) EnsureKubeadmInitUploadCertsPhase(c *Cluster) error
  • func (p *Provider) EnsureKubeadmInitUploadConfigPhase(c *Cluster) error
  • func (p *Provider) EnsureKubeadmInitWaitControlPlanePhase(c *Cluster) error
  • func (p *Provider) EnsureKubeconfig(c *Cluster) error
  • func (p *Provider) EnsureKubelet(c *Cluster) error
  • func (p *Provider) EnsureMarkControlPlane(c *Cluster) error
  • func (p *Provider) EnsureNvidiaContainerRuntime(c *Cluster) error
  • func (p *Provider) EnsureNvidiaDevicePlugin(c *Cluster) error
  • func (p *Provider) EnsureNvidiaDriver(c *Cluster) error
  • func (p *Provider) EnsurePatchAnnotation(c *Cluster) error
  • func (p *Provider) EnsurePostInstallHook(c *Cluster) error
  • func (p *Provider) EnsurePreInstallHook(c *Cluster) error
  • func (p *Provider) EnsurePreflight(c *Cluster) error
  • func (p *Provider) EnsurePrepareForControlplane(c *Cluster) error
  • func (p *Provider) EnsureRegistryHosts(c *Cluster) error
  • func (p *Provider) EnsureStoreCredential(c *Cluster) error
  • func (p *Provider) EnsureSysctl(c *Cluster) error
  • func (p *Provider) Name() string
  • func (p *Provider) OnDelete(cluster platformv1.Cluster) error
  • func (p *Provider) OnInitialize(args clusterprovider.Cluster) (clusterprovider.Cluster, error)
  • func (p *Provider) OnUpdate(args clusterprovider.Cluster) (clusterprovider.Cluster, error)
  • func (p *Provider) PreCreate(user clusterprovider.UserInfo, cluster platform.Cluster) (platform.Cluster, error)
  • func (p *Provider) Validate(c *platform.Cluster) field.ErrorList
  • func (p *Provider) ValidateCredential(cluster clusterprovider.InternalCluster) field.ErrorList

Constants

const (
	ReasonFailedProcess     = "FailedProcess"
	ReasonWaitingProcess    = "WaitingProcess"
	ReasonSuccessfulProcess = "SuccessfulProcess"
	ReasonSkipProcess       = "SkipProcess"

	ConditionTypeDone = "EnsureDone"
)

Functions

func GetIndexedIP

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

func GetNodeCIDRMaskSize

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

func GetServiceCIDRAndNodeCIDRMaskSize

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

Types

type Address

type Address platformv1.ClusterAddress

func (*Address) String

func (ca *Address) String() string

type Cluster

type Cluster struct {
	clusterprovider.Cluster
	*config.Config
	SSH map[string]ssh.Interface
}

func NewCluster

func NewCluster(c clusterprovider.Cluster, cfg *config.Config) (*Cluster, error)

func (*Cluster) AddAddress

func (c *Cluster) AddAddress(addrType platformv1.AddressType, host string, port int32)

func (*Cluster) Address

func (c *Cluster) Address(addrType platformv1.AddressType) *Address

func (*Cluster) Clientset

func (c *Cluster) Clientset() (*kubernetes.Clientset, error)

func (*Cluster) RemoveAddress

func (c *Cluster) RemoveAddress(addrType platformv1.AddressType)

func (*Cluster) SetCondition

func (c *Cluster) SetCondition(newCondition platformv1.ClusterCondition)

type Handler

type Handler func(*Cluster) error

type Provider

type Provider struct {
	// contains filtered or unexported fields
}

func NewProvider

func NewProvider() (*Provider, error)

func (*Provider) AfterCreate

func (p *Provider) AfterCreate(cluster platform.Cluster) ([]interface{}, error)

func (*Provider) EnsureCNIPlugins

func (p *Provider) EnsureCNIPlugins(c *Cluster) error

func (*Provider) EnsureCleanup

func (p *Provider) EnsureCleanup(c *Cluster) error

func (*Provider) EnsureClusterComplete

func (p *Provider) EnsureClusterComplete(cluster *Cluster) error

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

func (*Provider) EnsureCopyFiles

func (p *Provider) EnsureCopyFiles(c *Cluster) error

func (*Provider) EnsureDisableSwap

func (p *Provider) EnsureDisableSwap(c *Cluster) error

func (*Provider) EnsureDocker

func (p *Provider) EnsureDocker(c *Cluster) error

func (*Provider) EnsureGalaxy

func (p *Provider) EnsureGalaxy(c *Cluster) error

func (*Provider) EnsureJoinControlePlane

func (p *Provider) EnsureJoinControlePlane(c *Cluster) error

func (*Provider) EnsureKernelModule

func (p *Provider) EnsureKernelModule(c *Cluster) error

func (*Provider) EnsureKubeadm

func (p *Provider) EnsureKubeadm(c *Cluster) error

func (*Provider) EnsureKubeadmInitAddonPhase

func (p *Provider) EnsureKubeadmInitAddonPhase(c *Cluster) error

func (*Provider) EnsureKubeadmInitBootstrapTokenPhase

func (p *Provider) EnsureKubeadmInitBootstrapTokenPhase(c *Cluster) error

func (*Provider) EnsureKubeadmInitCertsPhase

func (p *Provider) EnsureKubeadmInitCertsPhase(c *Cluster) error

func (*Provider) EnsureKubeadmInitControlPlanePhase

func (p *Provider) EnsureKubeadmInitControlPlanePhase(c *Cluster) error

func (*Provider) EnsureKubeadmInitEtcdPhase

func (p *Provider) EnsureKubeadmInitEtcdPhase(c *Cluster) error

func (*Provider) EnsureKubeadmInitKubeConfigPhase

func (p *Provider) EnsureKubeadmInitKubeConfigPhase(c *Cluster) error

func (*Provider) EnsureKubeadmInitKubeletStartPhase

func (p *Provider) EnsureKubeadmInitKubeletStartPhase(c *Cluster) error

func (*Provider) EnsureKubeadmInitUploadCertsPhase

func (p *Provider) EnsureKubeadmInitUploadCertsPhase(c *Cluster) error

func (*Provider) EnsureKubeadmInitUploadConfigPhase

func (p *Provider) EnsureKubeadmInitUploadConfigPhase(c *Cluster) error

func (*Provider) EnsureKubeadmInitWaitControlPlanePhase

func (p *Provider) EnsureKubeadmInitWaitControlPlanePhase(c *Cluster) error

func (*Provider) EnsureKubeconfig

func (p *Provider) EnsureKubeconfig(c *Cluster) error

func (*Provider) EnsureKubelet

func (p *Provider) EnsureKubelet(c *Cluster) error

func (*Provider) EnsureMarkControlPlane

func (p *Provider) EnsureMarkControlPlane(c *Cluster) error

func (*Provider) EnsureNvidiaContainerRuntime

func (p *Provider) EnsureNvidiaContainerRuntime(c *Cluster) error

func (*Provider) EnsureNvidiaDevicePlugin

func (p *Provider) EnsureNvidiaDevicePlugin(c *Cluster) error

func (*Provider) EnsureNvidiaDriver

func (p *Provider) EnsureNvidiaDriver(c *Cluster) error

func (*Provider) EnsurePatchAnnotation

func (p *Provider) EnsurePatchAnnotation(c *Cluster) error

func (*Provider) EnsurePostInstallHook

func (p *Provider) EnsurePostInstallHook(c *Cluster) error

func (*Provider) EnsurePreInstallHook

func (p *Provider) EnsurePreInstallHook(c *Cluster) error

func (*Provider) EnsurePreflight

func (p *Provider) EnsurePreflight(c *Cluster) error

func (*Provider) EnsurePrepareForControlplane

func (p *Provider) EnsurePrepareForControlplane(c *Cluster) error

func (*Provider) EnsureRegistryHosts

func (p *Provider) EnsureRegistryHosts(c *Cluster) error

func (*Provider) EnsureStoreCredential

func (p *Provider) EnsureStoreCredential(c *Cluster) error

func (*Provider) EnsureSysctl

func (p *Provider) EnsureSysctl(c *Cluster) error

func (*Provider) Name

func (p *Provider) Name() string

func (*Provider) OnDelete

func (p *Provider) OnDelete(cluster platformv1.Cluster) error

func (*Provider) OnInitialize

func (p *Provider) OnInitialize(args clusterprovider.Cluster) (clusterprovider.Cluster, error)

func (*Provider) OnUpdate

func (p *Provider) OnUpdate(args clusterprovider.Cluster) (clusterprovider.Cluster, error)

func (*Provider) PreCreate

func (p *Provider) PreCreate(user clusterprovider.UserInfo, cluster platform.Cluster) (platform.Cluster, error)

func (*Provider) Validate

func (p *Provider) Validate(c *platform.Cluster) field.ErrorList

func (*Provider) ValidateCredential

func (p *Provider) ValidateCredential(cluster clusterprovider.InternalCluster) field.ErrorList