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

BuildHeadlessService builds the headless service for workers in multi-host worker groups to communicate.

BuildHeadServiceForRayService Builds the service for a pod.

BuildIngressForHeadService Builds the ingress for head service dashboard.

BuildPod a pod config.

BuildRole creates a new Role for an RayCluster resource.

BuildRole.

BuildRouteForHeadService Builds the Route (OpenShift) for head service dashboard.

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

BuildServeServiceForRayCluster builds the serve service for Ray cluster.

BuildServeServiceForRayService builds the serve service for RayService.

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.

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.

GetRayClusterHeadPod gets a *corev1.Pod from a *rayv1.RayCluster.

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

Check if the RayCluster has GCS fault tolerance enabled.

RayJobK8sJobNamespacedName is the only place to associate the RayJob with the submitter Kubernetes Job.

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

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