server

package
v0.0.0-...-a7197c5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 4, 2025 License: Apache-2.0, BSD-2-Clause, MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ValidateClusterSpec 

func ValidateClusterSpec(clusterSpec *api.ClusterSpec) error

ValidateClusterSpec validates that the *api.ClusterSpec is not nil and has all the required fields

func ValidateCreateClusterRequest 

func ValidateCreateClusterRequest(request *api.CreateClusterRequest) error

func ValidateCreateComputeTemplateRequest 

func ValidateCreateComputeTemplateRequest(request *api.CreateComputeTemplateRequest) error

func ValidateCreateJobRequest 

func ValidateCreateJobRequest(request *api.CreateRayJobRequest) error

func ValidateCreateServiceRequest 

func ValidateCreateServiceRequest(request *api.CreateRayServiceRequest) error

func ValidateUpdateServiceRequest 

func ValidateUpdateServiceRequest(request *api.UpdateRayServiceRequest) error

Types

type ClusterServer 

type ClusterServer struct {
	api.UnimplementedClusterServiceServer
	// contains filtered or unexported fields
}

implements `type ClusterServiceServer interface` in cluster_grpc.pb.go ClusterServer is the server API for ClusterService service.

func NewClusterServer 

func NewClusterServer(resourceManager *manager.ResourceManager, options *ClusterServerOptions) *ClusterServer

func (*ClusterServer) CreateCluster 

func (s *ClusterServer) CreateCluster(ctx context.Context, request *api.CreateClusterRequest) (*api.Cluster, error)

Creates a new Cluster.

func (*ClusterServer) DeleteCluster 

func (s *ClusterServer) DeleteCluster(ctx context.Context, request *api.DeleteClusterRequest) (*emptypb.Empty, error)

Deletes an Cluster without deleting the Cluster's runs and jobs. To avoid unexpected behaviors, delete an Cluster's runs and jobs before deleting the Cluster.

func (*ClusterServer) GetCluster 

func (s *ClusterServer) GetCluster(ctx context.Context, request *api.GetClusterRequest) (*api.Cluster, error)

Finds a specific Cluster by cluster name.

func (*ClusterServer) ListAllClusters 

func (s *ClusterServer) ListAllClusters(ctx context.Context, request *api.ListAllClustersRequest) (*api.ListAllClustersResponse, error)

Finds all Clusters in all namespaces. TODO: Supports pagination and sorting on certain fields when we have DB support. request needs to be extended.

func (*ClusterServer) ListCluster 

func (s *ClusterServer) ListCluster(ctx context.Context, request *api.ListClustersRequest) (*api.ListClustersResponse, error)

Finds all Clusters in a given namespace. TODO: Supports pagination and sorting on certain fields when we have DB support. request needs to be extended.

type ClusterServerOptions 

type ClusterServerOptions struct {
	CollectMetrics bool
}

type ComputeTemplateServer 

type ComputeTemplateServer struct {
	api.UnimplementedComputeTemplateServiceServer
	// contains filtered or unexported fields
}

implements `type ComputeTemplateServiceServer interface` in runtime_grpc.pb.go ComputeTemplateServer is the server API for ClusterRuntimeService.

func NewComputeTemplateServer 

func NewComputeTemplateServer(resourceManager *manager.ResourceManager, options *ComputeTemplateServerOptions) *ComputeTemplateServer

func (*ComputeTemplateServer) CreateComputeTemplate 

func (s *ComputeTemplateServer) CreateComputeTemplate(ctx context.Context, request *api.CreateComputeTemplateRequest) (*api.ComputeTemplate, error)

func (*ComputeTemplateServer) DeleteComputeTemplate 

func (s *ComputeTemplateServer) DeleteComputeTemplate(ctx context.Context, request *api.DeleteComputeTemplateRequest) (*emptypb.Empty, error)

func (*ComputeTemplateServer) GetComputeTemplate 

func (s *ComputeTemplateServer) GetComputeTemplate(ctx context.Context, request *api.GetComputeTemplateRequest) (*api.ComputeTemplate, error)

func (*ComputeTemplateServer) ListAllComputeTemplates 

func (s *ComputeTemplateServer) ListAllComputeTemplates(ctx context.Context, request *api.ListAllComputeTemplatesRequest) (*api.ListAllComputeTemplatesResponse, error)

func (*ComputeTemplateServer) ListComputeTemplates 

func (s *ComputeTemplateServer) ListComputeTemplates(ctx context.Context, request *api.ListComputeTemplatesRequest) (*api.ListComputeTemplatesResponse, error)

type ComputeTemplateServerOptions 

type ComputeTemplateServerOptions struct {
	CollectMetrics bool
}

type JobServerOptions 

type JobServerOptions struct {
	CollectMetrics bool
}

type RayJobServer 

type RayJobServer struct {
	api.UnimplementedRayJobServiceServer
	// contains filtered or unexported fields
}

func NewRayJobServer 

func NewRayJobServer(resourceManager *manager.ResourceManager, options *JobServerOptions) *RayJobServer

