Versions in this module Expand all Collapse all v0 v0.4.7 Apr 25, 2023 Changes in this version + const EnvKubeflowNamespace + const JobCreatedReason + const JobFailedReason + const JobFailedValidationReason + const JobRestartingReason + const JobRunningReason + const JobSucceededReason + func IsFailed(status apiv1.JobStatus) bool + func IsSucceeded(status apiv1.JobStatus) bool + func LoggerForJob(job metav1.Object) *log.Entry + func LoggerForKey(key string) *log.Entry + func LoggerForPod(pod *v1.Pod, kind string) *log.Entry + func LoggerForReplica(job metav1.Object, rtype string) *log.Entry + func LoggerForService(svc *v1.Service, kind string) *log.Entry + func LoggerForUnstructured(obj *metav1unstructured.Unstructured, kind string) *log.Entry + func Pformat(value interface{}) string + func RandString(n int) string + func UpdateJobConditions(jobStatus *apiv1.JobStatus, conditionType apiv1.JobConditionType, ...) error + type Counter struct + func NewCounter() *Counter + func (c *Counter) Counts(key string) (int, error) + func (c *Counter) Dec(key string) error + func (c *Counter) DeleteKey(key string) + func (c *Counter) Inc(key string)