Skip to content

Commit

Permalink
打印brocker to local ,local to broker list/watch 资源gvr
Browse files Browse the repository at this point in the history
  • Loading branch information
wangyd1988 committed Nov 15, 2023
1 parent 72f85b7 commit 86c9108
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions pkg/syncer/resource_syncer.go
Original file line number Diff line number Diff line change
Expand Up @@ -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{}),
Expand Down Expand Up @@ -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) {
Expand Down

0 comments on commit 86c9108

Please sign in to comment.