feat: add VerneMQ 2.x support and restore vmq_k8s Kubernetes plugin

Dockerfile

@@ -1,5 +1,5 @@
 # Build the manager binary
-FROM golang:1.18 as builder
+FROM golang:1.23 AS builder
 
 WORKDIR /workspace
 # Copy the Go Modules manifests

Dockerfile.prebuilt

@@ -0,0 +1,5 @@
+FROM gcr.io/distroless/static:nonroot
+WORKDIR /
+COPY manager .
+USER 65532:65532
+ENTRYPOINT ["/manager"]

controllers/statefulset.go

@@ -151,6 +151,8 @@ func makeStatefulSetSpec(instance *vernemqv1alpha1.VerneMQ) (*appsv1.StatefulSet
 		if version.Minor < 7 {
 			return nil, pkgerr.Errorf("unsupported VerneMQ minor version %s", version)
 		}
+	case 2:
+		// VerneMQ 2.x supported
 	default:
 		return nil, pkgerr.Errorf("unsupported VerneMQ major version %s", version)
 	}

controllers/vernemq_controller.go

@@ -37,7 +37,7 @@ const (
 	secretsDir        = "/vernemq/etc/secrets/"
 	sSetInputHashName = "vernemq-operator-input-hash"
 
-	defaultVerneMQVersion   = "1.13.0-alpine"
+	defaultVerneMQVersion   = "2.1.2-alpine"
 	defaultVerneMQBaseImage = "vernemq/vernemq"
 	defaultBundlerBaseImage = "vernemq/vmq-plugin-bundler"
 	defaultBundlerVersion   = "latest"

rebar.config

@@ -0,0 +1,5 @@
+{erl_opts, [debug_info]}.
+
+{deps, [
+    {yamerl, "0.10.0"}
+]}.

src/vmq_k8s.app.src

@@ -0,0 +1,17 @@
+{application, vmq_k8s,
+ [{description, "VMQ Kubernetes Helper Plugin"},
+  {vsn, git},
+  {registered, []},
+  {mod, { vmq_k8s_app, []}},
+  {applications,
+   [kernel,
+    stdlib,
+    yamerl
+   ]},
+  {env,[]},
+  {modules, []},
+
+  {maintainers, []},
+  {licenses, []},
+  {links, []}
+ ]}.

src/vmq_k8s_app.erl

@@ -0,0 +1,26 @@
+%%%-------------------------------------------------------------------
+%% @doc vmq_k8s public API
+%% @end
+%%%-------------------------------------------------------------------
+
+-module(vmq_k8s_app).
+
+-behaviour(application).
+
+%% Application callbacks
+-export([start/2, stop/1]).
+
+%%====================================================================
+%% API
+%%====================================================================
+
+start(_StartType, _StartArgs) ->
+    vmq_k8s_sup:start_link().
+
+%%--------------------------------------------------------------------
+stop(_State) ->
+    ok.
+
+%%====================================================================
+%% Internal functions
+%%====================================================================