Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + const ErrorCodeSystem + const ErrorCodeUnknown + const ErrorCodeUser + const ResourceNvidiaGPU + var NotTheOwnerError = errors.Errorf("KozmoPropeller is not the owner") + func CopyMap(o map[string]string) (r map[string]string) + func GetContainer(pod *v1.PodSpec, containerName string) (*v1.Container, error) + func GetKubeConfig(_ context.Context, cfg *config.Config) (*kubernetes.Clientset, *restclient.Config, error) + func GetProtoTime(t *metav1.Time) *timestamp.Timestamp + func GetSanitizedPrometheusKey(key string) (string, error) + func GetWorkflowIDFromOwner(reference *metav1.OwnerReference, namespace string) (v1alpha1.WorkflowID, error) + func MakeBinding(variable string, b *core.BindingData) *core.Binding + func MakeBindingDataCollection(bindings ...*core.BindingData) *core.BindingData + func MakeBindingDataMap(pairs ...Pair) *core.BindingData + func MakeBindingDataPromise(fromNode, fromVar string) *core.BindingData + func MakeBindingPromise(fromNode, fromVar, toVar string) *core.Binding + func MakePrimitiveBindingData(v interface{}) (*core.BindingData, error) + func MustMakePrimitiveBindingData(v interface{}) *core.BindingData + func NewK8sEventRecorder(ctx context.Context, kubeclientset kubernetes.Interface, ...) (record.EventRecorder, error) + func SanitizeLabelValue(name string) string + func ToK8sEnvVar(env []*core.KeyValuePair) []v1.EnvVar + type FailingRawStore struct + func (FailingRawStore) CopyRaw(ctx context.Context, source, destination storage.DataReference, ...) error + func (FailingRawStore) CreateSignedURL(ctx context.Context, reference storage.DataReference, ...) (storage.SignedURLResponse, error) + func (FailingRawStore) Delete(ctx context.Context, reference storage.DataReference) error + func (FailingRawStore) GetBaseContainerFQN(ctx context.Context) storage.DataReference + func (FailingRawStore) Head(ctx context.Context, reference storage.DataReference) (storage.Metadata, error) + func (FailingRawStore) ReadRaw(ctx context.Context, reference storage.DataReference) (io.ReadCloser, error) + func (FailingRawStore) WriteRaw(ctx context.Context, reference storage.DataReference, size int64, ...) error + type Pair struct + K string + V *core.BindingData + func NewPair(k string, v *core.BindingData) Pair
Go to main page