controller

Documentation

Index

• func ConvertInstanceToJob(ins *types.Instance) (job string, err error)
• func ConvertJobToInstance(job string) (ins *types.Instance, err error)
• type WorkerController
  • func NewWorkerController(kubeConfig string) (*WorkerController, error)
  • func (c *WorkerController) Run(ctx context.Context, workers int)

Functions

func ConvertInstanceToJob

func ConvertInstanceToJob(ins *types.Instance) (job string, err error)

func ConvertJobToInstance

func ConvertJobToInstance(job string) (ins *types.Instance, err error)

Types

type WorkerController

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

WorkerController is responsible for synchronizing job objects stored in the system with actual running replica sets and pods.

func NewWorkerController

func NewWorkerController(kubeConfig string) (*WorkerController, error)

NewWorkerController creates a new WorkerController.

func (*WorkerController) Run

func (c *WorkerController) Run(ctx context.Context, workers int)

Run begins watching and syncing.