func podRunning(event watch.Event) (bool, error) {
	switch event.Type {
	case watch.Deleted:
		return false, errors.New("pod deleted")
	}
	switch t := event.Object.(type) {
	case *v1.Pod:
		switch t.Status.Phase {
		case v1.PodRunning:
			return true, nil
		case v1.PodFailed, v1.PodSucceeded:
			return false, errors.New("pod ran to completion")
		}
	}
	return false, nil
}
// **NOTE**: Copy from kubernetes.
// podRunning returns true if the pod is running, false if the pod has not yet reached running state,
// returns ErrPodCompleted if the pod has run to completion, or an error in any other case.
NOTE**: Copy from kubernetes.
podRunning returns true if the pod is running, false if the pod has not yet reached running state,
returns ErrPodCompleted if the pod has run to completion, or an error in any other case.
// ** NOTE ** : Copy from kubernetes . // podRunning returns true if the pod is running false if the pod has not yet reached running state // returns ErrPodCompleted if the pod has run to completion or an error in any other case .
func podRunning(event watch.Event) (bool, error) {
	switch event.Type {
	case watch.Deleted:
		return false, errors.New("pod deleted")
	}
	switch t := event.Object.(type) {
	case *v1.Pod:
		switch t.Status.Phase {
		case v1.PodRunning:
			return true, nil
		case v1.PodFailed, v1.PodSucceeded:
			return false, errors.New("pod ran to completion")
		}
	}
	return false, nil
}
func podRunning ( event watch . Event ) ( bool , error ) { switch event . Type { case watch . Deleted : return false , errors . New ( " " ) } switch t := event . Object . ( type ) { case * v1 . Pod : switch t . Status . Phase { case v1 . PodRunning : return true , nil case v1 . PodFailed , v1 . PodSucceeded : return false , errors . New ( " " ) } } return false , nil }
NOTE**: Copy from kubernetes.
NOTE ** : Copy from kubernetes .