utils

package

Go to main page

Versions in this module

v1

v1.4.2

Jul 16, 2025

v1.4.1

Jul 6, 2025

v1.4.0

Jun 20, 2025

Changes in this version

+ const DEFAULT_RAYJOB_DEPLOYMENT_STATUS_TRANSITION_GRACE_PERIOD_SECONDS

+ const ENABLE_LOGIN_SHELL

+ const MaxRayClusterNameLength

+ const MaxRayJobNameLength

+ const MaxRayServiceNameLength

+ const RAYJOB_DEPLOYMENT_STATUS_TRANSITION_GRACE_PERIOD_SECONDS

+ const RAY_ENABLE_AUTOSCALER_V2

+ const USE_INGRESS_ON_OPENSHIFT

+ func GetClusterType() bool

+ func GetContainerCommand(additionalOptions []string) []string

+ func IsAutoscalingV2Enabled(spec *rayv1.RayClusterSpec) bool

+ func PodName(prefix string, nodeType rayv1.RayNodeType, isGenerateName bool) string

+ func SafeUint64ToInt64(n uint64) int64

+ func ValidateRayClusterMetadata(metadata metav1.ObjectMeta) error

+ func ValidateRayJobMetadata(metadata metav1.ObjectMeta) error

+ func ValidateRayServiceMetadata(metadata metav1.ObjectMeta) error

type K8sEventType

+ const InvalidRayClusterMetadata

+ const InvalidRayJobMetadata

+ const InvalidRayServiceMetadata

v1.4.0-rc.2

Jun 15, 2025

v1.4.0-rc.1

Jun 10, 2025

v1.4.0-rc.0

Jun 9, 2025

v1.3.2

Apr 3, 2025

v1.3.1

Mar 18, 2025

v1.3.0

Feb 18, 2025

Changes in this version

+ const DefaultGcsServerPort

+ const GcsServerPortName

+ const KubeRayController

+ const RAY_REDIS_ADDRESS

+ const REDIS_USERNAME

+ const ServeConfigLRUSize

+ func FindRayClusterSuspendStatus(instance *rayv1.RayCluster) rayv1.RayClusterConditionType

+ func GetRayClusterNameFromService(svc *corev1.Service) string

+ func IsAutoscalingEnabled[T *rayv1.RayCluster | *rayv1.RayJob | *rayv1.RayService](obj T) bool

+ func IsGCSFaultToleranceEnabled(instance rayv1.RayCluster) bool

+ func ManagedByExternalController(controllerName *string) *string

+ func TrimJobName(jobName string) string

+ func ValidateRayClusterSpec(instance *rayv1.RayCluster) error

+ func ValidateRayClusterStatus(instance *rayv1.RayCluster) error

+ func ValidateRayJobSpec(rayJob *rayv1.RayJob) error

+ func ValidateRayJobStatus(rayJob *rayv1.RayJob) error

+ func ValidateRayServiceSpec(rayService *rayv1.RayService) error

type FakeRayHttpProxyClient

+ IsHealthy bool

type K8sEventType

+ const FailedToDeletePodCollection

+ const FailedToDeleteWorkerPodCollection

+ const FailedToUpdateHeadPodServeLabel

+ const FailedToUpdateRayCluster

+ const FailedToUpdateServeApplications

+ const FailedToUpdateService

+ const InvalidRayClusterSpec

+ const InvalidRayClusterStatus

+ const InvalidRayJobSpec

+ const InvalidRayJobStatus

+ const InvalidRayServiceSpec

+ const UpdatedHeadPodServeLabel

+ const UpdatedRayCluster

+ const UpdatedServeApplications

+ const UpdatedService

v1.3.0-rc.1

Feb 10, 2025

v1.3.0-rc.0

Feb 4, 2025

v1.3.0-alpha.0

Jan 21, 2025

v1.2.2

Sep 29, 2024

Changes in this version

+ const DefaultHeadLivenessProbeTimeoutSeconds

+ const DefaultHeadReadinessProbeTimeoutSeconds

+ const RayClusterGangSchedulingEnabled

+ const RayJobSubmissionIdLabelKey

+ func CalculatePodResource(podSpec corev1.PodSpec) corev1.ResourceList

+ func ConvertResourceListToMapString(resourceList corev1.ResourceList) map[string]resource.Quantity

+ type K8sEventType string

+ const AutoscalerServiceAccountNotFound

+ const CreatedHeadPod

+ const CreatedIngress

+ const CreatedRayCluster

