Remove queryCache.checkQuery()

Signed-off-by: Vladimir Popov <vladimir.popov@xored.com>

pkg/registry/common/querycache/nse_client.go

@@ -21,9 +21,9 @@ import (
 	"context"
 
 	"github.com/golang/protobuf/ptypes/empty"
-	"github.com/networkservicemesh/api/pkg/api/registry"
 	"google.golang.org/grpc"
-	"google.golang.org/protobuf/proto"
+
+	"github.com/networkservicemesh/api/pkg/api/registry"
 
 	"github.com/networkservicemesh/sdk/pkg/registry/common/memory"
 	"github.com/networkservicemesh/sdk/pkg/registry/core/next"
@@ -84,10 +84,6 @@ func (q *queryCacheNSEClient) Find(ctx context.Context, in *registry.NetworkServ
 				return
 			}
 
-			if q.checkQuery(ctx, nseQuery, opts...) != nil {
-				return
-			}
-
 			for update, err := stream.Recv(); err == nil; update, err = stream.Recv() {
 				if update.Name != nseQuery.NetworkServiceEndpoint.Name {
 					continue
@@ -104,23 +100,6 @@ func (q *queryCacheNSEClient) Find(ctx context.Context, in *registry.NetworkServ
 	return streamchannel.NewNetworkServiceEndpointFindClient(ctx, resultCh), nil
 }
 
-func (q *queryCacheNSEClient) checkQuery(ctx context.Context, nseQuery *registry.NetworkServiceEndpointQuery, opts ...grpc.CallOption) error {
-	nseQuery = proto.Clone(nseQuery).(*registry.NetworkServiceEndpointQuery)
-	nseQuery.Watch = false
-
-	findCtx, findCancel := context.WithCancel(q.chainCtx)
-	defer findCancel()
-
-	client, err := next.NetworkServiceEndpointRegistryClient(ctx).Find(findCtx, nseQuery, opts...)
-	if err != nil {
-		return err
-	}
-
-	_, err = client.Recv()
-
-	return err
-}
-
 func (q *queryCacheNSEClient) Unregister(ctx context.Context, in *registry.NetworkServiceEndpoint, opts ...grpc.CallOption) (*empty.Empty, error) {
 	return next.NetworkServiceEndpointRegistryClient(ctx).Unregister(ctx, in, opts...)
 }