Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GCPodUpdated ¶
func GCPodUpdated(client kubernetes.Interface, pod *corev1.Pod)
GCPodUpdated handles GC pod update. If GC pod is terminated, it will be deleted.
func IsGCPod ¶
IsGCPod judges whether a pod is a GC pod by check whether it has label "gc.cyclone.dev".
func IsWorkloadPod ¶ added in v1.1.0
IsWorkloadPod judges whether a pod is a workload pod by check whether it has label "workload.cyclone.dev".
Types ¶
type Handler ¶
type Handler struct {
ClusterClient kubernetes.Interface
Client k8s.Interface
}
Handler ...
func NewHandler ¶ added in v1.1.0
func NewHandler(client k8s.Interface, clusterClient kubernetes.Interface) *Handler
NewHandler ...
func (*Handler) AddFinalizer ¶ added in v1.1.0
AddFinalizer adds a finalizer to the object and update the object to the Kubernetes.
func (*Handler) HandleFinalizer ¶ added in v1.1.0
HandleFinalizer does the finalizer key representing things.
type Operator ¶
type Operator struct {
// contains filtered or unexported fields
}
Operator ...
func NewOperator ¶
func NewOperator(clusterClient kubernetes.Interface, client k8s.Interface, pod *corev1.Pod) (*Operator, error)
NewOperator ...
func (*Operator) DetermineStatus ¶
func (p *Operator) DetermineStatus(wfrOperator workflowrun.Operator)
DetermineStatus determines status of a stage and update WorkflowRun status accordingly. Because coordinator container is the last container running in the pod (it performs collect logs, artifacts, notify resource resolver to push resource), when the coordinator container have been finished (no matter Succeed or Failed), we need to update stage status, and take necessary actions to stop the pod.
Source Files