+ const CreatedRayJobSubmitter

+ const CreatedRedisCleanupJob

+ const CreatedRole

+ const CreatedRoleBinding

+ const CreatedRoute

+ const CreatedService

+ const CreatedServiceAccount

+ const CreatedWorkerPod

+ const DeletedHeadPod

+ const DeletedPod

+ const DeletedRayCluster

+ const DeletedRayJobSubmitter

+ const DeletedWorkerPod

+ const FailedToCreateHeadPod

+ const FailedToCreateIngress

+ const FailedToCreateRayCluster

+ const FailedToCreateRayJobSubmitter

+ const FailedToCreateRedisCleanupJob

+ const FailedToCreateRole

+ const FailedToCreateRoleBinding

+ const FailedToCreateRoute

+ const FailedToCreateService

+ const FailedToCreateServiceAccount

+ const FailedToCreateWorkerPod

+ const FailedToDeleteHeadPod

+ const FailedToDeletePod

+ const FailedToDeleteRayCluster

+ const FailedToDeleteRayJobSubmitter

+ const FailedToDeleteWorkerPod

v1.2.1

Aug 31, 2024

v1.2.0

Aug 29, 2024

Changes in this version

+ const DELETE_RAYJOB_CR_AFTER_JOB_FINISHES

+ const ENABLE_RAY_HEAD_CLUSTER_IP_SERVICE

+ const KubeRayVersion

+ var ErrFailedCreateHeadPod = &errRayClusterReplicaFailure

+ var ErrFailedCreateWorkerPod = &errRayClusterReplicaFailure

+ var ErrFailedDeleteAllPods = &errRayClusterReplicaFailure

+ var ErrFailedDeleteHeadPod = &errRayClusterReplicaFailure

+ var ErrFailedDeleteWorkerPod = &errRayClusterReplicaFailure

+ func CalculateReadyReplicas(pods corev1.PodList) int32

+ func FindHeadPodReadyCondition(headPod *corev1.Pod) metav1.Condition

+ func PodGenerateName(prefix string, nodeType rayv1.RayNodeType) string

+ func RayClusterReplicaFailureReason(err error) string

+ type ClientProvider interface

+ GetDashboardClient func(mgr manager.Manager) func() RayDashboardClientInterface

+ GetHttpProxyClient func(mgr manager.Manager) func() RayHttpProxyClientInterface

type FakeRayHttpProxyClient

+ func (r *FakeRayHttpProxyClient) CheckProxyActorHealth(_ context.Context) error

type RayHttpProxyClient

+ func (r *RayHttpProxyClient) CheckProxyActorHealth(ctx context.Context) error

type RayHttpProxyClientInterface

+ CheckProxyActorHealth func(ctx context.Context) error

v1.2.0-rc.1

Aug 27, 2024

v1.2.0-rc.0

Aug 14, 2024

v1.1.1

May 7, 2024

v1.1.0

Mar 22, 2024

Changes in this version

+ const ApplicationName

+ const BaseWgetHealthCommand

+ const ClientPortName

+ const ComponentName

+ const DashSymbol

+ const DashboardPortName

+ const DefaultClientPort

+ const DefaultDashboardAgentListenPort

+ const DefaultDashboardPort

+ const DefaultLivenessProbeFailureThreshold

+ const DefaultLivenessProbeInitialDelaySeconds

+ const DefaultLivenessProbePeriodSeconds

+ const DefaultLivenessProbeSuccessThreshold

+ const DefaultLivenessProbeTimeoutSeconds

+ const DefaultMetricsPort

+ const DefaultReadinessProbeFailureThreshold

+ const DefaultReadinessProbeInitialDelaySeconds

+ const DefaultReadinessProbePeriodSeconds

+ const DefaultReadinessProbeSuccessThreshold

+ const DefaultReadinessProbeTimeoutSeconds

+ const DefaultRedisPort

+ const DefaultServeAppName

+ const DefaultServiceAppProtocol

+ const DefaultServingPort

+ const DefaultWorkerRayGcsReconnectTimeoutS

+ const ENABLE_GCS_FT_REDIS_CLEANUP

+ const ENABLE_PROBES_INJECTION

+ const ENABLE_RANDOM_POD_DELETE

+ const EnableRayClusterServingServiceFalse

+ const EnableRayClusterServingServiceTrue

+ const EnableServeServiceKey

+ const EnableServeServiceTrue

+ const FQ_RAY_IP

