go_client

package
v0.0.0-...-41c9e91 Latest Latest
Warning

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

 Go to latest Published: Jun 17, 2024 License: Apache-2.0, BSD-2-Clause, MIT Imports: 20 Imported by: 9

Documentation

Overview

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	EnvValueFrom_Source_name = map[int32]string{
		0: "CONFIGMAP",
		1: "SECRET",
		2: "RESOURCEFIELD",
		3: "FIELD",
	}
	EnvValueFrom_Source_value = map[string]int32{
		"CONFIGMAP":     0,
		"SECRET":        1,
		"RESOURCEFIELD": 2,
		"FIELD":         3,
	}
)

Enum value maps for EnvValueFrom_Source.

View Source 
var (
	Cluster_Environment_name = map[int32]string{
		0: "DEV",
		1: "TESTING",
		2: "STAGING",
		3: "PRODUCTION",
	}
	Cluster_Environment_value = map[string]int32{
		"DEV":        0,
		"TESTING":    1,
		"STAGING":    2,
		"PRODUCTION": 3,
	}
)

Enum value maps for Cluster_Environment.

View Source 
var (
	Volume_VolumeType_name = map[int32]string{
		0: "PERSISTENT_VOLUME_CLAIM",
		1: "HOST_PATH",
		2: "EPHEMERAL",
		3: "CONFIGMAP",
		4: "SECRET",
		5: "EMPTY_DIR",
	}
	Volume_VolumeType_value = map[string]int32{
		"PERSISTENT_VOLUME_CLAIM": 0,
		"HOST_PATH":               1,
		"EPHEMERAL":               2,
		"CONFIGMAP":               3,
		"SECRET":                  4,
		"EMPTY_DIR":               5,
	}
)

Enum value maps for Volume_VolumeType.

View Source 
var (
	Volume_HostPathType_name = map[int32]string{
		0: "DIRECTORY",
		1: "FILE",
	}
	Volume_HostPathType_value = map[string]int32{
		"DIRECTORY": 0,
		"FILE":      1,
	}
)

Enum value maps for Volume_HostPathType.

View Source 
var (
	Volume_MountPropagationMode_name = map[int32]string{
		0: "NONE",
		1: "HOSTTOCONTAINER",
		2: "BIDIRECTIONAL",
	}
	Volume_MountPropagationMode_value = map[string]int32{
		"NONE":            0,
		"HOSTTOCONTAINER": 1,
		"BIDIRECTIONAL":   2,
	}
)

Enum value maps for Volume_MountPropagationMode.

View Source 
var (
	Volume_AccessMode_name = map[int32]string{
		0: "RWO",
		1: "ROX",
		2: "RWX",
	}
	Volume_AccessMode_value = map[string]int32{
		"RWO": 0,
		"ROX": 1,
		"RWX": 2,
	}
)

Enum value maps for Volume_AccessMode.

View Source 
var ClusterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.ClusterService",
	HandlerType: (*ClusterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateCluster",
			Handler:    _ClusterService_CreateCluster_Handler,
		},
		{
			MethodName: "GetCluster",
			Handler:    _ClusterService_GetCluster_Handler,
		},
		{
			MethodName: "ListCluster",
			Handler:    _ClusterService_ListCluster_Handler,
		},
		{
			MethodName: "ListAllClusters",
			Handler:    _ClusterService_ListAllClusters_Handler,
		},
		{
			MethodName: "DeleteCluster",
			Handler:    _ClusterService_DeleteCluster_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cluster.proto",
}

ClusterService_ServiceDesc is the grpc.ServiceDesc for ClusterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ComputeTemplateService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.ComputeTemplateService",
	HandlerType: (*ComputeTemplateServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateComputeTemplate",
			Handler:    _ComputeTemplateService_CreateComputeTemplate_Handler,
		},
		{
			MethodName: "GetComputeTemplate",
			Handler:    _ComputeTemplateService_GetComputeTemplate_Handler,
		},
		{
			MethodName: "ListComputeTemplates",
			Handler:    _ComputeTemplateService_ListComputeTemplates_Handler,
		},
		{
			MethodName: "ListAllComputeTemplates",
			Handler:    _ComputeTemplateService_ListAllComputeTemplates_Handler,
		},
		{
			MethodName: "DeleteComputeTemplate",
			Handler:    _ComputeTemplateService_DeleteComputeTemplate_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "config.proto",
}

ComputeTemplateService_ServiceDesc is the grpc.ServiceDesc for ComputeTemplateService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_cluster_proto protoreflect.FileDescriptor
View Source 
var File_config_proto protoreflect.FileDescriptor
View Source 
var File_error_proto protoreflect.FileDescriptor
View Source 
var File_job_proto protoreflect.FileDescriptor
View Source 
var File_job_submission_proto protoreflect.FileDescriptor
View Source 
var File_serve_proto protoreflect.FileDescriptor
View Source 
var ImageTemplateService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.ImageTemplateService",
	HandlerType: (*ImageTemplateServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateImageTemplate",
			Handler:    _ImageTemplateService_CreateImageTemplate_Handler,
		},
		{
			MethodName: "GetImageTemplate",
			Handler:    _ImageTemplateService_GetImageTemplate_Handler,
		},
		{
			MethodName: "ListImageTemplates",
			Handler:    _ImageTemplateService_ListImageTemplates_Handler,
		},
		{
			MethodName: "DeleteImageTemplate",
			Handler:    _ImageTemplateService_DeleteImageTemplate_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "config.proto",
}

ImageTemplateService_ServiceDesc is the grpc.ServiceDesc for ImageTemplateService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var RayJobService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.RayJobService",
	HandlerType: (*RayJobServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateRayJob",
			Handler:    _RayJobService_CreateRayJob_Handler,
		},
		{
			MethodName: "GetRayJob",
			Handler:    _RayJobService_GetRayJob_Handler,
		},
		{
			MethodName: "ListRayJobs",
			Handler:    _RayJobService_ListRayJobs_Handler,
		},
		{
			MethodName: "ListAllRayJobs",
			Handler:    _RayJobService_ListAllRayJobs_Handler,
		},
		{
			MethodName: "DeleteRayJob",
			Handler:    _RayJobService_DeleteRayJob_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "job.proto",
}

RayJobService_ServiceDesc is the grpc.ServiceDesc for RayJobService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var RayJobSubmissionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.RayJobSubmissionService",
	HandlerType: (*RayJobSubmissionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SubmitRayJob",
			Handler:    _RayJobSubmissionService_SubmitRayJob_Handler,
		},
		{
			MethodName: "GetJobDetails",
			Handler:    _RayJobSubmissionService_GetJobDetails_Handler,
		},
		{
			MethodName: "GetJobLog",
			Handler:    _RayJobSubmissionService_GetJobLog_Handler,
		},
		{
			MethodName: "ListJobDetails",
			Handler:    _RayJobSubmissionService_ListJobDetails_Handler,
		},
		{
			MethodName: "StopRayJob",
			Handler:    _RayJobSubmissionService_StopRayJob_Handler,
		},
		{
			MethodName: "DeleteRayJob",
			Handler:    _RayJobSubmissionService_DeleteRayJob_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "job_submission.proto",
}

RayJobSubmissionService_ServiceDesc is the grpc.ServiceDesc for RayJobSubmissionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var RayServeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.RayServeService",
	HandlerType: (*RayServeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateRayService",
			Handler:    _RayServeService_CreateRayService_Handler,
		},
		{
			MethodName: "UpdateRayService",
			Handler:    _RayServeService_UpdateRayService_Handler,
		},
		{
			MethodName: "GetRayService",
			Handler:    _RayServeService_GetRayService_Handler,
		},
		{
			MethodName: "ListRayServices",
			Handler:    _RayServeService_ListRayServices_Handler,
		},
		{
			MethodName: "ListAllRayServices",
			Handler:    _RayServeService_ListAllRayServices_Handler,
		},
		{
			MethodName: "DeleteRayService",
			Handler:    _RayServeService_DeleteRayService_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "serve.proto",
}

RayServeService_ServiceDesc is the grpc.ServiceDesc for RayServeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterClusterServiceHandler 

func RegisterClusterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterClusterServiceHandler registers the http handlers for service ClusterService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterClusterServiceHandlerClient 

func RegisterClusterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ClusterServiceClient) error

RegisterClusterServiceHandlerClient registers the http handlers for service ClusterService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ClusterServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ClusterServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ClusterServiceClient" to call the correct interceptors.

func RegisterClusterServiceHandlerFromEndpoint 

func RegisterClusterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterClusterServiceHandlerFromEndpoint is same as RegisterClusterServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterClusterServiceHandlerServer 

func RegisterClusterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ClusterServiceServer) error

RegisterClusterServiceHandlerServer registers the http handlers for service ClusterService to "mux". UnaryRPC :call ClusterServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterClusterServiceHandlerFromEndpoint instead.

func RegisterClusterServiceServer 

func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)

func RegisterComputeTemplateServiceHandler 

func RegisterComputeTemplateServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterComputeTemplateServiceHandler registers the http handlers for service ComputeTemplateService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterComputeTemplateServiceHandlerClient 

func RegisterComputeTemplateServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ComputeTemplateServiceClient) error

RegisterComputeTemplateServiceHandlerClient registers the http handlers for service ComputeTemplateService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ComputeTemplateServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ComputeTemplateServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ComputeTemplateServiceClient" to call the correct interceptors.

func RegisterComputeTemplateServiceHandlerFromEndpoint 

func RegisterComputeTemplateServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterComputeTemplateServiceHandlerFromEndpoint is same as RegisterComputeTemplateServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterComputeTemplateServiceHandlerServer 

func RegisterComputeTemplateServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ComputeTemplateServiceServer) error

RegisterComputeTemplateServiceHandlerServer registers the http handlers for service ComputeTemplateService to "mux". UnaryRPC :call ComputeTemplateServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterComputeTemplateServiceHandlerFromEndpoint instead.

func RegisterComputeTemplateServiceServer 

func RegisterComputeTemplateServiceServer(s grpc.ServiceRegistrar, srv ComputeTemplateServiceServer)

func RegisterImageTemplateServiceHandler 

func RegisterImageTemplateServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterImageTemplateServiceHandler registers the http handlers for service ImageTemplateService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterImageTemplateServiceHandlerClient 

func RegisterImageTemplateServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ImageTemplateServiceClient) error

RegisterImageTemplateServiceHandlerClient registers the http handlers for service ImageTemplateService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ImageTemplateServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ImageTemplateServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ImageTemplateServiceClient" to call the correct interceptors.

func RegisterImageTemplateServiceHandlerFromEndpoint 

func RegisterImageTemplateServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterImageTemplateServiceHandlerFromEndpoint is same as RegisterImageTemplateServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterImageTemplateServiceHandlerServer 

func RegisterImageTemplateServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ImageTemplateServiceServer) error

RegisterImageTemplateServiceHandlerServer registers the http handlers for service ImageTemplateService to "mux". UnaryRPC :call ImageTemplateServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterImageTemplateServiceHandlerFromEndpoint instead.

func RegisterImageTemplateServiceServer 

func RegisterImageTemplateServiceServer(s grpc.ServiceRegistrar, srv ImageTemplateServiceServer)

func RegisterRayJobServiceHandler 

func RegisterRayJobServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRayJobServiceHandler registers the http handlers for service RayJobService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRayJobServiceHandlerClient 

func RegisterRayJobServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RayJobServiceClient) error

RegisterRayJobServiceHandlerClient registers the http handlers for service RayJobService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RayJobServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RayJobServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RayJobServiceClient" to call the correct interceptors.

func RegisterRayJobServiceHandlerFromEndpoint 

func RegisterRayJobServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRayJobServiceHandlerFromEndpoint is same as RegisterRayJobServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRayJobServiceHandlerServer 

func RegisterRayJobServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RayJobServiceServer) error

RegisterRayJobServiceHandlerServer registers the http handlers for service RayJobService to "mux". UnaryRPC :call RayJobServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRayJobServiceHandlerFromEndpoint instead.

func RegisterRayJobServiceServer 

func RegisterRayJobServiceServer(s grpc.ServiceRegistrar, srv RayJobServiceServer)

func RegisterRayJobSubmissionServiceHandler 

func RegisterRayJobSubmissionServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRayJobSubmissionServiceHandler registers the http handlers for service RayJobSubmissionService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRayJobSubmissionServiceHandlerClient 

func RegisterRayJobSubmissionServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RayJobSubmissionServiceClient) error

RegisterRayJobSubmissionServiceHandlerClient registers the http handlers for service RayJobSubmissionService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RayJobSubmissionServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RayJobSubmissionServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RayJobSubmissionServiceClient" to call the correct interceptors.

func RegisterRayJobSubmissionServiceHandlerFromEndpoint 

func RegisterRayJobSubmissionServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRayJobSubmissionServiceHandlerFromEndpoint is same as RegisterRayJobSubmissionServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRayJobSubmissionServiceHandlerServer 

func RegisterRayJobSubmissionServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RayJobSubmissionServiceServer) error

RegisterRayJobSubmissionServiceHandlerServer registers the http handlers for service RayJobSubmissionService to "mux". UnaryRPC :call RayJobSubmissionServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRayJobSubmissionServiceHandlerFromEndpoint instead.

func RegisterRayJobSubmissionServiceServer 

func RegisterRayJobSubmissionServiceServer(s grpc.ServiceRegistrar, srv RayJobSubmissionServiceServer)

func RegisterRayServeServiceHandler 

func RegisterRayServeServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRayServeServiceHandler registers the http handlers for service RayServeService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRayServeServiceHandlerClient 

func RegisterRayServeServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RayServeServiceClient) error

RegisterRayServeServiceHandlerClient registers the http handlers for service RayServeService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RayServeServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RayServeServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RayServeServiceClient" to call the correct interceptors.

func RegisterRayServeServiceHandlerFromEndpoint 

func RegisterRayServeServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRayServeServiceHandlerFromEndpoint is same as RegisterRayServeServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRayServeServiceHandlerServer 

func RegisterRayServeServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RayServeServiceServer) error

RegisterRayServeServiceHandlerServer registers the http handlers for service RayServeService to "mux". UnaryRPC :call RayServeServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRayServeServiceHandlerFromEndpoint instead.

func RegisterRayServeServiceServer 

func RegisterRayServeServiceServer(s grpc.ServiceRegistrar, srv RayServeServiceServer)

Types

type AutoscalerOptions 

type AutoscalerOptions struct {

	// IdleTimeoutSeconds is the number of seconds to wait before scaling down a worker pod which is not using Ray resources.
	// Defaults to 60 (one minute).
	IdleTimeoutSeconds int32 `protobuf:"varint,1,opt,name=idleTimeoutSeconds,proto3" json:"idleTimeoutSeconds,omitempty"`
	// UpscalingMode is "Conservative", "Default", or "Aggressive."
	// Conservative: Upscaling is rate-limited; the number of pending worker pods is at most the size of the Ray cluster.
	// Default: Upscaling is not rate-limited.
	// Aggressive: An alias for Default; upscaling is not rate-limited.
	// It is not read by the KubeRay operator but by the Ray autoscaler.
	UpscalingMode string `protobuf:"bytes,2,opt,name=upscalingMode,proto3" json:"upscalingMode,omitempty"`
	// Image optionally overrides the autoscaler's container image. This override is for provided for autoscaler testing and development.
	Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// ImagePullPolicy optionally overrides the autoscaler container's image pull policy. This override is for provided for autoscaler testing and development.
	ImagePullPolicy string `protobuf:"bytes,4,opt,name=imagePullPolicy,proto3" json:"imagePullPolicy,omitempty"`
	// Optional CPUs requirements for autoscaler - default "500m"
	Cpu string `protobuf:"bytes,5,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// Optional memory requirements for autoscaler - default "512Mi"
	Memory string `protobuf:"bytes,6,opt,name=memory,proto3" json:"memory,omitempty"`
	// Optional list of environment variables to set in the autoscaler container.
	Envs *EnvironmentVariables `protobuf:"bytes,7,opt,name=envs,proto3" json:"envs,omitempty"`
	// Optional list of volumeMounts.  This is needed for enabling TLS for the autoscaler container.
	Volumes []*Volume `protobuf:"bytes,8,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// contains filtered or unexported fields
}

func (*AutoscalerOptions) Descriptor deprecated 

func (*AutoscalerOptions) Descriptor() ([]byte, []int)

Deprecated: Use AutoscalerOptions.ProtoReflect.Descriptor instead.

func (*AutoscalerOptions) GetCpu 

func (x *AutoscalerOptions) GetCpu() string

func (*AutoscalerOptions) GetEnvs 

func (x *AutoscalerOptions) GetEnvs() *EnvironmentVariables

func (*AutoscalerOptions) GetIdleTimeoutSeconds 

func (x *AutoscalerOptions) GetIdleTimeoutSeconds() int32

func (*AutoscalerOptions) GetImage 

func (x *AutoscalerOptions) GetImage() string

func (*AutoscalerOptions) GetImagePullPolicy 

func (x *AutoscalerOptions) GetImagePullPolicy() string

func (*AutoscalerOptions) GetMemory 

func (x *AutoscalerOptions) GetMemory() string

func (*AutoscalerOptions) GetUpscalingMode 

func (x *AutoscalerOptions) GetUpscalingMode() string

func (*AutoscalerOptions) GetVolumes 

func (x *AutoscalerOptions) GetVolumes() []*Volume

func (*AutoscalerOptions) ProtoMessage 

func (*AutoscalerOptions) ProtoMessage()

func (*AutoscalerOptions) ProtoReflect 

func (x *AutoscalerOptions) ProtoReflect() protoreflect.Message

func (*AutoscalerOptions) Reset 

func (x *AutoscalerOptions) Reset()

func (*AutoscalerOptions) String 

func (x *AutoscalerOptions) String() string

type Cluster 

