feat: resource state versioning

Adds a system to version resource states and to migrate them to newer
versions. These migrations run when the server starts as well as when
they're retrieved from storage in order to handle cases where different
server versions are started simultaneously.

Author: jason-lynch

server/cmd/root.go

@@ -25,6 +25,7 @@ import (
 	"github.com/pgEdge/control-plane/server/internal/orchestrator/swarm"
 	"github.com/pgEdge/control-plane/server/internal/ports"
 	"github.com/pgEdge/control-plane/server/internal/resource"
+	"github.com/pgEdge/control-plane/server/internal/resource/migrations"
 	"github.com/pgEdge/control-plane/server/internal/scheduler"
 	"github.com/pgEdge/control-plane/server/internal/task"
 	"github.com/pgEdge/control-plane/server/internal/workflows"
@@ -79,6 +80,7 @@ func newRootCmd(i *do.Injector) *cobra.Command {
 			monitor.Provide(i)
 			ports.Provide(i)
 			resource.Provide(i)
+			migrations.Provide(i)
 			scheduler.Provide(i)
 			workflows.Provide(i)
 			activities.Provide(i)

server/internal/app/app.go

@@ -18,6 +18,7 @@ import (
 	"github.com/pgEdge/control-plane/server/internal/host"
 	"github.com/pgEdge/control-plane/server/internal/migrate"
 	"github.com/pgEdge/control-plane/server/internal/monitor"
+	"github.com/pgEdge/control-plane/server/internal/resource"
 	"github.com/pgEdge/control-plane/server/internal/scheduler"
 	"github.com/pgEdge/control-plane/server/internal/workflows"
 )
@@ -173,6 +174,14 @@ func (a *App) runInitialized(parentCtx context.Context) error {
 		return handleError(fmt.Errorf("failed to update host: %w", err))
 	}
 
+	resourceSvc, err := do.Invoke[*resource.Service](a.i)
+	if err != nil {
+		return handleError(fmt.Errorf("failed to initialize resource service: %w", err))
+	}
+	if err := resourceSvc.Start(a.serviceCtx); err != nil {
+		return handleError(fmt.Errorf("failed to start resource service: %w", err))
+	}
+
 	hostTicker, err := do.Invoke[*host.UpdateTicker](a.i)
 	if err != nil {
 		return handleError(fmt.Errorf("failed to initialize host ticker: %w", err))