controller

type ActivityPolicyReconciler struct {
	client.Client
	Scheme     *runtime.Scheme
	RESTMapper meta.RESTMapper
}

type JobBuildOptions struct {
	// ReindexJobName is the name of the ReindexJob resource.
	ReindexJobName string
	// JobNamespace is the namespace where the Job will be created.
	JobNamespace string
	// ActivityImage is the container image for the reindex worker.
	ActivityImage string
	// ControllerArgs are the arguments built from NATS config (appended after template args).
	ControllerArgs []string
	// ResourceRequirements are the resource limits/requests for the container.
	ResourceRequirements corev1.ResourceRequirements
	// ServiceAccountName overrides the template's service account if set.
	ServiceAccountName string
}

type ManagerOptions struct {
	// Workers is the number of worker threads for processing items.
	Workers int
	// MetricsAddr is the address to bind the metrics endpoint.
	MetricsAddr string
	// HealthProbeAddr is the address to bind the health probe endpoint.
	HealthProbeAddr string
	// JetStream is the NATS JetStream context for publishing activities (required)
	JetStream nats.JetStreamContext
	// JobClient is the Kubernetes client for Job operations in the infrastructure cluster
	JobClient client.Client

	// ReindexJob configuration
	ReindexJobNamespace      string
	ReindexServiceAccount    string
	ReindexMemoryLimit       string
	ReindexCPULimit          string
	MaxConcurrentReindexJobs int
	ActivityImage            string
	NATSURL                  string
	NATSTLSEnabled           bool
	NATSTLSCertFile          string
	NATSTLSKeyFile           string
	NATSTLSCAFile            string

	// JobTemplate is the PodTemplateSpec for reindex worker Jobs.
	// If nil, a default template is used.
	JobTemplate *corev1.PodTemplateSpec
}

type ReindexJobReconciler struct {
	client.Client
	JobClient client.Client
	Scheme    *runtime.Scheme
	JetStream nats.JetStreamContext
	Recorder  record.EventRecorder

	// Configuration for Kubernetes Jobs
	JobNamespace          string
	ActivityImage         string
	ReindexServiceAccount string
	ReindexMemoryLimit    string
	ReindexCPULimit       string
	MaxConcurrentJobs     int

	// JobTemplate is the PodTemplateSpec used as a base for worker Jobs.
	// This allows operators to configure volumes, security context, etc.
	// If nil, a minimal default template is used.
	JobTemplate *corev1.PodTemplateSpec

	// NATS configuration for worker pods
	NATSURL         string
	NATSTLSEnabled  bool
	NATSTLSCertFile string
	NATSTLSKeyFile  string
	NATSTLSCAFile   string
}