Skip to content

Commit 82f0e71

Browse files
elgnayelgnay
committed
🌱 upgrade add-on APIs to v1beta1
Signed-off-by: Yang Le <[email protected]>
1 parent b5846d7 commit 82f0e71

File tree

79 files changed

+1493
-1434
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

79 files changed

+1493
-1434
lines changed

‎cmd/example/helloworld/main.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ import (
1515
utilflag "k8s.io/component-base/cli/flag"
1616
logs "k8s.io/component-base/logs/api/v1"
1717
"k8s.io/klog/v2"
18-
addonv1alpha1client "open-cluster-management.io/api/client/addon/clientset/versioned"
18+
addonv1beta1client "open-cluster-management.io/api/client/addon/clientset/versioned"
1919

2020
"open-cluster-management.io/addon-framework/examples/helloworld"
2121
"open-cluster-management.io/addon-framework/examples/helloworld_agent"
@@ -85,7 +85,7 @@ type addManagerConfig struct {
8585
}
8686

8787
func (c *addManagerConfig) runController(ctx context.Context, kubeConfig *rest.Config) error {
88-
addonClient, err := addonv1alpha1client.NewForConfig(kubeConfig)
88+
addonClient, err := addonv1beta1client.NewForConfig(kubeConfig)
8989
if err != nil {
9090
return err
9191
}

‎cmd/example/helloworld_helm/main.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ import (
1717
utilflag "k8s.io/component-base/cli/flag"
1818
logs "k8s.io/component-base/logs/api/v1"
1919
"k8s.io/klog/v2"
20-
addonv1alpha1client "open-cluster-management.io/api/client/addon/clientset/versioned"
20+
addonv1beta1client "open-cluster-management.io/api/client/addon/clientset/versioned"
2121

2222
"open-cluster-management.io/addon-framework/examples/helloworld"
2323
"open-cluster-management.io/addon-framework/examples/helloworld_agent"
@@ -84,7 +84,7 @@ func runController(ctx context.Context, kubeConfig *rest.Config) error {
8484
return err
8585
}
8686

87-
addonClient, err := addonv1alpha1client.NewForConfig(kubeConfig)
87+
addonClient, err := addonv1beta1client.NewForConfig(kubeConfig)
8888
if err != nil {
8989
return err
9090
}

‎examples/helloworld/helloworld.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import (
1010
"open-cluster-management.io/addon-framework/pkg/addonfactory"
1111
"open-cluster-management.io/addon-framework/pkg/agent"
1212
"open-cluster-management.io/addon-framework/pkg/utils"
13-
addonapiv1alpha1 "open-cluster-management.io/api/addon/v1alpha1"
13+
addonapiv1beta1 "open-cluster-management.io/api/addon/v1beta1"
1414
clusterv1 "open-cluster-management.io/api/cluster/v1"
1515
)
1616

@@ -33,7 +33,7 @@ func NewRegistrationOption(kubeConfig *rest.Config, addonName, agentName string)
3333
}
3434

3535
func GetDefaultValues(cluster *clusterv1.ManagedCluster,
36-
addon *addonapiv1alpha1.ManagedClusterAddOn) (addonfactory.Values, error) {
36+
addon *addonapiv1beta1.ManagedClusterAddOn) (addonfactory.Values, error) {
3737

3838
image := os.Getenv("EXAMPLE_IMAGE_NAME")
3939
if len(image) == 0 {

‎examples/helloworld/helloworld_test.go‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import (
1010
"k8s.io/apimachinery/pkg/runtime"
1111
utilrand "k8s.io/apimachinery/pkg/util/rand"
1212
"k8s.io/klog/v2"
13-
addonapiv1alpha1 "open-cluster-management.io/api/addon/v1alpha1"
13+
addonapiv1beta1 "open-cluster-management.io/api/addon/v1beta1"
1414
fakeaddon "open-cluster-management.io/api/client/addon/clientset/versioned/fake"
1515
clusterv1 "open-cluster-management.io/api/cluster/v1"
1616

@@ -28,7 +28,7 @@ func TestManifestAddonAgent(t *testing.T) {
2828
cases := []struct {
2929
name string
3030
managedCluster *clusterv1.ManagedCluster
31-
managedClusterAddOn *addonapiv1alpha1.ManagedClusterAddOn
31+
managedClusterAddOn *addonapiv1beta1.ManagedClusterAddOn
3232
configs []runtime.Object
3333
verifyDeployment func(t *testing.T, objs []runtime.Object)
3434
}{
@@ -59,7 +59,7 @@ func TestManifestAddonAgent(t *testing.T) {
5959
{
6060
name: "override image with annotation",
6161
managedCluster: addontesting.NewManagedCluster("cluster1"),
62-
managedClusterAddOn: func() *addonapiv1alpha1.ManagedClusterAddOn {
62+
managedClusterAddOn: func() *addonapiv1beta1.ManagedClusterAddOn {
6363
addon := addontesting.NewAddon("test", "cluster1")
6464
addon.Annotations = map[string]string{
6565
"addon.open-cluster-management.io/values": `{"Image":"quay.io/test:test"}`}
@@ -88,20 +88,20 @@ func TestManifestAddonAgent(t *testing.T) {
8888
{
8989
name: "with addon deployment config",
9090
managedCluster: addontesting.NewManagedCluster("cluster1"),
91-
managedClusterAddOn: func() *addonapiv1alpha1.ManagedClusterAddOn {
91+
managedClusterAddOn: func() *addonapiv1beta1.ManagedClusterAddOn {
9292
addon := addontesting.NewAddon("test", "cluster1")
93-
addon.Status.ConfigReferences = []addonapiv1alpha1.ConfigReference{
93+
addon.Status.ConfigReferences = []addonapiv1beta1.ConfigReference{
9494
{
95-
ConfigGroupResource: addonapiv1alpha1.ConfigGroupResource{
95+
ConfigGroupResource: addonapiv1beta1.ConfigGroupResource{
9696
Group: "addon.open-cluster-management.io",
9797
Resource: "addondeploymentconfigs",
9898
},
99-
ConfigReferent: addonapiv1alpha1.ConfigReferent{
99+
ConfigReferent: addonapiv1beta1.ConfigReferent{
100100
Namespace: "cluster1",
101101
Name: "config",
102102
},
103-
DesiredConfig: &addonapiv1alpha1.ConfigSpecHash{
104-
ConfigReferent: addonapiv1alpha1.ConfigReferent{
103+
DesiredConfig: &addonapiv1beta1.ConfigSpecHash{
104+
ConfigReferent: addonapiv1beta1.ConfigReferent{
105105
Namespace: "cluster1",
106106
Name: "config",
107107
},
@@ -112,13 +112,13 @@ func TestManifestAddonAgent(t *testing.T) {
112112
return addon
113113
}(),
114114
configs: []runtime.Object{
115-
&addonapiv1alpha1.AddOnDeploymentConfig{
115+
&addonapiv1beta1.AddOnDeploymentConfig{
116116
ObjectMeta: metav1.ObjectMeta{
117117
Name: "config",
118118
Namespace: "cluster1",
119119
},
120-
Spec: addonapiv1alpha1.AddOnDeploymentConfigSpec{
121-
NodePlacement: &addonapiv1alpha1.NodePlacement{
120+
Spec: addonapiv1beta1.AddOnDeploymentConfigSpec{
121+
NodePlacement: &addonapiv1beta1.NodePlacement{
122122
Tolerations: tolerations,
123123
NodeSelector: nodeSelector,
124124
},

‎examples/helloworld_agent/agent.go‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ import (
2121
cmdfactory "open-cluster-management.io/addon-framework/pkg/cmd/factory"
2222
"open-cluster-management.io/addon-framework/pkg/lease"
2323
"open-cluster-management.io/addon-framework/pkg/version"
24-
addonv1alpha1client "open-cluster-management.io/api/client/addon/clientset/versioned"
24+
addonv1beta1client "open-cluster-management.io/api/client/addon/clientset/versioned"
2525
"open-cluster-management.io/sdk-go/pkg/basecontroller/factory"
2626
)
2727

@@ -93,7 +93,7 @@ func (o *AgentOptions) RunAgent(ctx context.Context, kubeconfig *rest.Config) er
9393
if err != nil {
9494
return err
9595
}
96-
addonClient, err := addonv1alpha1client.NewForConfig(hubRestConfig)
96+
addonClient, err := addonv1beta1client.NewForConfig(hubRestConfig)
9797
if err != nil {
9898
return err
9999
}
@@ -125,7 +125,7 @@ func (o *AgentOptions) RunAgent(ctx context.Context, kubeconfig *rest.Config) er
125125

126126
type agentController struct {
127127
spokeKubeClient kubernetes.Interface
128-
addonClient addonv1alpha1client.Interface
128+
addonClient addonv1beta1client.Interface
129129
hubConfigMapLister corev1lister.ConfigMapLister
130130
clusterName string
131131
addonName string
@@ -134,7 +134,7 @@ type agentController struct {
134134

135135
func newAgentController(
136136
spokeKubeClient kubernetes.Interface,
137-
addonClient addonv1alpha1client.Interface,
137+
addonClient addonv1beta1client.Interface,
138138
configmapInformers corev1informers.ConfigMapInformer,
139139
clusterName string,
140140
addonName string,
@@ -173,7 +173,7 @@ func (c *agentController) sync(ctx context.Context, syncCtx factory.SyncContext,
173173
return err
174174
}
175175

176-
addon, err := c.addonClient.AddonV1alpha1().ManagedClusterAddOns(clusterName).Get(ctx, c.addonName, metav1.GetOptions{})
176+
addon, err := c.addonClient.AddonV1beta1().ManagedClusterAddOns(clusterName).Get(ctx, c.addonName, metav1.GetOptions{})
177177
if err != nil {
178178
return err
179179
}

‎examples/helloworld_helm/helloworld_helm.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import (
1010
"k8s.io/client-go/kubernetes"
1111
"open-cluster-management.io/addon-framework/pkg/addonfactory"
1212
"open-cluster-management.io/addon-framework/pkg/agent"
13-
addonapiv1alpha1 "open-cluster-management.io/api/addon/v1alpha1"
13+
addonapiv1beta1 "open-cluster-management.io/api/addon/v1beta1"
1414
clusterv1 "open-cluster-management.io/api/cluster/v1"
1515
workapiv1 "open-cluster-management.io/api/work/v1"
1616
)
@@ -41,7 +41,7 @@ type userValues struct {
4141
}
4242

4343
func GetDefaultValues(cluster *clusterv1.ManagedCluster,
44-
addon *addonapiv1alpha1.ManagedClusterAddOn) (addonfactory.Values, error) {
44+
addon *addonapiv1beta1.ManagedClusterAddOn) (addonfactory.Values, error) {
4545
image := os.Getenv("EXAMPLE_IMAGE_NAME")
4646
if len(image) == 0 {
4747
image = defaultImage
@@ -66,7 +66,7 @@ func GetDefaultValues(cluster *clusterv1.ManagedCluster,
6666
func GetImageValues(kubeClient kubernetes.Interface) addonfactory.GetValuesFunc {
6767
return func(
6868
cluster *clusterv1.ManagedCluster,
69-
addon *addonapiv1alpha1.ManagedClusterAddOn,
69+
addon *addonapiv1beta1.ManagedClusterAddOn,
7070
) (addonfactory.Values, error) {
7171
overrideValues := addonfactory.Values{}
7272
for _, config := range addon.Status.ConfigReferences {
@@ -88,12 +88,12 @@ func GetImageValues(kubeClient kubernetes.Interface) addonfactory.GetValuesFunc
8888

8989
image, ok := configMap.Data["image"]
9090
if !ok {
91-
return nil, fmt.Errorf("no image in configmap %s/%s", config.Namespace, config.Name)
91+
return nil, fmt.Errorf("no image in configmap %s/%s", config.DesiredConfig.Namespace, config.DesiredConfig.Name)
9292
}
9393

9494
imagePullPolicy, ok := configMap.Data["imagePullPolicy"]
9595
if !ok {
96-
return nil, fmt.Errorf("no imagePullPolicy in configmap %s/%s", config.Namespace, config.Name)
96+
return nil, fmt.Errorf("no imagePullPolicy in configmap %s/%s", config.DesiredConfig.Namespace, config.DesiredConfig.Name)
9797
}
9898

9999
userJsonValues := userValues{
@@ -135,7 +135,7 @@ func AgentHealthProber() *agent.HealthProber {
135135
},
136136
},
137137
HealthChecker: func(fields []agent.FieldResult, cluster *clusterv1.ManagedCluster,
138-
addon *addonapiv1alpha1.ManagedClusterAddOn) error {
138+
addon *addonapiv1beta1.ManagedClusterAddOn) error {
139139
if len(fields) == 0 {
140140
return fmt.Errorf("no fields found in health checker")
141141
}

‎examples/helloworld_helm/helloworld_helm_test.go‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import (
1010
"k8s.io/apimachinery/pkg/runtime"
1111
fakekube "k8s.io/client-go/kubernetes/fake"
1212
"k8s.io/klog/v2"
13-
addonapiv1alpha1 "open-cluster-management.io/api/addon/v1alpha1"
13+
addonapiv1beta1 "open-cluster-management.io/api/addon/v1beta1"
1414
fakeaddon "open-cluster-management.io/api/client/addon/clientset/versioned/fake"
1515
clusterv1 "open-cluster-management.io/api/cluster/v1"
1616

@@ -34,7 +34,7 @@ func TestManifestAddonAgent(t *testing.T) {
3434
cases := []struct {
3535
name string
3636
managedCluster *clusterv1.ManagedCluster
37-
managedClusterAddOn *addonapiv1alpha1.ManagedClusterAddOn
37+
managedClusterAddOn *addonapiv1beta1.ManagedClusterAddOn
3838
configMaps []runtime.Object
3939
addOnDeploymentConfigs []runtime.Object
4040
verifyDeployment func(t *testing.T, objs []runtime.Object)
@@ -67,33 +67,33 @@ func TestManifestAddonAgent(t *testing.T) {
6767
{
6868
name: "with image config, addon deployment config and annotation",
6969
managedCluster: addontesting.NewManagedCluster("cluster1"),
70-
managedClusterAddOn: func() *addonapiv1alpha1.ManagedClusterAddOn {
70+
managedClusterAddOn: func() *addonapiv1beta1.ManagedClusterAddOn {
7171
addon := addontesting.NewAddon("test", "cluster1")
7272
addon.SetAnnotations(map[string]string{
7373
"addon.open-cluster-management.io/values": `{"global":{"imagePullSecret":"test-pull-secret","imagePullPolicy":"Never"}}`,
7474
})
75-
addon.Status.ConfigReferences = []addonapiv1alpha1.ConfigReference{
75+
addon.Status.ConfigReferences = []addonapiv1beta1.ConfigReference{
7676
{
77-
ConfigGroupResource: addonapiv1alpha1.ConfigGroupResource{
77+
ConfigGroupResource: addonapiv1beta1.ConfigGroupResource{
7878
Group: "",
7979
Resource: "configmaps",
8080
},
81-
ConfigReferent: addonapiv1alpha1.ConfigReferent{
81+
ConfigReferent: addonapiv1beta1.ConfigReferent{
8282
Namespace: "cluster1",
8383
Name: "image-config",
8484
},
8585
},
8686
{
87-
ConfigGroupResource: addonapiv1alpha1.ConfigGroupResource{
87+
ConfigGroupResource: addonapiv1beta1.ConfigGroupResource{
8888
Group: "addon.open-cluster-management.io",
8989
Resource: "addondeploymentconfigs",
9090
},
91-
ConfigReferent: addonapiv1alpha1.ConfigReferent{
91+
ConfigReferent: addonapiv1beta1.ConfigReferent{
9292
Namespace: "cluster1",
9393
Name: "deploy-config",
9494
},
95-
DesiredConfig: &addonapiv1alpha1.ConfigSpecHash{
96-
ConfigReferent: addonapiv1alpha1.ConfigReferent{
95+
DesiredConfig: &addonapiv1beta1.ConfigSpecHash{
96+
ConfigReferent: addonapiv1beta1.ConfigReferent{
9797
Namespace: "cluster1",
9898
Name: "deploy-config",
9999
},
@@ -116,13 +116,13 @@ func TestManifestAddonAgent(t *testing.T) {
116116
},
117117
},
118118
addOnDeploymentConfigs: []runtime.Object{
119-
&addonapiv1alpha1.AddOnDeploymentConfig{
119+
&addonapiv1beta1.AddOnDeploymentConfig{
120120
ObjectMeta: metav1.ObjectMeta{
121121
Name: "deploy-config",
122122
Namespace: "cluster1",
123123
},
124-
Spec: addonapiv1alpha1.AddOnDeploymentConfigSpec{
125-
NodePlacement: &addonapiv1alpha1.NodePlacement{
124+
Spec: addonapiv1beta1.AddOnDeploymentConfigSpec{
125+
NodePlacement: &addonapiv1beta1.NodePlacement{
126126
Tolerations: tolerations,
127127
NodeSelector: nodeSelector,
128128
},

‎examples/rbac/rbac.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,12 +10,12 @@ import (
1010
"k8s.io/client-go/kubernetes"
1111
"k8s.io/client-go/rest"
1212
"open-cluster-management.io/addon-framework/pkg/agent"
13-
addonapiv1alpha1 "open-cluster-management.io/api/addon/v1alpha1"
13+
addonapiv1beta1 "open-cluster-management.io/api/addon/v1beta1"
1414
clusterv1 "open-cluster-management.io/api/cluster/v1"
1515
)
1616

1717
func AddonRBAC(kubeConfig *rest.Config) agent.PermissionConfigFunc {
18-
return func(cluster *clusterv1.ManagedCluster, addon *addonapiv1alpha1.ManagedClusterAddOn) error {
18+
return func(cluster *clusterv1.ManagedCluster, addon *addonapiv1beta1.ManagedClusterAddOn) error {
1919
kubeclient, err := kubernetes.NewForConfig(kubeConfig)
2020
if err != nil {
2121
return err

‎pkg/addonfactory/addondeploymentconfig.go‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,8 @@ import (
99
"k8s.io/apimachinery/pkg/runtime/schema"
1010
"k8s.io/klog/v2"
1111
addonapiv1alpha1 "open-cluster-management.io/api/addon/v1alpha1"
12-
addonv1alpha1client "open-cluster-management.io/api/client/addon/clientset/versioned"
12+
addonapiv1beta1 "open-cluster-management.io/api/addon/v1beta1"
13+
addonv1beta1client "open-cluster-management.io/api/client/addon/clientset/versioned"
1314
clusterv1 "open-cluster-management.io/api/cluster/v1"
1415

1516
"open-cluster-management.io/addon-framework/pkg/utils"
@@ -191,7 +192,7 @@ type AddOnDeploymentConfigToValuesFunc func(config addonapiv1alpha1.AddOnDeploym
191192

192193
// NewAddOnDeploymentConfigGetter returns a AddOnDeploymentConfigGetter with addon client
193194
// Deprecated: use NewAddOnDeploymentConfigGetter in pkg/utils package instead.
194-
func NewAddOnDeploymentConfigGetter(addonClient addonv1alpha1client.Interface) utils.AddOnDeploymentConfigGetter {
195+
func NewAddOnDeploymentConfigGetter(addonClient addonv1beta1client.Interface) utils.AddOnDeploymentConfigGetter {
195196
return utils.NewAddOnDeploymentConfigGetter(addonClient)
196197
}
197198

@@ -201,7 +202,7 @@ func NewAddOnDeploymentConfigGetter(addonClient addonv1alpha1client.Interface) u
201202
// override the one from small index
202203
func GetAddOnDeploymentConfigValues(
203204
getter utils.AddOnDeploymentConfigGetter, toValuesFuncs ...AddOnDeploymentConfigToValuesFunc) GetValuesFunc {
204-
return func(cluster *clusterv1.ManagedCluster, addon *addonapiv1alpha1.ManagedClusterAddOn) (Values, error) {
205+
return func(cluster *clusterv1.ManagedCluster, addon *addonapiv1beta1.ManagedClusterAddOn) (Values, error) {
205206
var lastValues = Values{}
206207
addOnDeploymentConfig, err := utils.GetDesiredAddOnDeploymentConfig(addon, getter)
207208
if err != nil {
@@ -382,7 +383,7 @@ func getRegistriesFromClusterAnnotation(
382383
// will be: {"global": {"imageOverrides": {"helloWorldImage": "quay.io/ocm/addon-agent:v1"}}}
383384
// - Image registries configured in the addonDeploymentConfig will take precedence over the managed cluster annotation
384385
func GetAgentImageValues(getter utils.AddOnDeploymentConfigGetter, imageKey, image string) GetValuesFunc {
385-
return func(cluster *clusterv1.ManagedCluster, addon *addonapiv1alpha1.ManagedClusterAddOn) (Values, error) {
386+
return func(cluster *clusterv1.ManagedCluster, addon *addonapiv1beta1.ManagedClusterAddOn) (Values, error) {
386387
addOnDeploymentConfig, err := utils.GetDesiredAddOnDeploymentConfig(addon, getter)
387388
if err != nil {
388389
return nil, err

0 commit comments

Comments
 (0)