add dra usbip

Taskfile.yaml

@@ -314,5 +314,39 @@ tasks:
           }
         }
       }'
-      kubectl -n d8-virtualization port-forward deploy/virtualization-dra 2345:2345
+      kubectl -n d8-virtualization port-forward pod/<virtualization-dra-pod> 2345:2345
+      EOF
+
+  dlv:virtualization-dra-usb-gateway:build:
+    desc: "Build image virtualization-dra-usb-gateway with dlv"
+    cmds:
+      - docker build --build-arg BRANCH=$BRANCH -f ./images/virtualization-dra-usb-gateway/debug/dlv.Dockerfile -t "{{ .DLV_IMAGE }}" --platform linux/amd64 .
+
+  dlv:virtualization-dra-usb-gateway:build-push:
+    desc: "Build and Push image virtualization-dra-usb-gateway with dlv"
+    cmds:
+      - task: dlv:virtualization-dra-usb-gateway:build
+      - docker push "{{ .DLV_IMAGE }}"
+      - task: dlv:virtualization-dra-usb-gateway:print
+
+  dlv:virtualization-dra-usb-gateway:print:
+    desc: "Print commands for debug"
+    env:
+      IMAGE: "{{ .DLV_IMAGE }}"
+    cmd: |
+      cat <<EOF
+      kubectl -n d8-virtualization patch ds virtualization-dra-usb-gateway --type='strategic' -p '{
+        "spec": {
+          "template": {
+            "spec": {
+              "containers": [ {
+                "name": "virtualization-dra-usb-gateway",
+                "image": "${IMAGE}",
+                "ports": [ { "containerPort": 2345, "name": "dlv" } ]
+              }]
+            }
+          }
+        }
+      }'
+      kubectl -n d8-virtualization port-forward pod/<virtualization-dra-usb-gateway-pod> 2345:2345
       EOF

images/virtualization-artifact/pkg/common/patch/patch.go

@@ -19,6 +19,7 @@ package patch
 import (
 	"encoding/json"
 	"fmt"
+	"slices"
 	"strings"
 )
 
