Package taskgroup provides a mix of multierr and errgroup See documentation for https://pkg.go.dev/go.uber.org/multierr and https://pkg.go.dev/golang.org/x/sync/errgroup.

AbsDiff returns the absolute value of the difference between x and y.

AddHandler is a helper function to wrap the handle function with JSON [de]serialization and check that the HTTP method is correct The provided logPrefix is prepended to every log line emitted by the wrapped handler function, to offer distinction where that's useful.

AtomicMax atomically sets a to the maximum of *a and i, returning the old value at a.

NewChanMutex creates a new ChanMutex.

NewCondChannelPair creates a sender/receiver pair for a sync.Cond-like interface The differences from sync.Cond are that receiving is exposed through a channel (so it can be select-ed) and there is no equivalent to (*Cond).Broadcast().

PodCompleted returns true iff all of the Pod's containers have stopped and will not be restarted.

PodPreferredAZIfPresent returns the desired availability zone of the Pod, if it has one.

PodReady returns true iff the pod is marked as ready (as determined by the pod's Status.Conditions).

PodStartedBefore returns true iff Pod p started before Pod q.

RootError returns the root cause of the error, calling errors.Unwrap until it returns nil.

SaturatingSub returns x - y if x >= y, otherwise zero.

Starts the prometheus server in a background thread.

TryPodOwnerVirtualMachine returns the name of the VirtualMachine that owns the pod, if there is one that does.

TryPodOwnerVirtualMachineMigration returns the name of the VirtualMachineMigration that owns the pod, if there is one.

ChanMutex is a select-able mutex It is fair if and only if receiving on a channel is fair.

CondChannelReceiver is the receiving half of a sync.Cond-like interface.

CondChannelSender is the sending half of a sync.Cond-like interface.

NamespacedName represents a resource name with the namespace it's in.

RecentCounter is a struct that keeps track of recent timestamps within a given interval.

AtomicInt represents the shared interface provided by various atomic.<NAME> integers This interface type is primarily used by AtomicMax.