Documentation
¶
Index ¶
- func GetHollowKubeletConfig(opt *HollowKubeletOptions) (*options.KubeletFlags, *kubeletconfig.KubeletConfiguration)
- type HollowKubelet
- type HollowKubeletOptions
- type KubemarkController
- func (kubemarkController *KubemarkController) GetNodeGroupForNode(node string) (string, error)
- func (kubemarkController *KubemarkController) GetNodeGroupSize(nodeGroup string) (int, error)
- func (kubemarkController *KubemarkController) GetNodeGroupTargetSize(nodeGroup string) (int, error)
- func (kubemarkController *KubemarkController) GetNodeNamesForNodeGroup(nodeGroup string) ([]string, error)
- func (kubemarkController *KubemarkController) RemoveNodeFromNodeGroup(nodeGroup string, node string) error
- func (kubemarkController *KubemarkController) Run(stopCh chan struct{})
- func (kubemarkController *KubemarkController) SetNodeGroupSize(nodeGroup string, size int) error
- func (kubemarkController *KubemarkController) WaitForCacheSync(stopCh chan struct{}) bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetHollowKubeletConfig ¶ added in v1.4.0
func GetHollowKubeletConfig(opt *HollowKubeletOptions) (*options.KubeletFlags, *kubeletconfig.KubeletConfiguration)
Builds a KubeletConfiguration for the HollowKubelet, ensuring that the usual defaults are applied for fields we do not override.
Types ¶
type HollowKubelet ¶
type HollowKubelet struct {
KubeletFlags *options.KubeletFlags
KubeletConfiguration *kubeletconfig.KubeletConfiguration
KubeletDeps *kubelet.Dependencies
}
func NewHollowKubelet ¶
func NewHollowKubelet( flags *options.KubeletFlags, config *kubeletconfig.KubeletConfiguration, client *clientset.Clientset, heartbeatClient *clientset.Clientset, cadvisorInterface cadvisor.Interface, imageService internalapi.ImageManagerService, runtimeService internalapi.RuntimeService, containerManager cm.ContainerManager) *HollowKubelet
type HollowKubeletOptions ¶ added in v1.27.0
type HollowKubeletOptions struct {
NodeName string
KubeletPort int
KubeletReadOnlyPort int
MaxPods int
PodsPerCore int
NodeLabels map[string]string
RegisterWithTaints []v1.Taint
}
HollowKubeletOptions contains settable parameters for hollow kubelet.
type KubemarkController ¶ added in v1.8.0
type KubemarkController struct {
// contains filtered or unexported fields
}
KubemarkController is a simplified version of cloud provider for kubemark. It allows to add and delete nodes from a kubemark cluster and introduces nodegroups by applying labels to the kubemark's hollow-nodes.
func NewKubemarkController ¶ added in v1.8.0
func NewKubemarkController(externalClient kubeclient.Interface, externalInformerFactory informers.SharedInformerFactory, kubemarkClient kubeclient.Interface, kubemarkNodeInformer informersv1.NodeInformer) (*KubemarkController, error)
NewKubemarkController creates KubemarkController using the provided clients to talk to external and kubemark clusters.
func (*KubemarkController) GetNodeGroupForNode ¶ added in v1.8.0
func (kubemarkController *KubemarkController) GetNodeGroupForNode(node string) (string, error)
GetNodeGroupForNode returns the name of the node group to which the node belongs.
func (*KubemarkController) GetNodeGroupSize ¶ added in v1.8.0
func (kubemarkController *KubemarkController) GetNodeGroupSize(nodeGroup string) (int, error)
GetNodeGroupSize returns the current size for the node group as observed.
func (*KubemarkController) GetNodeGroupTargetSize ¶ added in v1.8.0
func (kubemarkController *KubemarkController) GetNodeGroupTargetSize(nodeGroup string) (int, error)
GetNodeGroupTargetSize returns the size of the node group as a sum of current observed size and number of upcoming nodes.
func (*KubemarkController) GetNodeNamesForNodeGroup ¶ added in v1.8.0
func (kubemarkController *KubemarkController) GetNodeNamesForNodeGroup(nodeGroup string) ([]string, error)
GetNodeNamesForNodeGroup returns list of the nodes in the node group.
func (*KubemarkController) RemoveNodeFromNodeGroup ¶ added in v1.8.0
func (kubemarkController *KubemarkController) RemoveNodeFromNodeGroup(nodeGroup string, node string) error
func (*KubemarkController) Run ¶ added in v1.8.0
func (kubemarkController *KubemarkController) Run(stopCh chan struct{})
Run populates the node template needed for creation of kubemark nodes and starts the worker routine for creating new nodes.
func (*KubemarkController) SetNodeGroupSize ¶ added in v1.8.0
func (kubemarkController *KubemarkController) SetNodeGroupSize(nodeGroup string, size int) error
SetNodeGroupSize changes the size of node group by adding or removing nodes.
func (*KubemarkController) WaitForCacheSync ¶ added in v1.8.0
func (kubemarkController *KubemarkController) WaitForCacheSync(stopCh chan struct{}) bool
WaitForCacheSync waits until all caches in the controller are populated.
Source Files