job

Documentation

Index

• Constants
• func NewController(client kubernetes.Interface, radixClient radixclient.Interface, ...) *common.Controller
• type Handler
  • func NewHandler(kubeclient kubernetes.Interface, kubeutil *kube.Kube, ...) Handler
  • func (t *Handler) Sync(namespace, name string, eventRecorder record.EventRecorder) error

Constants

const (
	// SuccessSynced is used as part of the Event 'reason' when a Job is synced
	SuccessSynced = "Synced"

	// MessageResourceSynced is the message used for an Event fired when a Job
	// is synced successfully
	MessageResourceSynced = "Radix Job synced successfully"
)

Functions

func NewController

func NewController(client kubernetes.Interface, radixClient radixclient.Interface, handler common.Handler, kubeInformerFactory kubeinformers.SharedInformerFactory, radixInformerFactory informers.SharedInformerFactory, waitForChildrenToSync bool, recorder record.EventRecorder) *common.Controller

NewController creates a new controller that handles RadixJobs

Types

type Handler

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

Handler Instance variables

func NewHandler

func NewHandler(kubeclient kubernetes.Interface, kubeutil *kube.Kube, radixclient radixclient.Interface, config *job.Config, hasSynced common.HasSynced) Handler

NewHandler Constructor

func (*Handler) Sync

func (t *Handler) Sync(namespace, name string, eventRecorder record.EventRecorder) error

Sync Is created on sync of resource