From f86f47cb304bc62255c45cf17e3943b2fe0ac39d Mon Sep 17 00:00:00 2001 From: Artem Glazychev Date: Thu, 18 May 2023 21:01:02 +0700 Subject: [PATCH] Add metadata chain element Signed-off-by: Artem Glazychev --- pkg/registry/chains/registryk8s/registry-k8s.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/pkg/registry/chains/registryk8s/registry-k8s.go b/pkg/registry/chains/registryk8s/registry-k8s.go index 4d9e138..95f9c27 100644 --- a/pkg/registry/chains/registryk8s/registry-k8s.go +++ b/pkg/registry/chains/registryk8s/registry-k8s.go @@ -1,6 +1,6 @@ // Copyright (c) 2020-2022 Doc.ai and/or its affiliates. // -// Copyright (c) 2022 Cisco and/or its affiliates. +// Copyright (c) 2022-2023 Cisco and/or its affiliates. // // SPDX-License-Identifier: Apache-2.0 // @@ -39,6 +39,7 @@ import ( "github.com/networkservicemesh/sdk/pkg/registry/common/updatepath" "github.com/networkservicemesh/sdk/pkg/registry/core/chain" "github.com/networkservicemesh/sdk/pkg/registry/switchcase" + "github.com/networkservicemesh/sdk/pkg/registry/utils/metadata" "github.com/networkservicemesh/sdk/pkg/tools/interdomain" "github.com/networkservicemesh/sdk/pkg/tools/token" @@ -132,6 +133,7 @@ func NewServer(config *Config, tokenGenerator token.GeneratorFunc, options ...Op updatepath.NewNetworkServiceEndpointRegistryServer(tokenGenerator), opts.authorizeNSERegistryServer, begin.NewNetworkServiceEndpointRegistryServer(), + metadata.NewNetworkServiceEndpointServer(), switchcase.NewNetworkServiceEndpointRegistryServer(switchcase.NSEServerCase{ Condition: func(c context.Context, nse *registry.NetworkServiceEndpoint) bool { if interdomain.Is(nse.GetName()) { @@ -174,6 +176,7 @@ func NewServer(config *Config, tokenGenerator token.GeneratorFunc, options ...Op grpcmetadata.NewNetworkServiceRegistryServer(), updatepath.NewNetworkServiceRegistryServer(tokenGenerator), opts.authorizeNSRegistryServer, + metadata.NewNetworkServiceServer(), setpayload.NewNetworkServiceRegistryServer(), switchcase.NewNetworkServiceRegistryServer( switchcase.NSServerCase{