upgrade sdk

Signed-off-by: Wei Liu <[email protected]>

go.mod

@@ -36,7 +36,7 @@ require (
 	k8s.io/utils v0.0.0-20240310230437-4693a0247e57
 	open-cluster-management.io/addon-framework v0.9.1-0.20240419070222-e703fc5a2556
 	open-cluster-management.io/api v0.13.1-0.20240605083248-f9e7f50520fc
-	open-cluster-management.io/sdk-go v0.13.1-0.20240605055850-874c2c7ac523
+	open-cluster-management.io/sdk-go v0.13.1-0.20240614070053-a01091a14da7
 	sigs.k8s.io/controller-runtime v0.17.3
 	sigs.k8s.io/kube-storage-version-migrator v0.0.6-0.20230721195810-5c8923c5ff96
 )

go.sum

@@ -469,8 +469,8 @@ open-cluster-management.io/addon-framework v0.9.1-0.20240419070222-e703fc5a2556
 open-cluster-management.io/addon-framework v0.9.1-0.20240419070222-e703fc5a2556/go.mod h1:HayKCznnlyW+0dUJQGj5sNR6i3tvylSySD3YnvZkBtY=
 open-cluster-management.io/api v0.13.1-0.20240605083248-f9e7f50520fc h1:tcfncubZRFphYtDXBE7ApBNlSnj1RNazhW+8F01XYYg=
 open-cluster-management.io/api v0.13.1-0.20240605083248-f9e7f50520fc/go.mod h1:ltijKJhDifrPH0csvCUmFt5lzaERv+BBfh6X3l83rT0=
-open-cluster-management.io/sdk-go v0.13.1-0.20240605055850-874c2c7ac523 h1:XMtsnv0zT8UvXcH4JbqquzhK4BK/XrCg81pCmp50VDs=
-open-cluster-management.io/sdk-go v0.13.1-0.20240605055850-874c2c7ac523/go.mod h1:muWzHWsgK8IsopltwTnsBjf4DN9IcC9rF0G2uEq/Pjw=
+open-cluster-management.io/sdk-go v0.13.1-0.20240614070053-a01091a14da7 h1:/Tit/ldsK/+gwYpljBPzOGpFwdN44+yIOiHO+kja5XU=
+open-cluster-management.io/sdk-go v0.13.1-0.20240614070053-a01091a14da7/go.mod h1:muWzHWsgK8IsopltwTnsBjf4DN9IcC9rF0G2uEq/Pjw=
 sigs.k8s.io/apiserver-network-proxy/konnectivity-client v0.28.0 h1:TgtAeesdhpm2SGwkQasmbeqDo8th5wOBA5h/AjTKA4I=
 sigs.k8s.io/apiserver-network-proxy/konnectivity-client v0.28.0/go.mod h1:VHVDI/KrK4fjnV61bE2g3sA7tiETLn8sooImelsCx3Y=
 sigs.k8s.io/controller-runtime v0.17.3 h1:65QmN7r3FWgTxDMz9fvGnO1kbf2nu+acg9p2R9oYYYk=

pkg/work/hub/manager.go

@@ -68,7 +68,7 @@ func (c *WorkHubManagerConfig) RunWorkHubManager(ctx context.Context, controller
 	)
 
 	var workClient workclientset.Interface
