From 2eb47cce18449866059b3ca8bdcb6d82791568f1 Mon Sep 17 00:00:00 2001 From: Artem Glazychev Date: Wed, 1 Dec 2021 18:01:11 +0700 Subject: [PATCH] Add registrationtime chain element Signed-off-by: Artem Glazychev --- pkg/registry/chains/registryk8s/registry-k8s.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pkg/registry/chains/registryk8s/registry-k8s.go b/pkg/registry/chains/registryk8s/registry-k8s.go index 536869a..3ffbeeb 100644 --- a/pkg/registry/chains/registryk8s/registry-k8s.go +++ b/pkg/registry/chains/registryk8s/registry-k8s.go @@ -28,6 +28,7 @@ import ( "github.com/networkservicemesh/sdk/pkg/registry/common/expire" "github.com/networkservicemesh/sdk/pkg/registry/common/proxy" "github.com/networkservicemesh/sdk/pkg/registry/common/serialize" + "github.com/networkservicemesh/sdk/pkg/registry/common/setregistrationtime" "github.com/networkservicemesh/sdk/pkg/registry/core/chain" "github.com/networkservicemesh/sdk-k8s/pkg/registry/etcd" @@ -47,6 +48,7 @@ type Config struct { func NewServer(config *Config, dialOptions ...grpc.DialOption) registryserver.Registry { nseChain := chain.NewNetworkServiceEndpointRegistryServer( serialize.NewNetworkServiceEndpointRegistryServer(), + setregistrationtime.NewNetworkServiceEndpointRegistryServer(), expire.NewNetworkServiceEndpointRegistryServer(config.ChainCtx, config.ExpirePeriod), etcd.NewNetworkServiceEndpointRegistryServer(config.ChainCtx, config.Namespace, config.ClientSet), proxy.NewNetworkServiceEndpointRegistryServer(config.ProxyRegistryURL),