package kubemark

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

Index ¶

• type FakeProxier
• func (*FakeProxier) OnEndpointSliceAdd(slice *discoveryv1.EndpointSlice)
• func (*FakeProxier) OnEndpointSliceDelete(slice *discoveryv1.EndpointSlice)
• func (*FakeProxier) OnEndpointSliceUpdate(oldSlice, slice *discoveryv1.EndpointSlice)
• func (*FakeProxier) OnEndpointSlicesSynced()
• 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 HollowProxy
• func NewHollowProxyOrDie( nodeName string, client clientset.Interface, eventClient v1core.EventsGetter, iptInterface utiliptables.Interface, sysctl utilsysctl.Interface, execer utilexec.Interface, broadcaster events.EventBroadcaster, recorder events.EventRecorder, useRealProxier bool, proxierSyncPeriod time.Duration, proxierMinSyncPeriod time.Duration, ) (*HollowProxy, error)
• func (hp *HollowProxy) Run() error

Types ¶

type FakeProxier ¶

type FakeProxier struct {
	proxyconfig.NoopNodeHandler
}

func (*FakeProxier) OnEndpointSliceAdd ¶

func (*FakeProxier) OnEndpointSliceAdd(slice *discoveryv1.EndpointSlice)

func (*FakeProxier) OnEndpointSliceDelete ¶

func (*FakeProxier) OnEndpointSliceDelete(slice *discoveryv1.EndpointSlice)

func (*FakeProxier) OnEndpointSliceUpdate ¶

func (*FakeProxier) OnEndpointSliceUpdate(oldSlice, slice *discoveryv1.EndpointSlice)

func (*FakeProxier) OnEndpointSlicesSynced ¶

func (*FakeProxier) OnEndpointSlicesSynced()

func (*FakeProxier) OnServiceAdd ¶

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

func (*FakeProxier) OnServiceDelete ¶

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

func (*FakeProxier) OnServiceSynced ¶

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 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 events.EventBroadcaster,
	recorder events.EventRecorder,
	useRealProxier bool,
	proxierSyncPeriod time.Duration,
	proxierMinSyncPeriod time.Duration,
) (*HollowProxy, error)

func (*HollowProxy) Run ¶

func (hp *HollowProxy) Run() error

Source Files ¶

hollow_proxy.go