Documentation
¶
Index ¶
Constants ¶
View Source
const ( // EventResourceCreated is an Event "reason" when a resource is created EventResourceCreated = "Created" // EventResourceNotCreated is an Event "reason" when a resource fails to be created EventResourceNotCreated = "ErrResourceNotCreated" // EventResourceSynced is an Event "reason" when a resource is synced EventResourceSynced = "Synced" // EventResourceExists is an Event "reason" when a resource fails to sync EventResourceExists = "ErrResourceExists" // EventMsgWorkflowCreated is an Event "message" when an Argo Workflow owned // by a KubebenchJob is created EventMsgWorkflowCreated = "Workflow created successfully" // EventMsgWorkflowNotCreated is an Event "message" when an Argo Workflow owned // by a KubebenchJob fails to be created EventMsgWorkflowNotCreated = "Workflow failed to be created" // EventMsgWorkflowExists is an Event "message" when a Kubebenchjob fails to sync // due to an Argo Workflow already existing EventMsgWorkflowExists = "Workflow already exists and is not managed by KubebenchJob" // EventMsgKubebenchJobSynced is the message used for an Event fired when a KubebenchJob // is synced successfully EventMsgKubebenchJobSynced = "KubebenchJob synced successfully" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KubebenchJobController ¶
type KubebenchJobController struct {
// contains filtered or unexported fields
}
KubebenchJobController is the controller for KubebenchJob
func NewKubebenchJobController ¶
func NewKubebenchJobController( argoClientSet argoclientset.Interface, kbJobClientSet kbjobclientset.Interface, argoInformer argoinformer.WorkflowInformer, kbJobInformer kbjobinformer.KubebenchJobInformer, config kbjobv1alpha2.KubebenchConfig) *KubebenchJobController
NewKubebenchJobController creates a new KubebenchJobController
func (*KubebenchJobController) Run ¶
func (c *KubebenchJobController) Run(threadiness int, stopCh <-chan struct{}) error
Run starts a KubebenchJobController
Source Files
Click to show internal directories.
Click to hide internal directories.