type Cluster struct {

	// Required input field. Unique cluster name provided by user.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required input field. Cluster's namespace provided by user
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required field. This field indicates the user who owns the cluster.
	User string `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	// Optional input field. Ray cluster version
	Version     string              `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Environment Cluster_Environment `protobuf:"varint,5,opt,name=environment,proto3,enum=proto.Cluster_Environment" json:"environment,omitempty"`
	// Required field. This field indicates ray cluster configuration
	ClusterSpec *ClusterSpec `protobuf:"bytes,6,opt,name=cluster_spec,json=clusterSpec,proto3" json:"cluster_spec,omitempty"`
	// Optional. Annotations, for example, "kubernetes.io/ingress.class" to define Ingress class
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// Optional input field. Container environment variables from user.
	Envs *EnvironmentVariables `protobuf:"bytes,8,opt,name=envs,proto3" json:"envs,omitempty"`
	// Output. The time that the cluster created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Output. The time that the cluster deleted.
	DeletedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
	// Output. The status to show the cluster status.state
	ClusterState string `protobuf:"bytes,11,opt,name=cluster_state,json=clusterState,proto3" json:"cluster_state,omitempty"`
	// Output. The list related to the cluster.
	Events []*ClusterEvent `protobuf:"bytes,12,rep,name=events,proto3" json:"events,omitempty"`
	// Output. The service endpoint of the cluster
	ServiceEndpoint map[string]string `` /* 195-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Cluster) Descriptor deprecated 

func (*Cluster) Descriptor() ([]byte, []int)

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetAnnotations 

func (x *Cluster) GetAnnotations() map[string]string

func (*Cluster) GetClusterSpec 

func (x *Cluster) GetClusterSpec() *ClusterSpec

func (*Cluster) GetClusterState 

func (x *Cluster) GetClusterState() string

func (*Cluster) GetCreatedAt 

func (x *Cluster) GetCreatedAt() *timestamppb.Timestamp

func (*Cluster) GetDeletedAt 

func (x *Cluster) GetDeletedAt() *timestamppb.Timestamp

func (*Cluster) GetEnvironment 

func (x *Cluster) GetEnvironment() Cluster_Environment

func (*Cluster) GetEnvs 

func (x *Cluster) GetEnvs() *EnvironmentVariables

func (*Cluster) GetEvents 

func (x *Cluster) GetEvents() []*ClusterEvent

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetNamespace 

func (x *Cluster) GetNamespace() string

func (*Cluster) GetServiceEndpoint 

func (x *Cluster) GetServiceEndpoint() map[string]string

func (*Cluster) GetUser 

func (x *Cluster) GetUser() string

func (*Cluster) GetVersion 

func (x *Cluster) GetVersion() string

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

func (x *Cluster) ProtoReflect() protoreflect.Message

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

type ClusterEvent 

type ClusterEvent struct {

	// Unique Event Id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Human readable name for event.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Event creation time.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// The first time the event occur.
	FirstTimestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=first_timestamp,json=firstTimestamp,proto3" json:"first_timestamp,omitempty"`
	// The last time the event occur
	LastTimestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_timestamp,json=lastTimestamp,proto3" json:"last_timestamp,omitempty"`
	// The reason for the transition into the object's current status.
	Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	// A human-readable description of the status of this operation.
	Message string `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`
	// Type of this event (Normal, Warning), new types could be added in the future
	Type string `protobuf:"bytes,8,opt,name=type,proto3" json:"type,omitempty"`
	// The number of times this event has occurred.
	Count int32 `protobuf:"varint,9,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterEvent) Descriptor deprecated 

func (*ClusterEvent) Descriptor() ([]byte, []int)

Deprecated: Use ClusterEvent.ProtoReflect.Descriptor instead.

func (*ClusterEvent) GetCount 

func (x *ClusterEvent) GetCount() int32

func (*ClusterEvent) GetCreatedAt 

func (x *ClusterEvent) GetCreatedAt() *timestamppb.Timestamp

func (*ClusterEvent) GetFirstTimestamp 

func (x *ClusterEvent) GetFirstTimestamp() *timestamppb.Timestamp

func (*ClusterEvent) GetId 

func (x *ClusterEvent) GetId() string

func (*ClusterEvent) GetLastTimestamp 

func (x *ClusterEvent) GetLastTimestamp() *timestamppb.Timestamp

func (*ClusterEvent) GetMessage 

func (x *ClusterEvent) GetMessage() string

func (*ClusterEvent) GetName 

func (x *ClusterEvent) GetName() string

func (*ClusterEvent) GetReason 

func (x *ClusterEvent) GetReason() string

func (*ClusterEvent) GetType 

func (x *ClusterEvent) GetType() string

func (*ClusterEvent) ProtoMessage 

func (*ClusterEvent) ProtoMessage()

func (*ClusterEvent) ProtoReflect 

func (x *ClusterEvent) ProtoReflect() protoreflect.Message

func (*ClusterEvent) Reset 

func (x *ClusterEvent) Reset()

func (*ClusterEvent) String 

func (x *ClusterEvent) String() string

type ClusterServiceClient 

type ClusterServiceClient interface {
	// Creates a new Cluster.
	CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
	// Finds a specific Cluster by ID.
	GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
	// Finds all Clusters in a given namespace. Supports pagination, and sorting on certain fields.
	ListCluster(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	// Finds all Clusters in all namespaces. Supports pagination, and sorting on certain fields.
	ListAllClusters(ctx context.Context, in *ListAllClustersRequest, opts ...grpc.CallOption) (*ListAllClustersResponse, 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.
	DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ClusterServiceClient is the client API for ClusterService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewClusterServiceClient 

func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient

type ClusterServiceServer 

type ClusterServiceServer interface {
	// Creates a new Cluster.
	CreateCluster(context.Context, *CreateClusterRequest) (*Cluster, error)
	// Finds a specific Cluster by ID.
	GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)
	// Finds all Clusters in a given namespace. Supports pagination, and sorting on certain fields.
	ListCluster(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	// Finds all Clusters in all namespaces. Supports pagination, and sorting on certain fields.
	ListAllClusters(context.Context, *ListAllClustersRequest) (*ListAllClustersResponse, 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.
	DeleteCluster(context.Context, *DeleteClusterRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ClusterServiceServer is the server API for ClusterService service. All implementations must embed UnimplementedClusterServiceServer for forward compatibility

type ClusterSpec 

type ClusterSpec struct {

	// Required. The head group configuration
	HeadGroupSpec *HeadGroupSpec `protobuf:"bytes,1,opt,name=head_group_spec,json=headGroupSpec,proto3" json:"head_group_spec,omitempty"`
	// Optional. The worker group configurations
	WorkerGroupSpec []*WorkerGroupSpec `protobuf:"bytes,2,rep,name=worker_group_spec,json=workerGroupSpec,proto3" json:"worker_group_spec,omitempty"`
	// EnableInTreeAutoscaling indicates whether operator should create in tree autoscaling configs
	EnableInTreeAutoscaling bool `protobuf:"varint,3,opt,name=enableInTreeAutoscaling,proto3" json:"enableInTreeAutoscaling,omitempty"`
	// AutoscalerOptions specifies optional configuration for the Ray autoscaler.
	AutoscalerOptions *AutoscalerOptions `protobuf:"bytes,4,opt,name=autoscalerOptions,proto3" json:"autoscalerOptions,omitempty"`
	// contains filtered or unexported fields
}

Cluster specification.

func (*ClusterSpec) Descriptor deprecated 

func (*ClusterSpec) Descriptor() ([]byte, []int)

Deprecated: Use ClusterSpec.ProtoReflect.Descriptor instead.

func (*ClusterSpec) GetAutoscalerOptions 

func (x *ClusterSpec) GetAutoscalerOptions() *AutoscalerOptions

func (*ClusterSpec) GetEnableInTreeAutoscaling 

func (x *ClusterSpec) GetEnableInTreeAutoscaling() bool

func (*ClusterSpec) GetHeadGroupSpec 

func (x *ClusterSpec) GetHeadGroupSpec() *HeadGroupSpec

func (*ClusterSpec) GetWorkerGroupSpec 

func (x *ClusterSpec) GetWorkerGroupSpec() []*WorkerGroupSpec

func (*ClusterSpec) ProtoMessage 

func (*ClusterSpec) ProtoMessage()

func (*ClusterSpec) ProtoReflect 

func (x *ClusterSpec) ProtoReflect() protoreflect.Message

func (*ClusterSpec) Reset 

func (x *ClusterSpec) Reset()

func (*ClusterSpec) String 

func (x *ClusterSpec) String() string

type Cluster_Environment 

type Cluster_Environment int32

Optional field. 

const (
	Cluster_DEV        Cluster_Environment = 0
	Cluster_TESTING    Cluster_Environment = 1
	Cluster_STAGING    Cluster_Environment = 2
	Cluster_PRODUCTION Cluster_Environment = 3
)

func (Cluster_Environment) Descriptor 

func (Cluster_Environment) Descriptor() protoreflect.EnumDescriptor

func (Cluster_Environment) Enum 

func (x Cluster_Environment) Enum() *Cluster_Environment

func (Cluster_Environment) EnumDescriptor deprecated 

func (Cluster_Environment) EnumDescriptor() ([]byte, []int)

Deprecated: Use Cluster_Environment.Descriptor instead.

func (Cluster_Environment) Number 

func (x Cluster_Environment) Number() protoreflect.EnumNumber

func (Cluster_Environment) String 

func (x Cluster_Environment) String() string

func (Cluster_Environment) Type 

func (Cluster_Environment) Type() protoreflect.EnumType

type ComputeTemplate 

type ComputeTemplate struct {

	// Required. The name of the compute template
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The namespace of the compute template
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required. Number of cpus
	Cpu uint32 `protobuf:"varint,3,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// Required. Number of memory
	Memory uint32 `protobuf:"varint,4,opt,name=memory,proto3" json:"memory,omitempty"`
	// Optional. Number of gpus
	Gpu uint32 `protobuf:"varint,5,opt,name=gpu,proto3" json:"gpu,omitempty"`
	// Optional. The detail gpu accelerator type
	GpuAccelerator string `protobuf:"bytes,6,opt,name=gpu_accelerator,json=gpuAccelerator,proto3" json:"gpu_accelerator,omitempty"`
	// Optional pod tolerations
	Tolerations []*PodToleration `protobuf:"bytes,7,rep,name=tolerations,proto3" json:"tolerations,omitempty"`
	// contains filtered or unexported fields
}

ComputeTemplate can be reused by any compute units like worker group, workspace, image build job, etc

func (*ComputeTemplate) Descriptor deprecated 

func (*ComputeTemplate) Descriptor() ([]byte, []int)

Deprecated: Use ComputeTemplate.ProtoReflect.Descriptor instead.

func (*ComputeTemplate) GetCpu 

func (x *ComputeTemplate) GetCpu() uint32

func (*ComputeTemplate) GetGpu 

func (x *ComputeTemplate) GetGpu() uint32

func (*ComputeTemplate) GetGpuAccelerator 

func (x *ComputeTemplate) GetGpuAccelerator() string

func (*ComputeTemplate) GetMemory 

func (x *ComputeTemplate) GetMemory() uint32

func (*ComputeTemplate) GetName 

func (x *ComputeTemplate) GetName() string

func (*ComputeTemplate) GetNamespace 

func (x *ComputeTemplate) GetNamespace() string

func (*ComputeTemplate) GetTolerations 

func (x *ComputeTemplate) GetTolerations() []*PodToleration

func (*ComputeTemplate) ProtoMessage 

func (*ComputeTemplate) ProtoMessage()

func (*ComputeTemplate) ProtoReflect 

func (x *ComputeTemplate) ProtoReflect() protoreflect.Message

func (*ComputeTemplate) Reset 

func (x *ComputeTemplate) Reset()

func (*ComputeTemplate) String 

func (x *ComputeTemplate) String() string

type ComputeTemplateServiceClient 

type ComputeTemplateServiceClient interface {
	// Creates a new compute template.
	CreateComputeTemplate(ctx context.Context, in *CreateComputeTemplateRequest, opts ...grpc.CallOption) (*ComputeTemplate, error)
	// Finds a specific compute template by its name and namespace.
	GetComputeTemplate(ctx context.Context, in *GetComputeTemplateRequest, opts ...grpc.CallOption) (*ComputeTemplate, error)
	// Finds all compute templates in a given namespace. Supports pagination, and sorting on certain fields.
	ListComputeTemplates(ctx context.Context, in *ListComputeTemplatesRequest, opts ...grpc.CallOption) (*ListComputeTemplatesResponse, error)
	// Finds all compute templates in all namespaces. Supports pagination, and sorting on certain fields.
	ListAllComputeTemplates(ctx context.Context, in *ListAllComputeTemplatesRequest, opts ...grpc.CallOption) (*ListAllComputeTemplatesResponse, error)
	// Deletes a compute template by its name and namespace
	DeleteComputeTemplate(ctx context.Context, in *DeleteComputeTemplateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ComputeTemplateServiceClient is the client API for ComputeTemplateService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewComputeTemplateServiceClient 

func NewComputeTemplateServiceClient(cc grpc.ClientConnInterface) ComputeTemplateServiceClient

type ComputeTemplateServiceServer 

type ComputeTemplateServiceServer interface {
	// Creates a new compute template.
	CreateComputeTemplate(context.Context, *CreateComputeTemplateRequest) (*ComputeTemplate, error)
	// Finds a specific compute template by its name and namespace.
	GetComputeTemplate(context.Context, *GetComputeTemplateRequest) (*ComputeTemplate, error)
	// Finds all compute templates in a given namespace. Supports pagination, and sorting on certain fields.
	ListComputeTemplates(context.Context, *ListComputeTemplatesRequest) (*ListComputeTemplatesResponse, error)
	// Finds all compute templates in all namespaces. Supports pagination, and sorting on certain fields.
	ListAllComputeTemplates(context.Context, *ListAllComputeTemplatesRequest) (*ListAllComputeTemplatesResponse, error)
	// Deletes a compute template by its name and namespace
	DeleteComputeTemplate(context.Context, *DeleteComputeTemplateRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ComputeTemplateServiceServer is the server API for ComputeTemplateService service. All implementations must embed UnimplementedComputeTemplateServiceServer for forward compatibility

type CreateClusterRequest 

type CreateClusterRequest struct {

	// Required. The cluster to be created.
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Required. The namespace of the cluster to be created.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateClusterRequest) Descriptor deprecated 

func (*CreateClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateClusterRequest) GetCluster 

func (x *CreateClusterRequest) GetCluster() *Cluster

func (*CreateClusterRequest) GetNamespace 

func (x *CreateClusterRequest) GetNamespace() string

func (*CreateClusterRequest) ProtoMessage 

func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) ProtoReflect 

func (x *CreateClusterRequest) ProtoReflect() protoreflect.Message

func (*CreateClusterRequest) Reset 

func (x *CreateClusterRequest) Reset()

func (*CreateClusterRequest) String 

func (x *CreateClusterRequest) String() string

type CreateComputeTemplateRequest 

type CreateComputeTemplateRequest struct {

	// The compute template to be created.
	ComputeTemplate *ComputeTemplate `protobuf:"bytes,1,opt,name=compute_template,json=computeTemplate,proto3" json:"compute_template,omitempty"`
	// Required. The namespace of the compute template to be created
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateComputeTemplateRequest) Descriptor deprecated 

func (*CreateComputeTemplateRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateComputeTemplateRequest.ProtoReflect.Descriptor instead.

func (*CreateComputeTemplateRequest) GetComputeTemplate 

func (x *CreateComputeTemplateRequest) GetComputeTemplate() *ComputeTemplate

func (*CreateComputeTemplateRequest) GetNamespace 

func (x *CreateComputeTemplateRequest) GetNamespace() string

func (*CreateComputeTemplateRequest) ProtoMessage 

func (*CreateComputeTemplateRequest) ProtoMessage()

func (*CreateComputeTemplateRequest) ProtoReflect 

func (x *CreateComputeTemplateRequest) ProtoReflect() protoreflect.Message

func (*CreateComputeTemplateRequest) Reset 

func (x *CreateComputeTemplateRequest) Reset()

func (*CreateComputeTemplateRequest) String 

func (x *CreateComputeTemplateRequest) String() string

type CreateImageTemplateRequest 

type CreateImageTemplateRequest struct {

	// The image template to be created.
	ImageTemplate *ImageTemplate `protobuf:"bytes,1,opt,name=image_template,json=imageTemplate,proto3" json:"image_template,omitempty"`
	// The namespace of the image template to be created.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateImageTemplateRequest) Descriptor deprecated 

func (*CreateImageTemplateRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateImageTemplateRequest.ProtoReflect.Descriptor instead.

func (*CreateImageTemplateRequest) GetImageTemplate 

func (x *CreateImageTemplateRequest) GetImageTemplate() *ImageTemplate

func (*CreateImageTemplateRequest) GetNamespace 

func (x *CreateImageTemplateRequest) GetNamespace() string

func (*CreateImageTemplateRequest) ProtoMessage 

func (*CreateImageTemplateRequest) ProtoMessage()

func (*CreateImageTemplateRequest) ProtoReflect 

func (x *CreateImageTemplateRequest) ProtoReflect() protoreflect.Message

func (*CreateImageTemplateRequest) Reset 

func (x *CreateImageTemplateRequest) Reset()

func (*CreateImageTemplateRequest) String 

func (x *CreateImageTemplateRequest) String() string

type CreateRayJobRequest 

type CreateRayJobRequest struct {

	// Required. The job to be created.
	Job *RayJob `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// Required. The namespace of the job to be created
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRayJobRequest) Descriptor deprecated 

func (*CreateRayJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateRayJobRequest.ProtoReflect.Descriptor instead.

func (*CreateRayJobRequest) GetJob 

func (x *CreateRayJobRequest) GetJob() *RayJob

func (*CreateRayJobRequest) GetNamespace 

func (x *CreateRayJobRequest) GetNamespace() string

func (*CreateRayJobRequest) ProtoMessage 

func (*CreateRayJobRequest) ProtoMessage()

func (*CreateRayJobRequest) ProtoReflect 

func (x *CreateRayJobRequest) ProtoReflect() protoreflect.Message

func (*CreateRayJobRequest) Reset 

func (x *CreateRayJobRequest) Reset()

func (*CreateRayJobRequest) String 

func (x *CreateRayJobRequest) String() string

type CreateRayServiceRequest 

type CreateRayServiceRequest struct {

	// Required. The ray service to be created.
	Service *RayService `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// Required. The namespace of the ray service to be created.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRayServiceRequest) Descriptor deprecated 

func (*CreateRayServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateRayServiceRequest.ProtoReflect.Descriptor instead.

func (*CreateRayServiceRequest) GetNamespace 

func (x *CreateRayServiceRequest) GetNamespace() string

func (*CreateRayServiceRequest) GetService 

func (x *CreateRayServiceRequest) GetService() *RayService

func (*CreateRayServiceRequest) ProtoMessage 

func (*CreateRayServiceRequest) ProtoMessage()

func (*CreateRayServiceRequest) ProtoReflect 

func (x *CreateRayServiceRequest) ProtoReflect() protoreflect.Message

func (*CreateRayServiceRequest) Reset 

func (x *CreateRayServiceRequest) Reset()

func (*CreateRayServiceRequest) String 

func (x *CreateRayServiceRequest) String() string

type DeleteClusterRequest 

type DeleteClusterRequest struct {

	// The name of the cluster to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The namespace of the cluster to be deleted.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteClusterRequest) Descriptor deprecated 

func (*DeleteClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteClusterRequest) GetName 

func (x *DeleteClusterRequest) GetName() string

func (*DeleteClusterRequest) GetNamespace 

func (x *DeleteClusterRequest) GetNamespace() string

func (*DeleteClusterRequest) ProtoMessage 

func (*DeleteClusterRequest) ProtoMessage()

func (*DeleteClusterRequest) ProtoReflect 

func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message

func (*DeleteClusterRequest) Reset 

func (x *DeleteClusterRequest) Reset()

func (*DeleteClusterRequest) String 

func (x *DeleteClusterRequest) String() string

type DeleteComputeTemplateRequest 

type DeleteComputeTemplateRequest struct {

	// Required. The name of the compute template to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The namespace of the compute template to be deleted.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteComputeTemplateRequest) Descriptor deprecated 

func (*DeleteComputeTemplateRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteComputeTemplateRequest.ProtoReflect.Descriptor instead.

func (*DeleteComputeTemplateRequest) GetName 

func (x *DeleteComputeTemplateRequest) GetName() string

func (*DeleteComputeTemplateRequest) GetNamespace 

func (x *DeleteComputeTemplateRequest) GetNamespace() string

func (*DeleteComputeTemplateRequest) ProtoMessage 

func (*DeleteComputeTemplateRequest) ProtoMessage()

func (*DeleteComputeTemplateRequest) ProtoReflect 

func (x *DeleteComputeTemplateRequest) ProtoReflect() protoreflect.Message

func (*DeleteComputeTemplateRequest) Reset 

func (x *DeleteComputeTemplateRequest) Reset()

func (*DeleteComputeTemplateRequest) String 

func (x *DeleteComputeTemplateRequest) String() string

type DeleteImageTemplateRequest 

type DeleteImageTemplateRequest struct {

	// The name of the image template to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The namespace of the image template to be deleted.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteImageTemplateRequest) Descriptor deprecated 

func (*DeleteImageTemplateRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteImageTemplateRequest.ProtoReflect.Descriptor instead.

func (*DeleteImageTemplateRequest) GetName 

func (x *DeleteImageTemplateRequest) GetName() string

func (*DeleteImageTemplateRequest) GetNamespace 

func (x *DeleteImageTemplateRequest) GetNamespace() string

func (*DeleteImageTemplateRequest) ProtoMessage 

func (*DeleteImageTemplateRequest) ProtoMessage()

func (*DeleteImageTemplateRequest) ProtoReflect 

func (x *DeleteImageTemplateRequest) ProtoReflect() protoreflect.Message

func (*DeleteImageTemplateRequest) Reset 

func (x *DeleteImageTemplateRequest) Reset()

func (*DeleteImageTemplateRequest) String 

func (x *DeleteImageTemplateRequest) String() string

type DeleteRayJobRequest 

type DeleteRayJobRequest struct {

	// Required. The name of the job to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The namespace of the job to be deleted.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRayJobRequest) Descriptor deprecated 

func (*DeleteRayJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteRayJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteRayJobRequest) GetName 

func (x *DeleteRayJobRequest) GetName() string

func (*DeleteRayJobRequest) GetNamespace 

func (x *DeleteRayJobRequest) GetNamespace() string

func (*DeleteRayJobRequest) ProtoMessage 

func (*DeleteRayJobRequest) ProtoMessage()

func (*DeleteRayJobRequest) ProtoReflect 

func (x *DeleteRayJobRequest) ProtoReflect() protoreflect.Message

func (*DeleteRayJobRequest) Reset 

func (x *DeleteRayJobRequest) Reset()

func (*DeleteRayJobRequest) String 

func (x *DeleteRayJobRequest) String() string

type DeleteRayJobSubmissionRequest 

type DeleteRayJobSubmissionRequest struct {

	// Required. The namespace of the cluster for the job
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required. The name of the cluster for the job
	Clustername string `protobuf:"bytes,2,opt,name=clustername,proto3" json:"clustername,omitempty"`
	// Required. The submission id of the job
	Submissionid string `protobuf:"bytes,3,opt,name=submissionid,proto3" json:"submissionid,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRayJobSubmissionRequest) Descriptor deprecated 

func (*DeleteRayJobSubmissionRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteRayJobSubmissionRequest.ProtoReflect.Descriptor instead.

func (*DeleteRayJobSubmissionRequest) GetClustername 

func (x *DeleteRayJobSubmissionRequest) GetClustername() string

func (*DeleteRayJobSubmissionRequest) GetNamespace 

func (x *DeleteRayJobSubmissionRequest) GetNamespace() string

func (*DeleteRayJobSubmissionRequest) GetSubmissionid 

func (x *DeleteRayJobSubmissionRequest) GetSubmissionid() string

func (*DeleteRayJobSubmissionRequest) ProtoMessage 

func (*DeleteRayJobSubmissionRequest) ProtoMessage()

func (*DeleteRayJobSubmissionRequest) ProtoReflect 

func (x *DeleteRayJobSubmissionRequest) ProtoReflect() protoreflect.Message

func (*DeleteRayJobSubmissionRequest) Reset 

func (x *DeleteRayJobSubmissionRequest) Reset()

func (*DeleteRayJobSubmissionRequest) String 

func (x *DeleteRayJobSubmissionRequest) String() string

type DeleteRayServiceRequest 

type DeleteRayServiceRequest struct {

	// The name of the ray service to be deleted.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The namespace of the ray service to be deleted.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRayServiceRequest) Descriptor deprecated 

func (*DeleteRayServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteRayServiceRequest.ProtoReflect.Descriptor instead.

func (*DeleteRayServiceRequest) GetName 

func (x *DeleteRayServiceRequest) GetName() string

func (*DeleteRayServiceRequest) GetNamespace 

func (x *DeleteRayServiceRequest) GetNamespace() string

func (*DeleteRayServiceRequest) ProtoMessage 

func (*DeleteRayServiceRequest) ProtoMessage()

func (*DeleteRayServiceRequest) ProtoReflect 

func (x *DeleteRayServiceRequest) ProtoReflect() protoreflect.Message

func (*DeleteRayServiceRequest) Reset 

func (x *DeleteRayServiceRequest) Reset()

func (*DeleteRayServiceRequest) String 

func (x *DeleteRayServiceRequest) String() string

type EnvValueFrom 

type EnvValueFrom struct {
	Source EnvValueFrom_Source `protobuf:"varint,1,opt,name=source,proto3,enum=proto.EnvValueFrom_Source" json:"source,omitempty"`
	// Name for config map or secret, container name for resource, path for field
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Key for config map or secret, resource name for resource
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvValueFrom) Descriptor deprecated 

func (*EnvValueFrom) Descriptor() ([]byte, []int)

Deprecated: Use EnvValueFrom.ProtoReflect.Descriptor instead.

func (*EnvValueFrom) GetKey 

func (x *EnvValueFrom) GetKey() string

func (*EnvValueFrom) GetName 

func (x *EnvValueFrom) GetName() string

func (*EnvValueFrom) GetSource 

func (x *EnvValueFrom) GetSource() EnvValueFrom_Source

func (*EnvValueFrom) ProtoMessage 

func (*EnvValueFrom) ProtoMessage()

func (*EnvValueFrom) ProtoReflect 

func (x *EnvValueFrom) ProtoReflect() protoreflect.Message

func (*EnvValueFrom) Reset 

func (x *EnvValueFrom) Reset()

func (*EnvValueFrom) String 

func (x *EnvValueFrom) String() string

type EnvValueFrom_Source 

type EnvValueFrom_Source int32

Source of environment variable 

const (
	EnvValueFrom_CONFIGMAP     EnvValueFrom_Source = 0
	EnvValueFrom_SECRET        EnvValueFrom_Source = 1
	EnvValueFrom_RESOURCEFIELD EnvValueFrom_Source = 2
	EnvValueFrom_FIELD         EnvValueFrom_Source = 3
)

func (EnvValueFrom_Source) Descriptor 

func (EnvValueFrom_Source) Descriptor() protoreflect.EnumDescriptor

func (EnvValueFrom_Source) Enum 

func (x EnvValueFrom_Source) Enum() *EnvValueFrom_Source

func (EnvValueFrom_Source) EnumDescriptor deprecated 

func (EnvValueFrom_Source) EnumDescriptor() ([]byte, []int)

Deprecated: Use EnvValueFrom_Source.Descriptor instead.

func (EnvValueFrom_Source) Number 

func (x EnvValueFrom_Source) Number() protoreflect.EnumNumber

func (EnvValueFrom_Source) String 

func (x EnvValueFrom_Source) String() string

func (EnvValueFrom_Source) Type 

func (EnvValueFrom_Source) Type() protoreflect.EnumType

type EnvironmentVariables 

type EnvironmentVariables struct {
	Values     map[string]string        `` /* 153-byte string literal not displayed */
	ValuesFrom map[string]*EnvValueFrom `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

This allows to specify both - environment variables containing values and environment values containing valueFrom

func (*EnvironmentVariables) Descriptor deprecated 

func (*EnvironmentVariables) Descriptor() ([]byte, []int)

Deprecated: Use EnvironmentVariables.ProtoReflect.Descriptor instead.

func (*EnvironmentVariables) GetValues 

func (x *EnvironmentVariables) GetValues() map[string]string

func (*EnvironmentVariables) GetValuesFrom 

func (x *EnvironmentVariables) GetValuesFrom() map[string]*EnvValueFrom

func (*EnvironmentVariables) ProtoMessage 

func (*EnvironmentVariables) ProtoMessage()

func (*EnvironmentVariables) ProtoReflect 

func (x *EnvironmentVariables) ProtoReflect() protoreflect.Message

func (*EnvironmentVariables) Reset 

func (x *EnvironmentVariables) Reset()

func (*EnvironmentVariables) String 

func (x *EnvironmentVariables) String() string

type GetClusterRequest 

type GetClusterRequest struct {

	// Required. The name of the cluster to be retrieved.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The namespace of the cluster to be retrieved.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClusterRequest) Descriptor deprecated 

func (*GetClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.

func (*GetClusterRequest) GetName 

func (x *GetClusterRequest) GetName() string

func (*GetClusterRequest) GetNamespace 

func (x *GetClusterRequest) GetNamespace() string

func (*GetClusterRequest) ProtoMessage 

func (*GetClusterRequest) ProtoMessage()

func (*GetClusterRequest) ProtoReflect 

func (x *GetClusterRequest) ProtoReflect() protoreflect.Message

func (*GetClusterRequest) Reset 

func (x *GetClusterRequest) Reset()

func (*GetClusterRequest) String 

func (x *GetClusterRequest) String() string

type GetComputeTemplateRequest 

type GetComputeTemplateRequest struct {

	// Required. The name of the ComputeTemplate to be retrieved.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The namespace of the compute template to be retrieved.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetComputeTemplateRequest) Descriptor deprecated 

func (*GetComputeTemplateRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetComputeTemplateRequest.ProtoReflect.Descriptor instead.

func (*GetComputeTemplateRequest) GetName 

func (x *GetComputeTemplateRequest) GetName() string

func (*GetComputeTemplateRequest) GetNamespace 

func (x *GetComputeTemplateRequest) GetNamespace() string

func (*GetComputeTemplateRequest) ProtoMessage 

func (*GetComputeTemplateRequest) ProtoMessage()

func (*GetComputeTemplateRequest) ProtoReflect 

func (x *GetComputeTemplateRequest) ProtoReflect() protoreflect.Message

func (*GetComputeTemplateRequest) Reset 

func (x *GetComputeTemplateRequest) Reset()

func (*GetComputeTemplateRequest) String 

func (x *GetComputeTemplateRequest) String() string

type GetImageTemplateRequest 

type GetImageTemplateRequest struct {

	// The name of the image template to be retrieved.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The namespace of the image template to be retrieved.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetImageTemplateRequest) Descriptor deprecated 

func (*GetImageTemplateRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetImageTemplateRequest.ProtoReflect.Descriptor instead.

func (*GetImageTemplateRequest) GetName 

func (x *GetImageTemplateRequest) GetName() string

func (*GetImageTemplateRequest) GetNamespace 

func (x *GetImageTemplateRequest) GetNamespace() string

func (*GetImageTemplateRequest) ProtoMessage 

func (*GetImageTemplateRequest) ProtoMessage()

func (*GetImageTemplateRequest) ProtoReflect 

func (x *GetImageTemplateRequest) ProtoReflect() protoreflect.Message

func (*GetImageTemplateRequest) Reset 

func (x *GetImageTemplateRequest) Reset()

func (*GetImageTemplateRequest) String 

func (x *GetImageTemplateRequest) String() string

type GetJobDetailsRequest 

type GetJobDetailsRequest struct {

	// Required. The namespace of the cluster for the job
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required. The name of the cluster for the job
	Clustername string `protobuf:"bytes,2,opt,name=clustername,proto3" json:"clustername,omitempty"`
	// Required. The submission id of the job
	Submissionid string `protobuf:"bytes,3,opt,name=submissionid,proto3" json:"submissionid,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobDetailsRequest) Descriptor deprecated 

func (*GetJobDetailsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetJobDetailsRequest.ProtoReflect.Descriptor instead.

func (*GetJobDetailsRequest) GetClustername 

func (x *GetJobDetailsRequest) GetClustername() string

func (*GetJobDetailsRequest) GetNamespace 

func (x *GetJobDetailsRequest) GetNamespace() string

func (*GetJobDetailsRequest) GetSubmissionid 

func (x *GetJobDetailsRequest) GetSubmissionid() string

func (*GetJobDetailsRequest) ProtoMessage 

func (*GetJobDetailsRequest) ProtoMessage()

func (*GetJobDetailsRequest) ProtoReflect 

func (x *GetJobDetailsRequest) ProtoReflect() protoreflect.Message

func (*GetJobDetailsRequest) Reset 

func (x *GetJobDetailsRequest) Reset()

func (*GetJobDetailsRequest) String 

func (x *GetJobDetailsRequest) String() string

type GetJobLogReply 

type GetJobLogReply struct {

	// Content of the log. Always from the beginning
	Log string `protobuf:"bytes,1,opt,name=log,proto3" json:"log,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobLogReply) Descriptor deprecated 

func (*GetJobLogReply) Descriptor() ([]byte, []int)

Deprecated: Use GetJobLogReply.ProtoReflect.Descriptor instead.

func (*GetJobLogReply) GetLog 

func (x *GetJobLogReply) GetLog() string

func (*GetJobLogReply) ProtoMessage 

func (*GetJobLogReply) ProtoMessage()

func (*GetJobLogReply) ProtoReflect 

func (x *GetJobLogReply) ProtoReflect() protoreflect.Message

func (*GetJobLogReply) Reset 

func (x *GetJobLogReply) Reset()

func (*GetJobLogReply) String 

func (x *GetJobLogReply) String() string

type GetJobLogRequest 

type GetJobLogRequest struct {

	// Required. The namespace of the cluster for the job
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required. The name of the cluster for the job
	Clustername string `protobuf:"bytes,2,opt,name=clustername,proto3" json:"clustername,omitempty"`
	// Required. The submission id of the job
	Submissionid string `protobuf:"bytes,3,opt,name=submissionid,proto3" json:"submissionid,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobLogRequest) Descriptor deprecated 

func (*GetJobLogRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetJobLogRequest.ProtoReflect.Descriptor instead.

func (*GetJobLogRequest) GetClustername 

func (x *GetJobLogRequest) GetClustername() string

func (*GetJobLogRequest) GetNamespace 

func (x *GetJobLogRequest) GetNamespace() string

func (*GetJobLogRequest) GetSubmissionid 

func (x *GetJobLogRequest) GetSubmissionid() string

func (*GetJobLogRequest) ProtoMessage 

func (*GetJobLogRequest) ProtoMessage()

func (*GetJobLogRequest) ProtoReflect 

func (x *GetJobLogRequest) ProtoReflect() protoreflect.Message

func (*GetJobLogRequest) Reset 

func (x *GetJobLogRequest) Reset()

func (*GetJobLogRequest) String 

func (x *GetJobLogRequest) String() string

type GetRayJobRequest 

type GetRayJobRequest struct {

	// Required. The name of the job to be retrieved.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The namespace of the job to be retrieved.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRayJobRequest) Descriptor deprecated 

func (*GetRayJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRayJobRequest.ProtoReflect.Descriptor instead.

func (*GetRayJobRequest) GetName 

func (x *GetRayJobRequest) GetName() string

func (*GetRayJobRequest) GetNamespace 

func (x *GetRayJobRequest) GetNamespace() string

func (*GetRayJobRequest) ProtoMessage 

func (*GetRayJobRequest) ProtoMessage()

func (*GetRayJobRequest) ProtoReflect 

func (x *GetRayJobRequest) ProtoReflect() protoreflect.Message

func (*GetRayJobRequest) Reset 

func (x *GetRayJobRequest) Reset()

func (*GetRayJobRequest) String 

func (x *GetRayJobRequest) String() string

type GetRayServiceRequest 

type GetRayServiceRequest struct {

	// Required. The name used for retrieving the ray service.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The namespace used for retrieving the ray service.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRayServiceRequest) Descriptor deprecated 

func (*GetRayServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRayServiceRequest.ProtoReflect.Descriptor instead.

func (*GetRayServiceRequest) GetName 

func (x *GetRayServiceRequest) GetName() string

func (*GetRayServiceRequest) GetNamespace 

func (x *GetRayServiceRequest) GetNamespace() string

func (*GetRayServiceRequest) ProtoMessage 

func (*GetRayServiceRequest) ProtoMessage()

func (*GetRayServiceRequest) ProtoReflect 

func (x *GetRayServiceRequest) ProtoReflect() protoreflect.Message

func (*GetRayServiceRequest) Reset 

func (x *GetRayServiceRequest) Reset()

func (*GetRayServiceRequest) String 

func (x *GetRayServiceRequest) String() string

type HeadGroupSpec 

type HeadGroupSpec struct {

	// Required. The computeTemplate of head node group
	ComputeTemplate string `protobuf:"bytes,1,opt,name=compute_template,json=computeTemplate,proto3" json:"compute_template,omitempty"`
	// Optional field. This field will be used to retrieve right ray container
	Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	// Optional. The service type (ClusterIP, NodePort, Load balancer) of the head node
	ServiceType string `protobuf:"bytes,3,opt,name=service_type,json=serviceType,proto3" json:"service_type,omitempty"`
	// Optional. Enable Ingress
	// if Ingress is enabled, we might have to specify annotation IngressClassAnnotationKey, for the cluster itself, defining Ingress class
	EnableIngress bool `protobuf:"varint,4,opt,name=enableIngress,proto3" json:"enableIngress,omitempty"`
	// Required. The ray start params of head node group.
	RayStartParams map[string]string `` /* 193-byte string literal not displayed */
	// Optional. The volumes mount to head pod
	Volumes []*Volume `protobuf:"bytes,6,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// Optional. ServiceAccount used by head pod
	// Note that the service account has to be created prior to usage here
	ServiceAccount string `protobuf:"bytes,7,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// Optional. image pull secret used by head pod
	ImagePullSecret string `protobuf:"bytes,8,opt,name=image_pull_secret,json=imagePullSecret,proto3" json:"image_pull_secret,omitempty"`
	// Optional. Environment variables for head pod
	Environment *EnvironmentVariables `protobuf:"bytes,9,opt,name=environment,proto3" json:"environment,omitempty"`
	// Optional. Annotations for the head pod
	Annotations map[string]string `` /* 164-byte string literal not displayed */
	// Optional. Labels for the head pod
	Labels map[string]string `` /* 154-byte string literal not displayed */
	// Optional image pull policy We only support Always and ifNotPresent
	ImagePullPolicy string `protobuf:"bytes,12,opt,name=imagePullPolicy,proto3" json:"imagePullPolicy,omitempty"`
	// contains filtered or unexported fields
}

Cluster HeadGroup specification

func (*HeadGroupSpec) Descriptor deprecated 

func (*HeadGroupSpec) Descriptor() ([]byte, []int)

Deprecated: Use HeadGroupSpec.ProtoReflect.Descriptor instead.

func (*HeadGroupSpec) GetAnnotations 

func (x *HeadGroupSpec) GetAnnotations() map[string]string

func (*HeadGroupSpec) GetComputeTemplate 

func (x *HeadGroupSpec) GetComputeTemplate() string

func (*HeadGroupSpec) GetEnableIngress 

func (x *HeadGroupSpec) GetEnableIngress() bool

func (*HeadGroupSpec) GetEnvironment 

func (x *HeadGroupSpec) GetEnvironment() *EnvironmentVariables

func (*HeadGroupSpec) GetImage 

func (x *HeadGroupSpec) GetImage() string

func (*HeadGroupSpec) GetImagePullPolicy 

func (x *HeadGroupSpec) GetImagePullPolicy() string

func (*HeadGroupSpec) GetImagePullSecret 

func (x *HeadGroupSpec) GetImagePullSecret() string

func (*HeadGroupSpec) GetLabels 

func (x *HeadGroupSpec) GetLabels() map[string]string

func (*HeadGroupSpec) GetRayStartParams 

func (x *HeadGroupSpec) GetRayStartParams() map[string]string

func (*HeadGroupSpec) GetServiceAccount 

func (x *HeadGroupSpec) GetServiceAccount() string

func (*HeadGroupSpec) GetServiceType 

func (x *HeadGroupSpec) GetServiceType() string

func (*HeadGroupSpec) GetVolumes 

func (x *HeadGroupSpec) GetVolumes() []*Volume

func (*HeadGroupSpec) ProtoMessage 

func (*HeadGroupSpec) ProtoMessage()

func (*HeadGroupSpec) ProtoReflect 

func (x *HeadGroupSpec) ProtoReflect() protoreflect.Message

func (*HeadGroupSpec) Reset 

func (x *HeadGroupSpec) Reset()

func (*HeadGroupSpec) String 

func (x *HeadGroupSpec) String() string

type ImageTemplate 

type ImageTemplate struct {

	// The ID of the image template
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The namespace of the image template
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The base container image to be used for image building
	BaseImage string `protobuf:"bytes,3,opt,name=base_image,json=baseImage,proto3" json:"base_image,omitempty"`
	// The pip packages to install
	PipPackages []string `protobuf:"bytes,4,rep,name=pip_packages,json=pipPackages,proto3" json:"pip_packages,omitempty"`
	// The conda packages to install
	CondaPackages []string `protobuf:"bytes,5,rep,name=conda_packages,json=condaPackages,proto3" json:"conda_packages,omitempty"`
	// The system packages to install
	SystemPackages []string `protobuf:"bytes,6,rep,name=system_packages,json=systemPackages,proto3" json:"system_packages,omitempty"`
	// The environment variables to set
	EnvironmentVariables map[string]string `` /* 209-byte string literal not displayed */
	// The post install commands to execute
	CustomCommands string `protobuf:"bytes,8,opt,name=custom_commands,json=customCommands,proto3" json:"custom_commands,omitempty"`
	// Output. The result image generated
	Image string `protobuf:"bytes,9,opt,name=image,proto3" json:"image,omitempty"`
	// contains filtered or unexported fields
}

ImageTemplate can be used by worker group and workspce. They can be distinguish by different entrypoints

func (*ImageTemplate) Descriptor deprecated 

func (*ImageTemplate) Descriptor() ([]byte, []int)

Deprecated: Use ImageTemplate.ProtoReflect.Descriptor instead.

func (*ImageTemplate) GetBaseImage 

func (x *ImageTemplate) GetBaseImage() string

func (*ImageTemplate) GetCondaPackages 

func (x *ImageTemplate) GetCondaPackages() []string

func (*ImageTemplate) GetCustomCommands 

func (x *ImageTemplate) GetCustomCommands() string

func (*ImageTemplate) GetEnvironmentVariables 

func (x *ImageTemplate) GetEnvironmentVariables() map[string]string

func (*ImageTemplate) GetImage 

func (x *ImageTemplate) GetImage() string

func (*ImageTemplate) GetName 

func (x *ImageTemplate) GetName() string

func (*ImageTemplate) GetNamespace 

func (x *ImageTemplate) GetNamespace() string

func (*ImageTemplate) GetPipPackages 

func (x *ImageTemplate) GetPipPackages() []string

func (*ImageTemplate) GetSystemPackages 

func (x *ImageTemplate) GetSystemPackages() []string

func (*ImageTemplate) ProtoMessage 

func (*ImageTemplate) ProtoMessage()

func (*ImageTemplate) ProtoReflect 

func (x *ImageTemplate) ProtoReflect() protoreflect.Message

func (*ImageTemplate) Reset 

func (x *ImageTemplate) Reset()

func (*ImageTemplate) String 

func (x *ImageTemplate) String() string

type ImageTemplateServiceClient 

type ImageTemplateServiceClient interface {
	// Not implemented. Creates a new ImageTemplate.
	CreateImageTemplate(ctx context.Context, in *CreateImageTemplateRequest, opts ...grpc.CallOption) (*ImageTemplate, error)
	// Not implemented. Finds a specific ImageTemplate by ID.
	GetImageTemplate(ctx context.Context, in *GetImageTemplateRequest, opts ...grpc.CallOption) (*ImageTemplate, error)
	// Not Implemented. Finds all ImageTemplates. Supports pagination, and sorting on certain fields.
	ListImageTemplates(ctx context.Context, in *ListImageTemplatesRequest, opts ...grpc.CallOption) (*ListImageTemplatesResponse, error)
	// Not implemented. Deletes an ImageTemplate.
	DeleteImageTemplate(ctx context.Context, in *DeleteImageTemplateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ImageTemplateServiceClient is the client API for ImageTemplateService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewImageTemplateServiceClient 

func NewImageTemplateServiceClient(cc grpc.ClientConnInterface) ImageTemplateServiceClient

type ImageTemplateServiceServer 

type ImageTemplateServiceServer interface {
	// Not implemented. Creates a new ImageTemplate.
	CreateImageTemplate(context.Context, *CreateImageTemplateRequest) (*ImageTemplate, error)
	// Not implemented. Finds a specific ImageTemplate by ID.
	GetImageTemplate(context.Context, *GetImageTemplateRequest) (*ImageTemplate, error)
	// Not Implemented. Finds all ImageTemplates. Supports pagination, and sorting on certain fields.
	ListImageTemplates(context.Context, *ListImageTemplatesRequest) (*ListImageTemplatesResponse, error)
	// Not implemented. Deletes an ImageTemplate.
	DeleteImageTemplate(context.Context, *DeleteImageTemplateRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ImageTemplateServiceServer is the server API for ImageTemplateService service. All implementations must embed UnimplementedImageTemplateServiceServer for forward compatibility

type JobSubmissionInfo 

type JobSubmissionInfo struct {

	// Submission entry point
	Entrypoint string `protobuf:"bytes,1,opt,name=entrypoint,proto3" json:"entrypoint,omitempty"`
	// Job ID
	JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Submission ID
	SubmissionId string `protobuf:"bytes,3,opt,name=submission_id,json=submissionId,proto3" json:"submission_id,omitempty"`
	// Submission status
	Status string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// Associated message
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// Error type
	ErrorType string `protobuf:"bytes,6,opt,name=error_type,json=errorType,proto3" json:"error_type,omitempty"`
	// Job Start time
	StartTime uint64 `protobuf:"varint,7,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Job end time
	EndTime uint64 `protobuf:"varint,8,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Arbitrary user-provided metadata for the job.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The runtime environment for the job
	RuntimeEnv map[string]string `` /* 180-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*JobSubmissionInfo) Descriptor deprecated 

func (*JobSubmissionInfo) Descriptor() ([]byte, []int)

Deprecated: Use JobSubmissionInfo.ProtoReflect.Descriptor instead.

func (*JobSubmissionInfo) GetEndTime 

func (x *JobSubmissionInfo) GetEndTime() uint64

func (*JobSubmissionInfo) GetEntrypoint 

func (x *JobSubmissionInfo) GetEntrypoint() string

func (*JobSubmissionInfo) GetErrorType 

func (x *JobSubmissionInfo) GetErrorType() string

func (*JobSubmissionInfo) GetJobId 

func (x *JobSubmissionInfo) GetJobId() string

func (*JobSubmissionInfo) GetMessage 

func (x *JobSubmissionInfo) GetMessage() string

func (*JobSubmissionInfo) GetMetadata 

func (x *JobSubmissionInfo) GetMetadata() map[string]string

func (*JobSubmissionInfo) GetRuntimeEnv 

func (x *JobSubmissionInfo) GetRuntimeEnv() map[string]string

func (*JobSubmissionInfo) GetStartTime 

func (x *JobSubmissionInfo) GetStartTime() uint64

func (*JobSubmissionInfo) GetStatus 

func (x *JobSubmissionInfo) GetStatus() string

func (*JobSubmissionInfo) GetSubmissionId 

func (x *JobSubmissionInfo) GetSubmissionId() string

func (*JobSubmissionInfo) ProtoMessage 

func (*JobSubmissionInfo) ProtoMessage()

func (*JobSubmissionInfo) ProtoReflect 

func (x *JobSubmissionInfo) ProtoReflect() protoreflect.Message

func (*JobSubmissionInfo) Reset 

func (x *JobSubmissionInfo) Reset()

func (*JobSubmissionInfo) String 

func (x *JobSubmissionInfo) String() string

type ListAllClustersRequest 

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

func (*ListAllClustersRequest) Descriptor deprecated 

func (*ListAllClustersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAllClustersRequest.ProtoReflect.Descriptor instead.

func (*ListAllClustersRequest) ProtoMessage 

func (*ListAllClustersRequest) ProtoMessage()

func (*ListAllClustersRequest) ProtoReflect 

func (x *ListAllClustersRequest) ProtoReflect() protoreflect.Message

func (*ListAllClustersRequest) Reset 

func (x *ListAllClustersRequest) Reset()

func (*ListAllClustersRequest) String 

func (x *ListAllClustersRequest) String() string

type ListAllClustersResponse 

type ListAllClustersResponse struct {

	// A list of clusters returned.
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAllClustersResponse) Descriptor deprecated 

func (*ListAllClustersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAllClustersResponse.ProtoReflect.Descriptor instead.

func (*ListAllClustersResponse) GetClusters 

func (x *ListAllClustersResponse) GetClusters() []*Cluster

func (*ListAllClustersResponse) ProtoMessage 

func (*ListAllClustersResponse) ProtoMessage()

func (*ListAllClustersResponse) ProtoReflect 

func (x *ListAllClustersResponse) ProtoReflect() protoreflect.Message

func (*ListAllClustersResponse) Reset 

func (x *ListAllClustersResponse) Reset()

func (*ListAllClustersResponse) String 

func (x *ListAllClustersResponse) String() string

type ListAllComputeTemplatesRequest 

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

func (*ListAllComputeTemplatesRequest) Descriptor deprecated 

func (*ListAllComputeTemplatesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAllComputeTemplatesRequest.ProtoReflect.Descriptor instead.

func (*ListAllComputeTemplatesRequest) ProtoMessage 

func (*ListAllComputeTemplatesRequest) ProtoMessage()

func (*ListAllComputeTemplatesRequest) ProtoReflect 

func (x *ListAllComputeTemplatesRequest) ProtoReflect() protoreflect.Message

func (*ListAllComputeTemplatesRequest) Reset 

func (x *ListAllComputeTemplatesRequest) Reset()

func (*ListAllComputeTemplatesRequest) String 

func (x *ListAllComputeTemplatesRequest) String() string

type ListAllComputeTemplatesResponse 

type ListAllComputeTemplatesResponse struct {
	ComputeTemplates []*ComputeTemplate `protobuf:"bytes,1,rep,name=compute_templates,json=computeTemplates,proto3" json:"compute_templates,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAllComputeTemplatesResponse) Descriptor deprecated 

func (*ListAllComputeTemplatesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAllComputeTemplatesResponse.ProtoReflect.Descriptor instead.

func (*ListAllComputeTemplatesResponse) GetComputeTemplates 

func (x *ListAllComputeTemplatesResponse) GetComputeTemplates() []*ComputeTemplate

func (*ListAllComputeTemplatesResponse) ProtoMessage 

func (*ListAllComputeTemplatesResponse) ProtoMessage()

func (*ListAllComputeTemplatesResponse) ProtoReflect 

func (x *ListAllComputeTemplatesResponse) ProtoReflect() protoreflect.Message

func (*ListAllComputeTemplatesResponse) Reset 

func (x *ListAllComputeTemplatesResponse) Reset()

func (*ListAllComputeTemplatesResponse) String 

func (x *ListAllComputeTemplatesResponse) String() string

type ListAllImageTemplatesRequest 

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

func (*ListAllImageTemplatesRequest) Descriptor deprecated 

func (*ListAllImageTemplatesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAllImageTemplatesRequest.ProtoReflect.Descriptor instead.

func (*ListAllImageTemplatesRequest) ProtoMessage 

func (*ListAllImageTemplatesRequest) ProtoMessage()

func (*ListAllImageTemplatesRequest) ProtoReflect 

func (x *ListAllImageTemplatesRequest) ProtoReflect() protoreflect.Message

func (*ListAllImageTemplatesRequest) Reset 

func (x *ListAllImageTemplatesRequest) Reset()

func (*ListAllImageTemplatesRequest) String 

func (x *ListAllImageTemplatesRequest) String() string

type ListAllImageTemplatesResponse 

type ListAllImageTemplatesResponse struct {

	// A list of Compute returned.
	ImageTemplates []*ImageTemplate `protobuf:"bytes,1,rep,name=image_templates,json=imageTemplates,proto3" json:"image_templates,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAllImageTemplatesResponse) Descriptor deprecated 

func (*ListAllImageTemplatesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAllImageTemplatesResponse.ProtoReflect.Descriptor instead.

func (*ListAllImageTemplatesResponse) GetImageTemplates 

func (x *ListAllImageTemplatesResponse) GetImageTemplates() []*ImageTemplate

func (*ListAllImageTemplatesResponse) ProtoMessage 

func (*ListAllImageTemplatesResponse) ProtoMessage()

func (*ListAllImageTemplatesResponse) ProtoReflect 

func (x *ListAllImageTemplatesResponse) ProtoReflect() protoreflect.Message

func (*ListAllImageTemplatesResponse) Reset 

func (x *ListAllImageTemplatesResponse) Reset()

func (*ListAllImageTemplatesResponse) String 

func (x *ListAllImageTemplatesResponse) String() string

type ListAllRayJobsRequest 

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

func (*ListAllRayJobsRequest) Descriptor deprecated 

func (*ListAllRayJobsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAllRayJobsRequest.ProtoReflect.Descriptor instead.

func (*ListAllRayJobsRequest) ProtoMessage 

func (*ListAllRayJobsRequest) ProtoMessage()

func (*ListAllRayJobsRequest) ProtoReflect 

func (x *ListAllRayJobsRequest) ProtoReflect() protoreflect.Message

func (*ListAllRayJobsRequest) Reset 

func (x *ListAllRayJobsRequest) Reset()

func (*ListAllRayJobsRequest) String 

func (x *ListAllRayJobsRequest) String() string

type ListAllRayJobsResponse 

type ListAllRayJobsResponse struct {
	Jobs []*RayJob `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAllRayJobsResponse) Descriptor deprecated 

func (*ListAllRayJobsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAllRayJobsResponse.ProtoReflect.Descriptor instead.

func (*ListAllRayJobsResponse) GetJobs 

func (x *ListAllRayJobsResponse) GetJobs() []*RayJob

func (*ListAllRayJobsResponse) ProtoMessage 

func (*ListAllRayJobsResponse) ProtoMessage()

func (*ListAllRayJobsResponse) ProtoReflect 

func (x *ListAllRayJobsResponse) ProtoReflect() protoreflect.Message

func (*ListAllRayJobsResponse) Reset 

func (x *ListAllRayJobsResponse) Reset()

func (*ListAllRayJobsResponse) String 

func (x *ListAllRayJobsResponse) String() string

type ListAllRayServicesRequest 

type ListAllRayServicesRequest struct {

	// A page token to request the next page of results. The token is acquried
	// from the nextPageToken field of the response from the previous
	// ListRayServices call or can be omitted when fetching the first page.
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The number of RayServices to be listed per page. If there are more
	// RayServices than this number, the response message will contain a
	// nextPageToken field you can use to fetch the next page.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAllRayServicesRequest) Descriptor deprecated 

func (*ListAllRayServicesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAllRayServicesRequest.ProtoReflect.Descriptor instead.

func (*ListAllRayServicesRequest) GetPageSize 

func (x *ListAllRayServicesRequest) GetPageSize() int32

func (*ListAllRayServicesRequest) GetPageToken 

func (x *ListAllRayServicesRequest) GetPageToken() string

func (*ListAllRayServicesRequest) ProtoMessage 

func (*ListAllRayServicesRequest) ProtoMessage()

func (*ListAllRayServicesRequest) ProtoReflect 

func (x *ListAllRayServicesRequest) ProtoReflect() protoreflect.Message

func (*ListAllRayServicesRequest) Reset 

func (x *ListAllRayServicesRequest) Reset()

func (*ListAllRayServicesRequest) String 

func (x *ListAllRayServicesRequest) String() string

type ListAllRayServicesResponse 

type ListAllRayServicesResponse struct {

	// A list of services.
	Services []*RayService `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// The total number of RayServices for the given query.
	TotalSize int32 `protobuf:"varint,2,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// The token to list the next page of RayServices.
	NextPageToken string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAllRayServicesResponse) Descriptor deprecated 

func (*ListAllRayServicesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAllRayServicesResponse.ProtoReflect.Descriptor instead.

func (*ListAllRayServicesResponse) GetNextPageToken 

func (x *ListAllRayServicesResponse) GetNextPageToken() string

func (*ListAllRayServicesResponse) GetServices 

func (x *ListAllRayServicesResponse) GetServices() []*RayService

func (*ListAllRayServicesResponse) GetTotalSize 

func (x *ListAllRayServicesResponse) GetTotalSize() int32

func (*ListAllRayServicesResponse) ProtoMessage 

func (*ListAllRayServicesResponse) ProtoMessage()

func (*ListAllRayServicesResponse) ProtoReflect 

func (x *ListAllRayServicesResponse) ProtoReflect() protoreflect.Message

func (*ListAllRayServicesResponse) Reset 

func (x *ListAllRayServicesResponse) Reset()

func (*ListAllRayServicesResponse) String 

func (x *ListAllRayServicesResponse) String() string

type ListClustersRequest 

type ListClustersRequest struct {

	// Required. The namespace of the clusters to be retrieved.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClustersRequest) Descriptor deprecated 

func (*ListClustersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) GetNamespace 

func (x *ListClustersRequest) GetNamespace() string

func (*ListClustersRequest) ProtoMessage 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) ProtoReflect 

func (x *ListClustersRequest) ProtoReflect() protoreflect.Message

func (*ListClustersRequest) Reset 

func (x *ListClustersRequest) Reset()

func (*ListClustersRequest) String 

func (x *ListClustersRequest) String() string

type ListClustersResponse 

type ListClustersResponse struct {

	// A list of clusters returned.
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClustersResponse) Descriptor deprecated 

func (*ListClustersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.

func (*ListClustersResponse) GetClusters 

func (x *ListClustersResponse) GetClusters() []*Cluster

func (*ListClustersResponse) ProtoMessage 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) ProtoReflect 

func (x *ListClustersResponse) ProtoReflect() protoreflect.Message

func (*ListClustersResponse) Reset 

func (x *ListClustersResponse) Reset()

func (*ListClustersResponse) String 

func (x *ListClustersResponse) String() string

type ListComputeTemplatesRequest 

type ListComputeTemplatesRequest struct {

	// Required. The namespace of the compute templates to be retrieved.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` // TODO: support paganation later
	// contains filtered or unexported fields
}

func (*ListComputeTemplatesRequest) Descriptor deprecated 

func (*ListComputeTemplatesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListComputeTemplatesRequest.ProtoReflect.Descriptor instead.

func (*ListComputeTemplatesRequest) GetNamespace 

func (x *ListComputeTemplatesRequest) GetNamespace() string

func (*ListComputeTemplatesRequest) ProtoMessage 

func (*ListComputeTemplatesRequest) ProtoMessage()

func (*ListComputeTemplatesRequest) ProtoReflect 

func (x *ListComputeTemplatesRequest) ProtoReflect() protoreflect.Message

func (*ListComputeTemplatesRequest) Reset 

func (x *ListComputeTemplatesRequest) Reset()

func (*ListComputeTemplatesRequest) String 

func (x *ListComputeTemplatesRequest) String() string

type ListComputeTemplatesResponse 

type ListComputeTemplatesResponse struct {
	ComputeTemplates []*ComputeTemplate `protobuf:"bytes,1,rep,name=compute_templates,json=computeTemplates,proto3" json:"compute_templates,omitempty"`
	// contains filtered or unexported fields
}

func (*ListComputeTemplatesResponse) Descriptor deprecated 

func (*ListComputeTemplatesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListComputeTemplatesResponse.ProtoReflect.Descriptor instead.

func (*ListComputeTemplatesResponse) GetComputeTemplates 

func (x *ListComputeTemplatesResponse) GetComputeTemplates() []*ComputeTemplate

func (*ListComputeTemplatesResponse) ProtoMessage 

func (*ListComputeTemplatesResponse) ProtoMessage()

func (*ListComputeTemplatesResponse) ProtoReflect 

func (x *ListComputeTemplatesResponse) ProtoReflect() protoreflect.Message

func (*ListComputeTemplatesResponse) Reset 

func (x *ListComputeTemplatesResponse) Reset()

func (*ListComputeTemplatesResponse) String 

func (x *ListComputeTemplatesResponse) String() string

type ListImageTemplatesRequest 

type ListImageTemplatesRequest struct {

	// The namespace of the image templates to be retrieved.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` // TODO: support pagingation later
	// contains filtered or unexported fields
}

func (*ListImageTemplatesRequest) Descriptor deprecated 

func (*ListImageTemplatesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListImageTemplatesRequest.ProtoReflect.Descriptor instead.

func (*ListImageTemplatesRequest) GetNamespace 

func (x *ListImageTemplatesRequest) GetNamespace() string

func (*ListImageTemplatesRequest) ProtoMessage 

func (*ListImageTemplatesRequest) ProtoMessage()

func (*ListImageTemplatesRequest) ProtoReflect 

func (x *ListImageTemplatesRequest) ProtoReflect() protoreflect.Message

func (*ListImageTemplatesRequest) Reset 

func (x *ListImageTemplatesRequest) Reset()

func (*ListImageTemplatesRequest) String 

func (x *ListImageTemplatesRequest) String() string

type ListImageTemplatesResponse 

type ListImageTemplatesResponse struct {

	// A list of Compute returned.
	ImageTemplates []*ImageTemplate `protobuf:"bytes,1,rep,name=image_templates,json=imageTemplates,proto3" json:"image_templates,omitempty"`
	// contains filtered or unexported fields
}

func (*ListImageTemplatesResponse) Descriptor deprecated 

func (*ListImageTemplatesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListImageTemplatesResponse.ProtoReflect.Descriptor instead.

func (*ListImageTemplatesResponse) GetImageTemplates 

func (x *ListImageTemplatesResponse) GetImageTemplates() []*ImageTemplate

func (*ListImageTemplatesResponse) ProtoMessage 

func (*ListImageTemplatesResponse) ProtoMessage()

func (*ListImageTemplatesResponse) ProtoReflect 

func (x *ListImageTemplatesResponse) ProtoReflect() protoreflect.Message

func (*ListImageTemplatesResponse) Reset 

func (x *ListImageTemplatesResponse) Reset()

func (*ListImageTemplatesResponse) String 

func (x *ListImageTemplatesResponse) String() string

type ListJobDetailsRequest 

type ListJobDetailsRequest struct {

	// Required. The namespace of the cluster for the job
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required. The name of the cluster for the job
	Clustername string `protobuf:"bytes,2,opt,name=clustername,proto3" json:"clustername,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobDetailsRequest) Descriptor deprecated 

func (*ListJobDetailsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListJobDetailsRequest.ProtoReflect.Descriptor instead.

func (*ListJobDetailsRequest) GetClustername 

func (x *ListJobDetailsRequest) GetClustername() string

func (*ListJobDetailsRequest) GetNamespace 

func (x *ListJobDetailsRequest) GetNamespace() string

func (*ListJobDetailsRequest) ProtoMessage 

func (*ListJobDetailsRequest) ProtoMessage()

func (*ListJobDetailsRequest) ProtoReflect 

func (x *ListJobDetailsRequest) ProtoReflect() protoreflect.Message

func (*ListJobDetailsRequest) Reset 

func (x *ListJobDetailsRequest) Reset()

func (*ListJobDetailsRequest) String 

func (x *ListJobDetailsRequest) String() string

type ListJobSubmissionInfo 

type ListJobSubmissionInfo struct {
	Submissions []*JobSubmissionInfo `protobuf:"bytes,1,rep,name=submissions,proto3" json:"submissions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobSubmissionInfo) Descriptor deprecated 

func (*ListJobSubmissionInfo) Descriptor() ([]byte, []int)

Deprecated: Use ListJobSubmissionInfo.ProtoReflect.Descriptor instead.

func (*ListJobSubmissionInfo) GetSubmissions 

func (x *ListJobSubmissionInfo) GetSubmissions() []*JobSubmissionInfo

func (*ListJobSubmissionInfo) ProtoMessage 

func (*ListJobSubmissionInfo) ProtoMessage()

func (*ListJobSubmissionInfo) ProtoReflect 

func (x *ListJobSubmissionInfo) ProtoReflect() protoreflect.Message

func (*ListJobSubmissionInfo) Reset 

func (x *ListJobSubmissionInfo) Reset()

func (*ListJobSubmissionInfo) String 

func (x *ListJobSubmissionInfo) String() string

type ListRayJobsRequest 

type ListRayJobsRequest struct {

	// Required. The namespace of the job to be retrieved.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` // TODO: support paganation later
	// contains filtered or unexported fields
}

func (*ListRayJobsRequest) Descriptor deprecated 

func (*ListRayJobsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListRayJobsRequest.ProtoReflect.Descriptor instead.

func (*ListRayJobsRequest) GetNamespace 

func (x *ListRayJobsRequest) GetNamespace() string

func (*ListRayJobsRequest) ProtoMessage 

func (*ListRayJobsRequest) ProtoMessage()

func (*ListRayJobsRequest) ProtoReflect 

func (x *ListRayJobsRequest) ProtoReflect() protoreflect.Message

func (*ListRayJobsRequest) Reset 

func (x *ListRayJobsRequest) Reset()

func (*ListRayJobsRequest) String 

func (x *ListRayJobsRequest) String() string

type ListRayJobsResponse 

type ListRayJobsResponse struct {
	Jobs []*RayJob `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRayJobsResponse) Descriptor deprecated 

func (*ListRayJobsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListRayJobsResponse.ProtoReflect.Descriptor instead.

func (*ListRayJobsResponse) GetJobs 

func (x *ListRayJobsResponse) GetJobs() []*RayJob

func (*ListRayJobsResponse) ProtoMessage 

func (*ListRayJobsResponse) ProtoMessage()

func (*ListRayJobsResponse) ProtoReflect 

func (x *ListRayJobsResponse) ProtoReflect() protoreflect.Message

func (*ListRayJobsResponse) Reset 

func (x *ListRayJobsResponse) Reset()

func (*ListRayJobsResponse) String 

func (x *ListRayJobsResponse) String() string

type ListRayServicesRequest 

type ListRayServicesRequest struct {

	// Required. The namespace of the ray services to be retrieved.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// A page token to request the next page of results. The token is acquried
	// from the nextPageToken field of the response from the previous
	// ListRayServices call or can be omitted when fetching the first page.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The number of RayServices to be listed per page. If there are more
	// RayServices than this number, the response message will contain a
	// nextPageToken field you can use to fetch the next page.
	PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRayServicesRequest) Descriptor deprecated 

func (*ListRayServicesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListRayServicesRequest.ProtoReflect.Descriptor instead.

func (*ListRayServicesRequest) GetNamespace 

func (x *ListRayServicesRequest) GetNamespace() string

func (*ListRayServicesRequest) GetPageSize 

func (x *ListRayServicesRequest) GetPageSize() int32

func (*ListRayServicesRequest) GetPageToken 

func (x *ListRayServicesRequest) GetPageToken() string

func (*ListRayServicesRequest) ProtoMessage 

func (*ListRayServicesRequest) ProtoMessage()

func (*ListRayServicesRequest) ProtoReflect 

func (x *ListRayServicesRequest) ProtoReflect() protoreflect.Message

func (*ListRayServicesRequest) Reset 

func (x *ListRayServicesRequest) Reset()

func (*ListRayServicesRequest) String 

func (x *ListRayServicesRequest) String() string

type ListRayServicesResponse 

type ListRayServicesResponse struct {

	// List of services
	Services []*RayService `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// The total number of RayServices for the given query.
	TotalSize int32 `protobuf:"varint,2,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// The token to list the next page of RayServices.
	NextPageToken string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRayServicesResponse) Descriptor deprecated 

func (*ListRayServicesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListRayServicesResponse.ProtoReflect.Descriptor instead.

func (*ListRayServicesResponse) GetNextPageToken 

func (x *ListRayServicesResponse) GetNextPageToken() string

func (*ListRayServicesResponse) GetServices 

func (x *ListRayServicesResponse) GetServices() []*RayService

func (*ListRayServicesResponse) GetTotalSize 

func (x *ListRayServicesResponse) GetTotalSize() int32

func (*ListRayServicesResponse) ProtoMessage 

func (*ListRayServicesResponse) ProtoMessage()

func (*ListRayServicesResponse) ProtoReflect 

func (x *ListRayServicesResponse) ProtoReflect() protoreflect.Message

func (*ListRayServicesResponse) Reset 

func (x *ListRayServicesResponse) Reset()

func (*ListRayServicesResponse) String 

func (x *ListRayServicesResponse) String() string

type PodToleration 

type PodToleration struct {

	// Required. Key created by the node's taint
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Required. Operator to apply
	Operator string `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	// optional string
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// Required. Effect
	Effect string `protobuf:"bytes,4,opt,name=effect,proto3" json:"effect,omitempty"`
	// contains filtered or unexported fields
}

Toleration for the compute template

func (*PodToleration) Descriptor deprecated 

func (*PodToleration) Descriptor() ([]byte, []int)

Deprecated: Use PodToleration.ProtoReflect.Descriptor instead.

func (*PodToleration) GetEffect 

func (x *PodToleration) GetEffect() string

func (*PodToleration) GetKey 

func (x *PodToleration) GetKey() string

func (*PodToleration) GetOperator 

func (x *PodToleration) GetOperator() string

func (*PodToleration) GetValue 

func (x *PodToleration) GetValue() string

func (*PodToleration) ProtoMessage 

func (*PodToleration) ProtoMessage()

func (*PodToleration) ProtoReflect 

func (x *PodToleration) ProtoReflect() protoreflect.Message

func (*PodToleration) Reset 

func (x *PodToleration) Reset()

func (*PodToleration) String 

func (x *PodToleration) String() string

type RayJob 

type RayJob struct {

	// Required input field. Unique job name provided by user.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required input field. job namespace provided by user
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required field. This field indicates the user who owns the job.
	User string `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	// Required field. This field indicates Ray version. Should be the same as image version
	Version string `protobuf:"bytes,21,opt,name=version,proto3" json:"version,omitempty"`
	// Required field. The entrypoint of the RayJob
	Entrypoint string `protobuf:"bytes,4,opt,name=entrypoint,proto3" json:"entrypoint,omitempty"`
	// Optional. Metadata is data to store along with this job.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// Optional. RuntimeEnv is a Yaml string which maps to the RuntimeEnvYAML field of the RayJobSpec
	RuntimeEnv string `protobuf:"bytes,6,opt,name=runtime_env,json=runtimeEnv,proto3" json:"runtime_env,omitempty"`
	// Optional. If jobId is not set, a new jobId will be auto-generated.
	JobId string `protobuf:"bytes,7,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Optional. If set to true, the rayCluster will be deleted after the rayJob finishes. Defaults to false.
	ShutdownAfterJobFinishes bool `` /* 138-byte string literal not displayed */
	// Optional. The label selectors to choose exiting clusters. If not specified, cluster_spec must be set.
	ClusterSelector map[string]string `` /* 194-byte string literal not displayed */
	// Optional. The cluster template, required if the cluster_selector is not specified.
	ClusterSpec *ClusterSpec `protobuf:"bytes,10,opt,name=cluster_spec,json=clusterSpec,proto3" json:"cluster_spec,omitempty"`
	// Optional. TTLSecondsAfterFinished is the TTL to clean up RayCluster.
	TtlSecondsAfterFinished int32 `` /* 136-byte string literal not displayed */
	// Optional Ray Job submitter
	JobSubmitter *RayJobSubmitter `protobuf:"bytes,17,opt,name=jobSubmitter,proto3" json:"jobSubmitter,omitempty"`
	// Optional entrypointNumCpus specifies the number of cpus to reserve for the entrypoint command.
	EntrypointNumCpus float32 `protobuf:"fixed32,18,opt,name=entrypointNumCpus,proto3" json:"entrypointNumCpus,omitempty"`
	// Optional entrypointNumGpus specifies the number of gpus to reserve for the entrypoint command.
	EntrypointNumGpus float32 `protobuf:"fixed32,19,opt,name=entrypointNumGpus,proto3" json:"entrypointNumGpus,omitempty"`
	// Optional entrypointResources specifies the custom resources and quantities to reserve
	// for the entrypoint command.
	EntrypointResources string `protobuf:"bytes,20,opt,name=entrypointResources,proto3" json:"entrypointResources,omitempty"`
	// Output. The time that the job created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Output. The time that the job deleted.
	DeleteAt *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=delete_at,json=deleteAt,proto3" json:"delete_at,omitempty"`
	// Output. The current job status
	JobStatus string `protobuf:"bytes,14,opt,name=job_status,json=jobStatus,proto3" json:"job_status,omitempty"`
	// Output. The current job deployment status
	JobDeploymentStatus string `protobuf:"bytes,15,opt,name=job_deployment_status,json=jobDeploymentStatus,proto3" json:"job_deployment_status,omitempty"`
	// Output. A human-readable description of the status of this operation.
	Message string `protobuf:"bytes,16,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

RayJob definition

func (*RayJob) Descriptor deprecated 

func (*RayJob) Descriptor() ([]byte, []int)

Deprecated: Use RayJob.ProtoReflect.Descriptor instead.

func (*RayJob) GetClusterSelector 

func (x *RayJob) GetClusterSelector() map[string]string

func (*RayJob) GetClusterSpec 

func (x *RayJob) GetClusterSpec() *ClusterSpec

func (*RayJob) GetCreatedAt 

func (x *RayJob) GetCreatedAt() *timestamppb.Timestamp

func (*RayJob) GetDeleteAt 

func (x *RayJob) GetDeleteAt() *timestamppb.Timestamp

func (*RayJob) GetEntrypoint 

func (x *RayJob) GetEntrypoint() string

func (*RayJob) GetEntrypointNumCpus 

func (x *RayJob) GetEntrypointNumCpus() float32

func (*RayJob) GetEntrypointNumGpus 

func (x *RayJob) GetEntrypointNumGpus() float32

func (*RayJob) GetEntrypointResources 

func (x *RayJob) GetEntrypointResources() string

func (*RayJob) GetJobDeploymentStatus 

func (x *RayJob) GetJobDeploymentStatus() string

func (*RayJob) GetJobId 

func (x *RayJob) GetJobId() string

func (*RayJob) GetJobStatus 

func (x *RayJob) GetJobStatus() string

func (*RayJob) GetJobSubmitter 

func (x *RayJob) GetJobSubmitter() *RayJobSubmitter

func (*RayJob) GetMessage 

func (x *RayJob) GetMessage() string

func (*RayJob) GetMetadata 

func (x *RayJob) GetMetadata() map[string]string

func (*RayJob) GetName 

func (x *RayJob) GetName() string

func (*RayJob) GetNamespace 

func (x *RayJob) GetNamespace() string

func (*RayJob) GetRuntimeEnv 

func (x *RayJob) GetRuntimeEnv() string

func (*RayJob) GetShutdownAfterJobFinishes 

func (x *RayJob) GetShutdownAfterJobFinishes() bool

func (*RayJob) GetTtlSecondsAfterFinished 

func (x *RayJob) GetTtlSecondsAfterFinished() int32

func (*RayJob) GetUser 

func (x *RayJob) GetUser() string

func (*RayJob) GetVersion 

func (x *RayJob) GetVersion() string

func (*RayJob) ProtoMessage 

func (*RayJob) ProtoMessage()

func (*RayJob) ProtoReflect 

func (x *RayJob) ProtoReflect() protoreflect.Message

func (*RayJob) Reset 

func (x *RayJob) Reset()

func (*RayJob) String 

func (x *RayJob) String() string

type RayJobServiceClient 

type RayJobServiceClient interface {
	// Creates a new job.
	CreateRayJob(ctx context.Context, in *CreateRayJobRequest, opts ...grpc.CallOption) (*RayJob, error)
	// Finds a specific job by its name and namespace.
	GetRayJob(ctx context.Context, in *GetRayJobRequest, opts ...grpc.CallOption) (*RayJob, error)
	// Finds all job in a given namespace. Supports pagination, and sorting on certain fields.
	ListRayJobs(ctx context.Context, in *ListRayJobsRequest, opts ...grpc.CallOption) (*ListRayJobsResponse, error)
	// Finds all job in all namespaces. Supports pagination, and sorting on certain fields.
	ListAllRayJobs(ctx context.Context, in *ListAllRayJobsRequest, opts ...grpc.CallOption) (*ListAllRayJobsResponse, error)
	// Deletes a job by its name and namespace.
	DeleteRayJob(ctx context.Context, in *DeleteRayJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

RayJobServiceClient is the client API for RayJobService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRayJobServiceClient 

func NewRayJobServiceClient(cc grpc.ClientConnInterface) RayJobServiceClient

type RayJobServiceServer 

type RayJobServiceServer interface {
	// Creates a new job.
	CreateRayJob(context.Context, *CreateRayJobRequest) (*RayJob, error)
	// Finds a specific job by its name and namespace.
	GetRayJob(context.Context, *GetRayJobRequest) (*RayJob, error)
	// Finds all job in a given namespace. Supports pagination, and sorting on certain fields.
	ListRayJobs(context.Context, *ListRayJobsRequest) (*ListRayJobsResponse, error)
	// Finds all job in all namespaces. Supports pagination, and sorting on certain fields.
	ListAllRayJobs(context.Context, *ListAllRayJobsRequest) (*ListAllRayJobsResponse, error)
	// Deletes a job by its name and namespace.
	DeleteRayJob(context.Context, *DeleteRayJobRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

RayJobServiceServer is the server API for RayJobService service. All implementations must embed UnimplementedRayJobServiceServer for forward compatibility

type RayJobSubmission 

type RayJobSubmission struct {

	// Required. Entry point
	Entrypoint string `protobuf:"bytes,1,opt,name=entrypoint,proto3" json:"entrypoint,omitempty"`
	// Optional submission id
	SubmissionId string `protobuf:"bytes,2,opt,name=submission_id,json=submissionId,proto3" json:"submission_id,omitempty"`
	// Optional. Arbitrary user-provided metadata for the job.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// Optional. The runtime environment for the job.  - yaml string.
	RuntimeEnv string `protobuf:"bytes,4,opt,name=runtime_env,json=runtimeEnv,proto3" json:"runtime_env,omitempty"`
	// Optional. Number of CPUs to allocate for the execution of the entrypoint command, separately from any Ray tasks or actors that are created by it.
	EntrypointNumCpus float32 `protobuf:"fixed32,5,opt,name=entrypoint_num_cpus,json=entrypointNumCpus,proto3" json:"entrypoint_num_cpus,omitempty"`
	// Optional. Number of GPUs to allocate for the execution of the entrypoint command, separately from any Ray tasks or actors that are created by it.
	EntrypointNumGpus float32 `protobuf:"fixed32,6,opt,name=entrypoint_num_gpus,json=entrypointNumGpus,proto3" json:"entrypoint_num_gpus,omitempty"`
	// Optional. The quantity of various custom resources to allocate for the execution of the entrypoint command, separately from any Ray tasks or actors that are created by it.
	EntrypointResources map[string]string `` /* 206-byte string literal not displayed */
	// contains filtered or unexported fields
}

RayJobSubmission definition

func (*RayJobSubmission) Descriptor deprecated 

func (*RayJobSubmission) Descriptor() ([]byte, []int)

Deprecated: Use RayJobSubmission.ProtoReflect.Descriptor instead.

func (*RayJobSubmission) GetEntrypoint 

func (x *RayJobSubmission) GetEntrypoint() string

func (*RayJobSubmission) GetEntrypointNumCpus 

func (x *RayJobSubmission) GetEntrypointNumCpus() float32

func (*RayJobSubmission) GetEntrypointNumGpus 

func (x *RayJobSubmission) GetEntrypointNumGpus() float32

func (*RayJobSubmission) GetEntrypointResources 

func (x *RayJobSubmission) GetEntrypointResources() map[string]string

func (*RayJobSubmission) GetMetadata 

func (x *RayJobSubmission) GetMetadata() map[string]string

func (*RayJobSubmission) GetRuntimeEnv 

func (x *RayJobSubmission) GetRuntimeEnv() string

func (*RayJobSubmission) GetSubmissionId 

func (x *RayJobSubmission) GetSubmissionId() string

func (*RayJobSubmission) ProtoMessage 

func (*RayJobSubmission) ProtoMessage()

func (*RayJobSubmission) ProtoReflect 

func (x *RayJobSubmission) ProtoReflect() protoreflect.Message

func (*RayJobSubmission) Reset 

func (x *RayJobSubmission) Reset()

func (*RayJobSubmission) String 

func (x *RayJobSubmission) String() string

type RayJobSubmissionServiceClient 

type RayJobSubmissionServiceClient interface {
	// Submit a new Ray job on the specified cluster.
	SubmitRayJob(ctx context.Context, in *SubmitRayJobRequest, opts ...grpc.CallOption) (*SubmitRayJobReply, error)
	// Finds a specific job by its submission_id for the cluster with name and namespace.
	GetJobDetails(ctx context.Context, in *GetJobDetailsRequest, opts ...grpc.CallOption) (*JobSubmissionInfo, error)
	// Gets a specific job log by its submissionid for the cluster with name and namespace.
	GetJobLog(ctx context.Context, in *GetJobLogRequest, opts ...grpc.CallOption) (*GetJobLogReply, error)
	// List all job in a given a given cluster in a namespace. Supports pagination, and sorting on certain fields.
	ListJobDetails(ctx context.Context, in *ListJobDetailsRequest, opts ...grpc.CallOption) (*ListJobSubmissionInfo, error)
	// Stops a job by its name and namespace.
	StopRayJob(ctx context.Context, in *StopRayJobSubmissionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Deletes a job by its name and namespace.
	DeleteRayJob(ctx context.Context, in *DeleteRayJobSubmissionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

RayJobSubmissionServiceClient is the client API for RayJobSubmissionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRayJobSubmissionServiceClient 

func NewRayJobSubmissionServiceClient(cc grpc.ClientConnInterface) RayJobSubmissionServiceClient

type RayJobSubmissionServiceServer 

type RayJobSubmissionServiceServer interface {
	// Submit a new Ray job on the specified cluster.
	SubmitRayJob(context.Context, *SubmitRayJobRequest) (*SubmitRayJobReply, error)
	// Finds a specific job by its submission_id for the cluster with name and namespace.
	GetJobDetails(context.Context, *GetJobDetailsRequest) (*JobSubmissionInfo, error)
	// Gets a specific job log by its submissionid for the cluster with name and namespace.
	GetJobLog(context.Context, *GetJobLogRequest) (*GetJobLogReply, error)
	// List all job in a given a given cluster in a namespace. Supports pagination, and sorting on certain fields.
	ListJobDetails(context.Context, *ListJobDetailsRequest) (*ListJobSubmissionInfo, error)
	// Stops a job by its name and namespace.
	StopRayJob(context.Context, *StopRayJobSubmissionRequest) (*emptypb.Empty, error)
	// Deletes a job by its name and namespace.
	DeleteRayJob(context.Context, *DeleteRayJobSubmissionRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

RayJobSubmissionServiceServer is the server API for RayJobSubmissionService service. All implementations must embed UnimplementedRayJobSubmissionServiceServer for forward compatibility

type RayJobSubmitter 

type RayJobSubmitter struct {

	// Required base image for job submitter. Make sure that Python/Ray version
	// of the image corresponds to the one used in the cluster
	Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	// Optional number of CPUs for submitter - default "1"
	Cpu string `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// Optional memory for the submitter - default "1Gi"
	Memory string `protobuf:"bytes,3,opt,name=memory,proto3" json:"memory,omitempty"`
	// contains filtered or unexported fields
}

func (*RayJobSubmitter) Descriptor deprecated 

func (*RayJobSubmitter) Descriptor() ([]byte, []int)

Deprecated: Use RayJobSubmitter.ProtoReflect.Descriptor instead.

func (*RayJobSubmitter) GetCpu 

func (x *RayJobSubmitter) GetCpu() string

func (*RayJobSubmitter) GetImage 

func (x *RayJobSubmitter) GetImage() string

func (*RayJobSubmitter) GetMemory 

func (x *RayJobSubmitter) GetMemory() string

func (*RayJobSubmitter) ProtoMessage 

func (*RayJobSubmitter) ProtoMessage()

func (*RayJobSubmitter) ProtoReflect 

func (x *RayJobSubmitter) ProtoReflect() protoreflect.Message

func (*RayJobSubmitter) Reset 

func (x *RayJobSubmitter) Reset()

func (*RayJobSubmitter) String 

func (x *RayJobSubmitter) String() string

type RayServeServiceClient 

type RayServeServiceClient interface {
	// Create a new ray serve.
	CreateRayService(ctx context.Context, in *CreateRayServiceRequest, opts ...grpc.CallOption) (*RayService, error)
	// Update a ray serve.
	// We may
	UpdateRayService(ctx context.Context, in *UpdateRayServiceRequest, opts ...grpc.CallOption) (*RayService, error)
	// Find a specific ray serve by name and namespace.
	GetRayService(ctx context.Context, in *GetRayServiceRequest, opts ...grpc.CallOption) (*RayService, error)
	// Finds all ray services in a given namespace. Supports pagination, and sorting on certain fields.
	ListRayServices(ctx context.Context, in *ListRayServicesRequest, opts ...grpc.CallOption) (*ListRayServicesResponse, error)
	// Finds all ray services in a given namespace. Supports pagination, and sorting on certain fields.
	ListAllRayServices(ctx context.Context, in *ListAllRayServicesRequest, opts ...grpc.CallOption) (*ListAllRayServicesResponse, error)
	// Deletes a ray service by its name and namespace
	DeleteRayService(ctx context.Context, in *DeleteRayServiceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

RayServeServiceClient is the client API for RayServeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRayServeServiceClient 

func NewRayServeServiceClient(cc grpc.ClientConnInterface) RayServeServiceClient

type RayServeServiceServer 

type RayServeServiceServer interface {
	// Create a new ray serve.
	CreateRayService(context.Context, *CreateRayServiceRequest) (*RayService, error)
	// Update a ray serve.
	// We may
	UpdateRayService(context.Context, *UpdateRayServiceRequest) (*RayService, error)
	// Find a specific ray serve by name and namespace.
	GetRayService(context.Context, *GetRayServiceRequest) (*RayService, error)
	// Finds all ray services in a given namespace. Supports pagination, and sorting on certain fields.
	ListRayServices(context.Context, *ListRayServicesRequest) (*ListRayServicesResponse, error)
	// Finds all ray services in a given namespace. Supports pagination, and sorting on certain fields.
	ListAllRayServices(context.Context, *ListAllRayServicesRequest) (*ListAllRayServicesResponse, error)
	// Deletes a ray service by its name and namespace
	DeleteRayService(context.Context, *DeleteRayServiceRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

RayServeServiceServer is the server API for RayServeService service. All implementations must embed UnimplementedRayServeServiceServer for forward compatibility

type RayService 

type RayService struct {

	// Required input field. Unique ray service name provided by user.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required input field. ray service namespace provided by user
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required field. This field indicates the user who owns the ray service.
	User string `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	// Required field. This field indicates Ray version. Should be the same as image version
	Version string `protobuf:"bytes,12,opt,name=version,proto3" json:"version,omitempty"`
	// Config for serve deployment V2. Note that only one config V1 or V2 can be specified
	ServeConfig_V2 string `protobuf:"bytes,9,opt,name=serve_config_V2,json=serveConfigV2,proto3" json:"serve_config_V2,omitempty"`
	// Serve deployment related health check
	//
	// Deprecated: Do not use.
	ServiceUnhealthySecondThreshold int32 `` /* 160-byte string literal not displayed */
	// Dashboard agent related health check
	//
	// Deprecated: Do not use.
	DeploymentUnhealthySecondThreshold int32 `` /* 169-byte string literal not displayed */
	// Required. The cluster template.
	ClusterSpec *ClusterSpec `protobuf:"bytes,5,opt,name=cluster_spec,json=clusterSpec,proto3" json:"cluster_spec,omitempty"`
	// Output. The status for the ray service.
	RayServiceStatus *RayServiceStatus `protobuf:"bytes,6,opt,name=ray_service_status,json=rayServiceStatus,proto3" json:"ray_service_status,omitempty"`
	// Output. The time that the ray service created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Output. The time that the ray service deleted.
	DeleteAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=delete_at,json=deleteAt,proto3" json:"delete_at,omitempty"`
	// contains filtered or unexported fields
}

func (*RayService) Descriptor deprecated 

func (*RayService) Descriptor() ([]byte, []int)

Deprecated: Use RayService.ProtoReflect.Descriptor instead.

func (*RayService) GetClusterSpec 

func (x *RayService) GetClusterSpec() *ClusterSpec

func (*RayService) GetCreatedAt 

func (x *RayService) GetCreatedAt() *timestamppb.Timestamp

func (*RayService) GetDeleteAt 

func (x *RayService) GetDeleteAt() *timestamppb.Timestamp

func (*RayService) GetDeploymentUnhealthySecondThreshold deprecated 

func (x *RayService) GetDeploymentUnhealthySecondThreshold() int32

Deprecated: Do not use.

func (*RayService) GetName 

func (x *RayService) GetName() string

func (*RayService) GetNamespace 

func (x *RayService) GetNamespace() string

func (*RayService) GetRayServiceStatus 

func (x *RayService) GetRayServiceStatus() *RayServiceStatus

func (*RayService) GetServeConfig_V2 

func (x *RayService) GetServeConfig_V2() string

func (*RayService) GetServiceUnhealthySecondThreshold deprecated 

func (x *RayService) GetServiceUnhealthySecondThreshold() int32

Deprecated: Do not use.

func (*RayService) GetUser 

func (x *RayService) GetUser() string

func (*RayService) GetVersion 

func (x *RayService) GetVersion() string

func (*RayService) ProtoMessage 

func (*RayService) ProtoMessage()

func (*RayService) ProtoReflect 

func (x *RayService) ProtoReflect() protoreflect.Message

func (*RayService) Reset 

func (x *RayService) Reset()

func (*RayService) String 

func (x *RayService) String() string

type RayServiceEvent 

type RayServiceEvent struct {

	// Output. Unique Event Id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Output. Human readable name for event.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Output. The creation time of the event.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Output. The last time the event occur.
	FirstTimestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=first_timestamp,json=firstTimestamp,proto3" json:"first_timestamp,omitempty"`
	// Output. The first time the event occur
	LastTimestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_timestamp,json=lastTimestamp,proto3" json:"last_timestamp,omitempty"`
	// Output. The reason for the transition into the object's current status.
	Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	// Output. A human-readable description of the status of this operation.
	Message string `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`
	// Output. Type of this event (Normal, Warning), new types could be added in the future
	Type string `protobuf:"bytes,8,opt,name=type,proto3" json:"type,omitempty"`
	// Output. The number of times this event has occurred.
	Count int32 `protobuf:"varint,9,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*RayServiceEvent) Descriptor deprecated 

func (*RayServiceEvent) Descriptor() ([]byte, []int)

Deprecated: Use RayServiceEvent.ProtoReflect.Descriptor instead.

func (*RayServiceEvent) GetCount 

func (x *RayServiceEvent) GetCount() int32

func (*RayServiceEvent) GetCreatedAt 

func (x *RayServiceEvent) GetCreatedAt() *timestamppb.Timestamp

func (*RayServiceEvent) GetFirstTimestamp 

func (x *RayServiceEvent) GetFirstTimestamp() *timestamppb.Timestamp

func (*RayServiceEvent) GetId 

func (x *RayServiceEvent) GetId() string

func (*RayServiceEvent) GetLastTimestamp 

func (x *RayServiceEvent) GetLastTimestamp() *timestamppb.Timestamp

func (*RayServiceEvent) GetMessage 

func (x *RayServiceEvent) GetMessage() string

func (*RayServiceEvent) GetName 

func (x *RayServiceEvent) GetName() string

func (*RayServiceEvent) GetReason 

func (x *RayServiceEvent) GetReason() string

func (*RayServiceEvent) GetType 

func (x *RayServiceEvent) GetType() string

func (*RayServiceEvent) ProtoMessage 

func (*RayServiceEvent) ProtoMessage()

func (*RayServiceEvent) ProtoReflect 

func (x *RayServiceEvent) ProtoReflect() protoreflect.Message

func (*RayServiceEvent) Reset 

func (x *RayServiceEvent) Reset()

func (*RayServiceEvent) String 

func (x *RayServiceEvent) String() string

type RayServiceStatus 

type RayServiceStatus struct {

	// NOTE(zcin): the first three fields are deprecated in favor of serve_application_status.
	// (Deprecated) The ray serve application status.
	ApplicationStatus string `protobuf:"bytes,1,opt,name=application_status,json=applicationStatus,proto3" json:"application_status,omitempty"`
	// (Deprecated) A human-readable description of the status of this operation.
	ApplicationMessage string `protobuf:"bytes,2,opt,name=application_message,json=applicationMessage,proto3" json:"application_message,omitempty"`
	// (Deprecated) The status for each deployment.
	ServeDeploymentStatus []*ServeDeploymentStatus `` /* 126-byte string literal not displayed */
	// The related event for the ray service.
	RayServiceEvents []*RayServiceEvent `protobuf:"bytes,4,rep,name=ray_service_events,json=rayServiceEvents,proto3" json:"ray_service_events,omitempty"`
	// The ray cluster name.
	RayClusterName string `protobuf:"bytes,5,opt,name=ray_cluster_name,json=rayClusterName,proto3" json:"ray_cluster_name,omitempty"`
	// The state for ray cluster.
	RayClusterState string `protobuf:"bytes,6,opt,name=ray_cluster_state,json=rayClusterState,proto3" json:"ray_cluster_state,omitempty"`
	// The service endpoint of the cluster and service.
	ServiceEndpoint map[string]string `` /* 194-byte string literal not displayed */
	// All ray serve application statuses
	ServeApplicationStatus []*ServeApplicationStatus `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RayServiceStatus) Descriptor deprecated 

func (*RayServiceStatus) Descriptor() ([]byte, []int)

Deprecated: Use RayServiceStatus.ProtoReflect.Descriptor instead.

func (*RayServiceStatus) GetApplicationMessage 

func (x *RayServiceStatus) GetApplicationMessage() string

func (*RayServiceStatus) GetApplicationStatus 

func (x *RayServiceStatus) GetApplicationStatus() string

func (*RayServiceStatus) GetRayClusterName 

func (x *RayServiceStatus) GetRayClusterName() string

func (*RayServiceStatus) GetRayClusterState 

func (x *RayServiceStatus) GetRayClusterState() string

func (*RayServiceStatus) GetRayServiceEvents 

func (x *RayServiceStatus) GetRayServiceEvents() []*RayServiceEvent

func (*RayServiceStatus) GetServeApplicationStatus 

func (x *RayServiceStatus) GetServeApplicationStatus() []*ServeApplicationStatus

func (*RayServiceStatus) GetServeDeploymentStatus 

func (x *RayServiceStatus) GetServeDeploymentStatus() []*ServeDeploymentStatus

func (*RayServiceStatus) GetServiceEndpoint 

func (x *RayServiceStatus) GetServiceEndpoint() map[string]string

func (*RayServiceStatus) ProtoMessage 

func (*RayServiceStatus) ProtoMessage()

func (*RayServiceStatus) ProtoReflect 

func (x *RayServiceStatus) ProtoReflect() protoreflect.Message

func (*RayServiceStatus) Reset 

func (x *RayServiceStatus) Reset()

func (*RayServiceStatus) String 

func (x *RayServiceStatus) String() string

type ServeApplicationStatus 

type ServeApplicationStatus struct {

	// Application name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Application status
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// Details about the application status.
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// All ray serve deployment statuses in this application
	ServeDeploymentStatus []*ServeDeploymentStatus `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ServeApplicationStatus) Descriptor deprecated 

func (*ServeApplicationStatus) Descriptor() ([]byte, []int)

Deprecated: Use ServeApplicationStatus.ProtoReflect.Descriptor instead.

func (*ServeApplicationStatus) GetMessage 

func (x *ServeApplicationStatus) GetMessage() string

func (*ServeApplicationStatus) GetName 

func (x *ServeApplicationStatus) GetName() string

func (*ServeApplicationStatus) GetServeDeploymentStatus 

func (x *ServeApplicationStatus) GetServeDeploymentStatus() []*ServeDeploymentStatus

func (*ServeApplicationStatus) GetStatus 

func (x *ServeApplicationStatus) GetStatus() string

func (*ServeApplicationStatus) ProtoMessage 

func (*ServeApplicationStatus) ProtoMessage()

func (*ServeApplicationStatus) ProtoReflect 

func (x *ServeApplicationStatus) ProtoReflect() protoreflect.Message

func (*ServeApplicationStatus) Reset 

func (x *ServeApplicationStatus) Reset()

func (*ServeApplicationStatus) String 

func (x *ServeApplicationStatus) String() string

type ServeDeploymentStatus 

type ServeDeploymentStatus struct {

	// Unique ray service deployment name.
	DeploymentName string `protobuf:"bytes,1,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"`
	// Status of single deployment.
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// A human-readable description of the status of this operation.
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ServeDeploymentStatus) Descriptor deprecated 

func (*ServeDeploymentStatus) Descriptor() ([]byte, []int)

Deprecated: Use ServeDeploymentStatus.ProtoReflect.Descriptor instead.

func (*ServeDeploymentStatus) GetDeploymentName 

func (x *ServeDeploymentStatus) GetDeploymentName() string

func (*ServeDeploymentStatus) GetMessage 

func (x *ServeDeploymentStatus) GetMessage() string

func (*ServeDeploymentStatus) GetStatus 

func (x *ServeDeploymentStatus) GetStatus() string

func (*ServeDeploymentStatus) ProtoMessage 

func (*ServeDeploymentStatus) ProtoMessage()

func (*ServeDeploymentStatus) ProtoReflect 

func (x *ServeDeploymentStatus) ProtoReflect() protoreflect.Message

func (*ServeDeploymentStatus) Reset 

func (x *ServeDeploymentStatus) Reset()

func (*ServeDeploymentStatus) String 

func (x *ServeDeploymentStatus) String() string

type Status 

type Status struct {
	Error   string       `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Code    int32        `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	Details []*anypb.Any `protobuf:"bytes,3,rep,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

Status of the request, including underling errors and codes

func (*Status) Descriptor deprecated 

func (*Status) Descriptor() ([]byte, []int)

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode 

func (x *Status) GetCode() int32

func (*Status) GetDetails 

func (x *Status) GetDetails() []*anypb.Any

func (*Status) GetError 

func (x *Status) GetError() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

func (x *Status) ProtoReflect() protoreflect.Message

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type StopRayJobSubmissionRequest 

type StopRayJobSubmissionRequest struct {

	// Required. The namespace of the cluster for the job
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required. The name of the cluster for the job
	Clustername string `protobuf:"bytes,2,opt,name=clustername,proto3" json:"clustername,omitempty"`
	// Required. The submission id of the job
	Submissionid string `protobuf:"bytes,3,opt,name=submissionid,proto3" json:"submissionid,omitempty"`
	// contains filtered or unexported fields
}

func (*StopRayJobSubmissionRequest) Descriptor deprecated 

func (*StopRayJobSubmissionRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopRayJobSubmissionRequest.ProtoReflect.Descriptor instead.

func (*StopRayJobSubmissionRequest) GetClustername 

func (x *StopRayJobSubmissionRequest) GetClustername() string

func (*StopRayJobSubmissionRequest) GetNamespace 

func (x *StopRayJobSubmissionRequest) GetNamespace() string

func (*StopRayJobSubmissionRequest) GetSubmissionid 

func (x *StopRayJobSubmissionRequest) GetSubmissionid() string

func (*StopRayJobSubmissionRequest) ProtoMessage 

func (*StopRayJobSubmissionRequest) ProtoMessage()

func (*StopRayJobSubmissionRequest) ProtoReflect 

func (x *StopRayJobSubmissionRequest) ProtoReflect() protoreflect.Message

func (*StopRayJobSubmissionRequest) Reset 

func (x *StopRayJobSubmissionRequest) Reset()

func (*StopRayJobSubmissionRequest) String 

func (x *StopRayJobSubmissionRequest) String() string

type SubmitRayJobReply 

type SubmitRayJobReply struct {

	// Created submission ID
	SubmissionId string `protobuf:"bytes,1,opt,name=submission_id,json=submissionId,proto3" json:"submission_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitRayJobReply) Descriptor deprecated 

func (*SubmitRayJobReply) Descriptor() ([]byte, []int)

Deprecated: Use SubmitRayJobReply.ProtoReflect.Descriptor instead.

func (*SubmitRayJobReply) GetSubmissionId 

func (x *SubmitRayJobReply) GetSubmissionId() string

func (*SubmitRayJobReply) ProtoMessage 

func (*SubmitRayJobReply) ProtoMessage()

func (*SubmitRayJobReply) ProtoReflect 

func (x *SubmitRayJobReply) ProtoReflect() protoreflect.Message

func (*SubmitRayJobReply) Reset 

func (x *SubmitRayJobReply) Reset()

func (*SubmitRayJobReply) String 

func (x *SubmitRayJobReply) String() string

type SubmitRayJobRequest 

type SubmitRayJobRequest struct {

	// Required. The namespace of the cluster for the job to be created
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required. The name of the cluster for the job
	Clustername string `protobuf:"bytes,2,opt,name=clustername,proto3" json:"clustername,omitempty"`
	// Required. The job to be created.
	Jobsubmission *RayJobSubmission `protobuf:"bytes,3,opt,name=jobsubmission,proto3" json:"jobsubmission,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitRayJobRequest) Descriptor deprecated 

func (*SubmitRayJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubmitRayJobRequest.ProtoReflect.Descriptor instead.

func (*SubmitRayJobRequest) GetClustername 

func (x *SubmitRayJobRequest) GetClustername() string

func (*SubmitRayJobRequest) GetJobsubmission 

func (x *SubmitRayJobRequest) GetJobsubmission() *RayJobSubmission

func (*SubmitRayJobRequest) GetNamespace 

func (x *SubmitRayJobRequest) GetNamespace() string

func (*SubmitRayJobRequest) ProtoMessage 

func (*SubmitRayJobRequest) ProtoMessage()

func (*SubmitRayJobRequest) ProtoReflect 

func (x *SubmitRayJobRequest) ProtoReflect() protoreflect.Message

func (*SubmitRayJobRequest) Reset 

func (x *SubmitRayJobRequest) Reset()

func (*SubmitRayJobRequest) String 

func (x *SubmitRayJobRequest) String() string

type UnimplementedClusterServiceServer 

type UnimplementedClusterServiceServer struct {
}

UnimplementedClusterServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedClusterServiceServer) CreateCluster 

func (UnimplementedClusterServiceServer) CreateCluster(context.Context, *CreateClusterRequest) (*Cluster, error)

func (UnimplementedClusterServiceServer) DeleteCluster 

func (UnimplementedClusterServiceServer) DeleteCluster(context.Context, *DeleteClusterRequest) (*emptypb.Empty, error)

func (UnimplementedClusterServiceServer) GetCluster 

func (UnimplementedClusterServiceServer) GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)

func (UnimplementedClusterServiceServer) ListAllClusters 

func (UnimplementedClusterServiceServer) ListAllClusters(context.Context, *ListAllClustersRequest) (*ListAllClustersResponse, error)

func (UnimplementedClusterServiceServer) ListCluster 

func (UnimplementedClusterServiceServer) ListCluster(context.Context, *ListClustersRequest) (*ListClustersResponse, error)

type UnimplementedComputeTemplateServiceServer 

type UnimplementedComputeTemplateServiceServer struct {
}

UnimplementedComputeTemplateServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedComputeTemplateServiceServer) CreateComputeTemplate 

func (UnimplementedComputeTemplateServiceServer) CreateComputeTemplate(context.Context, *CreateComputeTemplateRequest) (*ComputeTemplate, error)

func (UnimplementedComputeTemplateServiceServer) DeleteComputeTemplate 

func (UnimplementedComputeTemplateServiceServer) DeleteComputeTemplate(context.Context, *DeleteComputeTemplateRequest) (*emptypb.Empty, error)

func (UnimplementedComputeTemplateServiceServer) GetComputeTemplate 

func (UnimplementedComputeTemplateServiceServer) GetComputeTemplate(context.Context, *GetComputeTemplateRequest) (*ComputeTemplate, error)

func (UnimplementedComputeTemplateServiceServer) ListAllComputeTemplates 

func (UnimplementedComputeTemplateServiceServer) ListAllComputeTemplates(context.Context, *ListAllComputeTemplatesRequest) (*ListAllComputeTemplatesResponse, error)

func (UnimplementedComputeTemplateServiceServer) ListComputeTemplates 

func (UnimplementedComputeTemplateServiceServer) ListComputeTemplates(context.Context, *ListComputeTemplatesRequest) (*ListComputeTemplatesResponse, error)

type UnimplementedImageTemplateServiceServer 

type UnimplementedImageTemplateServiceServer struct {
}

UnimplementedImageTemplateServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedImageTemplateServiceServer) CreateImageTemplate 

func (UnimplementedImageTemplateServiceServer) CreateImageTemplate(context.Context, *CreateImageTemplateRequest) (*ImageTemplate, error)

func (UnimplementedImageTemplateServiceServer) DeleteImageTemplate 

func (UnimplementedImageTemplateServiceServer) DeleteImageTemplate(context.Context, *DeleteImageTemplateRequest) (*emptypb.Empty, error)

func (UnimplementedImageTemplateServiceServer) GetImageTemplate 

func (UnimplementedImageTemplateServiceServer) GetImageTemplate(context.Context, *GetImageTemplateRequest) (*ImageTemplate, error)

func (UnimplementedImageTemplateServiceServer) ListImageTemplates 

func (UnimplementedImageTemplateServiceServer) ListImageTemplates(context.Context, *ListImageTemplatesRequest) (*ListImageTemplatesResponse, error)

type UnimplementedRayJobServiceServer 

type UnimplementedRayJobServiceServer struct {
}

UnimplementedRayJobServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRayJobServiceServer) CreateRayJob 

func (UnimplementedRayJobServiceServer) CreateRayJob(context.Context, *CreateRayJobRequest) (*RayJob, error)

func (UnimplementedRayJobServiceServer) DeleteRayJob 

func (UnimplementedRayJobServiceServer) DeleteRayJob(context.Context, *DeleteRayJobRequest) (*emptypb.Empty, error)

func (UnimplementedRayJobServiceServer) GetRayJob 

func (UnimplementedRayJobServiceServer) GetRayJob(context.Context, *GetRayJobRequest) (*RayJob, error)

func (UnimplementedRayJobServiceServer) ListAllRayJobs 

func (UnimplementedRayJobServiceServer) ListAllRayJobs(context.Context, *ListAllRayJobsRequest) (*ListAllRayJobsResponse, error)

func (UnimplementedRayJobServiceServer) ListRayJobs 

func (UnimplementedRayJobServiceServer) ListRayJobs(context.Context, *ListRayJobsRequest) (*ListRayJobsResponse, error)

type UnimplementedRayJobSubmissionServiceServer 

type UnimplementedRayJobSubmissionServiceServer struct {
}

UnimplementedRayJobSubmissionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRayJobSubmissionServiceServer) DeleteRayJob 

func (UnimplementedRayJobSubmissionServiceServer) DeleteRayJob(context.Context, *DeleteRayJobSubmissionRequest) (*emptypb.Empty, error)

func (UnimplementedRayJobSubmissionServiceServer) GetJobDetails 

func (UnimplementedRayJobSubmissionServiceServer) GetJobDetails(context.Context, *GetJobDetailsRequest) (*JobSubmissionInfo, error)

func (UnimplementedRayJobSubmissionServiceServer) GetJobLog 

func (UnimplementedRayJobSubmissionServiceServer) GetJobLog(context.Context, *GetJobLogRequest) (*GetJobLogReply, error)

func (UnimplementedRayJobSubmissionServiceServer) ListJobDetails 

func (UnimplementedRayJobSubmissionServiceServer) ListJobDetails(context.Context, *ListJobDetailsRequest) (*ListJobSubmissionInfo, error)

func (UnimplementedRayJobSubmissionServiceServer) StopRayJob 

func (UnimplementedRayJobSubmissionServiceServer) StopRayJob(context.Context, *StopRayJobSubmissionRequest) (*emptypb.Empty, error)

func (UnimplementedRayJobSubmissionServiceServer) SubmitRayJob 

func (UnimplementedRayJobSubmissionServiceServer) SubmitRayJob(context.Context, *SubmitRayJobRequest) (*SubmitRayJobReply, error)

type UnimplementedRayServeServiceServer 

type UnimplementedRayServeServiceServer struct {
}

UnimplementedRayServeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRayServeServiceServer) CreateRayService 

func (UnimplementedRayServeServiceServer) CreateRayService(context.Context, *CreateRayServiceRequest) (*RayService, error)

func (UnimplementedRayServeServiceServer) DeleteRayService 

func (UnimplementedRayServeServiceServer) DeleteRayService(context.Context, *DeleteRayServiceRequest) (*emptypb.Empty, error)

func (UnimplementedRayServeServiceServer) GetRayService 

func (UnimplementedRayServeServiceServer) GetRayService(context.Context, *GetRayServiceRequest) (*RayService, error)

func (UnimplementedRayServeServiceServer) ListAllRayServices 

func (UnimplementedRayServeServiceServer) ListAllRayServices(context.Context, *ListAllRayServicesRequest) (*ListAllRayServicesResponse, error)

func (UnimplementedRayServeServiceServer) ListRayServices 

func (UnimplementedRayServeServiceServer) ListRayServices(context.Context, *ListRayServicesRequest) (*ListRayServicesResponse, error)

func (UnimplementedRayServeServiceServer) UpdateRayService 

func (UnimplementedRayServeServiceServer) UpdateRayService(context.Context, *UpdateRayServiceRequest) (*RayService, error)

type UnsafeClusterServiceServer 

type UnsafeClusterServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeClusterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterServiceServer will result in compilation errors.

type UnsafeComputeTemplateServiceServer 

type UnsafeComputeTemplateServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeComputeTemplateServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ComputeTemplateServiceServer will result in compilation errors.

type UnsafeImageTemplateServiceServer 

type UnsafeImageTemplateServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeImageTemplateServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ImageTemplateServiceServer will result in compilation errors.

type UnsafeRayJobServiceServer 

type UnsafeRayJobServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeRayJobServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RayJobServiceServer will result in compilation errors.

type UnsafeRayJobSubmissionServiceServer 

type UnsafeRayJobSubmissionServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeRayJobSubmissionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RayJobSubmissionServiceServer will result in compilation errors.

type UnsafeRayServeServiceServer 

type UnsafeRayServeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeRayServeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RayServeServiceServer will result in compilation errors.

type UpdateRayServiceRequest 

type UpdateRayServiceRequest struct {

	// Required. The ray service to be updated.
	Service *RayService `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// Required. The namespace of the ray service to be updated.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required. The name of the ray service to be updated.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRayServiceRequest) Descriptor deprecated 

func (*UpdateRayServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateRayServiceRequest.ProtoReflect.Descriptor instead.

func (*UpdateRayServiceRequest) GetName 

func (x *UpdateRayServiceRequest) GetName() string

func (*UpdateRayServiceRequest) GetNamespace 

func (x *UpdateRayServiceRequest) GetNamespace() string

func (*UpdateRayServiceRequest) GetService 

func (x *UpdateRayServiceRequest) GetService() *RayService

func (*UpdateRayServiceRequest) ProtoMessage 

func (*UpdateRayServiceRequest) ProtoMessage()

func (*UpdateRayServiceRequest) ProtoReflect 

func (x *UpdateRayServiceRequest) ProtoReflect() protoreflect.Message

func (*UpdateRayServiceRequest) Reset 

func (x *UpdateRayServiceRequest) Reset()

func (*UpdateRayServiceRequest) String 

func (x *UpdateRayServiceRequest) String() string

type Volume 

type Volume struct {
	MountPath            string                      `protobuf:"bytes,1,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty"`
	VolumeType           Volume_VolumeType           `protobuf:"varint,2,opt,name=volume_type,json=volumeType,proto3,enum=proto.Volume_VolumeType" json:"volume_type,omitempty"`
	Name                 string                      `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`                          // volume name
	Source               string                      `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`                      // volume source, for example hostpath source, secret or configMap name, etc
	ReadOnly             bool                        `protobuf:"varint,5,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"` // Read only flag
	HostPathType         Volume_HostPathType         ``                                                                                       /* 131-byte string literal not displayed */
	MountPropagationMode Volume_MountPropagationMode ``                                                                                       /* 163-byte string literal not displayed */
	// If indicate ephemeral, we need to let user specify volumeClaimTemplate
	StorageClassName string            `protobuf:"bytes,8,opt,name=storageClassName,proto3" json:"storageClassName,omitempty"` // If not defined, default is used
	AccessMode       Volume_AccessMode `protobuf:"varint,9,opt,name=accessMode,proto3,enum=proto.Volume_AccessMode" json:"accessMode,omitempty"`
	Storage          string            `protobuf:"bytes,10,opt,name=storage,proto3" json:"storage,omitempty"` // For ephemeral - required storage, GB, for empty dir - MB
	Items            map[string]string ``                                                                     // Items used for configMap and secrets
	/* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Volume) Descriptor deprecated 

func (*Volume) Descriptor() ([]byte, []int)

Deprecated: Use Volume.ProtoReflect.Descriptor instead.

func (*Volume) GetAccessMode 

func (x *Volume) GetAccessMode() Volume_AccessMode

func (*Volume) GetHostPathType 

func (x *Volume) GetHostPathType() Volume_HostPathType

func (*Volume) GetItems 

func (x *Volume) GetItems() map[string]string

func (*Volume) GetMountPath 

func (x *Volume) GetMountPath() string

func (*Volume) GetMountPropagationMode 

func (x *Volume) GetMountPropagationMode() Volume_MountPropagationMode

func (*Volume) GetName 

func (x *Volume) GetName() string

func (*Volume) GetReadOnly 

func (x *Volume) GetReadOnly() bool

func (*Volume) GetSource 

func (x *Volume) GetSource() string

func (*Volume) GetStorage 

func (x *Volume) GetStorage() string

func (*Volume) GetStorageClassName 

func (x *Volume) GetStorageClassName() string

func (*Volume) GetVolumeType 

func (x *Volume) GetVolumeType() Volume_VolumeType

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) ProtoReflect 

func (x *Volume) ProtoReflect() protoreflect.Message

func (*Volume) Reset 

func (x *Volume) Reset()

func (*Volume) String 

func (x *Volume) String() string

type Volume_AccessMode 

type Volume_AccessMode int32
const (
	Volume_RWO Volume_AccessMode = 0 // ReadWriteOnce
	Volume_ROX Volume_AccessMode = 1 // ReadOnlyMany
	Volume_RWX Volume_AccessMode = 2 // ReadWriteMany
)

func (Volume_AccessMode) Descriptor 

func (Volume_AccessMode) Descriptor() protoreflect.EnumDescriptor

func (Volume_AccessMode) Enum 

func (x Volume_AccessMode) Enum() *Volume_AccessMode

func (Volume_AccessMode) EnumDescriptor deprecated 

func (Volume_AccessMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use Volume_AccessMode.Descriptor instead.

func (Volume_AccessMode) Number 

func (x Volume_AccessMode) Number() protoreflect.EnumNumber

func (Volume_AccessMode) String 

func (x Volume_AccessMode) String() string

func (Volume_AccessMode) Type 

func (Volume_AccessMode) Type() protoreflect.EnumType

type Volume_HostPathType 

type Volume_HostPathType int32

If indicate hostpath, we need to let user indicate which type they would like to use. 

const (
	Volume_DIRECTORY Volume_HostPathType = 0
	Volume_FILE      Volume_HostPathType = 1
)

func (Volume_HostPathType) Descriptor 

func (Volume_HostPathType) Descriptor() protoreflect.EnumDescriptor

func (Volume_HostPathType) Enum 

func (x Volume_HostPathType) Enum() *Volume_HostPathType

func (Volume_HostPathType) EnumDescriptor deprecated 

func (Volume_HostPathType) EnumDescriptor() ([]byte, []int)

Deprecated: Use Volume_HostPathType.Descriptor instead.

func (Volume_HostPathType) Number 

func (x Volume_HostPathType) Number() protoreflect.EnumNumber

func (Volume_HostPathType) String 

func (x Volume_HostPathType) String() string

func (Volume_HostPathType) Type 

func (Volume_HostPathType) Type() protoreflect.EnumType

type Volume_MountPropagationMode 

type Volume_MountPropagationMode int32
const (
	Volume_NONE            Volume_MountPropagationMode = 0
	Volume_HOSTTOCONTAINER Volume_MountPropagationMode = 1
	Volume_BIDIRECTIONAL   Volume_MountPropagationMode = 2
)

func (Volume_MountPropagationMode) Descriptor 

func (Volume_MountPropagationMode) Descriptor() protoreflect.EnumDescriptor

func (Volume_MountPropagationMode) Enum 

func (x Volume_MountPropagationMode) Enum() *Volume_MountPropagationMode

func (Volume_MountPropagationMode) EnumDescriptor deprecated 

func (Volume_MountPropagationMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use Volume_MountPropagationMode.Descriptor instead.

func (Volume_MountPropagationMode) Number 

func (x Volume_MountPropagationMode) Number() protoreflect.EnumNumber

func (Volume_MountPropagationMode) String 

func (x Volume_MountPropagationMode) String() string

func (Volume_MountPropagationMode) Type 

func (Volume_MountPropagationMode) Type() protoreflect.EnumType

type Volume_VolumeType 

type Volume_VolumeType int32
const (
	Volume_PERSISTENT_VOLUME_CLAIM Volume_VolumeType = 0
	Volume_HOST_PATH               Volume_VolumeType = 1
	Volume_EPHEMERAL               Volume_VolumeType = 2 // Ephemeral (https://kubernetes.io/docs/concepts/storage/ephemeral-volumes/#generic-ephemeral-volumes)
	Volume_CONFIGMAP               Volume_VolumeType = 3 // Require map name and items, see https://kubernetes.io/docs/concepts/storage/volumes/#configmap
	Volume_SECRET                  Volume_VolumeType = 4 // Require secret name and optional items, see https://stackoverflow.com/questions/53296057/how-do-i-mount-a-single-file-from-a-secret-in-kubernetes
	Volume_EMPTY_DIR               Volume_VolumeType = 5 // Requires size limit, see https://kubernetes.io/docs/concepts/storage/volumes/#emptydir
)

func (Volume_VolumeType) Descriptor 

func (Volume_VolumeType) Descriptor() protoreflect.EnumDescriptor

func (Volume_VolumeType) Enum 

func (x Volume_VolumeType) Enum() *Volume_VolumeType

func (Volume_VolumeType) EnumDescriptor deprecated 

func (Volume_VolumeType) EnumDescriptor() ([]byte, []int)

Deprecated: Use Volume_VolumeType.Descriptor instead.

func (Volume_VolumeType) Number 

func (x Volume_VolumeType) Number() protoreflect.EnumNumber

func (Volume_VolumeType) String 

func (x Volume_VolumeType) String() string

func (Volume_VolumeType) Type 

func (Volume_VolumeType) Type() protoreflect.EnumType

type WorkerGroupSpec 

type WorkerGroupSpec struct {

	// Required. Group name of the current worker group
	GroupName string `protobuf:"bytes,1,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// Required. The computeTemplate of head node group
	ComputeTemplate string `protobuf:"bytes,2,opt,name=compute_template,json=computeTemplate,proto3" json:"compute_template,omitempty"`
	// Optional field. This field will be used to retrieve right ray container
	Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// Required. Desired replicas of the worker group
	Replicas int32 `protobuf:"varint,4,opt,name=replicas,proto3" json:"replicas,omitempty"`
	// Optional. Min replicas of the worker group, can't be greater than max_replicas.
	MinReplicas int32 `protobuf:"varint,5,opt,name=min_replicas,json=minReplicas,proto3" json:"min_replicas,omitempty"`
	// Required. Max replicas of the worker group (>0)
	MaxReplicas int32 `protobuf:"varint,6,opt,name=max_replicas,json=maxReplicas,proto3" json:"max_replicas,omitempty"`
	// Required. The ray start parameters of worker node group
	RayStartParams map[string]string `` /* 193-byte string literal not displayed */
	// Optional. The volumes mount to worker pods
	Volumes []*Volume `protobuf:"bytes,8,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// Optional. ServiceAccount used by worker pod
	// Note that the service account has to be created prior to usage here
	ServiceAccount string `protobuf:"bytes,9,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// Optional. image pull secret used by worker pod
	ImagePullSecret string `protobuf:"bytes,10,opt,name=image_pull_secret,json=imagePullSecret,proto3" json:"image_pull_secret,omitempty"`
	// Optional. Environment variables for worker pod
	Environment *EnvironmentVariables `protobuf:"bytes,11,opt,name=environment,proto3" json:"environment,omitempty"`
	// Optional. Annotations for the worker pod
	Annotations map[string]string `` /* 164-byte string literal not displayed */
	// Optional. Labels for the worker pod
	Labels map[string]string `` /* 154-byte string literal not displayed */
	// Optional image pull policy We only support Always and ifNotPresent
	ImagePullPolicy string `protobuf:"bytes,14,opt,name=imagePullPolicy,proto3" json:"imagePullPolicy,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerGroupSpec) Descriptor deprecated 

func (*WorkerGroupSpec) Descriptor() ([]byte, []int)

Deprecated: Use WorkerGroupSpec.ProtoReflect.Descriptor instead.

func (*WorkerGroupSpec) GetAnnotations 

func (x *WorkerGroupSpec) GetAnnotations() map[string]string

func (*WorkerGroupSpec) GetComputeTemplate 

func (x *WorkerGroupSpec) GetComputeTemplate() string

func (*WorkerGroupSpec) GetEnvironment 

func (x *WorkerGroupSpec) GetEnvironment() *EnvironmentVariables

func (*WorkerGroupSpec) GetGroupName 

func (x *WorkerGroupSpec) GetGroupName() string

func (*WorkerGroupSpec) GetImage 

func (x *WorkerGroupSpec) GetImage() string

func (*WorkerGroupSpec) GetImagePullPolicy 

func (x *WorkerGroupSpec) GetImagePullPolicy() string

func (*WorkerGroupSpec) GetImagePullSecret 

func (x *WorkerGroupSpec) GetImagePullSecret() string

func (*WorkerGroupSpec) GetLabels 

func (x *WorkerGroupSpec) GetLabels() map[string]string

func (*WorkerGroupSpec) GetMaxReplicas 

func (x *WorkerGroupSpec) GetMaxReplicas() int32

func (*WorkerGroupSpec) GetMinReplicas 

func (x *WorkerGroupSpec) GetMinReplicas() int32

func (*WorkerGroupSpec) GetRayStartParams 

func (x *WorkerGroupSpec) GetRayStartParams() map[string]string

func (*WorkerGroupSpec) GetReplicas 

func (x *WorkerGroupSpec) GetReplicas() int32

func (*WorkerGroupSpec) GetServiceAccount 

func (x *WorkerGroupSpec) GetServiceAccount() string

func (*WorkerGroupSpec) GetVolumes 

func (x *WorkerGroupSpec) GetVolumes() []*Volume

func (*WorkerGroupSpec) ProtoMessage 

func (*WorkerGroupSpec) ProtoMessage()

func (*WorkerGroupSpec) ProtoReflect 

func (x *WorkerGroupSpec) ProtoReflect() protoreflect.Message

func (*WorkerGroupSpec) Reset 

func (x *WorkerGroupSpec) Reset()

func (*WorkerGroupSpec) String 

func (x *WorkerGroupSpec) String() string

type WorkerGroupUpdateSpec 

type WorkerGroupUpdateSpec struct {

	// The name of the worker group to be updated.
	GroupName string `protobuf:"bytes,1,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// Required. The replicas of the worker group to be updated.
	Replicas int32 `protobuf:"varint,2,opt,name=replicas,proto3" json:"replicas,omitempty"`
	// Required. The min replicas of the worker group to be updated.
	MinReplicas int32 `protobuf:"varint,3,opt,name=min_replicas,json=minReplicas,proto3" json:"min_replicas,omitempty"`
	// Required. The max replicas of the worker group to be updated.
	MaxReplicas int32 `protobuf:"varint,4,opt,name=max_replicas,json=maxReplicas,proto3" json:"max_replicas,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerGroupUpdateSpec) Descriptor deprecated 

func (*WorkerGroupUpdateSpec) Descriptor() ([]byte, []int)

Deprecated: Use WorkerGroupUpdateSpec.ProtoReflect.Descriptor instead.

func (*WorkerGroupUpdateSpec) GetGroupName 

func (x *WorkerGroupUpdateSpec) GetGroupName() string

func (*WorkerGroupUpdateSpec) GetMaxReplicas 

func (x *WorkerGroupUpdateSpec) GetMaxReplicas() int32

func (*WorkerGroupUpdateSpec) GetMinReplicas 

func (x *WorkerGroupUpdateSpec) GetMinReplicas() int32

func (*WorkerGroupUpdateSpec) GetReplicas 

func (x *WorkerGroupUpdateSpec) GetReplicas() int32

func (*WorkerGroupUpdateSpec) ProtoMessage 

func (*WorkerGroupUpdateSpec) ProtoMessage()

func (*WorkerGroupUpdateSpec) ProtoReflect 

func (x *WorkerGroupUpdateSpec) ProtoReflect() protoreflect.Message

func (*WorkerGroupUpdateSpec) Reset 

func (x *WorkerGroupUpdateSpec) Reset()

func (*WorkerGroupUpdateSpec) String 

func (x *WorkerGroupUpdateSpec) String() string

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.