+ const GCSFaultToleranceRedisCleanupFinalizer

+ const HashWithoutReplicasAndWorkersToDeleteKey

+ const HeadlessServiceSuffix

+ const KUBERAY_GEN_RAY_START_CMD

+ const KUBERAY_VERSION

+ const KubernetesApplicationNameLabelKey

+ const KubernetesCreatedByLabelKey

+ const LOCAL_HOST

+ const MetricsPortName

+ const NumWorkerGroupsKey

+ const RAYCLUSTER_DEFAULT_REQUEUE_SECONDS

+ const RAYCLUSTER_DEFAULT_REQUEUE_SECONDS_ENV

+ const RAY_ADDRESS

+ const RAY_CLOUD_INSTANCE_ID

+ const RAY_CLUSTER_NAME

+ const RAY_DASHBOARD_ADDRESS

+ const RAY_DASHBOARD_ENABLE_K8S_DISK_USAGE

+ const RAY_EXTERNAL_STORAGE_NS

+ const RAY_GCS_RPC_SERVER_RECONNECT_TIMEOUT_S

+ const RAY_GCS_SERVER_REQUEST_TIMEOUT_SECONDS

+ const RAY_IP

+ const RAY_JOB_SUBMISSION_ID

+ const RAY_NODE_TYPE_NAME

+ const RAY_PORT

+ const RAY_SERVE_KV_TIMEOUT_S

+ const RAY_TIMEOUT_MS_TASK_WAIT_FOR_DEATH_INFO

+ const RAY_USAGE_STATS_EXTRA_TAGS

+ const RAY_USAGE_STATS_KUBERAY_IN_USE

+ const REDIS_PASSWORD

+ const RayAgentRayletHealthPath

+ const RayClusterHeadlessServiceLabelKey

+ const RayClusterLabelKey

+ const RayClusterServingServiceLabelKey

+ const RayContainerIndex

+ const RayDashboardGCSHealthPath

+ const RayExternalStorageNSAnnotationKey

+ const RayFTEnabledAnnotationKey

+ const RayIDLabelKey

+ const RayJobStopJobFinalizer

+ const RayNodeGroupLabelKey

+ const RayNodeHeadGroupLabelValue

+ const RayNodeLabelKey

+ const RayNodeTypeLabelKey

+ const RayOriginatedFromCRDLabelKey

+ const RayOriginatedFromCRNameLabelKey

+ const RayOverwriteContainerCmdAnnotationKey

+ const RayPriorityClassName

+ const RaySchedulerName

+ const RayServeProxyHealthPath

+ const RedisPortName

+ const ServeReadinessProbeFailureThreshold

+ const ServingPortName

+ func CheckRouteName(ctx context.Context, s string, n string) string

+ func EnvVarByName(envName string, envVars []corev1.EnvVar) (corev1.EnvVar, bool)

+ func EnvVarExists(envName string, envVars []corev1.EnvVar) bool

+ func IsJobFinished(j *batchv1.Job) (batchv1.JobConditionType, bool)

+ func RayOriginatedFromCRDLabelValue(crdType CRDType) string

type CRDType

+ func GetCRDType(key string) CRDType

type FakeRayDashboardClient

+ func (r *FakeRayDashboardClient) DeleteJob(_ context.Context, jobName string) error

+ func (r *FakeRayDashboardClient) GetJobLog(_ context.Context, jobName string) (*string, error)

+ func (r *FakeRayDashboardClient) ListJobs(ctx context.Context) (*[]RayJobInfo, error)

+ func (r *FakeRayDashboardClient) SubmitJobReq(_ context.Context, request *RayJobRequest, name *string) (string, error)

type RayDashboardClient

+ func (r *RayDashboardClient) DeleteJob(ctx context.Context, jobName string) error

+ func (r *RayDashboardClient) GetJobLog(ctx context.Context, jobName string) (*string, error)

+ func (r *RayDashboardClient) ListJobs(ctx context.Context) (*[]RayJobInfo, error)

+ func (r *RayDashboardClient) SubmitJobReq(ctx context.Context, request *RayJobRequest, name *string) (jobId string, err error)

type RayDashboardClientInterface

+ DeleteJob func(ctx context.Context, jobName string) error

+ GetJobLog func(ctx context.Context, jobName string) (*string, error)

+ ListJobs func(ctx context.Context) (*[]RayJobInfo, error)

+ SubmitJobReq func(ctx context.Context, request *RayJobRequest, name *string) (string, error)

type RayJobInfo

