provisioning

Documentation

Index

• Variables
• type Batcher
  • func NewBatcher(running context.Context, cfg config.Config) *Batcher
  • func (b *Batcher) Trigger()
  • func (b *Batcher) TriggerImmediate()
  • func (b *Batcher) Wait() (window time.Duration)
• type Controller
  • func NewController(kubeClient client.Client, provisioner *Provisioner, recorder events.Recorder) *Controller
  • func (c *Controller) LivenessProbe(req *http.Request) error
  • func (c *Controller) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (c *Controller) Recorder() events.Recorder
  • func (c *Controller) Register(_ context.Context, m manager.Manager) error
  • func (c *Controller) TriggerAndWait()
• type LaunchOptions
• type Provisioner
  • func NewProvisioner(ctx context.Context, cfg config.Config, kubeClient client.Client, ...) *Provisioner
  • func (p *Provisioner) LaunchNodes(ctx context.Context, opts LaunchOptions, nodes ...*scheduler.Node) ([]string, error)
  • func (p *Provisioner) LivenessProbe(req *http.Request) error
  • func (p *Provisioner) NewScheduler(ctx context.Context, pods []*v1.Pod, stateNodes []*state.Node, ...) (*scheduler.Scheduler, error)
  • func (p *Provisioner) Provision(ctx context.Context) error
  • func (p *Provisioner) Start(ctx context.Context)
  • func (p *Provisioner) Trigger()
  • func (p *Provisioner) TriggerAndWait()
  • func (p *Provisioner) Validate(ctx context.Context, pod *v1.Pod) error
• type VolumeTopology
  • func NewVolumeTopology(kubeClient client.Client) *VolumeTopology
  • func (v *VolumeTopology) Inject(ctx context.Context, pod *v1.Pod) error

Variables

var WaitForClusterSync = true

WaitForClusterSync controls whether or not we synchronize before scheduling. This is exposed for unit testing purposes so we can avoid a lengthy delay in cluster sync.

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(running context.Context, cfg config.Config) *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) TriggerImmediate

func (b *Batcher) TriggerImmediate()

TriggerImmediate causes the batcher to immediately end the current batching window and causes the waiter on the batching window to continue.

func (*Batcher) Wait

func (b *Batcher) Wait() (window time.Duration)

Wait starts a batching window and returns a slice of items when closed.

type Controller

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

Controller for the resource

func NewController

func NewController(kubeClient client.Client, provisioner *Provisioner, recorder events.Recorder) *Controller

NewController constructs a controller instance

func (*Controller) LivenessProbe

func (c *Controller) LivenessProbe(req *http.Request) error

func (*Controller) Reconcile

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

Reconcile the resource

func (*Controller) Recorder

func (c *Controller) Recorder() events.Recorder

func (*Controller) Register

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

func (*Controller) TriggerAndWait

func (c *Controller) TriggerAndWait()

Deprecated: TriggerAndWait is used for unit testing purposes only

type LaunchOptions

type LaunchOptions struct {
	// RecordPodNomination causes nominate pod events to be recorded against the node.
	RecordPodNomination bool
}

type Provisioner

type Provisioner struct {
	// State
	Stop context.CancelFunc
	// 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(ctx context.Context, cfg config.Config, kubeClient client.Client, coreV1Client corev1.CoreV1Interface, recorder events.Recorder, cloudProvider cloudprovider.CloudProvider, cluster *state.Cluster) *Provisioner

func (*Provisioner) LaunchNodes

func (p *Provisioner) LaunchNodes(ctx context.Context, opts LaunchOptions, nodes ...*scheduler.Node) ([]string, error)

LaunchNodes 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) LivenessProbe

func (p *Provisioner) LivenessProbe(req *http.Request) error

func (*Provisioner) NewScheduler

func (p *Provisioner) NewScheduler(ctx context.Context, pods []*v1.Pod, stateNodes []*state.Node, opts scheduler.SchedulerOptions) (*scheduler.Scheduler, error)

nolint: gocyclo

func (*Provisioner) Provision

func (p *Provisioner) Provision(ctx context.Context) error

func (*Provisioner) Start

func (p *Provisioner) Start(ctx context.Context)

func (*Provisioner) Trigger

func (p *Provisioner) Trigger()

func (*Provisioner) TriggerAndWait

func (p *Provisioner) TriggerAndWait()

Deprecated: TriggerAndWait is used for unit testing purposes only

func (*Provisioner) Validate

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

type VolumeTopology

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

func NewVolumeTopology

func NewVolumeTopology(kubeClient client.Client) *VolumeTopology

func (*VolumeTopology) Inject

func (v *VolumeTopology) Inject(ctx context.Context, pod *v1.Pod) error