provisioner

type Provisioner ¶

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

Provisioner provisions and terminates agent instances. It is composed of four parts: a provisioner, a scaling decision maker, a provider, and a rate limiter.

1. The provisioner is capable of reporting provider information and updating scaling info. 1.1. `Scheduler` pushes an immutable view of agents and tasks to `Provisioner`. `Provisioner` pulls instance data from instance providers.
2. Based on the pending tasks, the scaleDecider chooses how many new instances to launch and which instances to terminate. 2.1 It terminates instances if they stay idle for more than `maxIdleAgentPeriod` time. 2.2 It checks recently launched instances and avoids provisioning more than needed.
3. The instance providers take actions to launch/terminate instances.
4. The rate limiter ensures telemetry does not get sent more frequently than every 90sec.

func New(
	system *actor.System,
	resourcePool string, config *provconfig.Config, cert *tls.Certificate, db db.DB,
) (*Provisioner, error)

func Setup(
	ctx *actor.Context,
	config *provconfig.Config,
	resourcePool string,
	cert *tls.Certificate,
	db db.DB,
) (*Provisioner, error)

func (p *Provisioner) CurrentSlotCount() (int, error)

func (p *Provisioner) InstanceType() string

func (p *Provisioner) LaunchError() error

func (p *Provisioner) Provision()

func (p *Provisioner) Run()

func (p *Provisioner) SlotsPerInstance() int

func (p *Provisioner) UpdateScalingInfo(info *sproto.ScalingInfo)