@@ -74,18 +75,9 @@ func (jp *JSONPatch) Append(patches ...JSONPatchOperation) {
 }
 
 func (jp *JSONPatch) Delete(op, path string) {
-	var idx int
-	var found bool
-	for i, o := range jp.operations {
-		if o.Op == op && o.Path == path {
-			idx = i
-			found = true
-			break
-		}
-	}
-	if found {
-		jp.operations = append(jp.operations[:idx], jp.operations[idx+1:]...)
-	}
+	slices.DeleteFunc(jp.operations, func(o JSONPatchOperation) bool {
+		return o.Op == op && o.Path == path
+	})
 }
 
 func (jp *JSONPatch) Len() int {

images/virtualization-dra-plugin/debug/dlv.Dockerfile

@@ -1,4 +1,4 @@
-FROM golang:1.24.7-bookworm@sha256:2c5f7a0c252a17cf6aa30ddee15caa0f485ee29410a6ea64cddb62eea2b07bdf AS builder
+FROM golang:1.25-bookworm@sha256:019c22232e57fda8ded2b10a8f201989e839f3d3f962d4931375069bbb927e03 AS builder
 ARG TARGETOS
 ARG TARGETARCH
 
@@ -13,13 +13,14 @@ RUN go mod download
 COPY ./images/virtualization-dra/cmd /app/images/virtualization-dra/cmd
 COPY ./images/virtualization-dra/internal /app/images/virtualization-dra/internal
 COPY ./images/virtualization-dra/pkg /app/images/virtualization-dra/pkg
+COPY ./images/virtualization-dra/api /app/images/virtualization-dra/api
 
 ENV GO111MODULE=on
 ENV GOOS=${TARGETOS:-linux}
 ENV GOARCH=${TARGETARCH:-amd64}
 ENV CGO_ENABLED=0
 
-RUN go build -tags EE -gcflags "all=-N -l" -a -o virtualization-dra-plugin ./cmd/virtualization-dra-plugin
+RUN go build -gcflags "all=-N -l" -a -o virtualization-dra-plugin ./cmd/virtualization-dra-plugin/main.go
 
 FROM busybox:1.36.1-glibc
 

images/virtualization-dra-plugin/werf.inc.yaml

@@ -9,10 +9,10 @@ import:
     to: /app/virtualization-dra-plugin
     after: install
   {{- if eq $.DEBUG_COMPONENT "delve/virtualization-dra-plugin" }}
-- image: debugger
-  add: /app/dlv
-  to: /app/dlv
-  after: install
+  - image: debugger
+    add: /app/dlv
+    to: /app/dlv
+    after: install
   {{- end }}
 imageSpec:
   config:
@@ -22,7 +22,7 @@ imageSpec:
     env:
       PATH: "/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/app/dlv"
       XDG_CONFIG_HOME: "/tmp"
-    entrypoint: ["/app/dlv", "--listen=:2345", "--headless=true", "--continue", "--log=true", "--log-output=debugger,debuglineerr,gdbwire,lldbout,rpc", "--accept-multiclient", "--api-version=2", "exec", "/app/virtualization-dra-plugin", "--", "--leader-election=false"]
+    entrypoint: ["/app/dlv", "--listen=:2345", "--headless=true", "--continue", "--log=true", "--log-output=debugger,debuglineerr,gdbwire,lldbout,rpc", "--accept-multiclient", "--api-version=2", "exec", "/app/virtualization-dra-plugin", "--"]
     {{- else }}
     entrypoint: ["/app/virtualization-dra-plugin"]
     {{- end }}

images/virtualization-dra-usb-gateway/debug/dlv.Dockerfile

@@ -0,0 +1,32 @@
+FROM golang:1.25-bookworm@sha256:019c22232e57fda8ded2b10a8f201989e839f3d3f962d4931375069bbb927e03 AS builder
+ARG TARGETOS
+ARG TARGETARCH
+
+WORKDIR /app/images/virtualization-dra
+RUN go install github.com/go-delve/delve/cmd/dlv@latest
+
+COPY ./images/virtualization-dra/go.mod /app/images/virtualization-dra/
+COPY ./images/virtualization-dra/go.sum /app/images/virtualization-dra/
+
+RUN go mod download
+
+COPY ./images/virtualization-dra/cmd /app/images/virtualization-dra/cmd
+COPY ./images/virtualization-dra/internal /app/images/virtualization-dra/internal
+COPY ./images/virtualization-dra/pkg /app/images/virtualization-dra/pkg
+COPY ./images/virtualization-dra/api /app/images/virtualization-dra/api
+
+ENV GO111MODULE=on
+ENV GOOS=${TARGETOS:-linux}
+ENV GOARCH=${TARGETARCH:-amd64}
+ENV CGO_ENABLED=0
+
+RUN go build -gcflags "all=-N -l" -a -o virtualization-dra-usb-gateway ./cmd/usb-gateway/main.go
+
+FROM busybox:1.36.1-glibc
+
+WORKDIR /app
+COPY --from=builder /go/bin/dlv /app/dlv
+COPY --from=builder /app/images/virtualization-dra/virtualization-dra-usb-gateway /app/virtualization-dra-usb-gateway
+USER 65532:65532
+
+ENTRYPOINT ["./dlv", "--listen=:2345", "--headless=true", "--continue", "--log=true", "--log-output=debugger,debuglineerr,gdbwire,lldbout,rpc", "--accept-multiclient", "--api-version=2", "exec", "./virtualization-dra-usb-gateway", "--"]

images/virtualization-dra-usb-gateway/mount-points.yaml

@@ -0,0 +1,5 @@
+# A list of pre-created mount points for containerd strict mode.
+
+dirs:
+  - /var/run/usb-gateway
+

images/virtualization-dra-usb-gateway/werf.inc.yaml

@@ -0,0 +1,28 @@
+---
+image: {{ .ModuleNamePrefix }}{{ .ImageName }}
+fromImage: {{ .ModuleNamePrefix }}distroless
+git:
+  {{- include "image mount points" . }}
+import:
+  - image: {{ .ModuleNamePrefix }}virtualization-dra-builder
+    add: /out/virtualization-dra-usb-gateway
+    to: /app/virtualization-dra-usb-gateway
+    after: install
+  {{- if eq $.DEBUG_COMPONENT "delve/virtualization-dra-usb-gateway" }}
+  - image: debugger
+    add: /app/dlv
+    to: /app/dlv
+    after: install
+  {{- end }}
+imageSpec:
+  config:
+    user: 64535
+    workingDir: "/app"
+    {{- if eq $.DEBUG_COMPONENT "delve/virtualization-dra-usb-gateway" }}
+    env:
+      PATH: "/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/app/dlv"
+      XDG_CONFIG_HOME: "/tmp"
+    entrypoint: ["/app/dlv", "--listen=:2345", "--headless=true", "--continue", "--log=true", "--log-output=debugger,debuglineerr,gdbwire,lldbout,rpc", "--accept-multiclient", "--api-version=2", "exec", "/app/virtualization-dra-usb-gateway", "--"]
+    {{- else }}
+    entrypoint: ["/app/virtualization-dra-usb-gateway"]
+    {{- end }}

images/virtualization-dra/Taskfile.yaml

@@ -57,3 +57,13 @@ tasks:
     cmds:
       - |
         golangci-lint run
+
+  build:go-usbip:
+    desc: "Build go-usbip binary"
+    cmds:
+      - go build -o bin/go-usbip cmd/go-usbip/main.go
+
+  api:generate:
+    desc: "Generate API code"
+    cmds:
+      - hack/update-codegen.sh

images/virtualization-dra/api/doc.go

@@ -0,0 +1,20 @@
+/*
+Copyright 2025 Flant JSC
+
+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.
+*/
+
+// +k8s:deepcopy-gen=package
+// +groupName=dra.virtualization.deckhouse.io
+
+package api

images/virtualization-dra/api/sheme.go

@@ -0,0 +1,52 @@
+/*
+Copyright 2026 Flant JSC
+
+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.
+*/
+
+package api
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/apimachinery/pkg/runtime/schema"
+	"k8s.io/apimachinery/pkg/runtime/serializer"
+	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
+)
+
+const Version = "v1alpha2"
+const Group = "usb-gateway.virtualization.deckhouse.io"
+
+var SchemeGroupVersion = schema.GroupVersion{Group: Group, Version: Version}
+
+var (
+	Scheme = runtime.NewScheme()
+	Codecs = serializer.NewCodecFactory(Scheme)
+)
+
+var (
+	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
+	AddToScheme   = SchemeBuilder.AddToScheme
+)
+
+func addKnownTypes(scheme *runtime.Scheme) error {
+	scheme.AddKnownTypes(SchemeGroupVersion,
+		&USBGatewayStatus{},
+	)
+	return nil
+}
+
+func init() {
+	metav1.AddToGroupVersion(Scheme, SchemeGroupVersion)
+	utilruntime.Must(AddToScheme(Scheme))
+}

