Skip to content

Commit 379395c

Browse files
casibbaldcasibbald
authored
Support flux 2 4 0 (#4230)
Updates for API Changes in Flux v2.4.0
1 parent f4d477c commit 379395c

Some content is hidden

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

44 files changed

+6587
-3106
lines changed

‎Makefile

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -55,10 +55,10 @@ TEST_TO_RUN?=./...
5555
TEST_V?=-v
5656
##@ Test
5757
unit-tests: ## Run unit tests
58-
@go install github.com/onsi/ginkgo/v2/ginkgo@v2.1.3
58+
@go install github.com/onsi/ginkgo/v2/ginkgo@v2.19.0
5959
# This tool doesn't have releases - it also is only a shim
6060
@go install sigs.k8s.io/controller-runtime/tools/setup-envtest@latest
61-
KUBEBUILDER_ASSETS=$$(setup-envtest use -p path 1.24.2) CGO_ENABLED=0 ginkgo $(TEST_V) -tags unittest $(TEST_TO_RUN)
61+
KUBEBUILDER_ASSETS=$$(setup-envtest use -p path 1.31.0) CGO_ENABLED=0 ginkgo $(TEST_V) -tags unittest $(TEST_TO_RUN)
6262

6363
local-kind-cluster-with-registry:
6464
./tools/kind-with-registry.sh
@@ -233,10 +233,10 @@ download-test-crds:
233233
for group_resource in $$group_resources; do \
234234
group="$${group_resource%/*}"; resource="$${group_resource#*/}"; \
235235
echo "Downloading $${group}.$${resource}"; \
236-
curl -sL "https://raw.githubusercontent.com/fluxcd/source-controller/v1.0.0/config/crd/bases/$${group}.toolkit.fluxcd.io_$${resource}.yaml" -o "tools/testcrds/$${group}.toolkit.fluxcd.io_$${resource}.yaml"; \
236+
curl -sL "https://raw.githubusercontent.com/fluxcd/source-controller/v1.4.1/config/crd/bases/$${group}.toolkit.fluxcd.io_$${resource}.yaml" -o "tools/testcrds/$${group}.toolkit.fluxcd.io_$${resource}.yaml"; \
237237
done
238-
curl -sL "https://raw.githubusercontent.com/fluxcd/kustomize-controller/v1.0.0/config/crd/bases/kustomize.toolkit.fluxcd.io_kustomizations.yaml" -o "tools/testcrds/kustomize.toolkit.fluxcd.io_kustomizations.yaml"
239-
curl -sL "https://raw.githubusercontent.com/fluxcd/helm-controller/v0.37.0/config/crd/bases/helm.toolkit.fluxcd.io_helmreleases.yaml" -o "tools/testcrds/helm.toolkit.fluxcd.io_helmreleases.yaml"
238+
curl -sL "https://raw.githubusercontent.com/fluxcd/kustomize-controller/v1.4.0/config/crd/bases/kustomize.toolkit.fluxcd.io_kustomizations.yaml" -o "tools/testcrds/kustomize.toolkit.fluxcd.io_kustomizations.yaml"
239+
curl -sL "https://raw.githubusercontent.com/fluxcd/helm-controller/v1.1.0/config/crd/bases/helm.toolkit.fluxcd.io_helmreleases.yaml" -o "tools/testcrds/helm.toolkit.fluxcd.io_helmreleases.yaml"
240240

241241
.PHONY: help
242242
# Thanks to https://www.thapaliya.com/en/writings/well-documented-makefiles/

‎buf.lock

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ deps:
44
- remote: buf.build
55
owner: googleapis
66
repository: googleapis
7-
commit: 553fd4b4b3a640be9b69a3fa0c17b383
7+
commit: c0913f24652a4cfc95f77d97443a5005
88
- remote: buf.build
99
owner: grpc-ecosystem
1010
repository: grpc-gateway

‎charts/gitops-server/templates/deployment.yaml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ apiVersion: apps/v1
22
kind: Deployment
33
metadata:
44
name: {{ include "chart.fullname" . }}
5-
namespace: {{ .Release.Namespace }}
65
labels:
76
{{- include "chart.labels" . | nindent 4 }}
87
{{- include "chart.appSelectorLabels" . | nindent 4 }}

‎charts/gitops-server/templates/ingress.yaml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@ apiVersion: extensions/v1beta1
1616
kind: Ingress
1717
metadata:
1818
name: {{ $fullName }}
19-
namespace: {{ .Release.Namespace }}
2019
labels:
2120
{{- include "chart.labels" . | nindent 4 }}
2221
{{- with .Values.ingress.annotations }}

‎charts/gitops-server/templates/network-policy.yaml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@ apiVersion: networking.k8s.io/v1
44
kind: NetworkPolicy
55
metadata:
66
name: allow-dashboard-ingress
7-
namespace: {{ .Release.Namespace }}
87
spec:
98
podSelector:
109
matchLabels:

‎charts/gitops-server/templates/oidc-auth-secret.yaml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@ apiVersion: v1
33
kind: Secret
44
metadata:
55
name: oidc-auth
6-
namespace: {{ .Release.Namespace }}
76
labels:
87
{{- include "chart.labels" . | nindent 4 }}
98
data:

‎charts/gitops-server/templates/service.yaml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@ apiVersion: v1
33
kind: Service
44
metadata:
55
name: {{ include "chart.fullname" . }}
6-
namespace: {{ .Release.Namespace }}
76
labels:
87
{{- include "chart.labels" . | nindent 4 }}
98
annotations:

‎charts/gitops-server/templates/serviceaccount.yaml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@ apiVersion: v1
33
kind: ServiceAccount
44
metadata:
55
name: {{ include "chart.serviceAccountName" . }}
6-
namespace: {{ .Release.Namespace }}
76
labels:
87
{{- include "chart.labels" . | nindent 4 }}
98
{{- with .Values.serviceAccount.annotations }}

‎core/clustersmngr/cluster/delegating_cache.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ func (c *delegatingCacheCluster) makeCachingClient(leafClient client.Client) (cl
4646
return nil, fmt.Errorf("could not create HTTP client from config: %w", err)
4747
}
4848

49-
mapper, err := apiutil.NewDiscoveryRESTMapper(c.restConfig, httpClient)
49+
mapper, err := apiutil.NewDynamicRESTMapper(c.restConfig, httpClient)
5050
if err != nil {
5151
return nil, fmt.Errorf("could not create RESTMapper from config: %w", err)
5252
}

‎core/clustersmngr/cluster/single.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ func getClientFromConfig(config *rest.Config, scheme *apiruntime.Scheme) (client
6060
return nil, fmt.Errorf("could not create HTTP client from config: %w", err)
6161
}
6262

63-
mapper, err := apiutil.NewDiscoveryRESTMapper(config, httpClient)
63+
mapper, err := apiutil.NewDynamicRESTMapper(config, httpClient)
6464
if err != nil {
6565
return nil, fmt.Errorf("could not create RESTMapper from config: %w", err)
6666
}

‎core/clustersmngr/factory_test.go

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -202,10 +202,13 @@ func TestUpdateNamespaces(t *testing.T) {
202202
clustersFetcher.FetchReturns([]cluster.Cluster{c1, c2, c3}, nil)
203203

204204
g.Expect(clustersManager.UpdateClusters(ctx)).To(Succeed())
205-
g.Expect(clustersManager.UpdateNamespaces(ctx)).To(MatchError(MatchRegexp("failed creating server client to pool.*cluster: %s.*", clusterName3)))
205+
g.Expect(clustersManager.UpdateNamespaces(ctx)).To(MatchError(MatchRegexp("Failed to list resource on cluster=\"%s\".*", clusterName3)))
206206
contents := clustersManager.GetClustersNamespaces()
207207

208-
g.Expect(contents).To(HaveLen(2))
208+
// TODO(Flux 2.3 migration): Apparently a change in behavior. Check if more needs to be updated.
209+
g.Expect(contents).To(HaveLen(3))
210+
g.Expect(contents).To(HaveKeyWithValue(clusterName3, BeNil()))
211+
// g.Expect(contents).To(HaveLen(2))
209212
g.Expect(contents).To(HaveKey(clusterName1))
210213
g.Expect(contents).To(HaveKey(clusterName2))
211214
})

‎core/fluxsync/adapters.go

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
package fluxsync
22

33
import (
4-
helmv2 "github.com/fluxcd/helm-controller/api/v2beta2"
5-
imgautomationv1 "github.com/fluxcd/image-automation-controller/api/v1beta1"
4+
helmv2 "github.com/fluxcd/helm-controller/api/v2"
5+
imgautomationv1 "github.com/fluxcd/image-automation-controller/api/v1beta2"
66
reflectorv1 "github.com/fluxcd/image-reflector-controller/api/v1beta2"
77
kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1"
88
"github.com/fluxcd/pkg/apis/meta"
@@ -69,7 +69,7 @@ func (obj GitRepositoryAdapter) DeepCopyClientObject() client.Object {
6969
}
7070

7171
type BucketAdapter struct {
72-
*sourcev1b2.Bucket
72+
*sourcev1.Bucket
7373
}
7474

7575
func (obj BucketAdapter) GetLastHandledReconcileRequest() string {
@@ -81,7 +81,7 @@ func (obj BucketAdapter) AsClientObject() client.Object {
8181
}
8282

8383
func (obj BucketAdapter) GroupVersionKind() schema.GroupVersionKind {
84-
return sourcev1b2.GroupVersion.WithKind(sourcev1b2.BucketKind)
84+
return sourcev1.GroupVersion.WithKind(sourcev1.BucketKind)
8585
}
8686

8787
func (obj BucketAdapter) SetSuspended(suspend bool) error {
@@ -106,7 +106,7 @@ func (obj HelmChartAdapter) AsClientObject() client.Object {
106106
}
107107

108108
func (obj HelmChartAdapter) GroupVersionKind() schema.GroupVersionKind {
109-
return sourcev1b2.GroupVersion.WithKind(sourcev1b2.HelmChartKind)
109+
return sourcev1.GroupVersion.WithKind(sourcev1.HelmChartKind)
110110
}
111111

112112
func (obj HelmChartAdapter) SetSuspended(suspend bool) error {
@@ -131,7 +131,7 @@ func (obj HelmRepositoryAdapter) AsClientObject() client.Object {
131131
}
132132

133133
func (obj HelmRepositoryAdapter) GroupVersionKind() schema.GroupVersionKind {
134-
return sourcev1b2.GroupVersion.WithKind(sourcev1b2.HelmRepositoryKind)
134+
return sourcev1.GroupVersion.WithKind(sourcev1.HelmRepositoryKind)
135135
}
136136

137137
func (obj HelmRepositoryAdapter) SetSuspended(suspend bool) error {
@@ -374,8 +374,8 @@ func ToReconcileable(gvk schema.GroupVersionKind) Reconcilable {
374374
// TODO: remove all these and let them fall through to the Unstructured case?
375375
case sourcev1.GitRepositoryKind:
376376
return GitRepositoryAdapter{GitRepository: &sourcev1.GitRepository{}}
377-
case sourcev1b2.BucketKind:
378-
return BucketAdapter{Bucket: &sourcev1b2.Bucket{}}
377+
case sourcev1.BucketKind:
378+
return BucketAdapter{Bucket: &sourcev1.Bucket{}}
379379
case sourcev1b2.HelmRepositoryKind:
380380
return HelmRepositoryAdapter{HelmRepository: &sourcev1b2.HelmRepository{}}
381381
case sourcev1b2.HelmChartKind:

‎core/server/events_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ import (
66

77
"testing"
88

9-
helmv2 "github.com/fluxcd/helm-controller/api/v2beta2"
9+
helmv2 "github.com/fluxcd/helm-controller/api/v2"
1010
kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1"
1111
. "github.com/onsi/gomega"
1212
pb "github.com/weaveworks/weave-gitops/pkg/api/core"

‎core/server/fluxruntime.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ import (
1919
"k8s.io/apimachinery/pkg/types"
2020
"sigs.k8s.io/controller-runtime/pkg/client"
2121

22-
helmv2 "github.com/fluxcd/helm-controller/api/v2beta2"
22+
helmv2 "github.com/fluxcd/helm-controller/api/v2"
2323
kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1"
2424
appsv1 "k8s.io/api/apps/v1"
2525
v1 "k8s.io/api/core/v1"

‎core/server/helm_release.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ import (
55
"fmt"
66
"strings"
77

8-
helmv2 "github.com/fluxcd/helm-controller/api/v2beta2"
8+
helmv2 "github.com/fluxcd/helm-controller/api/v2"
99
"github.com/weaveworks/weave-gitops/core/clustersmngr"
1010
pb "github.com/weaveworks/weave-gitops/pkg/api/core"
1111
)

‎core/server/inventory.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ import (
1111
"strings"
1212
"sync"
1313

14-
helmv2 "github.com/fluxcd/helm-controller/api/v2beta2"
14+
helmv2 "github.com/fluxcd/helm-controller/api/v2"
1515
kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1"
1616
"github.com/fluxcd/pkg/ssa"
1717
"github.com/go-logr/logr"

‎core/server/inventory_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ import (
77
"fmt"
88
"testing"
99

10-
helmv2 "github.com/fluxcd/helm-controller/api/v2beta2"
10+
helmv2 "github.com/fluxcd/helm-controller/api/v2"
1111
kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1"
1212
"github.com/fluxcd/pkg/apis/meta"
1313
sourcev1 "github.com/fluxcd/source-controller/api/v1"

‎core/server/objects.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ import (
55
"errors"
66
"fmt"
77

8-
helmv2 "github.com/fluxcd/helm-controller/api/v2beta2"
8+
helmv2 "github.com/fluxcd/helm-controller/api/v2"
99
kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1"
1010
"github.com/hashicorp/go-multierror"
1111
"github.com/weaveworks/weave-gitops/core/clustersmngr"

‎core/server/objects_test.go

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,7 @@ import (
88
"encoding/json"
99
"testing"
1010

11-
sourcev1b2 "github.com/fluxcd/source-controller/api/v1beta2"
12-
13-
helmv2 "github.com/fluxcd/helm-controller/api/v2beta2"
11+
helmv2 "github.com/fluxcd/helm-controller/api/v2"
1412
kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1"
1513
sourcev1 "github.com/fluxcd/source-controller/api/v1"
1614
. "github.com/onsi/gomega"
@@ -929,12 +927,12 @@ func TestGetObjectSessionObjects(t *testing.T) {
929927
Spec: helmv2.HelmReleaseSpec{},
930928
}
931929

932-
bucket := &sourcev1b2.Bucket{
930+
bucket := &sourcev1.Bucket{
933931
ObjectMeta: metav1.ObjectMeta{
934932
Name: constants.RunDevBucketName,
935933
Namespace: testNS,
936934
},
937-
Spec: sourcev1b2.BucketSpec{},
935+
Spec: sourcev1.BucketSpec{},
938936
}
939937

940938
fakeClient := fake.NewClientBuilder().WithScheme(scheme).WithRuntimeObjects(ns, kust, helm, bucket).Build()
@@ -966,7 +964,7 @@ func TestGetObjectSessionObjects(t *testing.T) {
966964
res, err = c.GetObject(ctx, &pb.GetObjectRequest{
967965
Name: constants.RunDevBucketName,
968966
Namespace: testNS,
969-
Kind: sourcev1b2.BucketKind,
967+
Kind: sourcev1.BucketKind,
970968
ClusterName: testCluster,
971969
})
972970

‎core/server/session_logs.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,15 +4,14 @@ import (
44
"context"
55
"encoding/json"
66
"fmt"
7+
sourcev1 "github.com/fluxcd/source-controller/api/v1"
78
"io"
89
"regexp"
910
"sort"
1011
"strconv"
1112
"strings"
1213
"time"
1314

14-
sourcev1b2 "github.com/fluxcd/source-controller/api/v1beta2"
15-
1615
"github.com/weaveworks/weave-gitops/pkg/compositehash"
1716

1817
"github.com/minio/minio-go/v7"
@@ -421,7 +420,7 @@ func getBucketConnectionInfo(ctx context.Context, clusterName, fluxNamespace str
421420
}
422421

423422
// get bucket source
424-
bucket := sourcev1b2.Bucket{
423+
bucket := sourcev1.Bucket{
425424
ObjectMeta: metav1.ObjectMeta{
426425
Name: constants.RunDevBucketName,
427426
Namespace: fluxNamespace,

‎core/server/session_logs_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import (
44
"context"
55
"encoding/json"
66
"fmt"
7-
sourcev1b2 "github.com/fluxcd/source-controller/api/v1beta2"
7+
sourcev1 "github.com/fluxcd/source-controller/api/v1"
88
"io"
99
"strings"
1010
"testing"
@@ -33,7 +33,7 @@ func (m *mockGet) Get(ctx context.Context, key types.NamespacedName, obj client.
3333
"accesskey": []byte("abcd"),
3434
"secretkey": []byte("1234"),
3535
}
36-
case *sourcev1b2.Bucket:
36+
case *sourcev1.Bucket:
3737
obj.Spec.Endpoint = "endpoint:9000"
3838
obj.Spec.Insecure = false
3939
}

‎core/server/suspend_test.go

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -4,12 +4,11 @@ import (
44
"context"
55
"testing"
66

7-
helmv2 "github.com/fluxcd/helm-controller/api/v2beta2"
8-
imgautomationv1 "github.com/fluxcd/image-automation-controller/api/v1beta1"
7+
helmv2 "github.com/fluxcd/helm-controller/api/v2"
8+
imgautomationv1 "github.com/fluxcd/image-automation-controller/api/v1beta2"
99
reflectorv1 "github.com/fluxcd/image-reflector-controller/api/v1beta2"
1010
kustomizev1 "github.com/fluxcd/kustomize-controller/api/v1"
1111
sourcev1 "github.com/fluxcd/source-controller/api/v1"
12-
sourcev1b2 "github.com/fluxcd/source-controller/api/v1beta2"
1312
. "github.com/onsi/gomega"
1413
api "github.com/weaveworks/weave-gitops/pkg/api/core"
1514
"github.com/weaveworks/weave-gitops/pkg/kube"
@@ -51,13 +50,13 @@ func TestSuspend_Suspend(t *testing.T) {
5150
obj: gr,
5251
},
5352
{
54-
kind: sourcev1b2.HelmRepositoryKind,
55-
apiVersion: sourcev1b2.GroupVersion.String(),
53+
kind: sourcev1.HelmRepositoryKind,
54+
apiVersion: sourcev1.GroupVersion.String(),
5655
obj: hr,
5756
},
5857
{
59-
kind: sourcev1b2.BucketKind,
60-
apiVersion: sourcev1b2.GroupVersion.String(),
58+
kind: sourcev1.BucketKind,
59+
apiVersion: sourcev1.GroupVersion.String(),
6160
obj: makeBucket("bucket-1", *ns),
6261
},
6362
{

0 commit comments

Comments
 (0)