http

Documentation

Index

• func IsNotFoundError(err error) bool
• type KuberayAPIServerClient
  • func NewKuberayAPIServerClient(baseURL string, httpClient *http.Client) *KuberayAPIServerClient
  • func (krc *KuberayAPIServerClient) CreateCluster(request *api.CreateClusterRequest) (*api.Cluster, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) CreateComputeTemplate(request *api.CreateComputeTemplateRequest) (*api.ComputeTemplate, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) CreateRayJob(request *api.CreateRayJobRequest) (*api.RayJob, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) CreateRayService(request *api.CreateRayServiceRequest) (*api.RayService, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) DeleteCluster(request *api.DeleteClusterRequest) (*rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) DeleteComputeTemplate(request *api.DeleteComputeTemplateRequest) (*rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) DeleteRayJob(request *api.DeleteRayJobRequest) (*rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) DeleteRayJobCluster(request *api.DeleteRayJobSubmissionRequest) (*rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) DeleteRayService(request *api.DeleteRayServiceRequest) (*rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) GetAllComputeTemplates() (*api.ListAllComputeTemplatesResponse, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) GetAllComputeTemplatesInNamespace(request *api.ListComputeTemplatesRequest) (*api.ListComputeTemplatesResponse, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) GetCluster(request *api.GetClusterRequest) (*api.Cluster, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) GetComputeTemplate(request *api.GetComputeTemplateRequest) (*api.ComputeTemplate, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) GetRayJob(request *api.GetRayJobRequest) (*api.RayJob, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) GetRayJobDetails(request *api.GetJobDetailsRequest) (*api.JobSubmissionInfo, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) GetRayJobLog(request *api.GetJobLogRequest) (*api.GetJobLogReply, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) GetRayService(request *api.GetRayServiceRequest) (*api.RayService, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) ListAllClusters() (*api.ListAllClustersResponse, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) ListAllRayJobs() (*api.ListAllRayJobsResponse, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) ListAllRayServices() (*api.ListAllRayServicesResponse, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) ListClusters(request *api.ListClustersRequest) (*api.ListClustersResponse, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) ListRayJobs(request *api.ListRayJobsRequest) (*api.ListRayJobsResponse, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) ListRayJobsCluster(request *api.ListJobDetailsRequest) (*api.ListJobSubmissionInfo, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) ListRayServices(request *api.ListRayServicesRequest) (*api.ListRayServicesResponse, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) StopRayJob(request *api.StopRayJobSubmissionRequest) (*rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) SubmitRayJob(request *api.SubmitRayJobRequest) (*api.SubmitRayJobReply, *rpcStatus.Status, error)
  • func (krc *KuberayAPIServerClient) UpdateRayService(request *api.UpdateRayServiceRequest) (*api.RayService, *rpcStatus.Status, error)
• type KuberayAPIServerClientError
  • func (krce *KuberayAPIServerClientError) Error() string

Functions

func IsNotFoundError

func IsNotFoundError(err error) bool

Types

type KuberayAPIServerClient

type KuberayAPIServerClient struct {
	// contains filtered or unexported fields
}

func NewKuberayAPIServerClient

func NewKuberayAPIServerClient(baseURL string, httpClient *http.Client) *KuberayAPIServerClient

func (*KuberayAPIServerClient) CreateCluster

func (krc *KuberayAPIServerClient) CreateCluster(request *api.CreateClusterRequest) (*api.Cluster, *rpcStatus.Status, error)

CreateCluster creates a new cluster.

func (*KuberayAPIServerClient) CreateComputeTemplate

func (krc *KuberayAPIServerClient) CreateComputeTemplate(request *api.CreateComputeTemplateRequest) (*api.ComputeTemplate, *rpcStatus.Status, error)

CreateComputeTemplate creates a new compute template.

func (*KuberayAPIServerClient) CreateRayJob

func (krc *KuberayAPIServerClient) CreateRayJob(request *api.CreateRayJobRequest) (*api.RayJob, *rpcStatus.Status, error)

CreateRayJob creates a new job.

func (*KuberayAPIServerClient) CreateRayService

func (krc *KuberayAPIServerClient) CreateRayService(request *api.CreateRayServiceRequest) (*api.RayService, *rpcStatus.Status, error)

CreateRayService create a new ray serve.

func (*KuberayAPIServerClient) DeleteCluster

func (krc *KuberayAPIServerClient) DeleteCluster(request *api.DeleteClusterRequest) (*rpcStatus.Status, error)

DeleteCluster deletes a cluster

func (*KuberayAPIServerClient) DeleteComputeTemplate

func (krc *KuberayAPIServerClient) DeleteComputeTemplate(request *api.DeleteComputeTemplateRequest) (*rpcStatus.Status, error)

DeleteComputeTemplate deletes a compute template.

func (*KuberayAPIServerClient) DeleteRayJob

func (krc *KuberayAPIServerClient) DeleteRayJob(request *api.DeleteRayJobRequest) (*rpcStatus.Status, error)

Deletes a job by its name and namespace.

func (*KuberayAPIServerClient) DeleteRayJobCluster

func (krc *KuberayAPIServerClient) DeleteRayJobCluster(request *api.DeleteRayJobSubmissionRequest) (*rpcStatus.Status, error)

DeleteRayService deletes a ray service by its name and namespace

func (*KuberayAPIServerClient) DeleteRayService

func (krc *KuberayAPIServerClient) DeleteRayService(request *api.DeleteRayServiceRequest) (*rpcStatus.Status, error)

DeleteRayService deletes a ray service by its name and namespace

func (*KuberayAPIServerClient) GetAllComputeTemplates

func (krc *KuberayAPIServerClient) GetAllComputeTemplates() (*api.ListAllComputeTemplatesResponse, *rpcStatus.Status, error)

GetAllComputeTemplates finds all compute templates in all namespaces.

func (*KuberayAPIServerClient) GetAllComputeTemplatesInNamespace

func (krc *KuberayAPIServerClient) GetAllComputeTemplatesInNamespace(request *api.ListComputeTemplatesRequest) (*api.ListComputeTemplatesResponse, *rpcStatus.Status, error)

GetAllComputeTemplatesInNamespace Finds all compute templates in a given namespace.

func (*KuberayAPIServerClient) GetCluster

func (krc *KuberayAPIServerClient) GetCluster(request *api.GetClusterRequest) (*api.Cluster, *rpcStatus.Status, error)

GetCluster finds a specific Cluster by ID.

func (*KuberayAPIServerClient) GetComputeTemplate

func (krc *KuberayAPIServerClient) GetComputeTemplate(request *api.GetComputeTemplateRequest) (*api.ComputeTemplate, *rpcStatus.Status, error)

Finds a specific compute template by its name and namespace.

func (*KuberayAPIServerClient) GetRayJob

func (krc *KuberayAPIServerClient) GetRayJob(request *api.GetRayJobRequest) (*api.RayJob, *rpcStatus.Status, error)

GetRayJob finds a specific job by its name and namespace.

func (*KuberayAPIServerClient) GetRayJobDetails

func (krc *KuberayAPIServerClient) GetRayJobDetails(request *api.GetJobDetailsRequest) (*api.JobSubmissionInfo, *rpcStatus.Status, error)

GetRayJobDetails. Get details about specific job on a given cluster.

func (*KuberayAPIServerClient) GetRayJobLog

func (krc *KuberayAPIServerClient) GetRayJobLog(request *api.GetJobLogRequest) (*api.GetJobLogReply, *rpcStatus.Status, error)

GetRayJobLog. Get log for a specific job on a given cluster.

func (*KuberayAPIServerClient) GetRayService

func (krc *KuberayAPIServerClient) GetRayService(request *api.GetRayServiceRequest) (*api.RayService, *rpcStatus.Status, error)

Find a specific ray serve by name and namespace.

func (*KuberayAPIServerClient) ListAllClusters

func (krc *KuberayAPIServerClient) ListAllClusters() (*api.ListAllClustersResponse, *rpcStatus.Status, error)

ListAllClusters finds all Clusters in all namespaces. Supports pagination, and sorting on certain fields.

func (*KuberayAPIServerClient) ListAllRayJobs

func (krc *KuberayAPIServerClient) ListAllRayJobs() (*api.ListAllRayJobsResponse, *rpcStatus.Status, error)

ListAllRayJobs Finds all job in all namespaces.

func (*KuberayAPIServerClient) ListAllRayServices

func (krc *KuberayAPIServerClient) ListAllRayServices() (*api.ListAllRayServicesResponse, *rpcStatus.Status, error)

Finds all ray services in a given namespace. Supports pagination, and sorting on certain fields.

func (*KuberayAPIServerClient) ListClusters

func (krc *KuberayAPIServerClient) ListClusters(request *api.ListClustersRequest) (*api.ListClustersResponse, *rpcStatus.Status, error)

ListCluster finds all clusters in a given namespace.

func (*KuberayAPIServerClient) ListRayJobs

func (krc *KuberayAPIServerClient) ListRayJobs(request *api.ListRayJobsRequest) (*api.ListRayJobsResponse, *rpcStatus.Status, error)

Finds all job in a given namespace.

func (*KuberayAPIServerClient) ListRayJobsCluster

func (krc *KuberayAPIServerClient) ListRayJobsCluster(request *api.ListJobDetailsRequest) (*api.ListJobSubmissionInfo, *rpcStatus.Status, error)

ListRayJobsCluster. List Ray jobs on a given cluster.

func (*KuberayAPIServerClient) ListRayServices

func (krc *KuberayAPIServerClient) ListRayServices(request *api.ListRayServicesRequest) (*api.ListRayServicesResponse, *rpcStatus.Status, error)

Finds all ray services in a given namespace. Supports pagination, and sorting on certain fields.

func (*KuberayAPIServerClient) StopRayJob

func (krc *KuberayAPIServerClient) StopRayJob(request *api.StopRayJobSubmissionRequest) (*rpcStatus.Status, error)

StopRayJob stops job on a given cluster.

func (*KuberayAPIServerClient) SubmitRayJob

func (krc *KuberayAPIServerClient) SubmitRayJob(request *api.SubmitRayJobRequest) (*api.SubmitRayJobReply, *rpcStatus.Status, error)

SubmitRayJob creates a new job on a given cluster.

func (*KuberayAPIServerClient) UpdateRayService

func (krc *KuberayAPIServerClient) UpdateRayService(request *api.UpdateRayServiceRequest) (*api.RayService, *rpcStatus.Status, error)

UpdateRayService updates a ray serve service.

type KuberayAPIServerClientError

type KuberayAPIServerClientError struct {
	HTTPStatusCode int
}

func (*KuberayAPIServerClientError) Error

func (krce *KuberayAPIServerClientError) Error() string