-	var watcherStore *store.InformerWatcherStore
+	var watcherStore *store.SourceInformerWatcherStore
 
 	if c.workOptions.WorkDriver == "kube" {
 		config := controllerContext.KubeConfig
@@ -88,7 +88,7 @@ func (c *WorkHubManagerConfig) RunWorkHubManager(ctx context.Context, controller
 		// ManifestWorkInterface and ManifestWork informer based on different driver configuration.
 		// Refer to Event Based Manifestwork proposal in enhancements repo to get more details.
 
-		watcherStore = store.NewInformerWatcherStore(ctx)
+		watcherStore = store.NewSourceInformerWatcherStore(ctx)
 
 		_, config, err := generic.NewConfigLoader(c.workOptions.WorkDriver, c.workOptions.WorkDriverConfig).
 			LoadConfig()

pkg/work/spoke/spokeagent.go

@@ -22,6 +22,7 @@ import (
 	"open-cluster-management.io/sdk-go/pkg/cloudevents/generic"
 	cloudeventswork "open-cluster-management.io/sdk-go/pkg/cloudevents/work"
 	"open-cluster-management.io/sdk-go/pkg/cloudevents/work/agent/codec"
+	"open-cluster-management.io/sdk-go/pkg/cloudevents/work/store"
 
 	"open-cluster-management.io/ocm/pkg/common/options"
 	"open-cluster-management.io/ocm/pkg/features"
@@ -213,45 +214,60 @@ func (o *WorkAgentConfig) newHubWorkClientAndInformer(
 	ctx context.Context,
 	restMapper meta.RESTMapper,
 ) (string, workv1client.ManifestWorkInterface, workv1informers.ManifestWorkInformer, error) {
+	var workClient workclientset.Interface
+	var watcherStore *store.AgentInformerWatcherStore
+	var hubHost string
+
 	if o.workOptions.WorkloadSourceDriver == "kube" {
 		config, err := clientcmd.BuildConfigFromFlags("", o.workOptions.WorkloadSourceConfig)
 		if err != nil {
 			return "", nil, nil, err
 		}
 
-		kubeWorkClientSet, err := workclientset.NewForConfig(config)
+		workClient, err = workclientset.NewForConfig(config)
 		if err != nil {
 			return "", nil, nil, err
 		}
 
-		factory := workinformers.NewSharedInformerFactoryWithOptions(
-			kubeWorkClientSet,
-			5*time.Minute,
-			workinformers.WithNamespace(o.agentOptions.SpokeClusterName),
-		)
-		informer := factory.Work().V1().ManifestWorks()
+		hubHost = config.Host
+	} else {
+		// For cloudevents drivers, we build ManifestWork client that implements the
+		// ManifestWorkInterface and ManifestWork informer based on different driver configuration.
+		// Refer to Event Based Manifestwork proposal in enhancements repo to get more details.
 
-		return config.Host, kubeWorkClientSet.WorkV1().ManifestWorks(o.agentOptions.SpokeClusterName), informer, nil
-	}
+		watcherStore = store.NewAgentInformerWatcherStore()
 
-	// For cloudevents drivers, we build ManifestWork client that implements the
-	// ManifestWorkInterface and ManifestWork informer based on different driver configuration.
-	// Refer to Event Based Manifestwork proposal in enhancements repo to get more details.
-	hubHost, config, err := generic.NewConfigLoader(o.workOptions.WorkloadSourceDriver, o.workOptions.WorkloadSourceConfig).
-		LoadConfig()
-	if err != nil {
-		return "", nil, nil, err
+		serverHost, config, err := generic.NewConfigLoader(o.workOptions.WorkloadSourceDriver, o.workOptions.WorkloadSourceConfig).
+			LoadConfig()
+		if err != nil {
+			return "", nil, nil, err
+		}
+
+		clientHolder, err := cloudeventswork.NewClientHolderBuilder(config).
+			WithClientID(o.workOptions.CloudEventsClientID).
+			WithClusterName(o.agentOptions.SpokeClusterName).
+			WithCodecs(buildCodecs(o.workOptions.CloudEventsClientCodecs, restMapper)...).
+			WithWorkClientWatcherStore(watcherStore).
+			NewAgentClientHolder(ctx)
+		if err != nil {
+			return "", nil, nil, err
+		}
+
+		hubHost = serverHost
+		workClient = clientHolder.WorkInterface()
 	}
 
-	clientHolder, informer, err := cloudeventswork.NewClientHolderBuilder(config).
-		WithClientID(o.workOptions.CloudEventsClientID).
-		WithInformerConfig(5*time.Minute, workinformers.WithNamespace(o.agentOptions.SpokeClusterName)).
-		WithClusterName(o.agentOptions.SpokeClusterName).
-		WithCodecs(buildCodecs(o.workOptions.CloudEventsClientCodecs, restMapper)...).
-		NewAgentClientHolderWithInformer(ctx)
-	if err != nil {
-		return "", nil, nil, err
+	factory := workinformers.NewSharedInformerFactoryWithOptions(
+		workClient,
+		5*time.Minute,
+		workinformers.WithNamespace(o.agentOptions.SpokeClusterName),
+	)
+	informer := factory.Work().V1().ManifestWorks()
+
+	// For cloudevents work client, we use the informer store as the client store
+	if watcherStore != nil {
+		watcherStore.SetStore(informer.Informer().GetStore())
 	}
 
-	return hubHost, clientHolder.ManifestWorks(o.agentOptions.SpokeClusterName), informer, err
+	return hubHost, workClient.WorkV1().ManifestWorks(o.agentOptions.SpokeClusterName), informer, nil
 }

vendor/modules.txt

@@ -1589,7 +1589,7 @@ open-cluster-management.io/api/utils/work/v1/workapplier
 open-cluster-management.io/api/utils/work/v1/workvalidator
 open-cluster-management.io/api/work/v1
 open-cluster-management.io/api/work/v1alpha1
-# open-cluster-management.io/sdk-go v0.13.1-0.20240605055850-874c2c7ac523
+# open-cluster-management.io/sdk-go v0.13.1-0.20240614070053-a01091a14da7
 ## explicit; go 1.21
 open-cluster-management.io/sdk-go/pkg/apis/cluster/v1alpha1
 open-cluster-management.io/sdk-go/pkg/apis/cluster/v1beta1
@@ -1611,7 +1611,7 @@ open-cluster-management.io/sdk-go/pkg/cloudevents/generic/types
 open-cluster-management.io/sdk-go/pkg/cloudevents/work
 open-cluster-management.io/sdk-go/pkg/cloudevents/work/agent/client
 open-cluster-management.io/sdk-go/pkg/cloudevents/work/agent/codec
-open-cluster-management.io/sdk-go/pkg/cloudevents/work/agent/handler
+open-cluster-management.io/sdk-go/pkg/cloudevents/work/agent/lister
 open-cluster-management.io/sdk-go/pkg/cloudevents/work/common
 open-cluster-management.io/sdk-go/pkg/cloudevents/work/internal
 open-cluster-management.io/sdk-go/pkg/cloudevents/work/payload