mirror of
https://github.com/YuzuZensai/netbird-kubernetes-operator.git
synced 2026-09-13 10:49:15 +00:00
Update Golang CI Lint to the latest version (#113)
This change updates Golang CI Lint to the latest version and fixes new linter errors that came along with the update. These changes were split out of #112 and are required to update the Go version.
This commit is contained in:
@@ -31,7 +31,7 @@ type NBPolicyReconciler struct {
|
||||
}
|
||||
|
||||
var (
|
||||
errUnknownProtocol = fmt.Errorf("Unknown protocol")
|
||||
errUnknownProtocol = fmt.Errorf("unknown protocol")
|
||||
errKubernetesAPI = fmt.Errorf("kubernetes API error")
|
||||
errNetBirdAPI = fmt.Errorf("netbird API error")
|
||||
errInvalidValue = fmt.Errorf("invalid value")
|
||||
|
||||
@@ -222,7 +222,8 @@ var _ = Describe("NBResource Controller", func() {
|
||||
resourceUpdated := false
|
||||
mux.HandleFunc("/api/networks/test/resources/test", func(w http.ResponseWriter, r *http.Request) {
|
||||
defer GinkgoRecover()
|
||||
if r.Method == http.MethodGet {
|
||||
switch r.Method {
|
||||
case http.MethodGet:
|
||||
resp := api.NetworkResource{
|
||||
Address: nbresource.Spec.Address,
|
||||
Description: &networkDescription,
|
||||
@@ -245,7 +246,7 @@ var _ = Describe("NBResource Controller", func() {
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
_, err = w.Write(bs)
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
} else if r.Method == http.MethodPut {
|
||||
case http.MethodPut:
|
||||
resourceUpdated = true
|
||||
bs, err := io.ReadAll(r.Body)
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
|
||||
@@ -172,7 +172,8 @@ var _ = Describe("NBRoutingPeer Controller", func() {
|
||||
networkCreated := false
|
||||
mux.HandleFunc("/api/networks", func(w http.ResponseWriter, r *http.Request) {
|
||||
defer GinkgoRecover()
|
||||
if r.Method == http.MethodPost {
|
||||
switch r.Method {
|
||||
case http.MethodPost:
|
||||
networkCreated = true
|
||||
var req api.PostApiNetworksJSONRequestBody
|
||||
bs, err := io.ReadAll(r.Body)
|
||||
@@ -190,7 +191,7 @@ var _ = Describe("NBRoutingPeer Controller", func() {
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
_, err = w.Write(bs)
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
} else if r.Method == http.MethodGet {
|
||||
case http.MethodGet:
|
||||
_, err := w.Write([]byte("[]"))
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
}
|
||||
@@ -276,7 +277,8 @@ var _ = Describe("NBRoutingPeer Controller", func() {
|
||||
routerCreated := false
|
||||
mux.HandleFunc("/api/networks/test/routers", func(w http.ResponseWriter, r *http.Request) {
|
||||
defer GinkgoRecover()
|
||||
if r.Method == http.MethodPost {
|
||||
switch r.Method {
|
||||
case http.MethodPost:
|
||||
routerCreated = true
|
||||
var req api.PostApiNetworksNetworkIdRoutersJSONRequestBody
|
||||
bs, err := io.ReadAll(r.Body)
|
||||
@@ -299,7 +301,7 @@ var _ = Describe("NBRoutingPeer Controller", func() {
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
_, err = w.Write(bs)
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
} else if r.Method == http.MethodGet {
|
||||
case http.MethodGet:
|
||||
resp := []api.NetworkRouter{}
|
||||
bs, err := json.Marshal(resp)
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
@@ -555,7 +557,8 @@ var _ = Describe("NBRoutingPeer Controller", func() {
|
||||
setupKeyDeleted := false
|
||||
mux.HandleFunc("/api/setup-keys/skid", func(w http.ResponseWriter, r *http.Request) {
|
||||
defer GinkgoRecover()
|
||||
if r.Method == http.MethodGet {
|
||||
switch r.Method {
|
||||
case http.MethodGet:
|
||||
resp := api.SetupKey{
|
||||
Id: "skid",
|
||||
Revoked: false,
|
||||
@@ -564,7 +567,7 @@ var _ = Describe("NBRoutingPeer Controller", func() {
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
_, err = w.Write(bs)
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
} else if r.Method == http.MethodDelete {
|
||||
case http.MethodDelete:
|
||||
setupKeyDeleted = true
|
||||
_, err := w.Write([]byte(`{}`))
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
@@ -628,7 +631,8 @@ var _ = Describe("NBRoutingPeer Controller", func() {
|
||||
setupKeyDeleted := false
|
||||
mux.HandleFunc("/api/setup-keys/skid", func(w http.ResponseWriter, r *http.Request) {
|
||||
defer GinkgoRecover()
|
||||
if r.Method == http.MethodGet {
|
||||
switch r.Method {
|
||||
case http.MethodGet:
|
||||
resp := api.SetupKey{
|
||||
Id: "skid",
|
||||
Revoked: true,
|
||||
@@ -637,7 +641,7 @@ var _ = Describe("NBRoutingPeer Controller", func() {
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
_, err = w.Write(bs)
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
} else if r.Method == http.MethodDelete {
|
||||
case http.MethodDelete:
|
||||
setupKeyDeleted = true
|
||||
_, err := w.Write([]byte(`{}`))
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
@@ -712,11 +716,12 @@ var _ = Describe("NBRoutingPeer Controller", func() {
|
||||
setupKeyDeleted := false
|
||||
mux.HandleFunc("/api/setup-keys/skid", func(w http.ResponseWriter, r *http.Request) {
|
||||
defer GinkgoRecover()
|
||||
if r.Method == http.MethodGet {
|
||||
switch r.Method {
|
||||
case http.MethodGet:
|
||||
w.WriteHeader(404)
|
||||
_, err := w.Write([]byte(`{"message": "setup-key skid not found", "code": 404}`))
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
} else if r.Method == http.MethodDelete {
|
||||
case http.MethodDelete:
|
||||
setupKeyDeleted = true
|
||||
_, err := w.Write([]byte(`{}`))
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
@@ -761,7 +766,8 @@ var _ = Describe("NBRoutingPeer Controller", func() {
|
||||
setupKeyDeleted := false
|
||||
mux.HandleFunc("/api/setup-keys/skid", func(w http.ResponseWriter, r *http.Request) {
|
||||
defer GinkgoRecover()
|
||||
if r.Method == http.MethodGet {
|
||||
switch r.Method {
|
||||
case http.MethodGet:
|
||||
resp := api.SetupKey{
|
||||
Id: "skid",
|
||||
Revoked: false,
|
||||
@@ -770,7 +776,7 @@ var _ = Describe("NBRoutingPeer Controller", func() {
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
_, err = w.Write(bs)
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
} else if r.Method == http.MethodDelete {
|
||||
case http.MethodDelete:
|
||||
setupKeyDeleted = true
|
||||
_, err := w.Write([]byte(`{}`))
|
||||
Expect(err).NotTo(HaveOccurred())
|
||||
|
||||
@@ -194,6 +194,7 @@ func (r *ServiceReconciler) exposeService(ctx context.Context, req ctrl.Request,
|
||||
func (r *ServiceReconciler) reconcileNBResource(nbResource *netbirdiov1.NBResource, req ctrl.Request, svc corev1.Service, routingPeer netbirdiov1.NBRoutingPeer, logger logr.Logger) error {
|
||||
groups := []string{fmt.Sprintf("%s-%s-%s", r.ClusterName, req.Namespace, req.Name)}
|
||||
if v, ok := svc.Annotations[serviceGroupsAnnotation]; ok {
|
||||
//nolint:prealloc
|
||||
groups = nil
|
||||
for _, g := range strings.Split(v, ",") {
|
||||
groups = append(groups, strings.TrimSpace(g))
|
||||
|
||||
Reference in New Issue
Block a user