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() +}