+ JobId string

+ RuntimeEnv RuntimeEnvType

+ SubmissionId string

+ type RayJobLogsResponse struct

+ Logs string

type RayJobRequest

+ NumCpus float32

+ NumGpus float32

+ Resources map[string]float32

+ SubmissionId string

+ type RuntimeEnvType map[string]interface

+ func UnmarshalRuntimeEnvYAML(runtimeEnvYAML string) (RuntimeEnvType, error)

+ type ServiceType string

+ const HeadService

+ const ServingService

v1.1.0-rc.1

Mar 15, 2024

v1.1.0-rc.0

Mar 2, 2024

v1.1.0-alpha.0

Jan 27, 2024

v1.0.0

Nov 6, 2023

Changes in this version

+ func GenerateHeadServiceName(crdType CRDType, clusterSpec rayv1.RayClusterSpec, ownerName string) (string, error)

+ func GenerateRouteName(clusterName string) string

+ func GetWorkerGroupDesiredReplicas(workerGroupSpec rayv1.WorkerGroupSpec) int32

+ type CRDType string

+ const RayClusterCRD

+ const RayJobCRD

+ const RayServiceCRD

type FakeRayDashboardClient

+ GetJobInfoMock atomic.Pointer[func(context.Context, string) (*RayJobInfo, error)]

v1.0.0-rc.2

Nov 2, 2023

v1.0.0-rc.1

Oct 17, 2023

v1.0.0-rc.0

Sep 18, 2023

v0

v0.6.0

Jul 26, 2023

Changes in this version

+ var DeployPathV2 = "/api/serve/applications/"

+ var ServeDetailsPath = "/api/serve/applications/"

+ func CheckAllPodsRunning(runningPods corev1.PodList) bool

+ func FetchHeadServiceURL(ctx context.Context, log *logr.Logger, cli client.Client, ...) (string, error)

+ func FindContainerPort(container *corev1.Container, portName string, defaultPort int) int

+ type BaseDashboardClient struct

+ func (r *BaseDashboardClient) ConvertServeConfigV1(configV1Spec rayv1alpha1.ServeDeploymentGraphSpec) ServingClusterDeployments

type FakeRayDashboardClient

+ func (r *FakeRayDashboardClient) GetMultiApplicationStatus(_ context.Context) (map[string]*ServeApplicationStatus, error)

+ func (r *FakeRayDashboardClient) GetServeDetails(_ context.Context) (*ServeDetails, error)

+ func (r *FakeRayDashboardClient) GetSingleApplicationStatus(_ context.Context) (*ServeApplicationStatus, error)

+ func (r *FakeRayDashboardClient) SetMultiApplicationStatuses(statuses map[string]*ServeApplicationStatus)

+ func (r *FakeRayDashboardClient) SetSingleApplicationStatus(status ServeApplicationStatus)

type RayDashboardClient

+ func (r *RayDashboardClient) ConvertServeDetailsToApplicationStatuses(serveDetails *ServeDetails) (map[string]*ServeApplicationStatus, error)

+ func (r *RayDashboardClient) GetMultiApplicationStatus(ctx context.Context) (map[string]*ServeApplicationStatus, error)

+ func (r *RayDashboardClient) GetServeDetails(ctx context.Context) (*ServeDetails, error)

+ func (r *RayDashboardClient) GetSingleApplicationStatus(ctx context.Context) (*ServeApplicationStatus, error)

type RayDashboardClientInterface

+ ConvertServeConfigV1 func(rayv1alpha1.ServeDeploymentGraphSpec) ServingClusterDeployments

+ GetMultiApplicationStatus func(context.Context) (map[string]*ServeApplicationStatus, error)

+ GetServeDetails func(ctx context.Context) (*ServeDetails, error)

+ GetSingleApplicationStatus func(context.Context) (*ServeApplicationStatus, error)

+ type RayServeConfigType string

+ const MULTI_APP

+ const SINGLE_APP

+ type ServeAppStatusInfoV1 struct

+ Message string

+ Status string

+ type ServeApplicationDetails struct

+ Deployments map[string]ServeDeploymentDetails

+ DocsPath string

+ RoutePrefix string

+ type ServeApplicationStatus struct

+ Deployments map[string]ServeDeploymentStatus

+ Message string

+ Name string

+ Status string

+ type ServeDeploymentDetails struct

+ RoutePrefix string

+ type ServeDeploymentStatus struct

+ Message string

+ Name string

+ Status string

