resources

package

Go to main page

Versions in this module

v0

v0.5.0

Oct 14, 2026

Changes in this version

+ const FSCheckpointSubdir

+ const SingletonName

+ func ValidateAssetHash(sha256Hash string) error

+ func ValidateCSIMap(fldPath *field.Path, m map[string]string) field.ErrorList

+ func ValidateCapabilities(fldPath *field.Path, caps []string, allowAll bool) field.ErrorList

+ func ValidateEnvVarName(fldPath *field.Path, name string) field.ErrorList

+ func ValidateHTTPGetPath(fldPath *field.Path, p string) field.ErrorList

+ func ValidateHostPort(fldPath *field.Path, value string) field.ErrorList

+ func ValidateMountPath(fldPath *field.Path, p string) field.ErrorList

+ func ValidateNestedMountPaths(fldPath *field.Path, paths []string) field.ErrorList

+ func ValidatePinnedImage(fldPath *field.Path, value string) field.ErrorList

+ func ValidateProjectedPath(fldPath *field.Path, p string) field.ErrorList

+ func ValidateSandboxClass(fldPath *field.Path, value string) field.ErrorList

+ func ValidateSnapshotFidelity(fidelity ateompb.SnapshotFidelity, supported []ateompb.SnapshotFidelity, ...) field.ErrorList

+ func ValidateSnapshotFileNames(files []string) error

+ func ValidateStorageVolumeID(fldPath *field.Path, id string) field.ErrorList

+ func ValidateVolumeType(fldPath *field.Path, volumeType string) field.ErrorList

+ func ValidateWorkerPodUID(workerPodUID string) error

type StoragePrefix

+ func ParseStoragePrefix(uri string) (StoragePrefix, error)

v0.4.0

Oct 7, 2026

Changes in this version

+ func ToAPIError(errs field.ErrorList) error

+ func ValidateRuntimeAssetPath(root, p string, fldPath *field.Path) field.ErrorList

v0.3.0

Sep 30, 2026

Changes in this version

+ const DurableDirTarFile

+ func AteomForActorSPIFFEID(r ActorRef) *url.URL

+ func DeepEqual[T any](a, b T) bool

+ func ToGRPCStatusError(errs field.ErrorList) error

+ func ValidateActorDirs(actorDirs *ateompb.ActorDirs, fldPath *field.Path) field.ErrorList

+ func ValidateLimit(fldPath *field.Path, name, quantity string) field.ErrorList

type ActorRef

+ func ActorRefFromActorSPIFFEID(id string) (ActorRef, error)

+ func ActorRefFromActorSPIFFEURL(u *url.URL) (ActorRef, error)

+ func ActorRefFromAteomForActorSPIFFEID(id string) (ActorRef, error)

+ func ActorRefFromAteomForActorSPIFFEURL(u *url.URL) (ActorRef, error)

v0.2.0

Sep 25, 2026

Changes in this version

+ const ActorSPIFFETrustDomain

+ func ActorSPIFFEID(r ActorRef) *url.URL

type ActorRef

+ func ActorRefFromSPIFFEID(id string) (ActorRef, error)

v0.1.0

Sep 9, 2026

Changes in this version

+ const GoldenActorAtespace

+ const ResourceCPU

+ const ResourceMemory

+ const ResourceNameRegexPattern

+ func ActorDNSName(r ActorRef) string

+ func AddToAllocated(total *ateapipb.WorkerResources, assignment *ateapipb.ActorAssignment, ...) (*ateapipb.WorkerResources, error)

+ func CPUMemory(cpuMilli, memoryBytes int64) *ateapipb.Resources

+ func IsValidResourceName(name string) bool

+ func NetworkPolicyName(wpName string) string

+ func NewSnapshotName() string

+ func SumAllocated(assignments []*ateapipb.ActorAssignment) (*ateapipb.WorkerResources, error)

+ func ValidateAteomUID(targetAteomUID string) error

+ func ValidateContainerNames(names []string) error

