Versions in this module Expand all Collapse all v0 v0.3.0 Sep 29, 2018 Changes in this version + var DefaultJobBackOff = 10 * time.Second + var ErrVersionOutdated = errors.New("requested version is outdated in apiserver") + var MaxJobBackOff = 360 * time.Second + type Controller struct + KubeClient kubernetes.Interface + PyTorchJobClient torchjobclient.Interface + PyTorchJobLister listers.PyTorchJobLister + PyTorchJobSynced cache.InformerSynced + WorkQueue workqueue.RateLimitingInterface + func New(kubeClient kubernetes.Interface, tfJobClient torchjobclient.Interface, ...) (*Controller, error) + func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error