Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

jobcontroller

package

Go to main page

Versions in this module

v0

v0.5.0

Mar 26, 2019

Changes in this version

type ControllerInterface

+ GetJobRoleKey func() string

type JobController

+ KubeBatchClientSet kubebatchclient.Interface

+ func (jc *JobController) DeletePodGroup(job metav1.Object) error

+ func (jc *JobController) SyncPodGroup(job metav1.Object, minAvailableReplicas int32) (*v1alpha1.PodGroup, error)

v0.4.0

Feb 13, 2019

Changes in this version

+ func GenExpectationPodsKey(jobKey, replicaType string) string

+ func GenExpectationServicesKey(jobKey, replicaType string) string

+ func GenGeneralName(jobName, rtype, index string) string

+ func RecheckDeletionTimestamp(getObject func() (metav1.Object, error)) func() error

+ type ControllerInterface interface

+ ControllerName func() string

+ GetAPIGroupVersion func() schema.GroupVersion

+ GetAPIGroupVersionKind func() schema.GroupVersionKind

+ GetGroupNameLabelKey func() string

+ GetGroupNameLabelValue func() string

+ GetJobFromAPIClient func(namespace, name string) (metav1.Object, error)

+ GetJobFromInformerCache func(namespace, name string) (metav1.Object, error)

+ GetJobNameLabelKey func() string

+ GetReplicaIndexLabelKey func() string

+ GetReplicaTypeLabelKey func() string

+ type JobController struct

+ Config JobControllerConfiguration

+ Controller ControllerInterface

+ Expectations controller.ControllerExpectationsInterface

+ KubeClientSet kubeclientset.Interface

+ PodControl controller.PodControlInterface

+ PodInformerSynced cache.InformerSynced

+ PodLister corelisters.PodLister

+ Recorder record.EventRecorder

+ ServiceControl control.ServiceControlInterface

+ ServiceInformerSynced cache.InformerSynced

+ ServiceLister corelisters.ServiceLister

+ WorkQueue workqueue.RateLimitingInterface

+ func NewJobController(controllerImpl ControllerInterface, reconcilerSyncPeriod metav1.Duration, ...) JobController

+ func (jc *JobController) AddPod(obj interface{})

+ func (jc *JobController) AddService(obj interface{})

+ func (jc *JobController) DeletePdb(job metav1.Object) error

+ func (jc *JobController) DeletePod(obj interface{})

+ func (jc *JobController) DeleteService(obj interface{})

+ func (jc *JobController) FilterPodsForReplicaType(pods []*v1.Pod, replicaType string) ([]*v1.Pod, error)

+ func (jc *JobController) FilterServicesForReplicaType(services []*v1.Service, replicaType string) ([]*v1.Service, error)

+ func (jc *JobController) GenLabels(jobName string) map[string]string

+ func (jc *JobController) GenOwnerReference(obj metav1.Object) *metav1.OwnerReference

+ func (jc *JobController) GetPodSlices(pods []*v1.Pod, replicas int, logger *log.Entry) [][]*v1.Pod

+ func (jc *JobController) GetPodsForJob(job metav1.Object) ([]*v1.Pod, error)

+ func (jc *JobController) GetServiceSlices(services []*v1.Service, replicas int, logger *log.Entry) [][]*v1.Service

+ func (jc *JobController) GetServicesForJob(job metav1.Object) ([]*v1.Service, error)

+ func (jc *JobController) SyncPdb(job metav1.Object, minAvailableReplicas int32) (*v1beta1.PodDisruptionBudget, error)

+ func (jc *JobController) UpdatePod(old, cur interface{})

+ func (jc *JobController) UpdateService(old, cur interface{})

+ type JobControllerConfiguration struct

+ EnableGangScheduling bool

+ ReconcilerSyncLoopPeriod metav1.Duration

v0.4.0-rc.1

Nov 28, 2018

v0.4.0-rc.0

Nov 19, 2018