feat: support virtual workspace URL path in --config-workspace

Allow --config-workspace to accept a direct URL path (starting with /)
in addition to logical cluster paths. This enables init-agent to watch
InitTarget/InitTemplate resources via an APIExport virtual workspace,
which aggregates resources from multiple provider workspaces.

When the value starts with /, it is used as a direct URL path appended
to the base KCP host. Otherwise, existing behavior is preserved
(appending /clusters/<path>).

Ref: #18

Author: ifdotpy

cmd/init-agent/main.go

@@ -21,6 +21,7 @@ import (
 	"flag"
 	"fmt"
 	golog "log"
+	"strings"
 
 	"github.com/go-logr/zapr"
 	"github.com/spf13/pflag"
@@ -145,7 +146,15 @@ func setupManager(ctx context.Context, cfg *rest.Config, opts *Options) (manager
 		return nil, fmt.Errorf("failed to register local scheme %s: %w", initializationv1alpha1.SchemeGroupVersion, err)
 	}
 
-	cfg = kcp.RetargetRestConfig(cfg, logicalcluster.Name(opts.ConfigWorkspace))
+	if strings.HasPrefix(opts.ConfigWorkspace, "/") {
+		// Direct URL path (e.g., virtual workspace)
+		stripped := kcp.StripCluster(cfg)
+		stripped.Host = strings.TrimRight(stripped.Host, "/") + opts.ConfigWorkspace
+		cfg = stripped
+	} else {
+		// Logical cluster path (existing behavior)
+		cfg = kcp.RetargetRestConfig(cfg, logicalcluster.Name(opts.ConfigWorkspace))
+	}
 
 	return manager.New(cfg, manager.Options{
 		Scheme: scheme,

cmd/init-agent/options.go

@@ -34,9 +34,9 @@ type Options struct {
 	// work.
 	// KubeconfigFile string
 
-	// ConfigWorkspace is the kcp workspace (either a path or a cluster name)
-	// where the InitTarget and InitTemplate objects live that should be processed
-	// by this init-agent.
+	// ConfigWorkspace is the kcp workspace (either a path, a cluster name, or a
+	// URL path starting with / for virtual workspaces) where the InitTarget and
+	// InitTemplate objects live that should be processed by this init-agent.
 	ConfigWorkspace string
 
 	// Whether or not to perform leader election (requires permissions to
@@ -67,7 +67,7 @@ func NewOptions() *Options {
 func (o *Options) AddFlags(flags *pflag.FlagSet) {
 	o.LogOptions.AddPFlags(flags)
 
-	flags.StringVar(&o.ConfigWorkspace, "config-workspace", o.ConfigWorkspace, "kcp workspace or cluster where the InitTargets live that should be processed")
+	flags.StringVar(&o.ConfigWorkspace, "config-workspace", o.ConfigWorkspace, "kcp workspace, cluster, or URL path (starting with /) where the InitTargets live that should be processed")
 	flags.StringVar(&o.InitTargetSelectorString, "init-target-selector", o.InitTargetSelectorString, "restrict to only process InitTargets matching this label selector (optional)")
 	flags.BoolVar(&o.EnableLeaderElection, "enable-leader-election", o.EnableLeaderElection, "whether to perform leader election")
 	flags.StringVar(&o.LeaderElectionNamespace, "leader-election-namespace", o.LeaderElectionNamespace, "Kubernetes namespace for the leader election lease")