controller

Documentation

Index

• type GarbageCollector
  • func NewGarbageCollector(kubeCli kubernetes.Interface, ...) *GarbageCollector
  • func (gc *GarbageCollector) CleanGarbagePods()
  • func (gc *GarbageCollector) CleanOrphans(d time.Duration)
• type TrainingJobController
  • func New(kubeCli kubernetes.Interface, apiCli apiextensionsclient.Interface, ...) *TrainingJobController
  • func (c *TrainingJobController) Run(threadiness int, maxLoadDesired float64, stopCh <-chan struct{}) error

Types

type GarbageCollector

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

func NewGarbageCollector

func NewGarbageCollector(kubeCli kubernetes.Interface,
	trainingjobLister paddlelisters.TrainingJobLister) *GarbageCollector

func (*GarbageCollector) CleanGarbagePods

func (gc *GarbageCollector) CleanGarbagePods()

func (*GarbageCollector) CleanOrphans

func (gc *GarbageCollector) CleanOrphans(d time.Duration)

type TrainingJobController

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

TrainingJobController defines the structure to manage TrainingJob resource

func New

func New(
	kubeCli kubernetes.Interface,
	apiCli apiextensionsclient.Interface,
	paddleCli paddleclientset.Interface,
	tjInformer paddleinformers.SharedInformerFactory,
	auto bool, restartLimit int, outter bool) *TrainingJobController

New returns a TrainingJobController object

func (*TrainingJobController) Run

func (c *TrainingJobController) Run(threadiness int, maxLoadDesired float64, stopCh <-chan struct{}) error

Run will set up the event handlers for trainingjob, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items.