NewDemandCache creates a new cache.

NewResourceReservationCache creates a new cache.

NewSafeDemandCache returns a demand cache which fallbacks to no-op if demand CRD doesn't exist.

NewSoftReservationStore builds and returns a SoftReservationStore and instantiates the needed background informer event handlers to keep the store up to date.

ObjectSafeParams returns safe logging params for a name and a namespace.

AsyncClientMetrics emits metrics on retries and failures of the internal async client calls to the api server TODO: Move this to the metrics package after a refactor of that package to avoid cyclical imports.

DemandCache is a cache for demands.

ResourceReservationCache is a cache for resource reservations.

SafeDemandCache wraps a demand cache by checking if the demand CRD exists before each operation.

SoftReservation is an in-memory reservation for a particular spark application that keeps track of extra executors allocated over the min reservation count.

SoftReservationStore is an in-memory store that keeps track of soft reservations granted to extra executors for applications that support dynamic allocation.

Client is a generic representation of a kube client that acts on metav1.Object, asyncClient can be used for multiple k8s resources.