code: func PodRunning(event watch.Event) (bool, error) {
  	switch event.Type {
  	case watch.Deleted:
  		return false, errors.NewNotFound(schema.GroupResource{Resource: "pods"}, "")
  	}
  	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, ErrPodCompleted
  		}
  	}
  	return false, nil
  }
docs: // 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.