mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-24 20:24:09 +00:00
Merge pull request #45227 from wojtek-t/edge_based_hollow_proxy
Automatic merge from submit-queue Fix hollow proxy to watch services and endpoints Ref #34727
This commit is contained in:
commit
1a09348541
@ -38,7 +38,10 @@ type HollowProxy struct {
|
||||
|
||||
type FakeProxyHandler struct{}
|
||||
|
||||
func (*FakeProxyHandler) OnServiceUpdate(services []*api.Service) {}
|
||||
func (*FakeProxyHandler) OnServiceAdd(service *api.Service) {}
|
||||
func (*FakeProxyHandler) OnServiceUpdate(oldService, service *api.Service) {}
|
||||
func (*FakeProxyHandler) OnServiceDelete(service *api.Service) {}
|
||||
func (*FakeProxyHandler) OnServiceSynced() {}
|
||||
func (*FakeProxyHandler) OnEndpointsAdd(endpoints *api.Endpoints) {}
|
||||
func (*FakeProxyHandler) OnEndpointsUpdate(oldEndpoints, endpoints *api.Endpoints) {}
|
||||
func (*FakeProxyHandler) OnEndpointsDelete(endpoints *api.Endpoints) {}
|
||||
@ -46,7 +49,6 @@ func (*FakeProxyHandler) OnEndpointsSynced()
|
||||
|
||||
type FakeProxier struct{}
|
||||
|
||||
func (*FakeProxier) OnServiceUpdate(services []*api.Service) {}
|
||||
func (*FakeProxier) Sync() {}
|
||||
func (*FakeProxier) SyncLoop() {
|
||||
select {}
|
||||
@ -81,6 +83,8 @@ func NewHollowProxyOrDie(
|
||||
OOMScoreAdj: util.Int32Ptr(0),
|
||||
ResourceContainer: "",
|
||||
ConfigSyncPeriod: 30 * time.Second,
|
||||
ServiceEventHandler: &FakeProxyHandler{},
|
||||
EndpointsEventHandler: &FakeProxyHandler{},
|
||||
},
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user