[controller] New version of extender scheduler (#5)

Signed-off-by: Viktor Kramarenko <viktor.kramarenko@flant.com>

images/sds-lvm-controller/Makefile

@@ -0,0 +1,41 @@
+SHELL := /bin/bash
+TEST-ARGS=-race -timeout 30s -count 1
+base_golang_20_alpine := golang:1.20-alpine3.18
+repo_fox := registry.flant.com/deckhouse/storage
+image_name := sds-lvm
+
+
+deployment_name=sds-lvm-controller
+deployment_container_name=sds-lvm-controller
+namespace=d8-sds-lvm
+system_namespace=d8-system
+pull_secret_name=fox-registry
+
+USER := $(shell whoami)
+image_tag := sds-lvm-controller-$(USER)
+
+run: ## run go
+		go run -race ./cmd/main.go
+
+test:
+		go test $(TEST-ARGS) ./...
+
+fox_build_and_push:
+		docker build --build-arg="BASE_GOLANG_20_ALPINE_BUILDER=$(base_golang_20_alpine)" . -t $(repo_fox)/$(image_name):$(image_tag)
+		docker push $(repo_fox)/$(image_name):$(image_tag)
+
+redeploy:
+		kubectl -n $(namespace) rollout restart deployment $(deployment_name)
+		kubectl -n $(namespace) rollout restart daemonset $(daemonset_name)
+
+switch_to_local_dev:
+		kubectl -n $(system_namespace) scale deployment deckhouse --replicas=0
+		kubectl -n $(namespace) patch deployment $(deployment_name) -p \
+		   '{"spec": {"template": {"spec": {"containers": [{"name": "$(deployment_container_name)", "image": "$(repo_fox)/$(image_name):$(image_tag)"}]}}}}'
+		kubectl -n $(namespace) patch deployment $(deployment_name) -p \
+		   '{"spec": {"template": {"spec": {"containers": [{"name": "$(deployment_container_name)", "imagePullPolicy": "Always"}]}}}}'
+		kubectl  -n $(namespace) patch deployment $(deployment_name) --type='json' \
+		   -p='[{"op": "add", "path": "/spec/template/spec/imagePullSecrets", "value": [{"name": "$(pull_secret_name)"}]}]'
+
+
+.PHONY: switch_to_local_dev

images/sds-lvm-scheduler-extender/cmd/cmd/root.go

@@ -83,6 +83,7 @@ func subMain(parentCtx context.Context) error {
 		}
 	}
 
+	ctx := context.Background()
 	log, err := logger.NewLogger(logger.Verbosity(config.LogLevel))
 	if err != nil {
 		fmt.Println(fmt.Sprintf("[subMain] unable to initialize logger, err: %s", err.Error()))
@@ -111,7 +112,7 @@ func subMain(parentCtx context.Context) error {
 		WarningHandler: client.WarningHandlerOptions{},
 	})
 
-	h, err := scheduler.NewHandler(cl, *log, config.DefaultDivisor)
+	h, err := scheduler.NewHandler(ctx, cl, *log, config.DefaultDivisor)
 	if err != nil {
 		return err
 	}