kubernetes

type Adapter struct {
	// contains filtered or unexported fields
}

type DeploymentClient interface {
	// Get reads the named Deployment in the client's configured namespace
	// honoring ctx.
	Get(context.Context, string, metav1.GetOptions) (*appsv1.Deployment, error)
	// List must honor namespace and server pagination limits; Adapter does not
	// cap an already materialized response.
	List(context.Context, metav1.ListOptions) (*appsv1.DeploymentList, error)
	// GetScale reads the named autoscaling/v1 scale subresource honoring ctx.
	GetScale(context.Context, string, metav1.GetOptions) (*autoscalingv1.Scale, error)
	// UpdateScale updates only the borrowed scale subresource in the configured
	// namespace; failure may follow remote acceptance.
	UpdateScale(context.Context, string, *autoscalingv1.Scale, metav1.UpdateOptions) (*autoscalingv1.Scale, error)
}

type DeploymentFactory func(namespace string) DeploymentClient

type Page struct {
	// Items is a newly projected status slice; the client must honor the
	// requested page bound.
	Items []Status `json:"items"`
	// Continue is provider-supplied opaque pagination state, not authorization.
	Continue string `json:"continue,omitempty"`
	// Remaining is provider-reported remaining item count; zero also represents
	// absent metadata.
	Remaining int64 `json:"remaining"`
}

type ScaleDispatcher struct {
	// contains filtered or unexported fields
}

type ScaleResult struct {
	// Namespace is configured namespace attribution; the provider must honor
	// that scope.
	Namespace string `json:"namespace"`
	// Name is the requested workload attribution.
	Name string `json:"name"`
	// DesiredReplicas is the update response's desired replica count, not
	// observed convergence.
	DesiredReplicas int32 `json:"desired_replicas"`
	// CurrentReplicas is the update response's observed replica count.
	CurrentReplicas int32 `json:"current_replicas"`
	// ResourceVersion is the update response's opaque resource version.
	ResourceVersion string `json:"resource_version"`
}

type Scaler interface {
	// Scale updates the named workload replicas honoring ctx;
	// authorization/confirmation must happen before this borrowed provider
	// call.
	Scale(context.Context, string, uint32) (ScaleResult, error)
}

type StaticTenantResolver struct {
	// contains filtered or unexported fields
}

type Status struct {
	// Namespace is the validated configured namespace of the reported
	// Deployment.
	Namespace string `json:"namespace"`
	// Name is the validated DNS-compatible Deployment name.
	Name string `json:"name"`
	// Generation is the API object's desired configuration generation.
	Generation int64 `json:"generation"`
	// ObservedGeneration is the controller's last observed generation, not
	// necessarily Generation.
	ObservedGeneration int64 `json:"observed_generation"`
	// DesiredReplicas is the reported spec replica count; absent Spec.Replicas
	// projects to zero.
	DesiredReplicas int32 `json:"desired_replicas"`
	// UpdatedReplicas is the reported updated replica count.
	UpdatedReplicas int32 `json:"updated_replicas"`
	// ReadyReplicas is the reported ready replica count.
	ReadyReplicas int32 `json:"ready_replicas"`
	// AvailableReplicas is the reported available replica count.
	AvailableReplicas int32 `json:"available_replicas"`
	// UnavailableReplicas is the reported unavailable replica count.
	UnavailableReplicas int32 `json:"unavailable_replicas"`
}

type TenantAdapter interface {
	Scaler
	// List returns a page honoring requested namespace, limit and cursor; the
	// resolver borrows the adapter and does not close it.
	List(context.Context, int64, string) (Page, error)
}

type TenantResolver interface {
	// ResolveTenant returns the borrowed namespace-scoped scaler for a tenant;
	// errors refuse dispatch.
	ResolveTenant(context.Context, string) (Scaler, error)
}