provisioning

Documentation

Index

• Variables
• func RecordPodNomination(o *LaunchOptions)
• func WithReason(reason string) func(*LaunchOptions)
• type Batcher
  • func NewBatcher() *Batcher
  • func (b *Batcher) Trigger()
  • func (b *Batcher) Wait(ctx context.Context) bool
• type LaunchOptions
• type NodeController
  • func NewNodeController(kubeClient client.Client, provisioner *Provisioner) *NodeController
  • func (c *NodeController) Reconcile(ctx context.Context, n *corev1.Node) (reconcile.Result, error)
  • func (c *NodeController) Register(_ context.Context, m manager.Manager) error
• type PodController
  • func NewPodController(kubeClient client.Client, provisioner *Provisioner) *PodController
  • func (c *PodController) Reconcile(ctx context.Context, p *corev1.Pod) (reconcile.Result, error)
  • func (c *PodController) Register(_ context.Context, m manager.Manager) error
• type Provisioner
  • func NewProvisioner(kubeClient client.Client, recorder events.Recorder, ...) *Provisioner
  • func (p *Provisioner) Create(ctx context.Context, n *scheduler.NodeClaim, ...) (string, error)
  • func (p *Provisioner) CreateNodeClaims(ctx context.Context, nodeClaims []*scheduler.NodeClaim, ...) ([]string, error)
  • func (p *Provisioner) GetPendingPods(ctx context.Context) ([]*corev1.Pod, error)
  • func (p *Provisioner) NewScheduler(ctx context.Context, pods []*corev1.Pod, stateNodes []*state.StateNode) (*scheduler.Scheduler, error)
  • func (p *Provisioner) Reconcile(ctx context.Context) (result reconcile.Result, err error)
  • func (p *Provisioner) Register(_ context.Context, m manager.Manager) error
  • func (p *Provisioner) Schedule(ctx context.Context) (scheduler.Results, error)
  • func (p *Provisioner) Trigger()
  • func (p *Provisioner) Validate(ctx context.Context, pod *corev1.Pod) error

Variables

var ErrNodePoolsNotFound = errors.New("no nodepools found")

Functions

func RecordPodNomination

func RecordPodNomination(o *LaunchOptions)

RecordPodNomination causes nominate pod events to be recorded against the node.

func WithReason

func WithReason(reason string) func(*LaunchOptions)

Types

type Batcher

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

Batcher separates a stream of Trigger() calls into windowed slices. The window is dynamic and will be extended if additional items are added up to a maximum batch duration.

func NewBatcher

func NewBatcher() *Batcher

NewBatcher is a constructor for the Batcher

func (*Batcher) Trigger

func (b *Batcher) Trigger()

Trigger causes the batcher to start a batching window, or extend the current batching window if it hasn't reached the maximum length.

func (*Batcher) Wait

func (b *Batcher) Wait(ctx context.Context) bool

Wait starts a batching window and continues waiting as long as it continues receiving triggers within the idleDuration, up to the maxDuration

type LaunchOptions

type LaunchOptions struct {
	RecordPodNomination bool
	Reason              string
}

LaunchOptions are the set of options that can be used to trigger certain actions and configuration during scheduling

type NodeController

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

NodeController for the resource

func NewNodeController

func NewNodeController(kubeClient client.Client, provisioner *Provisioner) *NodeController

NewNodeController constructs a controller instance

func (*NodeController) Reconcile

func (c *NodeController) Reconcile(ctx context.Context, n *corev1.Node) (reconcile.Result, error)

Reconcile the resource

func (*NodeController) Register

func (c *NodeController) Register(_ context.Context, m manager.Manager) error

type PodController

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

PodController for the resource

func NewPodController

func NewPodController(kubeClient client.Client, provisioner *Provisioner) *PodController

NewPodController constructs a controller instance

func (*PodController) Reconcile

func (c *PodController) Reconcile(ctx context.Context, p *corev1.Pod) (reconcile.Result, error)

Reconcile the resource

func (*PodController) Register

func (c *PodController) Register(_ context.Context, m manager.Manager) error

type Provisioner

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

Provisioner waits for enqueued pods, batches them, creates capacity and binds the pods to the capacity.

func NewProvisioner

func NewProvisioner(kubeClient client.Client, recorder events.Recorder,
	cloudProvider cloudprovider.CloudProvider, cluster *state.Cluster,
	clock clock.Clock,
) *Provisioner

func (*Provisioner) Create

func (p *Provisioner) Create(ctx context.Context, n *scheduler.NodeClaim, opts ...option.Function[LaunchOptions]) (string, error)

func (*Provisioner) CreateNodeClaims

func (p *Provisioner) CreateNodeClaims(ctx context.Context, nodeClaims []*scheduler.NodeClaim, opts ...option.Function[LaunchOptions]) ([]string, error)

CreateNodeClaims launches nodes passed into the function in parallel. It returns a slice of the successfully created node names as well as a multierr of any errors that occurred while launching nodes

func (*Provisioner) GetPendingPods

func (p *Provisioner) GetPendingPods(ctx context.Context) ([]*corev1.Pod, error)

func (*Provisioner) NewScheduler

func (p *Provisioner) NewScheduler(ctx context.Context, pods []*corev1.Pod, stateNodes []*state.StateNode) (*scheduler.Scheduler, error)

func (*Provisioner) Reconcile

func (p *Provisioner) Reconcile(ctx context.Context) (result reconcile.Result, err error)

func (*Provisioner) Register

func (p *Provisioner) Register(_ context.Context, m manager.Manager) error

func (*Provisioner) Schedule

func (p *Provisioner) Schedule(ctx context.Context) (scheduler.Results, error)

func (*Provisioner) Trigger

func (p *Provisioner) Trigger()

func (*Provisioner) Validate

func (p *Provisioner) Validate(ctx context.Context, pod *corev1.Pod) error