From 1e1c4c5ac9a72728228141c79b6286f98947decb Mon Sep 17 00:00:00 2001 From: Antonio Ojea Date: Sun, 4 Apr 2021 02:13:10 +0200 Subject: [PATCH] add node handlers to the metaproxier --- pkg/proxy/metaproxier/meta_proxier.go | 28 +++++++++++++++++++++++++++ 1 file changed, 28 insertions(+) diff --git a/pkg/proxy/metaproxier/meta_proxier.go b/pkg/proxy/metaproxier/meta_proxier.go index 20b0413ea0f..40a570d2b3d 100644 --- a/pkg/proxy/metaproxier/meta_proxier.go +++ b/pkg/proxy/metaproxier/meta_proxier.go @@ -216,3 +216,31 @@ func endpointsIPFamily(endpoints *v1.Endpoints) (*v1.IPFamily, error) { return &ipv4, nil } + +// OnNodeAdd is called whenever creation of new node object is observed. +func (proxier *metaProxier) OnNodeAdd(node *v1.Node) { + proxier.ipv4Proxier.OnNodeAdd(node) + proxier.ipv6Proxier.OnNodeAdd(node) +} + +// OnNodeUpdate is called whenever modification of an existing +// node object is observed. +func (proxier *metaProxier) OnNodeUpdate(oldNode, node *v1.Node) { + proxier.ipv4Proxier.OnNodeUpdate(oldNode, node) + proxier.ipv6Proxier.OnNodeUpdate(oldNode, node) +} + +// OnNodeDelete is called whenever deletion of an existing node +// object is observed. +func (proxier *metaProxier) OnNodeDelete(node *v1.Node) { + proxier.ipv4Proxier.OnNodeDelete(node) + proxier.ipv6Proxier.OnNodeDelete(node) + +} + +// OnNodeSynced is called once all the initial event handlers were +// called and the state is fully propagated to local cache. +func (proxier *metaProxier) OnNodeSynced() { + proxier.ipv4Proxier.OnNodeSynced() + proxier.ipv6Proxier.OnNodeSynced() +}