provisioning

Documentation

Index

• Variables
• type Batcher
  • func NewBatcher(running context.Context) *Batcher
  • func (b *Batcher) Trigger()
  • func (b *Batcher) TriggerImmediate()
  • func (b *Batcher) Wait() (window time.Duration)
• type Controller
  • func NewController(ctx context.Context, kubeClient client.Client, ...) *Controller
  • func (c *Controller) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (c *Controller) Register(_ context.Context, m manager.Manager) error
  • func (c *Controller) TriggerAndWait()
• type Provisioner
  • func NewProvisioner(ctx context.Context, kubeClient client.Client, ...) *Provisioner
  • func (p *Provisioner) Trigger()
  • func (p *Provisioner) TriggerAndWait()
• type VolumeTopology
  • func NewVolumeTopology(kubeClient client.Client) *VolumeTopology
  • func (v *VolumeTopology) Inject(ctx context.Context, pod *v1.Pod) error

Variables

var (
	MaxBatchDuration  = time.Second * 10
	BatchIdleDuration = time.Second * 1
)

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) *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(ctx context.Context, kubeClient client.Client, coreV1Client corev1.CoreV1Interface, cloudProvider cloudprovider.CloudProvider, cluster *state.Cluster) *Controller

NewController constructs a controller instance

func (*Controller) Reconcile

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

Reconcile the resource

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 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, kubeClient client.Client, coreV1Client corev1.CoreV1Interface, cloudProvider cloudprovider.CloudProvider, cluster *state.Cluster) *Provisioner

func (*Provisioner) Trigger

func (p *Provisioner) Trigger()

func (*Provisioner) TriggerAndWait

func (p *Provisioner) TriggerAndWait()

Deprecated: TriggerAndWait is used for unit testing purposes only

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