kubemark

Documentation

Index

• func GetHollowKubeletConfig(nodeName string, kubeletPort int, kubeletReadOnlyPort int, maxPods int, ...) (*options.KubeletFlags, *componentconfig.KubeletConfiguration)
• type FakeProxier
  • func (*FakeProxier) Sync()
  • func (*FakeProxier) SyncLoop()
• type FakeProxyHandler
  • func (*FakeProxyHandler) OnEndpointsAdd(endpoints *api.Endpoints)
  • func (*FakeProxyHandler) OnEndpointsDelete(endpoints *api.Endpoints)
  • func (*FakeProxyHandler) OnEndpointsSynced()
  • func (*FakeProxyHandler) OnEndpointsUpdate(oldEndpoints, endpoints *api.Endpoints)
  • func (*FakeProxyHandler) OnServiceAdd(service *api.Service)
  • func (*FakeProxyHandler) OnServiceDelete(service *api.Service)
  • func (*FakeProxyHandler) OnServiceSynced()
  • func (*FakeProxyHandler) OnServiceUpdate(oldService, service *api.Service)
• type HollowKubelet
  • func NewHollowKubelet(nodeName string, client *clientset.Clientset, ...) *HollowKubelet
  • func (hk *HollowKubelet) Run()
• type HollowProxy
  • func NewHollowProxyOrDie(nodeName string, client clientset.Interface, eventClient v1core.EventsGetter, ...) *HollowProxy
  • func (hp *HollowProxy) Run()

Functions

func GetHollowKubeletConfig

func GetHollowKubeletConfig(
	nodeName string,
	kubeletPort int,
	kubeletReadOnlyPort int,
	maxPods int,
	podsPerCore int) (*options.KubeletFlags, *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) Sync

func (*FakeProxier) Sync()

func (*FakeProxier) SyncLoop

func (*FakeProxier) SyncLoop()

type FakeProxyHandler

type FakeProxyHandler struct{}

func (*FakeProxyHandler) OnEndpointsAdd

func (*FakeProxyHandler) OnEndpointsAdd(endpoints *api.Endpoints)

func (*FakeProxyHandler) OnEndpointsDelete

func (*FakeProxyHandler) OnEndpointsDelete(endpoints *api.Endpoints)

func (*FakeProxyHandler) OnEndpointsSynced

func (*FakeProxyHandler) OnEndpointsSynced()

func (*FakeProxyHandler) OnEndpointsUpdate

func (*FakeProxyHandler) OnEndpointsUpdate(oldEndpoints, endpoints *api.Endpoints)

func (*FakeProxyHandler) OnServiceAdd

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

func (*FakeProxyHandler) OnServiceDelete

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

func (*FakeProxyHandler) OnServiceSynced

func (*FakeProxyHandler) OnServiceSynced()

func (*FakeProxyHandler) OnServiceUpdate

func (*FakeProxyHandler) OnServiceUpdate(oldService, service *api.Service)

type HollowKubelet

type HollowKubelet struct {
	KubeletFlags         *options.KubeletFlags
	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 clientset.Interface,
	eventClient v1core.EventsGetter,
	iptInterface utiliptables.Interface,
	broadcaster record.EventBroadcaster,
	recorder record.EventRecorder,
) *HollowProxy

func (*HollowProxy) Run

func (hp *HollowProxy) Run()