images/virtualization-dra/api/types.go

@@ -0,0 +1,73 @@
+/*
+Copyright 2025 Flant JSC
+
+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.
+*/
+
+package api
+
+import (
+	"fmt"
+
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime"
+)
+
+const USBGatewayStatusKind = "USBGatewayStatus"
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+type USBGatewayStatus struct {
+	metav1.TypeMeta `json:",inline"`
+
+	BusID string `json:"busID"`
+
+	RemoteIP   string `json:"remoteIP"`
+	RemotePort int    `json:"remotePort"`
+
+	Bound    bool `json:"bound"`
+	Attached bool `json:"attached"`
+}
+
+func FromData(data *runtime.RawExtension) (*USBGatewayStatus, error) {
+	if data == nil {
+		return nil, nil
+	}
+
+	obj, err := runtime.Decode(Codecs.UniversalDecoder(SchemeGroupVersion), data.Raw)
+	if err != nil {
+		return nil, fmt.Errorf("failed to decode USBGatewayStatus: %w", err)
+	}
+	status, ok := obj.(*USBGatewayStatus)
+	if !ok {
+		return nil, fmt.Errorf("failed to decode USBGatewayStatus: unexpected object type: %T", obj)
+	}
+
+	return status, nil
+}
+
+func ToData(status *USBGatewayStatus) (*runtime.RawExtension, error) {
+	if status == nil {
+		return nil, nil
+	}
+
+	raw, err := runtime.Encode(Codecs.LegacyCodec(SchemeGroupVersion), status)
+	if err != nil {
+		return nil, fmt.Errorf("failed to encode USBGatewayStatus: %w", err)
+	}
+
+	return &runtime.RawExtension{
+		Raw:    raw,
+		Object: status,
+	}, nil
+}