package kubemark

import "k8s.io/kubernetes/pkg/kubemark"

Index ¶

• func GetHollowKubeletConfig( nodeName string, kubeletPort int, kubeletReadOnlyPort int, maxPods int, podsPerCore int) *componentconfig.KubeletConfiguration
• type FakeProxier
• func (*FakeProxier) OnServiceUpdate(services []api.Service)
• func (*FakeProxier) Sync()
• func (*FakeProxier) SyncLoop()
• type FakeProxyHandler
• func (*FakeProxyHandler) OnEndpointsUpdate(endpoints []api.Endpoints)
• func (*FakeProxyHandler) OnServiceUpdate(services []api.Service)
• type HollowKubelet
• func NewHollowKubelet( nodeName string, client *clientset.Clientset, cadvisorInterface cadvisor.Interface, dockerClient dockertools.DockerInterface, kubeletPort, kubeletReadOnlyPort int, containerManager cm.ContainerManager, maxPods int, podsPerCore int, ) *HollowKubelet
• func (hk *HollowKubelet) Run()
• type HollowProxy
• func NewHollowProxyOrDie( nodeName string, client *client.Client, endpointsConfig *proxyconfig.EndpointsConfig, serviceConfig *proxyconfig.ServiceConfig, iptInterface utiliptables.Interface, broadcaster record.EventBroadcaster, recorder record.EventRecorder, ) *HollowProxy
• func (hp *HollowProxy) Run()

Functions ¶

func GetHollowKubeletConfig ¶

func GetHollowKubeletConfig(
	nodeName string,
	kubeletPort int,
	kubeletReadOnlyPort int,
	maxPods int,
	podsPerCore int) *componentconfig.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) OnServiceUpdate ¶

func (*FakeProxier) OnServiceUpdate(services []api.Service)

func (*FakeProxier) Sync ¶

func (*FakeProxier) Sync()

func (*FakeProxier) SyncLoop ¶

func (*FakeProxier) SyncLoop()

type FakeProxyHandler ¶

type FakeProxyHandler struct{}

func (*FakeProxyHandler) OnEndpointsUpdate ¶

func (*FakeProxyHandler) OnEndpointsUpdate(endpoints []api.Endpoints)

func (*FakeProxyHandler) OnServiceUpdate ¶

func (*FakeProxyHandler) OnServiceUpdate(services []api.Service)

type HollowKubelet ¶

type HollowKubelet struct {
	KubeletConfiguration *componentconfig.KubeletConfiguration
	KubeletDeps          *kubelet.KubeletDeps
}

func NewHollowKubelet ¶

func NewHollowKubelet(
	nodeName string,
	client *clientset.Clientset,
	cadvisorInterface cadvisor.Interface,
	dockerClient dockertools.DockerInterface,
	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 *client.Client,
	endpointsConfig *proxyconfig.EndpointsConfig,
	serviceConfig *proxyconfig.ServiceConfig,
	iptInterface utiliptables.Interface,
	broadcaster record.EventBroadcaster,
	recorder record.EventRecorder,
) *HollowProxy

func (*HollowProxy) Run ¶

func (hp *HollowProxy) Run()

Source Files ¶

hollow_kubelet.go hollow_proxy.go