core

Documentation

Index

• type Actuator
• type Controller
  • func NewController(scheme *runtime.Scheme, client client.Client, podBatcher util.Batcher[v1.Pod], ...) Controller
  • func (c *Controller) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (c *Controller) SetupWithManager(mgr ctrl.Manager, name string) error
• type PartitioningPlan
  • func NewPartitioningPlan(s state.PartitioningState) PartitioningPlan
  • func (p PartitioningPlan) GetId() string
• type Planner

Types

type Actuator

type Actuator interface {
	Apply(ctx context.Context, snapshot state.ClusterSnapshot, plan PartitioningPlan) (bool, error)
}

type Controller

type Controller struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

func NewController

func NewController(
	scheme *runtime.Scheme,
	client client.Client,
	podBatcher util.Batcher[v1.Pod],
	clusterState *state.ClusterState,
	planner Planner,
	actuator Actuator) Controller

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*Controller) SetupWithManager

func (c *Controller) SetupWithManager(mgr ctrl.Manager, name string) error

type PartitioningPlan

type PartitioningPlan struct {
	DesiredState state.PartitioningState
	// contains filtered or unexported fields
}

func NewPartitioningPlan

func NewPartitioningPlan(s state.PartitioningState) PartitioningPlan

func (PartitioningPlan) GetId

func (p PartitioningPlan) GetId() string

type Planner

type Planner interface {
	Plan(ctx context.Context, snapshot state.ClusterSnapshot, pendingPods []v1.Pod) (PartitioningPlan, error)
}