kubemark

Documentation

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) OnServiceCIDRsChanged(_ []string)
  • 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 NewHollowProxy(nodeName string, client clientset.Interface, eventClient v1core.EventsGetter, ...) *HollowProxy
  • 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) OnServiceCIDRsChanged

func (*FakeProxier) OnServiceCIDRsChanged(_ []string)

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 NewHollowProxy

func NewHollowProxy(
	nodeName string,
	client clientset.Interface,
	eventClient v1core.EventsGetter,
	broadcaster events.EventBroadcaster,
	recorder events.EventRecorder,
) *HollowProxy

func (*HollowProxy) Run

func (hp *HollowProxy) Run() error