Help us shape the future of Go! Take the 2026 Go Developer Survey

kubemark

package
v1.10.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 16, 2019 License: Apache-2.0 Imports: 45 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetHollowKubeletConfig added in v1.4.0 

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 *api.Endpoints)

func (*FakeProxier) OnEndpointsDelete added in v1.7.0 

func (*FakeProxier) OnEndpointsDelete(endpoints *api.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 *api.Endpoints)

func (*FakeProxier) OnServiceAdd added in v1.7.0 

func (*FakeProxier) OnServiceAdd(service *api.Service)

func (*FakeProxier) OnServiceDelete added in v1.7.0 

func (*FakeProxier) OnServiceDelete(service *api.Service)

func (*FakeProxier) OnServiceSynced added in v1.7.0 

func (*FakeProxier) OnServiceSynced()

func (*FakeProxier) OnServiceUpdate 

func (*FakeProxier) OnServiceUpdate(oldService, service *api.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

func (*HollowKubelet) Run 

func (hk *HollowKubelet) Run()

Starts this HollowKubelet and blocks.

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,
) (*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.

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.