scalertypes

type AutoScalerOptions struct {
	Namespace            string
	ScaleInterval        Duration
	GroupKind            schema.GroupKind
	MetricsClientOptions MetricsClientOptions
}

type DLXOptions struct {
	Namespace string

	// comma delimited
	TargetNameHeader                  string
	TargetPathHeader                  string
	TargetPort                        int
	ListenAddress                     string
	ResourceReadinessTimeout          Duration
	MultiTargetStrategy               MultiTargetStrategy
	LabelSelector                     string
	ResolveTargetsFromIngressCallback ResolveTargetsFromIngressCallback `json:"-"`
	TargetAuthenticator               TargetAuthenticator               `json:"-"`
	ResyncInterval                    Duration
	KubeClientSet                     kubernetes.Interface `json:"-"`
}

type Duration struct {
	time.Duration
}

type MetricsClient interface {
	// GetResourceMetrics retrieves metrics for multiple resources.
	//
	// Parameters:
	//   - resources: A slice of resources to retrieve metrics for
	//
	// Returns:
	//   - map[string]map[string]int: A nested map structure where:
	//     * The outer map key is the resource name (e.g., deployment name)
	//     * The inner map key is the metric name
	//     * The inner map value is the metric value as an integer
	//     Example: map["my-deployment"]["requests_per_minute"] = 42
	//   - error: An error if metric retrieval fails
	//
	// The dual map structure allows efficient lookup of metric values by resource name
	// and then by metric name, enabling the autoscaler to check multiple metrics
	// per resource when making scaling decisions.
	GetResourceMetrics(resources []Resource) (map[string]map[string]int, error)
}

type MetricsClientKind string

type MetricsClientOptions struct {
	MetricsClientKind MetricsClientKind
	URL               string
	QueryTemplates    []QueryTemplate
}

type MultiTargetStrategy string

type QueryTemplate struct {
	Name     string
	Template string
}

type ResolveTargetsFromIngressCallback func(ingress *networkingv1.Ingress) ([]string, error)

type Resource struct {
	Name               string          `json:"name,omitempty"`
	Namespace          string          `json:"namespace,omitempty"`
	ScaleResources     []ScaleResource `json:"scale_resources,omitempty"`
	LastScaleEvent     *ScaleEvent     `json:"last_scale_event,omitempty"`
	LastScaleEventTime *time.Time      `json:"last_scale_event_time,omitempty"`
}

type ResourceScaler interface {
	SetScale([]Resource, int) error
	SetScaleCtx(context.Context, []Resource, int) error
	GetResources() ([]Resource, error)
	GetConfig() (*ResourceScalerConfig, error)
	ResolveServiceName(Resource) (string, error)
}

type ResourceScalerConfig struct {
	KubeconfigPath    string
	AutoScalerOptions AutoScalerOptions
	DLXOptions        DLXOptions
}

type ScaleEvent string

type ScaleResource struct {
	MetricName string   `json:"metric_name,omitempty"`
	WindowSize Duration `json:"windows_size,omitempty"`
	Threshold  int      `json:"threshold,omitempty"`
}

type TargetAuthenticator interface {
	// AuthenticateTarget returns true if req is authorized for functionName. The request is
	// passed in because the credential lives on it (Authorization, Cookie, and the
	// authenticator-kind header), and res because on false the implementation, not the DLX,
	// writes the mode-appropriate rejection.
	AuthenticateTarget(res http.ResponseWriter, req *http.Request, functionName string) bool
}