package job

import "k8s.io/kubernetes/federation/pkg/federation-controller/job"

Index ¶

• Constants
• Variables
• type FederationJobController
• func NewJobController(fedClient fedclientset.Interface) *FederationJobController
• func (fjc *FederationJobController) Run(workers int, stopCh <-chan struct{})

Constants ¶

const (

	// UserAgentName is the user agent used in the federation client
	UserAgentName = "Federation-Job-Controller"
	// ControllerName is name of this controller
	ControllerName = "jobs"
)

Variables ¶

var (
	// RequiredResources is the resource group version of the type this controller manages
	RequiredResources = []schema.GroupVersionResource{batchv1.SchemeGroupVersion.WithResource("jobs")}
)

Types ¶

type FederationJobController ¶

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

FederationJobController synchronizes the state of a federated job object to clusters that are members of the federation.

func NewJobController ¶

func NewJobController(fedClient fedclientset.Interface) *FederationJobController

NewJobController creates a new federation job controller

func (*FederationJobController) Run ¶

func (fjc *FederationJobController) Run(workers int, stopCh <-chan struct{})

Run starts the syncing of federation jobs to the clusters.

Source Files ¶

jobcontroller.go