+ type ServeDetails struct

+ Applications map[string]ServeApplicationDetails

+ DeployMode string

+ type ServeSingleApplicationStatusV1 struct

+ ApplicationStatus ServeAppStatusInfoV1

+ DeploymentStatuses []ServeDeploymentStatus

type ServingClusterDeployments

+ Port int

v0.5.0

Apr 4, 2023

Changes in this version

+ const ClusterDomainEnvKey

+ const DashboardName

+ const DefaultDashboardAgentListenPortName

+ const DefaultDashboardName

+ const DefaultDomainName

+ const RayClusterSuffix

+ const ServeName

+ var DefaultHttpProxyPort = 8000

+ var DeployPath = "/api/serve/deployments/"

+ var GetRayDashboardClientFunc = GetRayDashboardClient

+ var GetRayHttpProxyClientFunc = GetRayHttpProxyClient

+ var HealthCheckPath = "/-/healthz"

+ var JobPath = "/api/jobs/"

+ var StatusPath = "/api/serve/deployments/status"

+ func Before(value string, a string) string

+ func CalculateAvailableReplicas(pods corev1.PodList) int32

+ func CalculateDesiredReplicas(cluster *rayiov1alpha1.RayCluster) int32

+ func CalculateDesiredResources(cluster *rayiov1alpha1.RayCluster) corev1.ResourceList

+ func CalculateMaxReplicas(cluster *rayiov1alpha1.RayCluster) int32

+ func CalculateMinReplicas(cluster *rayiov1alpha1.RayCluster) int32

+ func CalculateMinResources(cluster *rayiov1alpha1.RayCluster) corev1.ResourceList

+ func CheckAllPodsRunnning(runningPods corev1.PodList) bool

+ func CheckLabel(s string) string

+ func CheckName(s string) string

+ func CompareJsonStruct(objA interface{}, objB interface{}) bool

+ func Contains(elems []string, searchTerm string) bool

+ func ConvertUnixTimeToMetav1Time(unixTime int64) *metav1.Time

+ func ExtractRayIPFromFQDN(fqdnRayIP string) string

+ func FetchDashboardAgentURL(ctx context.Context, log *logr.Logger, cli client.Client, ...) (string, error)

+ func FetchDashboardURL(ctx context.Context, log *logr.Logger, cli client.Client, ...) (string, error)

+ func FilterContainerByName(containers []corev1.Container, name string) (corev1.Container, error)

+ func FindRayContainerIndex(spec corev1.PodSpec) (index int)

+ func FormatInt32(n int32) string

+ func GenerateDashboardAgentLabel(clusterName string) string

+ func GenerateDashboardServiceName(clusterName string) string

+ func GenerateFQDNServiceName(clusterName string, namespace string) string

+ func GenerateIdentifier(clusterName string, nodeType rayiov1alpha1.RayNodeType) string

+ func GenerateIngressName(clusterName string) string

+ func GenerateJsonHash(obj interface{}) (string, error)

+ func GenerateRayClusterName(serviceName string) string

+ func GenerateRayJobId(rayjob string) string

+ func GenerateServeServiceLabel(serviceName string) string

+ func GenerateServeServiceName(serviceName string) string

+ func GenerateServiceName(clusterName string) string

+ func GetClusterDomainName() string

+ func GetHeadGroupServiceAccountName(cluster *rayiov1alpha1.RayCluster) string

+ func GetNamespace(metaData metav1.ObjectMeta) string

+ func IsCreated(pod *corev1.Pod) bool

+ func IsRunningAndReady(pod *corev1.Pod) bool

+ func PodNotMatchingTemplate(pod corev1.Pod, template corev1.PodTemplateSpec) bool

+ type FakeRayDashboardClient struct

+ func (r *FakeRayDashboardClient) ConvertServeConfig(specs []rayv1alpha1.ServeConfigSpec) []ServeConfigSpec

+ func (r *FakeRayDashboardClient) GetDeployments() (string, error)

+ func (r *FakeRayDashboardClient) GetDeploymentsStatus() (*ServeDeploymentStatuses, error)

+ func (r *FakeRayDashboardClient) GetJobInfo(jobId string) (*RayJobInfo, error)

+ func (r *FakeRayDashboardClient) InitClient(url string)

+ func (r *FakeRayDashboardClient) SetServeStatus(status ServeDeploymentStatuses)

+ func (r *FakeRayDashboardClient) StopJob(jobName string, log *logr.Logger) (err error)

