kubemark

package

v1.7.8-beta.0 Latest Latest Go to latest Published: Sep 29, 2017 License: Apache-2.0 Imports: 37 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Miciah/kubernetes

Documentation ¶

Index ¶

func GetHollowKubeletConfig(nodeName string, kubeletPort int, kubeletReadOnlyPort int, maxPods int, ...) (*options.KubeletFlags, *componentconfig.KubeletConfiguration)
type FakeProxier
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, error)
- func (hp *HollowProxy) Run()

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, *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) 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 *componentconfig.KubeletConfiguration
	KubeletDeps          *kubelet.KubeletDeps
}

func NewHollowKubelet ¶

func NewHollowKubelet(
	nodeName string,
	client *clientset.Clientset,
	cadvisorInterface cadvisor.Interface,
	dockerClient libdocker.Interface,
	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()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL