BuildAutoscalerContainer builds a Ray autoscaler container which can be appended to the head pod.

BuildHeadServiceForRayService Builds the service for a pod.

BuildIngressForHeadService Builds the ingress for head service dashboard.

BuildIngressForRayService Builds the ingress for head service dashboard for RayService.

BuildPod a pod config.

BuildRole creates a new Role for an RayCluster resource.

BuildRole.

BuildServeServiceForRayService builds the service for head node and worker nodes who have healthy http proxy to serve traffics.

BuildServiceAccount creates a new ServiceAccount for a head pod with autoscaler.

BuildServiceForHeadPod Builds the service for a pod.

DefaultHeadPodTemplate sets the config values.

DefaultWorkerPodTemplate sets the config values.

TODO: We don't handle the delete events in new reconciler mode, how to emit deletion metrics?.

GetBaseRayJobCommand returns the first part of the Ray Job command up to and including the address, e.g.

GetDecodedRuntimeEnv decodes the runtime environment for the Ray job from a base64-encoded string.

getDefaultSubmitterTemplate creates a default submitter template for the Ray job.

Get the port required to connect to the Ray cluster by worker nodes and drivers started within the cluster.

GetK8sJobCommand builds the K8s job command for the Ray job.

GetMetadataJson returns the JSON string of the metadata for the Ray job.

HeadServiceLabels returns the default labels for a cluster's head service.

ValidateHeadRayStartParams will validate the head node's RayStartParams.

TODO (davidxia): should be a const in upstream ray-project/ray.

The default application name.

The default name for kuberay operator.

Use as separator for pod name, for example, raycluster-small-size-worker-0.

Use as default port.

Ray FT default liveness probe values.

Ray FT default readiness probe values.

Ray core default configurations.

For Ray >= 1.11.0, "DefaultRedisPort" actually refers to the GCS server port.

Default application name.

The default AppProtocol for Kubernetes service.

This KubeRay operator environment variable is used to determine if random Pod deletion should be enabled.

If set to true, kuberay auto injects an init container waiting for ray GCS.

Default autoscaler image when running Ray at versions older than 2.0.0.

Use as container env variable.

Check node if ready by checking the path exists or not.

Pod health state values.

Ray health check related configurations.

Ray GCS FT related annotations.

Finalizers for RayJob.

Batch scheduling labels TODO(tgaddair): consider making these part of the CRD.

The defaule RayService Identifier.

Belows used as label key.