util

May 28, 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)