DemandName returns a demand name from a pod name.

GetPodFromObjectOrTombstone tries to cast the passed object to a Pod object, and if that's not possible tries to get the Pod object from the tombstone.

IsPodTerminated returns whether the pod is considered to be terminated.

IsSparkSchedulerDemand returns whether the passed object is a demand created by the spark scheduler extender.

IsSparkSchedulerExecutorPod returns whether the passed object is a spark application pod which has this scheduler in the scheduler spec and is an executor.

IsSparkSchedulerPod returns whether the passed object is a spark application pod which has this scheduler in the scheduler spec.

ListWithPredicate gets nodes that matches predicate function.

NewStringSet constructs and returns a StringSet.

OnDemandFulfilled returns a function that calls the wrapped function if the demand object is fulfilled.

OnPodScheduled returns a function that calls the wrapped function if the pod is scheduled.

PodName returns a pod name from a demand name.

NodeConditionPredicate is a function that indicates whether the given node's conditions meet some set of criteria defined by the function.

StringSet is a non-thread safe set of unique strings.