Documentation
¶
Index ¶
- func EnsureCreateCRD(clientset apiextensionsclient.Interface, ...) error
- func GetJobCondition(j *batch.Job) (batch.JobConditionType, string)
- func GetVertexStatus(exec *genev1alpha1.Execution, vertexName string) *genev1alpha1.VertexStatus
- func InitializeVertexStatus(vertexName string, phase genev1alpha1.VertexPhase, message string, ...) genev1alpha1.VertexStatus
- func IsExecutionCompleted(exec *genev1alpha1.Execution) bool
- func IsJobFinished(j *batch.Job) bool
- func KeyOf(obj interface{}) string
- func MarkExecutionError(exec *genev1alpha1.Execution, err error)
- func MarkExecutionFailed(exec *genev1alpha1.Execution, message string)
- func MarkExecutionPhase(exec *genev1alpha1.Execution, phase genev1alpha1.VertexPhase, message string)
- func MarkExecutionRunning(exec *genev1alpha1.Execution, message string)
- func MarkExecutionSuccess(exec *genev1alpha1.Execution, message string)
- func MarkVertexError(exec *genev1alpha1.Execution, vertexName string, err error)
- func MarkVertexFailed(exec *genev1alpha1.Execution, vertexName string, message string)
- func MarkVertexPhase(exec *genev1alpha1.Execution, vertexName string, ...)
- func MarkVertexSuccess(exec *genev1alpha1.Execution, vertexName string, message string)
- func RuleSatisfied(r genev1alpha1.MatchRule, kv map[string]string) bool
- func VertexId(vertexName string) string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EnsureCreateCRD ¶
func EnsureCreateCRD(clientset apiextensionsclient.Interface, crd *apiextensionsv1beta1.CustomResourceDefinition) error
EnsureCreateCRD creates CustomResourceDefinition
func GetJobCondition ¶
func GetJobCondition(j *batch.Job) (batch.JobConditionType, string)
func GetVertexStatus ¶
func GetVertexStatus(exec *genev1alpha1.Execution, vertexName string) *genev1alpha1.VertexStatus
func InitializeVertexStatus ¶
func InitializeVertexStatus(vertexName string, phase genev1alpha1.VertexPhase, message string, children []*graph.Vertex) genev1alpha1.VertexStatus
func IsExecutionCompleted ¶
func IsExecutionCompleted(exec *genev1alpha1.Execution) bool
func IsJobFinished ¶
func MarkExecutionError ¶
func MarkExecutionError(exec *genev1alpha1.Execution, err error)
func MarkExecutionFailed ¶
func MarkExecutionFailed(exec *genev1alpha1.Execution, message string)
func MarkExecutionPhase ¶
func MarkExecutionPhase(exec *genev1alpha1.Execution, phase genev1alpha1.VertexPhase, message string)
func MarkExecutionRunning ¶
func MarkExecutionRunning(exec *genev1alpha1.Execution, message string)
func MarkExecutionSuccess ¶
func MarkExecutionSuccess(exec *genev1alpha1.Execution, message string)
func MarkVertexError ¶
func MarkVertexError(exec *genev1alpha1.Execution, vertexName string, err error)
func MarkVertexFailed ¶
func MarkVertexFailed(exec *genev1alpha1.Execution, vertexName string, message string)
func MarkVertexPhase ¶
func MarkVertexPhase(exec *genev1alpha1.Execution, vertexName string, phase genev1alpha1.VertexPhase, message string)
func MarkVertexSuccess ¶
func MarkVertexSuccess(exec *genev1alpha1.Execution, vertexName string, message string)
func RuleSatisfied ¶
func RuleSatisfied(r genev1alpha1.MatchRule, kv map[string]string) bool
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.