+ func ValidateGlobalObjectRef(ref *ateapipb.ObjectRef, fldPath *field.Path) field.ErrorList

+ func ValidateIP(ip string, fldPath *field.Path) field.ErrorList

+ func ValidateResourceName(name string, fldPath *field.Path) field.ErrorList

+ func ValidateRunscHash(sha256Hash string) error

+ func ValidateSnapshotLocation(location string) error

+ func ValidateUUID(uuid string, fldPath *field.Path) field.ErrorList

+ type ActorAttribution struct

+ Ref ActorRef

+ TemplateAtespace string

+ TemplateName string

+ UID string

+ func ActorAttributionFromActor(a *ateapipb.Actor) ActorAttribution

+ type ActorRef = ResourceRef[*ateapipb.Actor]

+ func ActorRefFromActor(a *ateapipb.Actor) ActorRef

+ func ActorRefFromObjectRef(ref *ateapipb.ObjectRef) ActorRef

+ func ParseActorDNSName(name string) (ActorRef, error)

+ type ActorTemplateRef = ResourceRef[*ateapipb.ActorTemplate]

+ func ActorTemplateRefFromActorTemplate(t *ateapipb.ActorTemplate) ActorTemplateRef

+ func ActorTemplateRefFromObjectRef(ref *ateapipb.ObjectRef) ActorTemplateRef

+ type Quantities map[string]resource.Quantity

+ func ParseQuantities(r *ateapipb.Resources) (Quantities, error)

+ func (q Quantities) Add(other Quantities)

+ func (q Quantities) Covers(want Quantities) bool

+ func (q Quantities) Proto() *ateapipb.Resources

+ func (q Quantities) Sub(other Quantities)

+ type Resource interface

+ GetMetadata func() *ateapipb.ResourceMetadata

+ type ResourceRef struct

+ Atespace string

+ Name string

+ func (r ResourceRef[R]) LogValue() slog.Value

+ func (r ResourceRef[R]) String() string

+ func (r ResourceRef[R]) ToObjectRef() *ateapipb.ObjectRef

+ type SnapshotOwner struct

+ func ActorSnapshotOwner(atespace, actorUID string) SnapshotOwner

+ func TagSnapshotOwner(atespace, snapshotName string) SnapshotOwner

+ func (o SnapshotOwner) Atespace() string

+ func (o SnapshotOwner) IsZero() bool

+ func (o SnapshotOwner) Prefix(location string) (StoragePrefix, error)

+ func (o SnapshotOwner) String() string

+ type SnapshotURI struct

+ func NewActorSnapshotURI(location, atespace, actorUID, name string) (SnapshotURI, error)

+ func NewTagSnapshotURI(location, atespace, name string) (SnapshotURI, error)

+ func ParseSnapshotURI(uri string) (SnapshotURI, error)

+ func (u SnapshotURI) Atespace() string

+ func (u SnapshotURI) IsZero() bool

+ func (u SnapshotURI) Location() string

+ func (u SnapshotURI) Name() string

+ func (u SnapshotURI) ObjectURI(name string) (string, error)

+ func (u SnapshotURI) OwnedBy(o SnapshotOwner) bool

+ func (u SnapshotURI) Owner() SnapshotOwner

+ func (u SnapshotURI) OwnerPrefix() StoragePrefix

+ func (u SnapshotURI) Prefix() StoragePrefix

+ func (u SnapshotURI) String() string

+ type StoragePrefix struct

+ func (p StoragePrefix) IsZero() bool

+ func (p StoragePrefix) String() string

+ type TagRef = ResourceRef[*ateapipb.Tag]

+ func TagRefFromObjectRef(ref *ateapipb.ObjectRef) TagRef

+ func TagRefFromTag(t *ateapipb.Tag) TagRef

v0.0.0

May 19, 2026

Changes in this version

+ const ActorDNSSuffix

+ const ActorIDRegexPattern

+ func ValidateActorID(id string) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL