CompareSemanticVersion compares two semantic versions.

Helper functions to check and remove a string from a slice of strings.

DriverStateToApplicationState converts driver state to application state.

ExposeDriverMetrics returns if driver metrics should be exposed.

ExposeExecutorMetrics returns if executor metrics should be exposed.

GetApplicationState returns the state of the given SparkApplication.

GetAppName returns the spark application name by checking out pod labels.

GetContainerTerminatedState returns the terminated state of the container.

GetDriverContainerTerminatedState returns the terminated state of the driver container.

GetDriverPodName returns name of the driver pod of the given spark application.

GetDriverRequestResource returns the driver request resource list.

GetDriverState returns the driver state from the given driver pod.

GetExecutorContainerTerminatedState returns the terminated state of the executor container.

GetExecutorRequestResource returns the executor request resource list.

GetExecutorState returns the executor state from the given executor pod.

GetInitialExecutorNumber calculates the initial number of executor pods that will be requested by the driver on startup.

GetOwnerReference returns an OwnerReference pointing to the given app.

GetPrometheusConfigMapName returns the name of the ConfigMap for Prometheus configuration.

GetSparkApplicationID returns the spark application ID by checking out pod labels.

GetSparkExecutorID returns the Spark executor ID by checking out pod labels.

HasPrometheusConfig returns if Prometheus monitoring defines metricsProperties in the spec.

HasPrometheusConfigFile returns if Monitoring defines metricsPropertiesFile in the spec.

HasPrometheusConfigFile returns if Prometheus monitoring uses a configuration file in the container.

IsDriverPod returns whether the given pod is a Spark driver Pod.

IsDriverRunning returns whether the driver pod of the given SparkApplication is running.

IsDriverTerminated returns whether the driver state is a terminated state.

IsExecutorPod returns whether the given pod is a Spark executor Pod.

IsExecutorTerminated returns whether the executor state is a terminated state.

IsExpired returns whether the given SparkApplication is expired.

IsLaunchedBySparkOperator returns whether the given pod is launched by the Spark Operator.

IsTerminated returns whether the given SparkApplication is terminated.

This allow to create a new rate limiter while tuning the BucketRateLimiter parameters This also prevent a "bug" in the BucketRateLimiter due to the fact that a BucketRateLimiter does not have a maxDelay parameter.

PrometheusMonitoringEnabled returns if Prometheus monitoring is enabled or not.

RemoveString removes a given string from a slice, if present.

SumResourceList sums the resource list.

WriteObjectToFile marshals the given object into a YAML document and writes it to the given file.