Documentation
¶
Index ¶
- func BytesToInternalConfig(b []byte) (*kubeadmapi.InitConfiguration, error)
- func ChooseAPIServerBindAddress(bindAddress net.IP) (net.IP, error)
- func DefaultedInitConfiguration(defaultversionedcfg *kubeadmapiv1beta1.InitConfiguration) (*kubeadmapi.InitConfiguration, error)
- func DefaultedJoinConfiguration(defaultversionedcfg *kubeadmapiv1beta1.JoinConfiguration) (*kubeadmapi.JoinConfiguration, error)
- func FetchInitConfigurationFromCluster(client clientset.Interface, w io.Writer, logPrefix string, ...) (*kubeadmapi.InitConfiguration, error)
- func GetClusterStatus(client clientset.Interface) (*kubeadmapi.ClusterStatus, error)
- func LoadInitConfigurationFromFile(cfgPath string) (*kubeadmapi.InitConfiguration, error)
- func LoadJoinConfigurationFromFile(cfgPath string) (*kubeadmapi.JoinConfiguration, error)
- func LoadOrDefaultInitConfiguration(cfgPath string, defaultversionedcfg *kubeadmapiv1beta1.InitConfiguration) (*kubeadmapi.InitConfiguration, error)
- func LoadOrDefaultJoinConfiguration(cfgPath string, defaultversionedcfg *kubeadmapiv1beta1.JoinConfiguration) (*kubeadmapi.JoinConfiguration, error)
- func LowercaseSANs(sans []string)
- func MarshalClusterConfigurationToBytes(clustercfg *kubeadmapi.ClusterConfiguration, gv schema.GroupVersion) ([]byte, error)
- func MarshalInitConfigurationToBytes(cfg *kubeadmapi.InitConfiguration, gv schema.GroupVersion) ([]byte, error)
- func MarshalKubeadmConfigObject(obj runtime.Object) ([]byte, error)
- func MigrateOldConfigFromFile(cfgPath string) ([]byte, error)
- func NormalizeKubernetesVersion(cfg *kubeadmapi.ClusterConfiguration) error
- func SetAPIEndpointDynamicDefaults(cfg *kubeadmapi.APIEndpoint) error
- func SetBootstrapTokensDynamicDefaults(cfg *[]kubeadmapi.BootstrapToken) error
- func SetClusterDynamicDefaults(cfg *kubeadmapi.ClusterConfiguration, advertiseAddress string, bindPort int32) error
- func SetInitDynamicDefaults(cfg *kubeadmapi.InitConfiguration) error
- func SetJoinControlPlaneDefaults(cfg *kubeadmapi.JoinControlPlane) error
- func SetJoinDynamicDefaults(cfg *kubeadmapi.JoinConfiguration) error
- func SetNodeRegistrationDynamicDefaults(cfg *kubeadmapi.NodeRegistrationOptions, masterTaint bool) error
- func ValidateSupportedVersion(gv schema.GroupVersion) error
- func VerifyAPIServerBindAddress(address string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BytesToInternalConfig ¶ added in v1.11.0
func BytesToInternalConfig(b []byte) (*kubeadmapi.InitConfiguration, error)
BytesToInternalConfig converts a byte slice to an internal, defaulted and validated configuration object. The byte slice may contain one or many different YAML documents. These YAML documents are parsed one-by-one and well-known ComponentConfig GroupVersionKinds are stored inside of the internal InitConfiguration struct
func ChooseAPIServerBindAddress ¶ added in v1.12.0
ChooseAPIServerBindAddress is a wrapper for netutil.ChooseBindAddress that also handles the case where no default routes were found and an IP for the API server could not be obatained.
func DefaultedInitConfiguration ¶
func DefaultedInitConfiguration(defaultversionedcfg *kubeadmapiv1beta1.InitConfiguration) (*kubeadmapi.InitConfiguration, error)
DefaultedInitConfiguration takes a versioned init config (often populated by flags), defaults it and converts it into internal InitConfiguration
func DefaultedJoinConfiguration ¶
func DefaultedJoinConfiguration(defaultversionedcfg *kubeadmapiv1beta1.JoinConfiguration) (*kubeadmapi.JoinConfiguration, error)
DefaultedJoinConfiguration takes a versioned JoinConfiguration (usually filled in by command line parameters), defaults it, converts it to internal and validates it
func FetchInitConfigurationFromCluster ¶
func FetchInitConfigurationFromCluster(client clientset.Interface, w io.Writer, logPrefix string, newControlPlane bool) (*kubeadmapi.InitConfiguration, error)
FetchInitConfigurationFromCluster fetches configuration from a ConfigMap in the cluster
func GetClusterStatus ¶
func GetClusterStatus(client clientset.Interface) (*kubeadmapi.ClusterStatus, error)
GetClusterStatus returns the kubeadm cluster status read from the kubeadm-config ConfigMap
func LoadInitConfigurationFromFile ¶
func LoadInitConfigurationFromFile(cfgPath string) (*kubeadmapi.InitConfiguration, error)
LoadInitConfigurationFromFile loads a supported versioned InitConfiguration from a file, converts it into internal config, defaults it and verifies it.
func LoadJoinConfigurationFromFile ¶
func LoadJoinConfigurationFromFile(cfgPath string) (*kubeadmapi.JoinConfiguration, error)
LoadJoinConfigurationFromFile loads versioned JoinConfiguration from file, converts it to internal, defaults and validates it
func LoadOrDefaultInitConfiguration ¶
func LoadOrDefaultInitConfiguration(cfgPath string, defaultversionedcfg *kubeadmapiv1beta1.InitConfiguration) (*kubeadmapi.InitConfiguration, error)
LoadOrDefaultInitConfiguration takes a path to a config file and a versioned configuration that can serve as the default config If cfgPath is specified, defaultversionedcfg will always get overridden. Otherwise, the default config (often populated by flags) will be used. Then the external, versioned configuration is defaulted and converted to the internal type. Right thereafter, the configuration is defaulted again with dynamic values (like IP addresses of a machine, etc) Lastly, the internal config is validated and returned.
func LoadOrDefaultJoinConfiguration ¶
func LoadOrDefaultJoinConfiguration(cfgPath string, defaultversionedcfg *kubeadmapiv1beta1.JoinConfiguration) (*kubeadmapi.JoinConfiguration, error)
LoadOrDefaultJoinConfiguration takes a path to a config file and a versioned configuration that can serve as the default config If cfgPath is specified, defaultversionedcfg will always get overridden. Otherwise, the default config (often populated by flags) will be used. Then the external, versioned configuration is defaulted and converted to the internal type. Right thereafter, the configuration is defaulted again with dynamic values (like IP addresses of a machine, etc) Lastly, the internal config is validated and returned.
func LowercaseSANs ¶ added in v1.11.0
func LowercaseSANs(sans []string)
LowercaseSANs can be used to force all SANs to be lowercase so it passes IsDNS1123Subdomain
func MarshalClusterConfigurationToBytes ¶ added in v1.12.0
func MarshalClusterConfigurationToBytes(clustercfg *kubeadmapi.ClusterConfiguration, gv schema.GroupVersion) ([]byte, error)
MarshalClusterConfigurationToBytes marshals the internal ClusterConfiguration object to bytes. It writes the embedded ComponentConfiguration objects out as separate YAML documents
func MarshalInitConfigurationToBytes ¶ added in v1.12.0
func MarshalInitConfigurationToBytes(cfg *kubeadmapi.InitConfiguration, gv schema.GroupVersion) ([]byte, error)
MarshalInitConfigurationToBytes marshals the internal InitConfiguration object to bytes. It writes the embedded ClusterConfiguration object with ComponentConfigs out as separate YAML documents
func MarshalKubeadmConfigObject ¶ added in v1.12.0
MarshalKubeadmConfigObject marshals an Object registered in the kubeadm scheme. If the object is a InitConfiguration or ClusterConfiguration, some extra logic is run
func MigrateOldConfigFromFile ¶
MigrateOldConfigFromFile migrates an old configuration from a file into a new one (returned as a byte slice). Only kubeadm kinds are migrated. Others are silently ignored.
func NormalizeKubernetesVersion ¶ added in v1.9.0
func NormalizeKubernetesVersion(cfg *kubeadmapi.ClusterConfiguration) error
NormalizeKubernetesVersion resolves version labels, sets alternative image registry if requested for CI builds, and validates minimal version that kubeadm SetInitDynamicDefaultssupports.
func SetAPIEndpointDynamicDefaults ¶ added in v1.12.0
func SetAPIEndpointDynamicDefaults(cfg *kubeadmapi.APIEndpoint) error
SetAPIEndpointDynamicDefaults checks and sets configuration values for the APIEndpoint object
func SetBootstrapTokensDynamicDefaults ¶ added in v1.12.0
func SetBootstrapTokensDynamicDefaults(cfg *[]kubeadmapi.BootstrapToken) error
SetBootstrapTokensDynamicDefaults checks and sets configuration values for the BootstrapTokens object
func SetClusterDynamicDefaults ¶ added in v1.12.0
func SetClusterDynamicDefaults(cfg *kubeadmapi.ClusterConfiguration, advertiseAddress string, bindPort int32) error
SetClusterDynamicDefaults checks and sets values for the ClusterConfiguration object
func SetInitDynamicDefaults ¶
func SetInitDynamicDefaults(cfg *kubeadmapi.InitConfiguration) error
SetInitDynamicDefaults checks and sets configuration values for the InitConfiguration object
func SetJoinControlPlaneDefaults ¶
func SetJoinControlPlaneDefaults(cfg *kubeadmapi.JoinControlPlane) error
SetJoinControlPlaneDefaults checks and sets configuration values for the JoinControlPlane object
func SetJoinDynamicDefaults ¶ added in v1.11.0
func SetJoinDynamicDefaults(cfg *kubeadmapi.JoinConfiguration) error
SetJoinDynamicDefaults checks and sets configuration values for the JoinConfiguration object
func SetNodeRegistrationDynamicDefaults ¶ added in v1.12.0
func SetNodeRegistrationDynamicDefaults(cfg *kubeadmapi.NodeRegistrationOptions, masterTaint bool) error
SetNodeRegistrationDynamicDefaults checks and sets configuration values for the NodeRegistration object
func ValidateSupportedVersion ¶
func ValidateSupportedVersion(gv schema.GroupVersion) error
ValidateSupportedVersion checks if a supplied GroupVersion is not on the list of unsupported GVs. If it is, an error is returned.
func VerifyAPIServerBindAddress ¶ added in v1.12.0
VerifyAPIServerBindAddress can be used to verify if a bind address for the API Server is 0.0.0.0, in which case this address is not valid and should not be used.
Types ¶
This section is empty.
Source Files
Directories