func (*RayJobServer) CreateRayJob 

func (s *RayJobServer) CreateRayJob(ctx context.Context, request *api.CreateRayJobRequest) (*api.RayJob, error)

Creates a new Ray Job.

func (*RayJobServer) DeleteRayJob 

func (s *RayJobServer) DeleteRayJob(ctx context.Context, request *api.DeleteRayJobRequest) (*emptypb.Empty, error)

Deletes an Job

func (*RayJobServer) GetRayJob 

func (s *RayJobServer) GetRayJob(ctx context.Context, request *api.GetRayJobRequest) (*api.RayJob, error)

Finds a specific Job by job name.

func (*RayJobServer) ListAllRayJobs 

func (s *RayJobServer) ListAllRayJobs(ctx context.Context, request *api.ListAllRayJobsRequest) (*api.ListAllRayJobsResponse, error)

Finds all Jobs in all namespaces.

func (*RayJobServer) ListRayJobs 

func (s *RayJobServer) ListRayJobs(ctx context.Context, request *api.ListRayJobsRequest) (*api.ListRayJobsResponse, error)

Finds all Jobs in a given namespace.

type RayJobSubmissionServiceServer 

type RayJobSubmissionServiceServer struct {
	api.UnimplementedRayJobSubmissionServiceServer
	// contains filtered or unexported fields
}

implements `type ClusterServiceServer interface` in cluster_grpc.pb.go ClusterServer is the server API for ClusterService service.

func NewRayJobSubmissionServiceServer 

func NewRayJobSubmissionServiceServer(clusterServer *ClusterServer, options *RayJobSubmissionServiceServerOptions) *RayJobSubmissionServiceServer

Create RayJobSubmissionServiceServer

func (*RayJobSubmissionServiceServer) DeleteRayJob 

func (s *RayJobSubmissionServiceServer) DeleteRayJob(ctx context.Context, req *api.DeleteRayJobSubmissionRequest) (*emptypb.Empty, error)

Delete Job

func (*RayJobSubmissionServiceServer) GetJobDetails 

func (s *RayJobSubmissionServiceServer) GetJobDetails(ctx context.Context, req *api.GetJobDetailsRequest) (*api.JobSubmissionInfo, error)

Get job details

func (*RayJobSubmissionServiceServer) GetJobLog 

func (s *RayJobSubmissionServiceServer) GetJobLog(ctx context.Context, req *api.GetJobLogRequest) (*api.GetJobLogReply, error)

Get Job log

func (*RayJobSubmissionServiceServer) ListJobDetails 

func (s *RayJobSubmissionServiceServer) ListJobDetails(ctx context.Context, req *api.ListJobDetailsRequest) (*api.ListJobSubmissionInfo, error)

List jobs

func (*RayJobSubmissionServiceServer) StopRayJob 

func (s *RayJobSubmissionServiceServer) StopRayJob(ctx context.Context, req *api.StopRayJobSubmissionRequest) (*emptypb.Empty, error)

Stop job

func (*RayJobSubmissionServiceServer) SubmitRayJob 

func (s *RayJobSubmissionServiceServer) SubmitRayJob(ctx context.Context, req *api.SubmitRayJobRequest) (*api.SubmitRayJobReply, error)

Submit Ray job

type RayJobSubmissionServiceServerOptions 

type RayJobSubmissionServiceServerOptions struct {
	CollectMetrics bool
}

type RayServiceServer 

type RayServiceServer struct {
	api.UnimplementedRayServeServiceServer
	// contains filtered or unexported fields
}

implements `type RayServeServiceServer interface` in serve_grpc.pb.go RayServiceServer is the server API for RayServeService service.

func NewRayServiceServer 

func NewRayServiceServer(resourceManager *manager.ResourceManager, options *ServiceServerOptions) *RayServiceServer

func (*RayServiceServer) CreateRayService 

func (s *RayServiceServer) CreateRayService(ctx context.Context, request *api.CreateRayServiceRequest) (*api.RayService, error)

Create a new Ray Service

func (*RayServiceServer) DeleteRayService 

func (s *RayServiceServer) DeleteRayService(ctx context.Context, request *api.DeleteRayServiceRequest) (*emptypb.Empty, error)

func (*RayServiceServer) GetRayService 

func (s *RayServiceServer) GetRayService(ctx context.Context, request *api.GetRayServiceRequest) (*api.RayService, error)

func (*RayServiceServer) ListAllRayServices 

func (s *RayServiceServer) ListAllRayServices(ctx context.Context, request *api.ListAllRayServicesRequest) (*api.ListAllRayServicesResponse, error)

func (*RayServiceServer) ListRayServices 

func (s *RayServiceServer) ListRayServices(ctx context.Context, request *api.ListRayServicesRequest) (*api.ListRayServicesResponse, error)

func (*RayServiceServer) UpdateRayService 

func (s *RayServiceServer) UpdateRayService(ctx context.Context, request *api.UpdateRayServiceRequest) (*api.RayService, error)

type ServiceServerOptions 

type ServiceServerOptions struct {
	CollectMetrics bool
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.