+ func (r *FakeRayDashboardClient) SubmitJob(rayJob *rayv1alpha1.RayJob, log *logr.Logger) (jobId string, err error)

+ func (r *FakeRayDashboardClient) UpdateDeployments(specs rayv1alpha1.ServeDeploymentGraphSpec) error

+ type FakeRayHttpProxyClient struct

+ func (r *FakeRayHttpProxyClient) CheckHealth() error

+ func (r *FakeRayHttpProxyClient) InitClient()

+ func (r *FakeRayHttpProxyClient) SetHostIp(hostIp string)

+ type RayActorOptionSpec struct

+ AcceleratorType string

+ Memory *int32

+ NumCpus *float64

+ NumGpus *float64

+ ObjectStoreMemory *int32

+ Resources map[string]interface{}

+ RuntimeEnv map[string]interface{}

+ type RayDashboardClient struct

+ func (r *RayDashboardClient) ConvertServeConfig(specs []rayv1alpha1.ServeConfigSpec) []ServeConfigSpec

+ func (r *RayDashboardClient) GetDeployments() (string, error)

+ func (r *RayDashboardClient) GetDeploymentsStatus() (*ServeDeploymentStatuses, error)

+ func (r *RayDashboardClient) GetJobInfo(jobId string) (*RayJobInfo, error)

+ func (r *RayDashboardClient) InitClient(url string)

+ func (r *RayDashboardClient) StopJob(jobName string, log *logr.Logger) (err error)

+ func (r *RayDashboardClient) SubmitJob(rayJob *rayv1alpha1.RayJob, log *logr.Logger) (jobId string, err error)

+ func (r *RayDashboardClient) UpdateDeployments(specs rayv1alpha1.ServeDeploymentGraphSpec) error

+ type RayDashboardClientInterface interface

+ ConvertServeConfig func(specs []rayv1alpha1.ServeConfigSpec) []ServeConfigSpec

+ GetDeployments func() (string, error)

+ GetDeploymentsStatus func() (*ServeDeploymentStatuses, error)

+ GetJobInfo func(jobId string) (*RayJobInfo, error)

+ InitClient func(url string)

+ StopJob func(jobName string, log *logr.Logger) (err error)

+ SubmitJob func(rayJob *rayv1alpha1.RayJob, log *logr.Logger) (jobId string, err error)

+ UpdateDeployments func(specs rayv1alpha1.ServeDeploymentGraphSpec) error

+ func GetRayDashboardClient() RayDashboardClientInterface

+ type RayHttpProxyClient struct

+ func (r *RayHttpProxyClient) CheckHealth() error

+ func (r *RayHttpProxyClient) InitClient()

+ func (r *RayHttpProxyClient) SetHostIp(hostIp string)

+ type RayHttpProxyClientInterface interface

+ CheckHealth func() error

+ InitClient func()

+ SetHostIp func(hostIp string)

+ func GetFakeRayHttpProxyClient() RayHttpProxyClientInterface

+ func GetRayHttpProxyClient() RayHttpProxyClientInterface

+ type RayJobInfo struct

+ EndTime int64

+ Entrypoint string

+ ErrorType *string

+ JobStatus rayv1alpha1.JobStatus

+ Message string

+ Metadata map[string]string

+ StartTime int64

+ type RayJobRequest struct

+ Entrypoint string

+ JobId string

+ Metadata map[string]string

+ RuntimeEnv map[string]interface{}

+ func ConvertRayJobToReq(rayJob *rayv1alpha1.RayJob) (*RayJobRequest, error)

+ type RayJobResponse struct

+ JobId string

+ type RayJobStopResponse struct

+ Stopped bool

+ type ServeConfigSpec struct

+ AutoscalingConfig map[string]interface{}

+ GracefulShutdownTimeoutS *int32

+ GracefulShutdownWaitLoopS *int32

+ HealthCheckPeriodS *int32

+ HealthCheckTimeoutS *int32

+ MaxConcurrentQueries *int32

+ Name string

+ NumReplicas *int32

+ RayActorOptions RayActorOptionSpec

+ RoutePrefix string

+ UserConfig map[string]interface{}

+ type ServeDeploymentStatuses struct

+ ApplicationStatus rayv1alpha1.AppStatus

+ DeploymentStatuses []rayv1alpha1.ServeDeploymentStatus

+ type ServingClusterDeployments struct

+ Deployments []ServeConfigSpec

+ ImportPath string

+ RuntimeEnv map[string]interface{}

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL