Documentation ¶
Index ¶
- func GetHollowKubeletConfig(nodeName string, kubeletPort int, kubeletReadOnlyPort int, maxPods int, ...) (*options.KubeletFlags, *kubeletconfig.KubeletConfiguration)
- type FakeProxier
- func (*FakeProxier) OnEndpointsAdd(endpoints *v1.Endpoints)
- func (*FakeProxier) OnEndpointsDelete(endpoints *v1.Endpoints)
- func (*FakeProxier) OnEndpointsSynced()
- func (*FakeProxier) OnEndpointsUpdate(oldEndpoints, endpoints *v1.Endpoints)
- func (*FakeProxier) OnServiceAdd(service *v1.Service)
- func (*FakeProxier) OnServiceDelete(service *v1.Service)
- func (*FakeProxier) OnServiceSynced()
- func (*FakeProxier) OnServiceUpdate(oldService, service *v1.Service)
- func (*FakeProxier) Sync()
- func (*FakeProxier) SyncLoop()
- type HollowKubelet
- type HollowProxy
- 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.2
func GetHollowKubeletConfig( nodeName string, kubeletPort int, kubeletReadOnlyPort int, maxPods int, podsPerCore int) (*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 FakeProxier ¶
type FakeProxier struct{}
func (*FakeProxier) OnEndpointsAdd ¶ added in v1.7.0
func (*FakeProxier) OnEndpointsAdd(endpoints *v1.Endpoints)
func (*FakeProxier) OnEndpointsDelete ¶ added in v1.7.0
func (*FakeProxier) OnEndpointsDelete(endpoints *v1.Endpoints)
func (*FakeProxier) OnEndpointsSynced ¶ added in v1.7.0
func (*FakeProxier) OnEndpointsSynced()
func (*FakeProxier) OnEndpointsUpdate ¶ added in v1.7.0
func (*FakeProxier) OnEndpointsUpdate(oldEndpoints, endpoints *v1.Endpoints)
func (*FakeProxier) OnServiceAdd ¶ added in v1.7.0
func (*FakeProxier) OnServiceAdd(service *v1.Service)
func (*FakeProxier) OnServiceDelete ¶ added in v1.7.0
func (*FakeProxier) OnServiceDelete(service *v1.Service)
func (*FakeProxier) OnServiceSynced ¶ added in v1.7.0
func (*FakeProxier) OnServiceSynced()
func (*FakeProxier) OnServiceUpdate ¶
func (*FakeProxier) OnServiceUpdate(oldService, service *v1.Service)
func (*FakeProxier) Sync ¶
func (*FakeProxier) Sync()
func (*FakeProxier) SyncLoop ¶
func (*FakeProxier) SyncLoop()
type HollowKubelet ¶
type HollowKubelet struct { KubeletFlags *options.KubeletFlags KubeletConfiguration *kubeletconfig.KubeletConfiguration KubeletDeps *kubelet.Dependencies }
func NewHollowKubelet ¶
func NewHollowKubelet( nodeName string, client *clientset.Clientset, cadvisorInterface cadvisor.Interface, dockerClientConfig *dockershim.ClientConfig, kubeletPort, kubeletReadOnlyPort int, containerManager cm.ContainerManager, maxPods int, podsPerCore int, ) *HollowKubelet
type HollowProxy ¶
type HollowProxy struct {
ProxyServer *proxyapp.ProxyServer
}
func NewHollowProxyOrDie ¶
func NewHollowProxyOrDie( nodeName string, client clientset.Interface, eventClient v1core.EventsGetter, iptInterface utiliptables.Interface, sysctl utilsysctl.Interface, execer utilexec.Interface, broadcaster record.EventBroadcaster, recorder record.EventRecorder, useRealProxier bool, proxierSyncPeriod time.Duration, proxierMinSyncPeriod time.Duration, ) (*HollowProxy, error)
func (*HollowProxy) Run ¶
func (hp *HollowProxy) Run()
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.