[Feature] [Scheduler] SchedV1 Integration

Author: ajanikow

CHANGELOG.md

@@ -35,6 +35,7 @@
 - (Improvement) Improve Metrics Handling
 - (Feature) (Scheduler) Create Integration Profile
 - (Feature) (Scheduler) Additional types
+- (Feature) (Scheduler) SchedV1 Integration
 
 ## [1.2.42](https://github.com/arangodb/kube-arangodb/tree/1.2.42) (2024-07-23)
 - (Maintenance) Go 1.22.4 & Kubernetes 1.29.6 libraries

pkg/deployment/resources/arango_profiles.go

@@ -81,6 +81,8 @@ func (r *Resources) EnsureArangoProfiles(ctx context.Context, cachedStatus inspe
 				return "", nil, err
 			}
 
+			key, v := constants.NewProfileIntegration(name, version)
+
 			return fullName, &schedulerApi.ArangoProfile{
 				ObjectMeta: meta.ObjectMeta{
 					Name:      fullName,
@@ -91,8 +93,8 @@ func (r *Resources) EnsureArangoProfiles(ctx context.Context, cachedStatus inspe
 				},
 				Spec: schedulerApi.ProfileSpec{
 					Selectors: matchArangoProfilesLabels(map[string]string{
-						constants.ProfilesDeployment:                                    deploymentName,
-						fmt.Sprintf("%s/%s", constants.ProfilesIntegrationPrefix, name): version,
+						constants.ProfilesDeployment: deploymentName,
+						key:                          v,
 					}),
 					Template: integration,
 				},
@@ -128,8 +130,9 @@ func (r *Resources) EnsureArangoProfiles(ctx context.Context, cachedStatus inspe
 				},
 			}, nil
 		},
-		gen("authz", "v0", sidecar.IntegrationAuthorizationV0{}),
-		gen("authn", "v1", sidecar.IntegrationAuthenticationV1{Spec: spec, DeploymentName: apiObject.GetName()}),
+		gen(constants.ProfilesIntegrationAuthz, constants.ProfilesIntegrationV0, sidecar.IntegrationAuthorizationV0{}),
+		gen(constants.ProfilesIntegrationAuthn, constants.ProfilesIntegrationV1, sidecar.IntegrationAuthenticationV1{Spec: spec, DeploymentName: apiObject.GetName()}),
+		gen(constants.ProfilesIntegrationSched, constants.ProfilesIntegrationV1, sidecar.IntegrationSchedulerV1{}),
 	); err != nil {
 		return err
 	} else if changed {

pkg/integrations/sidecar/integration.scheduler.v1.go

@@ -0,0 +1,73 @@
+//
+// DISCLAIMER
+//
+// Copyright 2024 ArangoDB GmbH, Cologne, Germany
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+// Copyright holder is ArangoDB GmbH, Cologne, Germany
+//
+
+package sidecar
+
+import (
+	core "k8s.io/api/core/v1"
+
+	api "github.com/arangodb/kube-arangodb/pkg/apis/deployment/v1"
+)
+
+type IntegrationSchedulerV1 struct {
+	Core *Core
+
+	DeploymentName string
+	Spec           api.DeploymentSpec
+}
+
+func (i IntegrationSchedulerV1) Name() []string {
+	return []string{"SCHEDULER", "V1"}
+}
+
+func (i IntegrationSchedulerV1) Validate() error {
+	return nil
+}
+
+func (i IntegrationSchedulerV1) Envs() ([]core.EnvVar, error) {
+	var envs = []core.EnvVar{
+		{
+			Name:  "INTEGRATION_SCHEDULER_V1",
+			Value: "true",
+		},
+		{
+			Name:  "INTEGRATION_SCHEDULER_V1_VERIFY_ACCESS",
+			Value: "true",
+		},
+		{
+			Name: "INTEGRATION_SCHEDULER_V1_NAMESPACE",
+			ValueFrom: &core.EnvVarSource{
+				FieldRef: &core.ObjectFieldSelector{
+					FieldPath: "metadata.namespace",
+				},
+			},
+		},
+	}
+
+	return i.Core.Envs(i, envs...), nil
+}
+
+func (i IntegrationSchedulerV1) GlobalEnvs() ([]core.EnvVar, error) {
+	return nil, nil
+}
+
+func (i IntegrationSchedulerV1) Volumes() ([]core.Volume, []core.VolumeMount, error) {
+	return nil, nil, nil
+}

pkg/util/constants/profiles.go

@@ -20,7 +20,24 @@
 
 package constants
 
+import "fmt"
+
 const ProfileGroup = "profiles.arangodb.com"
 
 const ProfilesDeployment = ProfileGroup + "/deployment"
 const ProfilesIntegrationPrefix = "integration." + ProfileGroup
+
+const (
+	ProfilesIntegrationAuthn = "authn"
+	ProfilesIntegrationAuthz = "authz"
+	ProfilesIntegrationSched = "sched"
+)
+
+const (
+	ProfilesIntegrationV0 = "v0"
+	ProfilesIntegrationV1 = "v1"
+)
+
+func NewProfileIntegration(name, version string) (string, string) {
+	return fmt.Sprintf("%s/%s", ProfilesIntegrationPrefix, name), version
+}