From 86c9108eb7237040cdb977ed1e015c6445f61b0f Mon Sep 17 00:00:00 2001 From: wangyd1988 Date: Wed, 15 Nov 2023 20:01:35 +0800 Subject: [PATCH] =?UTF-8?q?=E6=89=93=E5=8D=B0brocker=20to=20local=20,local?= =?UTF-8?q?=20to=20broker=20=20list/watch=20=20=E8=B5=84=E6=BA=90gvr?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/syncer/resource_syncer.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/syncer/resource_syncer.go b/pkg/syncer/resource_syncer.go index 56738a0d..2c8d8749 100644 --- a/pkg/syncer/resource_syncer.go +++ b/pkg/syncer/resource_syncer.go @@ -218,6 +218,8 @@ type resourceSyncer struct { } func NewResourceSyncer(config *ResourceSyncerConfig) (Interface, error) { + + utilruntime.HandleError(fmt.Errorf("NewResourceSyncer,Direction:%v;",config.Direction)) syncer := &resourceSyncer{ config: *config, stopped: make(chan struct{}), @@ -260,6 +262,8 @@ func NewResourceSyncer(config *ResourceSyncerConfig) (Interface, error) { resourceClient := config.SourceClient.Resource(*gvr).Namespace(config.SourceNamespace) + + utilruntime.HandleError(fmt.Errorf("NewResourceSyncer,by gvr:%+v list or watch resource;",gvr)) //nolint:wrapcheck // These are wrapper functions. syncer.store, syncer.informer = cache.NewInformer(&cache.ListWatch{ ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {