pod

Documentation

Index

• func GCPodUpdated(client kubernetes.Interface, pod *corev1.Pod)
• func IsGCPod(pod *corev1.Pod) bool
• type Handler
  • func (h *Handler) ObjectCreated(obj interface{})
  • func (h *Handler) ObjectDeleted(obj interface{})
  • func (h *Handler) ObjectUpdated(old, new interface{})
• type Operator
  • func NewOperator(clusterClient kubernetes.Interface, client clientset.Interface, ...) (*Operator, error)
  • func (p *Operator) DetermineStatus(wfrOperator workflowrun.Operator)
  • func (p *Operator) OnDelete() error
  • func (p *Operator) OnUpdated() error

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

func IsGCPod(pod *corev1.Pod) bool

IsGCPod judges whether a pod is a GC pod by check whether it has annotation "gc.cyclone.dev".

Types

type Handler

type Handler struct {
	ClusterClient kubernetes.Interface
	Client        clientset.Interface
}

Handler ...

func (*Handler) ObjectCreated

func (h *Handler) ObjectCreated(obj interface{})

ObjectCreated ...

func (*Handler) ObjectDeleted

func (h *Handler) ObjectDeleted(obj interface{})

ObjectDeleted ...

func (*Handler) ObjectUpdated

func (h *Handler) ObjectUpdated(old, new interface{})

ObjectUpdated ...

type Operator

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

Operator ...

func NewOperator

func NewOperator(clusterClient kubernetes.Interface, client clientset.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.

func (*Operator) OnDelete

func (p *Operator) OnDelete() error

OnDelete handles the situation when a stage pod gotten delete. It updates corresponding WorkflowRun's status.

func (*Operator) OnUpdated

func (p *Operator) OnUpdated() error

OnUpdated ...