v1

package
v1.27.0 Latest Latest
Warning

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

Go to latest
Published: Sep 18, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var (
	InternalBatchJob_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "QUEUED",
		2: "RUNNING",
		3: "SUCCEEDED",
		4: "FAILED",
		5: "CANCELED",
		6: "DELETED",
	}
	InternalBatchJob_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"QUEUED":            1,
		"RUNNING":           2,
		"SUCCEEDED":         3,
		"FAILED":            4,
		"CANCELED":          5,
		"DELETED":           6,
	}
)

Enum value maps for InternalBatchJob_State.

View Source
var (
	InternalBatchJob_Action_name = map[int32]string{
		0: "ACTION_UNSPECIFIED",
		1: "CREATING",
		2: "CANCELING",
		3: "DELETING",
	}
	InternalBatchJob_Action_value = map[string]int32{
		"ACTION_UNSPECIFIED": 0,
		"CREATING":           1,
		"CANCELING":          2,
		"DELETING":           3,
	}
)

Enum value maps for InternalBatchJob_Action.

View Source
var (
	InternalJob_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "QUEUED",
		2: "RUNNING",
		3: "FAILED",
		4: "SUCCEEDED",
		5: "CANCELED",
	}
	InternalJob_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"QUEUED":            1,
		"RUNNING":           2,
		"FAILED":            3,
		"SUCCEEDED":         4,
		"CANCELED":          5,
	}
)

Enum value maps for InternalJob_State.

View Source
var (
	InternalJob_Action_name = map[int32]string{
		0: "ACTION_UNSPECIFIED",
		1: "CREATING",
		2: "CANCELING",
	}
	InternalJob_Action_value = map[string]int32{
		"ACTION_UNSPECIFIED": 0,
		"CREATING":           1,
		"CANCELING":          2,
	}
)

Enum value maps for InternalJob_Action.

View Source
var (
	UpdateJobPhaseRequest_Phase_name = map[int32]string{
		0: "PHASE_UNSPECIFIED",
		1: "PREPROCESSED",
		2: "JOB_CREATED",
		3: "FINETUNED",
		4: "FAILED",
		5: "RECREATE",
		6: "CANCELED",
	}
	UpdateJobPhaseRequest_Phase_value = map[string]int32{
		"PHASE_UNSPECIFIED": 0,
		"PREPROCESSED":      1,
		"JOB_CREATED":       2,
		"FINETUNED":         3,
		"FAILED":            4,
		"RECREATE":          5,
		"CANCELED":          6,
	}
)

Enum value maps for UpdateJobPhaseRequest_Phase.

View Source
var (
	NotebookState_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "QUEUED",
		2: "INITIALIZING",
		3: "RUNNING",
		4: "STOPPED",
		5: "FAILED",
		6: "DELETED",
		7: "REQUEUED",
	}
	NotebookState_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"QUEUED":            1,
		"INITIALIZING":      2,
		"RUNNING":           3,
		"STOPPED":           4,
		"FAILED":            5,
		"DELETED":           6,
		"REQUEUED":          7,
	}
)

Enum value maps for NotebookState.

View Source
var (
	NotebookQueuedAction_name = map[int32]string{
		0: "ACTION_UNSPECIFIED",
		1: "STARTING",
		2: "STOPPING",
		3: "DELETING",
		4: "REQUEUEING",
	}
	NotebookQueuedAction_value = map[string]int32{
		"ACTION_UNSPECIFIED": 0,
		"STARTING":           1,
		"STOPPING":           2,
		"DELETING":           3,
		"REQUEUEING":         4,
	}
)

Enum value maps for NotebookQueuedAction.

View Source
var BatchService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.batch.server.v1.BatchService",
	HandlerType: (*BatchServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateBatchJob",
			Handler:    _BatchService_CreateBatchJob_Handler,
		},
		{
			MethodName: "ListBatchJobs",
			Handler:    _BatchService_ListBatchJobs_Handler,
		},
		{
			MethodName: "GetBatchJob",
			Handler:    _BatchService_GetBatchJob_Handler,
		},
		{
			MethodName: "CancelBatchJob",
			Handler:    _BatchService_CancelBatchJob_Handler,
		},
		{
			MethodName: "DeleteBatchJob",
			Handler:    _BatchService_DeleteBatchJob_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/batch_service.proto",
}

BatchService_ServiceDesc is the grpc.ServiceDesc for BatchService 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 BatchWorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.batch.server.v1.BatchWorkerService",
	HandlerType: (*BatchWorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListQueuedInternalBatchJobs",
			Handler:    _BatchWorkerService_ListQueuedInternalBatchJobs_Handler,
		},
		{
			MethodName: "GetInternalBatchJob",
			Handler:    _BatchWorkerService_GetInternalBatchJob_Handler,
		},
		{
			MethodName: "UpdateBatchJobState",
			Handler:    _BatchWorkerService_UpdateBatchJobState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/batch_service.proto",
}

BatchWorkerService_ServiceDesc is the grpc.ServiceDesc for BatchWorkerService 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_api_v1_batch_service_proto protoreflect.FileDescriptor
View Source
var File_api_v1_fine_tuning_service_proto protoreflect.FileDescriptor
View Source
var File_api_v1_job_manager_server_proto protoreflect.FileDescriptor
View Source
var File_api_v1_job_manager_server_worker_proto protoreflect.FileDescriptor
View Source
var File_api_v1_syncer_service_proto protoreflect.FileDescriptor
View Source
var File_api_v1_workspace_service_proto protoreflect.FileDescriptor
View Source
var FineTuningService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.fine_tuning.server.v1.FineTuningService",
	HandlerType: (*FineTuningServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateJob",
			Handler:    _FineTuningService_CreateJob_Handler,
		},
		{
			MethodName: "ListJobs",
			Handler:    _FineTuningService_ListJobs_Handler,
		},
		{
			MethodName: "GetJob",
			Handler:    _FineTuningService_GetJob_Handler,
		},
		{
			MethodName: "CancelJob",
			Handler:    _FineTuningService_CancelJob_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/fine_tuning_service.proto",
}

FineTuningService_ServiceDesc is the grpc.ServiceDesc for FineTuningService 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 FineTuningWorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.fine_tuning.server.v1.FineTuningWorkerService",
	HandlerType: (*FineTuningWorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListQueuedInternalJobs",
			Handler:    _FineTuningWorkerService_ListQueuedInternalJobs_Handler,
		},
		{
			MethodName: "GetInternalJob",
			Handler:    _FineTuningWorkerService_GetInternalJob_Handler,
		},
		{
			MethodName: "UpdateJobPhase",
			Handler:    _FineTuningWorkerService_UpdateJobPhase_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/fine_tuning_service.proto",
}

FineTuningWorkerService_ServiceDesc is the grpc.ServiceDesc for FineTuningWorkerService 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 JobService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.jobs.server.v1.JobService",
	HandlerType: (*JobServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListClusters",
			Handler:    _JobService_ListClusters_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/job_manager_server.proto",
}

JobService_ServiceDesc is the grpc.ServiceDesc for JobService 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 JobWorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.jobs.server.v1.JobWorkerService",
	HandlerType: (*JobWorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpdateClusterStatus",
			Handler:    _JobWorkerService_UpdateClusterStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/job_manager_server_worker.proto",
}

JobWorkerService_ServiceDesc is the grpc.ServiceDesc for JobWorkerService 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 SyncerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.syncer.server.v1.SyncerService",
	HandlerType: (*SyncerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PatchKubernetesObject",
			Handler:    _SyncerService_PatchKubernetesObject_Handler,
		},
		{
			MethodName: "DeleteKubernetesObject",
			Handler:    _SyncerService_DeleteKubernetesObject_Handler,
		},
		{
			MethodName: "ListClusterIDs",
			Handler:    _SyncerService_ListClusterIDs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/syncer_service.proto",
}

SyncerService_ServiceDesc is the grpc.ServiceDesc for SyncerService 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 WorkspaceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.workspace.server.v1.WorkspaceService",
	HandlerType: (*WorkspaceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateNotebook",
			Handler:    _WorkspaceService_CreateNotebook_Handler,
		},
		{
			MethodName: "ListNotebooks",
			Handler:    _WorkspaceService_ListNotebooks_Handler,
		},
		{
			MethodName: "GetNotebook",
			Handler:    _WorkspaceService_GetNotebook_Handler,
		},
		{
			MethodName: "DeleteNotebook",
			Handler:    _WorkspaceService_DeleteNotebook_Handler,
		},
		{
			MethodName: "StopNotebook",
			Handler:    _WorkspaceService_StopNotebook_Handler,
		},
		{
			MethodName: "StartNotebook",
			Handler:    _WorkspaceService_StartNotebook_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/workspace_service.proto",
}

WorkspaceService_ServiceDesc is the grpc.ServiceDesc for WorkspaceService 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 WorkspaceWorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.workspace.server.v1.WorkspaceWorkerService",
	HandlerType: (*WorkspaceWorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListQueuedInternalNotebooks",
			Handler:    _WorkspaceWorkerService_ListQueuedInternalNotebooks_Handler,
		},
		{
			MethodName: "UpdateNotebookState",
			Handler:    _WorkspaceWorkerService_UpdateNotebookState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/workspace_service.proto",
}

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

Functions

func RegisterBatchServiceHandler

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

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

func RegisterBatchServiceHandlerClient

func RegisterBatchServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BatchServiceClient) error

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

func RegisterBatchServiceHandlerFromEndpoint

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

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

func RegisterBatchServiceHandlerServer

func RegisterBatchServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BatchServiceServer) error

RegisterBatchServiceHandlerServer registers the http handlers for service BatchService to "mux". UnaryRPC :call BatchServiceServer 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 RegisterBatchServiceHandlerFromEndpoint instead.

func RegisterBatchServiceServer

func RegisterBatchServiceServer(s grpc.ServiceRegistrar, srv BatchServiceServer)

func RegisterBatchWorkerServiceServer

func RegisterBatchWorkerServiceServer(s grpc.ServiceRegistrar, srv BatchWorkerServiceServer)

func RegisterFineTuningServiceHandler

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

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

func RegisterFineTuningServiceHandlerClient

func RegisterFineTuningServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FineTuningServiceClient) error

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

func RegisterFineTuningServiceHandlerFromEndpoint

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

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

func RegisterFineTuningServiceHandlerServer

func RegisterFineTuningServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server FineTuningServiceServer) error

RegisterFineTuningServiceHandlerServer registers the http handlers for service FineTuningService to "mux". UnaryRPC :call FineTuningServiceServer 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 RegisterFineTuningServiceHandlerFromEndpoint instead.

func RegisterFineTuningServiceServer

func RegisterFineTuningServiceServer(s grpc.ServiceRegistrar, srv FineTuningServiceServer)

func RegisterFineTuningWorkerServiceServer

func RegisterFineTuningWorkerServiceServer(s grpc.ServiceRegistrar, srv FineTuningWorkerServiceServer)

func RegisterJobServiceHandler added in v1.6.0

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

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

func RegisterJobServiceHandlerClient added in v1.6.0

func RegisterJobServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobServiceClient) error

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

func RegisterJobServiceHandlerFromEndpoint added in v1.6.0

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

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

func RegisterJobServiceHandlerServer added in v1.6.0

func RegisterJobServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobServiceServer) error

RegisterJobServiceHandlerServer registers the http handlers for service JobService to "mux". UnaryRPC :call JobServiceServer 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 RegisterJobServiceHandlerFromEndpoint instead.

func RegisterJobServiceServer added in v1.5.0

func RegisterJobServiceServer(s grpc.ServiceRegistrar, srv JobServiceServer)

func RegisterJobWorkerServiceServer added in v1.5.0

func RegisterJobWorkerServiceServer(s grpc.ServiceRegistrar, srv JobWorkerServiceServer)

func RegisterSyncerServiceServer added in v1.5.0

func RegisterSyncerServiceServer(s grpc.ServiceRegistrar, srv SyncerServiceServer)

func RegisterWorkspaceServiceHandler

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

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

func RegisterWorkspaceServiceHandlerClient

func RegisterWorkspaceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WorkspaceServiceClient) error

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

func RegisterWorkspaceServiceHandlerFromEndpoint

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

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

func RegisterWorkspaceServiceHandlerServer

func RegisterWorkspaceServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WorkspaceServiceServer) error

RegisterWorkspaceServiceHandlerServer registers the http handlers for service WorkspaceService to "mux". UnaryRPC :call WorkspaceServiceServer 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 RegisterWorkspaceServiceHandlerFromEndpoint instead.

func RegisterWorkspaceServiceServer

func RegisterWorkspaceServiceServer(s grpc.ServiceRegistrar, srv WorkspaceServiceServer)

func RegisterWorkspaceWorkerServiceServer

func RegisterWorkspaceWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkspaceWorkerServiceServer)

Types

type BatchJob

type BatchJob struct {
	Id                  string              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt           int64               `protobuf:"varint,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	FinishedAt          int64               `protobuf:"varint,3,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	Error               *BatchJob_Error     `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	Status              string              `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	Image               string              `protobuf:"bytes,6,opt,name=image,proto3" json:"image,omitempty"`
	Command             string              `protobuf:"bytes,7,opt,name=command,proto3" json:"command,omitempty"`
	Resources           *BatchJob_Resources `protobuf:"bytes,8,opt,name=resources,proto3" json:"resources,omitempty"`
	Envs                map[string]string   `` /* 149-byte string literal not displayed */
	DataFiles           []string            `protobuf:"bytes,10,rep,name=data_files,json=dataFiles,proto3" json:"data_files,omitempty"`
	ProjectId           string              `protobuf:"bytes,11,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	KubernetesNamespace string              `protobuf:"bytes,12,opt,name=kubernetes_namespace,json=kubernetesNamespace,proto3" json:"kubernetes_namespace,omitempty"`
	// cluster_id is the ID of the cluster where he job runs.
	ClusterId         string         `protobuf:"bytes,13,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Kind              *BatchJob_Kind `protobuf:"bytes,15,opt,name=kind,proto3" json:"kind,omitempty"`
	OrganizationTitle string         `protobuf:"bytes,16,opt,name=organization_title,json=organizationTitle,proto3" json:"organization_title,omitempty"`
	ProjectTitle      string         `protobuf:"bytes,17,opt,name=project_title,json=projectTitle,proto3" json:"project_title,omitempty"`
	ClusterName       string         `protobuf:"bytes,18,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchJob) Descriptor deprecated

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

Deprecated: Use BatchJob.ProtoReflect.Descriptor instead.

func (*BatchJob) GetClusterId

func (x *BatchJob) GetClusterId() string

func (*BatchJob) GetClusterName added in v1.5.0

func (x *BatchJob) GetClusterName() string

func (*BatchJob) GetCommand

func (x *BatchJob) GetCommand() string

func (*BatchJob) GetCreatedAt

func (x *BatchJob) GetCreatedAt() int64

func (*BatchJob) GetDataFiles

func (x *BatchJob) GetDataFiles() []string

func (*BatchJob) GetEnvs

func (x *BatchJob) GetEnvs() map[string]string

func (*BatchJob) GetError

func (x *BatchJob) GetError() *BatchJob_Error

func (*BatchJob) GetFinishedAt

func (x *BatchJob) GetFinishedAt() int64

func (*BatchJob) GetId

func (x *BatchJob) GetId() string

func (*BatchJob) GetImage

func (x *BatchJob) GetImage() string

func (*BatchJob) GetKind

func (x *BatchJob) GetKind() *BatchJob_Kind

func (*BatchJob) GetKubernetesNamespace

func (x *BatchJob) GetKubernetesNamespace() string

func (*BatchJob) GetOrganizationTitle added in v1.5.0

func (x *BatchJob) GetOrganizationTitle() string

func (*BatchJob) GetProjectId

func (x *BatchJob) GetProjectId() string

func (*BatchJob) GetProjectTitle added in v1.5.0

func (x *BatchJob) GetProjectTitle() string

func (*BatchJob) GetResources

func (x *BatchJob) GetResources() *BatchJob_Resources

func (*BatchJob) GetStatus

func (x *BatchJob) GetStatus() string

func (*BatchJob) ProtoMessage

func (*BatchJob) ProtoMessage()

func (*BatchJob) ProtoReflect

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

func (*BatchJob) Reset

func (x *BatchJob) Reset()

func (*BatchJob) String

func (x *BatchJob) String() string

type BatchJob_Error

type BatchJob_Error struct {
	Code    string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchJob_Error) Descriptor deprecated

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

Deprecated: Use BatchJob_Error.ProtoReflect.Descriptor instead.

func (*BatchJob_Error) GetCode

func (x *BatchJob_Error) GetCode() string

func (*BatchJob_Error) GetMessage

func (x *BatchJob_Error) GetMessage() string

func (*BatchJob_Error) ProtoMessage

func (*BatchJob_Error) ProtoMessage()

func (*BatchJob_Error) ProtoReflect

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

func (*BatchJob_Error) Reset

func (x *BatchJob_Error) Reset()

func (*BatchJob_Error) String

func (x *BatchJob_Error) String() string

type BatchJob_Kind

type BatchJob_Kind struct {

	// Types that are assignable to Kind:
	//
	//	*BatchJob_Kind_Pytorch
	Kind isBatchJob_Kind_Kind `protobuf_oneof:"Kind"`
	// contains filtered or unexported fields
}

func (*BatchJob_Kind) Descriptor deprecated

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

Deprecated: Use BatchJob_Kind.ProtoReflect.Descriptor instead.

func (*BatchJob_Kind) GetKind

func (m *BatchJob_Kind) GetKind() isBatchJob_Kind_Kind

func (*BatchJob_Kind) GetPytorch

func (x *BatchJob_Kind) GetPytorch() *PyTorchJob

func (*BatchJob_Kind) ProtoMessage

func (*BatchJob_Kind) ProtoMessage()

func (*BatchJob_Kind) ProtoReflect

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

func (*BatchJob_Kind) Reset

func (x *BatchJob_Kind) Reset()

func (*BatchJob_Kind) String

func (x *BatchJob_Kind) String() string

type BatchJob_Kind_Pytorch

type BatchJob_Kind_Pytorch struct {
	Pytorch *PyTorchJob `protobuf:"bytes,14,opt,name=pytorch,proto3,oneof"`
}

type BatchJob_Resources

type BatchJob_Resources struct {
	GpuCount int32 `protobuf:"varint,1,opt,name=gpu_count,json=gpuCount,proto3" json:"gpu_count,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchJob_Resources) Descriptor deprecated

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

Deprecated: Use BatchJob_Resources.ProtoReflect.Descriptor instead.

func (*BatchJob_Resources) GetGpuCount

func (x *BatchJob_Resources) GetGpuCount() int32

func (*BatchJob_Resources) ProtoMessage

func (*BatchJob_Resources) ProtoMessage()

func (*BatchJob_Resources) ProtoReflect

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

func (*BatchJob_Resources) Reset

func (x *BatchJob_Resources) Reset()

func (*BatchJob_Resources) String

func (x *BatchJob_Resources) String() string

type BatchServiceClient

type BatchServiceClient interface {
	CreateBatchJob(ctx context.Context, in *CreateBatchJobRequest, opts ...grpc.CallOption) (*BatchJob, error)
	ListBatchJobs(ctx context.Context, in *ListBatchJobsRequest, opts ...grpc.CallOption) (*ListBatchJobsResponse, error)
	GetBatchJob(ctx context.Context, in *GetBatchJobRequest, opts ...grpc.CallOption) (*BatchJob, error)
	CancelBatchJob(ctx context.Context, in *CancelBatchJobRequest, opts ...grpc.CallOption) (*BatchJob, error)
	DeleteBatchJob(ctx context.Context, in *DeleteBatchJobRequest, opts ...grpc.CallOption) (*BatchJob, error)
}

BatchServiceClient is the client API for BatchService 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.

type BatchServiceServer

type BatchServiceServer interface {
	CreateBatchJob(context.Context, *CreateBatchJobRequest) (*BatchJob, error)
	ListBatchJobs(context.Context, *ListBatchJobsRequest) (*ListBatchJobsResponse, error)
	GetBatchJob(context.Context, *GetBatchJobRequest) (*BatchJob, error)
	CancelBatchJob(context.Context, *CancelBatchJobRequest) (*BatchJob, error)
	DeleteBatchJob(context.Context, *DeleteBatchJobRequest) (*BatchJob, error)
	// contains filtered or unexported methods
}

BatchServiceServer is the server API for BatchService service. All implementations must embed UnimplementedBatchServiceServer for forward compatibility

type BatchWorkerServiceClient

type BatchWorkerServiceClient interface {
	ListQueuedInternalBatchJobs(ctx context.Context, in *ListQueuedInternalBatchJobsRequest, opts ...grpc.CallOption) (*ListQueuedInternalBatchJobsResponse, error)
	GetInternalBatchJob(ctx context.Context, in *GetInternalBatchJobRequest, opts ...grpc.CallOption) (*InternalBatchJob, error)
	UpdateBatchJobState(ctx context.Context, in *UpdateBatchJobStateRequest, opts ...grpc.CallOption) (*UpdateBatchJobStateResponse, error)
}

BatchWorkerServiceClient is the client API for BatchWorkerService 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.

type BatchWorkerServiceServer

type BatchWorkerServiceServer interface {
	ListQueuedInternalBatchJobs(context.Context, *ListQueuedInternalBatchJobsRequest) (*ListQueuedInternalBatchJobsResponse, error)
	GetInternalBatchJob(context.Context, *GetInternalBatchJobRequest) (*InternalBatchJob, error)
	UpdateBatchJobState(context.Context, *UpdateBatchJobStateRequest) (*UpdateBatchJobStateResponse, error)
	// contains filtered or unexported methods
}

BatchWorkerServiceServer is the server API for BatchWorkerService service. All implementations must embed UnimplementedBatchWorkerServiceServer for forward compatibility

type CancelBatchJobRequest

type CancelBatchJobRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelBatchJobRequest) Descriptor deprecated

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

Deprecated: Use CancelBatchJobRequest.ProtoReflect.Descriptor instead.

func (*CancelBatchJobRequest) GetId

func (x *CancelBatchJobRequest) GetId() string

func (*CancelBatchJobRequest) ProtoMessage

func (*CancelBatchJobRequest) ProtoMessage()

func (*CancelBatchJobRequest) ProtoReflect

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

func (*CancelBatchJobRequest) Reset

func (x *CancelBatchJobRequest) Reset()

func (*CancelBatchJobRequest) String

func (x *CancelBatchJobRequest) String() string

type CancelJobRequest

type CancelJobRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelJobRequest) Descriptor deprecated

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

Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.

func (*CancelJobRequest) GetId

func (x *CancelJobRequest) GetId() string

func (*CancelJobRequest) ProtoMessage

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) ProtoReflect

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

func (*CancelJobRequest) Reset

func (x *CancelJobRequest) Reset()

func (*CancelJobRequest) String

func (x *CancelJobRequest) String() string

type Cluster added in v1.5.0

type Cluster struct {
	Id      string           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name    string           `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Status  *ClusterStatus   `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Summary *Cluster_Summary `protobuf:"bytes,4,opt,name=summary,proto3" json:"summary,omitempty"`
	// last_updated_at is the last time the cluster was updated in Unix nano seconds.
	LastUpdatedAt int64 `protobuf:"varint,5,opt,name=last_updated_at,json=lastUpdatedAt,proto3" json:"last_updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster) Descriptor deprecated added in v1.5.0

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetId added in v1.5.0

func (x *Cluster) GetId() string

func (*Cluster) GetLastUpdatedAt added in v1.6.0

func (x *Cluster) GetLastUpdatedAt() int64

func (*Cluster) GetName added in v1.6.0

func (x *Cluster) GetName() string

func (*Cluster) GetStatus added in v1.5.0

func (x *Cluster) GetStatus() *ClusterStatus

func (*Cluster) GetSummary added in v1.6.0

func (x *Cluster) GetSummary() *Cluster_Summary

func (*Cluster) ProtoMessage added in v1.5.0

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect added in v1.5.0

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

func (*Cluster) Reset added in v1.5.0

func (x *Cluster) Reset()

func (*Cluster) String added in v1.5.0

func (x *Cluster) String() string

type ClusterStatus added in v1.5.0

type ClusterStatus struct {
	GpuNodes               []*GpuNode               `protobuf:"bytes,1,rep,name=gpu_nodes,json=gpuNodes,proto3" json:"gpu_nodes,omitempty"`
	ProvisionableResources []*ProvisionableResource `` /* 127-byte string literal not displayed */
	// TODO(kenji): Revisit if this becomes too large.
	GpuPods []*GpuPod `protobuf:"bytes,3,rep,name=gpu_pods,json=gpuPods,proto3" json:"gpu_pods,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterStatus) Descriptor deprecated added in v1.5.0

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

Deprecated: Use ClusterStatus.ProtoReflect.Descriptor instead.

func (*ClusterStatus) GetGpuNodes added in v1.5.0

func (x *ClusterStatus) GetGpuNodes() []*GpuNode

func (*ClusterStatus) GetGpuPods added in v1.6.0

func (x *ClusterStatus) GetGpuPods() []*GpuPod

func (*ClusterStatus) GetProvisionableResources added in v1.5.0

func (x *ClusterStatus) GetProvisionableResources() []*ProvisionableResource

func (*ClusterStatus) ProtoMessage added in v1.5.0

func (*ClusterStatus) ProtoMessage()

func (*ClusterStatus) ProtoReflect added in v1.5.0

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

func (*ClusterStatus) Reset added in v1.5.0

func (x *ClusterStatus) Reset()

func (*ClusterStatus) String added in v1.5.0

func (x *ClusterStatus) String() string

type Cluster_Summary added in v1.6.0

type Cluster_Summary struct {
	GpuCapacity  int32 `protobuf:"varint,1,opt,name=gpu_capacity,json=gpuCapacity,proto3" json:"gpu_capacity,omitempty"`
	GpuAllocated int32 `protobuf:"varint,2,opt,name=gpu_allocated,json=gpuAllocated,proto3" json:"gpu_allocated,omitempty"`
	GpuPodCount  int32 `protobuf:"varint,3,opt,name=gpu_pod_count,json=gpuPodCount,proto3" json:"gpu_pod_count,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster_Summary) Descriptor deprecated added in v1.6.0

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

Deprecated: Use Cluster_Summary.ProtoReflect.Descriptor instead.

func (*Cluster_Summary) GetGpuAllocated added in v1.6.0

func (x *Cluster_Summary) GetGpuAllocated() int32

func (*Cluster_Summary) GetGpuCapacity added in v1.6.0

func (x *Cluster_Summary) GetGpuCapacity() int32

func (*Cluster_Summary) GetGpuPodCount added in v1.6.0

func (x *Cluster_Summary) GetGpuPodCount() int32

func (*Cluster_Summary) ProtoMessage added in v1.6.0

func (*Cluster_Summary) ProtoMessage()

func (*Cluster_Summary) ProtoReflect added in v1.6.0

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

func (*Cluster_Summary) Reset added in v1.6.0

func (x *Cluster_Summary) Reset()

func (*Cluster_Summary) String added in v1.6.0

func (x *Cluster_Summary) String() string

type CreateBatchJobRequest

type CreateBatchJobRequest struct {
	Image   string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// scripts is a map of script names to script contents.
	// The total size of the scripts should not exceed 1MB.
	Scripts   map[string][]byte   `` /* 155-byte string literal not displayed */
	Resources *BatchJob_Resources `protobuf:"bytes,4,opt,name=resources,proto3" json:"resources,omitempty"`
	Envs      map[string]string   `` /* 149-byte string literal not displayed */
	// data_files is a list of file IDs that will be downloaded to the container.
	DataFiles []string       `protobuf:"bytes,6,rep,name=data_files,json=dataFiles,proto3" json:"data_files,omitempty"`
	Kind      *BatchJob_Kind `protobuf:"bytes,7,opt,name=kind,proto3" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBatchJobRequest) Descriptor deprecated

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

Deprecated: Use CreateBatchJobRequest.ProtoReflect.Descriptor instead.

func (*CreateBatchJobRequest) GetCommand

func (x *CreateBatchJobRequest) GetCommand() string

func (*CreateBatchJobRequest) GetDataFiles

func (x *CreateBatchJobRequest) GetDataFiles() []string

func (*CreateBatchJobRequest) GetEnvs

func (x *CreateBatchJobRequest) GetEnvs() map[string]string

func (*CreateBatchJobRequest) GetImage

func (x *CreateBatchJobRequest) GetImage() string

func (*CreateBatchJobRequest) GetKind

func (x *CreateBatchJobRequest) GetKind() *BatchJob_Kind

func (*CreateBatchJobRequest) GetResources

func (x *CreateBatchJobRequest) GetResources() *BatchJob_Resources

func (*CreateBatchJobRequest) GetScripts

func (x *CreateBatchJobRequest) GetScripts() map[string][]byte

func (*CreateBatchJobRequest) ProtoMessage

func (*CreateBatchJobRequest) ProtoMessage()

func (*CreateBatchJobRequest) ProtoReflect

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

func (*CreateBatchJobRequest) Reset

func (x *CreateBatchJobRequest) Reset()

func (*CreateBatchJobRequest) String

func (x *CreateBatchJobRequest) String() string

type CreateJobRequest

type CreateJobRequest struct {
	Model           string                            `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"`
	TrainingFile    string                            `protobuf:"bytes,2,opt,name=training_file,json=trainingFile,proto3" json:"training_file,omitempty"`
	Hyperparameters *CreateJobRequest_Hyperparameters `protobuf:"bytes,3,opt,name=hyperparameters,proto3" json:"hyperparameters,omitempty"`
	// A string of up to 18 characters that will be added to your fine-tuned model name.
	//
	// For example, a suffix of "custom-model-name" would produce a
	// model name like
	// ft:gpt-3.5-turbo:openai:custom-model-name:7p4lURel.
	Suffix         string         `protobuf:"bytes,4,opt,name=suffix,proto3" json:"suffix,omitempty"`
	ValidationFile string         `protobuf:"bytes,5,opt,name=validation_file,json=validationFile,proto3" json:"validation_file,omitempty"`
	Integrations   []*Integration `protobuf:"bytes,6,rep,name=integrations,proto3" json:"integrations,omitempty"`
	Seed           int32          `protobuf:"varint,7,opt,name=seed,proto3" json:"seed,omitempty"`
	Resources      *Job_Resources `protobuf:"bytes,8,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateJobRequest) Descriptor deprecated

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

Deprecated: Use CreateJobRequest.ProtoReflect.Descriptor instead.

func (*CreateJobRequest) GetHyperparameters

func (x *CreateJobRequest) GetHyperparameters() *CreateJobRequest_Hyperparameters

func (*CreateJobRequest) GetIntegrations

func (x *CreateJobRequest) GetIntegrations() []*Integration

func (*CreateJobRequest) GetModel

func (x *CreateJobRequest) GetModel() string

func (*CreateJobRequest) GetResources added in v1.17.0

func (x *CreateJobRequest) GetResources() *Job_Resources

func (*CreateJobRequest) GetSeed

func (x *CreateJobRequest) GetSeed() int32

func (*CreateJobRequest) GetSuffix

func (x *CreateJobRequest) GetSuffix() string

func (*CreateJobRequest) GetTrainingFile

func (x *CreateJobRequest) GetTrainingFile() string

func (*CreateJobRequest) GetValidationFile

func (x *CreateJobRequest) GetValidationFile() string

func (*CreateJobRequest) ProtoMessage

func (*CreateJobRequest) ProtoMessage()

func (*CreateJobRequest) ProtoReflect

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

func (*CreateJobRequest) Reset

func (x *CreateJobRequest) Reset()

func (*CreateJobRequest) String

func (x *CreateJobRequest) String() string

type CreateJobRequest_Hyperparameters

type CreateJobRequest_Hyperparameters struct {

	// Note: OpenAI API supports string or interger.
	BatchSize int32 `protobuf:"varint,1,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// Note: OpenAI API supports string or number.
	LearningRateMultiplier float64 `` /* 131-byte string literal not displayed */
	// Note: OpenAI API supports string or interger.
	NEpochs int32 `protobuf:"varint,3,opt,name=n_epochs,json=nEpochs,proto3" json:"n_epochs,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateJobRequest_Hyperparameters) Descriptor deprecated

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

Deprecated: Use CreateJobRequest_Hyperparameters.ProtoReflect.Descriptor instead.

func (*CreateJobRequest_Hyperparameters) GetBatchSize

func (x *CreateJobRequest_Hyperparameters) GetBatchSize() int32

func (*CreateJobRequest_Hyperparameters) GetLearningRateMultiplier

func (x *CreateJobRequest_Hyperparameters) GetLearningRateMultiplier() float64

func (*CreateJobRequest_Hyperparameters) GetNEpochs

func (x *CreateJobRequest_Hyperparameters) GetNEpochs() int32

func (*CreateJobRequest_Hyperparameters) ProtoMessage

func (*CreateJobRequest_Hyperparameters) ProtoMessage()

func (*CreateJobRequest_Hyperparameters) ProtoReflect

func (*CreateJobRequest_Hyperparameters) Reset

func (*CreateJobRequest_Hyperparameters) String

type CreateNotebookRequest

type CreateNotebookRequest struct {
	Name                   string                       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Image                  *CreateNotebookRequest_Image `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Resources              *Resources                   `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"`
	Envs                   map[string]string            `` /* 149-byte string literal not displayed */
	AdditionalExposedPorts []int32                      `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateNotebookRequest) Descriptor deprecated

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

Deprecated: Use CreateNotebookRequest.ProtoReflect.Descriptor instead.

func (*CreateNotebookRequest) GetAdditionalExposedPorts added in v1.24.0

func (x *CreateNotebookRequest) GetAdditionalExposedPorts() []int32

func (*CreateNotebookRequest) GetEnvs

func (x *CreateNotebookRequest) GetEnvs() map[string]string

func (*CreateNotebookRequest) GetImage

func (*CreateNotebookRequest) GetName

func (x *CreateNotebookRequest) GetName() string

func (*CreateNotebookRequest) GetResources

func (x *CreateNotebookRequest) GetResources() *Resources

func (*CreateNotebookRequest) ProtoMessage

func (*CreateNotebookRequest) ProtoMessage()

func (*CreateNotebookRequest) ProtoReflect

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

func (*CreateNotebookRequest) Reset

func (x *CreateNotebookRequest) Reset()

func (*CreateNotebookRequest) String

func (x *CreateNotebookRequest) String() string

type CreateNotebookRequest_Image

type CreateNotebookRequest_Image struct {

	// Types that are assignable to Image:
	//
	//	*CreateNotebookRequest_Image_Type
	//	*CreateNotebookRequest_Image_Uri
	Image isCreateNotebookRequest_Image_Image `protobuf_oneof:"image"`
	// contains filtered or unexported fields
}

func (*CreateNotebookRequest_Image) Descriptor deprecated

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

Deprecated: Use CreateNotebookRequest_Image.ProtoReflect.Descriptor instead.

func (*CreateNotebookRequest_Image) GetImage

func (m *CreateNotebookRequest_Image) GetImage() isCreateNotebookRequest_Image_Image

func (*CreateNotebookRequest_Image) GetType

func (x *CreateNotebookRequest_Image) GetType() string

func (*CreateNotebookRequest_Image) GetUri

func (x *CreateNotebookRequest_Image) GetUri() string

func (*CreateNotebookRequest_Image) ProtoMessage

func (*CreateNotebookRequest_Image) ProtoMessage()

func (*CreateNotebookRequest_Image) ProtoReflect

func (*CreateNotebookRequest_Image) Reset

func (x *CreateNotebookRequest_Image) Reset()

func (*CreateNotebookRequest_Image) String

func (x *CreateNotebookRequest_Image) String() string

type CreateNotebookRequest_Image_Type

type CreateNotebookRequest_Image_Type struct {
	// Type of preset images.
	Type string `protobuf:"bytes,1,opt,name=type,proto3,oneof"`
}

type CreateNotebookRequest_Image_Uri

type CreateNotebookRequest_Image_Uri struct {
	// URI to the custom container image.
	Uri string `protobuf:"bytes,2,opt,name=uri,proto3,oneof"`
}

type DeleteBatchJobRequest

type DeleteBatchJobRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBatchJobRequest) Descriptor deprecated

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

Deprecated: Use DeleteBatchJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteBatchJobRequest) GetId

func (x *DeleteBatchJobRequest) GetId() string

func (*DeleteBatchJobRequest) ProtoMessage

func (*DeleteBatchJobRequest) ProtoMessage()

func (*DeleteBatchJobRequest) ProtoReflect

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

func (*DeleteBatchJobRequest) Reset

func (x *DeleteBatchJobRequest) Reset()

func (*DeleteBatchJobRequest) String

func (x *DeleteBatchJobRequest) String() string

type DeleteKubernetesObjectRequest added in v1.5.0

type DeleteKubernetesObjectRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Group     string `protobuf:"bytes,4,opt,name=Group,proto3" json:"Group,omitempty"`
	Version   string `protobuf:"bytes,5,opt,name=Version,proto3" json:"Version,omitempty"`
	Resource  string `protobuf:"bytes,6,opt,name=Resource,proto3" json:"Resource,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKubernetesObjectRequest) Descriptor deprecated added in v1.5.0

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

Deprecated: Use DeleteKubernetesObjectRequest.ProtoReflect.Descriptor instead.

func (*DeleteKubernetesObjectRequest) GetClusterId added in v1.5.0

func (x *DeleteKubernetesObjectRequest) GetClusterId() string

func (*DeleteKubernetesObjectRequest) GetGroup added in v1.5.0

func (x *DeleteKubernetesObjectRequest) GetGroup() string

func (*DeleteKubernetesObjectRequest) GetName added in v1.5.0

func (*DeleteKubernetesObjectRequest) GetNamespace added in v1.5.0

func (x *DeleteKubernetesObjectRequest) GetNamespace() string

func (*DeleteKubernetesObjectRequest) GetResource added in v1.5.0

func (x *DeleteKubernetesObjectRequest) GetResource() string

func (*DeleteKubernetesObjectRequest) GetVersion added in v1.5.0

func (x *DeleteKubernetesObjectRequest) GetVersion() string

func (*DeleteKubernetesObjectRequest) ProtoMessage added in v1.5.0

func (*DeleteKubernetesObjectRequest) ProtoMessage()

func (*DeleteKubernetesObjectRequest) ProtoReflect added in v1.5.0

func (*DeleteKubernetesObjectRequest) Reset added in v1.5.0

func (x *DeleteKubernetesObjectRequest) Reset()

func (*DeleteKubernetesObjectRequest) String added in v1.5.0

type DeleteKubernetesObjectResponse added in v1.5.0

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

func (*DeleteKubernetesObjectResponse) Descriptor deprecated added in v1.5.0

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

Deprecated: Use DeleteKubernetesObjectResponse.ProtoReflect.Descriptor instead.

func (*DeleteKubernetesObjectResponse) ProtoMessage added in v1.5.0

func (*DeleteKubernetesObjectResponse) ProtoMessage()

func (*DeleteKubernetesObjectResponse) ProtoReflect added in v1.5.0

func (*DeleteKubernetesObjectResponse) Reset added in v1.5.0

func (x *DeleteKubernetesObjectResponse) Reset()

func (*DeleteKubernetesObjectResponse) String added in v1.5.0

type DeleteNotebookRequest

type DeleteNotebookRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteNotebookRequest) Descriptor deprecated

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

Deprecated: Use DeleteNotebookRequest.ProtoReflect.Descriptor instead.

func (*DeleteNotebookRequest) GetId

func (x *DeleteNotebookRequest) GetId() string

func (*DeleteNotebookRequest) ProtoMessage

func (*DeleteNotebookRequest) ProtoMessage()

func (*DeleteNotebookRequest) ProtoReflect

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

func (*DeleteNotebookRequest) Reset

func (x *DeleteNotebookRequest) Reset()

func (*DeleteNotebookRequest) String

func (x *DeleteNotebookRequest) String() string

type DeleteNotebookResponse

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

func (*DeleteNotebookResponse) Descriptor deprecated

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

Deprecated: Use DeleteNotebookResponse.ProtoReflect.Descriptor instead.

func (*DeleteNotebookResponse) ProtoMessage

func (*DeleteNotebookResponse) ProtoMessage()

func (*DeleteNotebookResponse) ProtoReflect

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

func (*DeleteNotebookResponse) Reset

func (x *DeleteNotebookResponse) Reset()

func (*DeleteNotebookResponse) String

func (x *DeleteNotebookResponse) String() string

type FineTuningServiceClient

type FineTuningServiceClient interface {
	CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error)
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
	CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*Job, error)
}

FineTuningServiceClient is the client API for FineTuningService 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.

type FineTuningServiceServer

type FineTuningServiceServer interface {
	CreateJob(context.Context, *CreateJobRequest) (*Job, error)
	ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
	GetJob(context.Context, *GetJobRequest) (*Job, error)
	CancelJob(context.Context, *CancelJobRequest) (*Job, error)
	// contains filtered or unexported methods
}

FineTuningServiceServer is the server API for FineTuningService service. All implementations must embed UnimplementedFineTuningServiceServer for forward compatibility

type FineTuningWorkerServiceClient

type FineTuningWorkerServiceClient interface {
	ListQueuedInternalJobs(ctx context.Context, in *ListQueuedInternalJobsRequest, opts ...grpc.CallOption) (*ListQueuedInternalJobsResponse, error)
	GetInternalJob(ctx context.Context, in *GetInternalJobRequest, opts ...grpc.CallOption) (*InternalJob, error)
	// UpdateJobPhase updates the job status depending on the phase.
	UpdateJobPhase(ctx context.Context, in *UpdateJobPhaseRequest, opts ...grpc.CallOption) (*UpdateJobPhaseResponse, error)
}

FineTuningWorkerServiceClient is the client API for FineTuningWorkerService 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.

type FineTuningWorkerServiceServer

type FineTuningWorkerServiceServer interface {
	ListQueuedInternalJobs(context.Context, *ListQueuedInternalJobsRequest) (*ListQueuedInternalJobsResponse, error)
	GetInternalJob(context.Context, *GetInternalJobRequest) (*InternalJob, error)
	// UpdateJobPhase updates the job status depending on the phase.
	UpdateJobPhase(context.Context, *UpdateJobPhaseRequest) (*UpdateJobPhaseResponse, error)
	// contains filtered or unexported methods
}

FineTuningWorkerServiceServer is the server API for FineTuningWorkerService service. All implementations must embed UnimplementedFineTuningWorkerServiceServer for forward compatibility

type GetBatchJobRequest

type GetBatchJobRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBatchJobRequest) Descriptor deprecated

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

Deprecated: Use GetBatchJobRequest.ProtoReflect.Descriptor instead.

func (*GetBatchJobRequest) GetId

func (x *GetBatchJobRequest) GetId() string

func (*GetBatchJobRequest) ProtoMessage

func (*GetBatchJobRequest) ProtoMessage()

func (*GetBatchJobRequest) ProtoReflect

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

func (*GetBatchJobRequest) Reset

func (x *GetBatchJobRequest) Reset()

func (*GetBatchJobRequest) String

func (x *GetBatchJobRequest) String() string

type GetInternalBatchJobRequest

type GetInternalBatchJobRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInternalBatchJobRequest) Descriptor deprecated

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

Deprecated: Use GetInternalBatchJobRequest.ProtoReflect.Descriptor instead.

func (*GetInternalBatchJobRequest) GetId

func (*GetInternalBatchJobRequest) ProtoMessage

func (*GetInternalBatchJobRequest) ProtoMessage()

func (*GetInternalBatchJobRequest) ProtoReflect

func (*GetInternalBatchJobRequest) Reset

func (x *GetInternalBatchJobRequest) Reset()

func (*GetInternalBatchJobRequest) String

func (x *GetInternalBatchJobRequest) String() string

type GetInternalJobRequest

type GetInternalJobRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInternalJobRequest) Descriptor deprecated

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

Deprecated: Use GetInternalJobRequest.ProtoReflect.Descriptor instead.

func (*GetInternalJobRequest) GetId

func (x *GetInternalJobRequest) GetId() string

func (*GetInternalJobRequest) ProtoMessage

func (*GetInternalJobRequest) ProtoMessage()

func (*GetInternalJobRequest) ProtoReflect

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

func (*GetInternalJobRequest) Reset

func (x *GetInternalJobRequest) Reset()

func (*GetInternalJobRequest) String

func (x *GetInternalJobRequest) String() string

type GetJobRequest

type GetJobRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobRequest) Descriptor deprecated

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetId

func (x *GetJobRequest) GetId() string

func (*GetJobRequest) ProtoMessage

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect

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

func (*GetJobRequest) Reset

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String

func (x *GetJobRequest) String() string

type GetNotebookRequest

type GetNotebookRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNotebookRequest) Descriptor deprecated

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

Deprecated: Use GetNotebookRequest.ProtoReflect.Descriptor instead.

func (*GetNotebookRequest) GetId

func (x *GetNotebookRequest) GetId() string

func (*GetNotebookRequest) ProtoMessage

func (*GetNotebookRequest) ProtoMessage()

func (*GetNotebookRequest) ProtoReflect

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

func (*GetNotebookRequest) Reset

func (x *GetNotebookRequest) Reset()

func (*GetNotebookRequest) String

func (x *GetNotebookRequest) String() string

type GpuNode added in v1.5.0

type GpuNode struct {
	ResourceName     string `protobuf:"bytes,1,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	AllocatableCount int32  `protobuf:"varint,2,opt,name=allocatable_count,json=allocatableCount,proto3" json:"allocatable_count,omitempty"` // TODO(kenji): Add more information such as Nvidia GPU architecture.
	// contains filtered or unexported fields
}

func (*GpuNode) Descriptor deprecated added in v1.5.0

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

Deprecated: Use GpuNode.ProtoReflect.Descriptor instead.

func (*GpuNode) GetAllocatableCount added in v1.5.0

func (x *GpuNode) GetAllocatableCount() int32

func (*GpuNode) GetResourceName added in v1.5.0

func (x *GpuNode) GetResourceName() string

func (*GpuNode) ProtoMessage added in v1.5.0

func (*GpuNode) ProtoMessage()

func (*GpuNode) ProtoReflect added in v1.5.0

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

func (*GpuNode) Reset added in v1.5.0

func (x *GpuNode) Reset()

func (*GpuNode) String added in v1.5.0

func (x *GpuNode) String() string

type GpuPod added in v1.6.0

type GpuPod struct {
	ResourceName   string `protobuf:"bytes,1,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	AllocatedCount int32  `protobuf:"varint,2,opt,name=allocated_count,json=allocatedCount,proto3" json:"allocated_count,omitempty"`
	NamespacedName string `protobuf:"bytes,3,opt,name=namespaced_name,json=namespacedName,proto3" json:"namespaced_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GpuPod) Descriptor deprecated added in v1.6.0

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

Deprecated: Use GpuPod.ProtoReflect.Descriptor instead.

func (*GpuPod) GetAllocatedCount added in v1.6.0

func (x *GpuPod) GetAllocatedCount() int32

func (*GpuPod) GetNamespacedName added in v1.8.0

func (x *GpuPod) GetNamespacedName() string

func (*GpuPod) GetResourceName added in v1.6.0

func (x *GpuPod) GetResourceName() string

func (*GpuPod) ProtoMessage added in v1.6.0

func (*GpuPod) ProtoMessage()

func (*GpuPod) ProtoReflect added in v1.6.0

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

func (*GpuPod) Reset added in v1.6.0

func (x *GpuPod) Reset()

func (*GpuPod) String added in v1.6.0

func (x *GpuPod) String() string

type Integration

type Integration struct {
	Type  string             `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Wandb *Integration_Wandb `protobuf:"bytes,2,opt,name=wandb,proto3" json:"wandb,omitempty"`
	// contains filtered or unexported fields
}

func (*Integration) Descriptor deprecated

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

Deprecated: Use Integration.ProtoReflect.Descriptor instead.

func (*Integration) GetType

func (x *Integration) GetType() string

func (*Integration) GetWandb

func (x *Integration) GetWandb() *Integration_Wandb

func (*Integration) ProtoMessage

func (*Integration) ProtoMessage()

func (*Integration) ProtoReflect

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

func (*Integration) Reset

func (x *Integration) Reset()

func (*Integration) String

func (x *Integration) String() string

type Integration_Wandb

type Integration_Wandb struct {
	Project string   `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Name    string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Entity  string   `protobuf:"bytes,3,opt,name=entity,proto3" json:"entity,omitempty"`
	Tags    []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*Integration_Wandb) Descriptor deprecated

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

Deprecated: Use Integration_Wandb.ProtoReflect.Descriptor instead.

func (*Integration_Wandb) GetEntity

func (x *Integration_Wandb) GetEntity() string

func (*Integration_Wandb) GetName

func (x *Integration_Wandb) GetName() string

func (*Integration_Wandb) GetProject

func (x *Integration_Wandb) GetProject() string

func (*Integration_Wandb) GetTags

func (x *Integration_Wandb) GetTags() []string

func (*Integration_Wandb) ProtoMessage

func (*Integration_Wandb) ProtoMessage()

func (*Integration_Wandb) ProtoReflect

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

func (*Integration_Wandb) Reset

func (x *Integration_Wandb) Reset()

func (*Integration_Wandb) String

func (x *Integration_Wandb) String() string

type InternalBatchJob

type InternalBatchJob struct {
	Job          *BatchJob               `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	State        InternalBatchJob_State  `protobuf:"varint,2,opt,name=state,proto3,enum=llmariner.batch.server.v1.InternalBatchJob_State" json:"state,omitempty"`
	QueuedAction InternalBatchJob_Action `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InternalBatchJob) Descriptor deprecated

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

Deprecated: Use InternalBatchJob.ProtoReflect.Descriptor instead.

func (*InternalBatchJob) GetJob

func (x *InternalBatchJob) GetJob() *BatchJob

func (*InternalBatchJob) GetQueuedAction

func (x *InternalBatchJob) GetQueuedAction() InternalBatchJob_Action

func (*InternalBatchJob) GetState

func (*InternalBatchJob) ProtoMessage

func (*InternalBatchJob) ProtoMessage()

func (*InternalBatchJob) ProtoReflect

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

func (*InternalBatchJob) Reset

func (x *InternalBatchJob) Reset()

func (*InternalBatchJob) String

func (x *InternalBatchJob) String() string

type InternalBatchJob_Action

type InternalBatchJob_Action int32
const (
	InternalBatchJob_ACTION_UNSPECIFIED InternalBatchJob_Action = 0
	InternalBatchJob_CREATING           InternalBatchJob_Action = 1
	InternalBatchJob_CANCELING          InternalBatchJob_Action = 2
	InternalBatchJob_DELETING           InternalBatchJob_Action = 3
)

func (InternalBatchJob_Action) Descriptor

func (InternalBatchJob_Action) Enum

func (InternalBatchJob_Action) EnumDescriptor deprecated

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

Deprecated: Use InternalBatchJob_Action.Descriptor instead.

func (InternalBatchJob_Action) Number

func (InternalBatchJob_Action) String

func (x InternalBatchJob_Action) String() string

func (InternalBatchJob_Action) Type

type InternalBatchJob_State

type InternalBatchJob_State int32
const (
	InternalBatchJob_STATE_UNSPECIFIED InternalBatchJob_State = 0
	InternalBatchJob_QUEUED            InternalBatchJob_State = 1
	InternalBatchJob_RUNNING           InternalBatchJob_State = 2
	InternalBatchJob_SUCCEEDED         InternalBatchJob_State = 3
	InternalBatchJob_FAILED            InternalBatchJob_State = 4
	InternalBatchJob_CANCELED          InternalBatchJob_State = 5
	InternalBatchJob_DELETED           InternalBatchJob_State = 6
)

func (InternalBatchJob_State) Descriptor

func (InternalBatchJob_State) Enum

func (InternalBatchJob_State) EnumDescriptor deprecated

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

Deprecated: Use InternalBatchJob_State.Descriptor instead.

func (InternalBatchJob_State) Number

func (InternalBatchJob_State) String

func (x InternalBatchJob_State) String() string

func (InternalBatchJob_State) Type

type InternalJob

type InternalJob struct {
	Job           *Job   `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	OutputModelId string `protobuf:"bytes,2,opt,name=output_model_id,json=outputModelId,proto3" json:"output_model_id,omitempty"`
	Suffix        string `protobuf:"bytes,3,opt,name=suffix,proto3" json:"suffix,omitempty"`
	// state is also stored in the job object, but this value takes precedence.
	State        InternalJob_State  `protobuf:"varint,4,opt,name=state,proto3,enum=llmariner.fine_tuning.server.v1.InternalJob_State" json:"state,omitempty"`
	QueuedAction InternalJob_Action `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InternalJob) Descriptor deprecated

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

Deprecated: Use InternalJob.ProtoReflect.Descriptor instead.

func (*InternalJob) GetJob

func (x *InternalJob) GetJob() *Job

func (*InternalJob) GetOutputModelId

func (x *InternalJob) GetOutputModelId() string

func (*InternalJob) GetQueuedAction

func (x *InternalJob) GetQueuedAction() InternalJob_Action

func (*InternalJob) GetState

func (x *InternalJob) GetState() InternalJob_State

func (*InternalJob) GetSuffix

func (x *InternalJob) GetSuffix() string

func (*InternalJob) ProtoMessage

func (*InternalJob) ProtoMessage()

func (*InternalJob) ProtoReflect

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

func (*InternalJob) Reset

func (x *InternalJob) Reset()

func (*InternalJob) String

func (x *InternalJob) String() string

type InternalJob_Action

type InternalJob_Action int32
const (
	InternalJob_ACTION_UNSPECIFIED InternalJob_Action = 0
	InternalJob_CREATING           InternalJob_Action = 1
	InternalJob_CANCELING          InternalJob_Action = 2
)

func (InternalJob_Action) Descriptor

func (InternalJob_Action) Enum

func (InternalJob_Action) EnumDescriptor deprecated

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

Deprecated: Use InternalJob_Action.Descriptor instead.

func (InternalJob_Action) Number

func (InternalJob_Action) String

func (x InternalJob_Action) String() string

func (InternalJob_Action) Type

type InternalJob_State

type InternalJob_State int32
const (
	InternalJob_STATE_UNSPECIFIED InternalJob_State = 0
	InternalJob_QUEUED            InternalJob_State = 1
	InternalJob_RUNNING           InternalJob_State = 2
	InternalJob_FAILED            InternalJob_State = 3
	InternalJob_SUCCEEDED         InternalJob_State = 4
	InternalJob_CANCELED          InternalJob_State = 5
)

func (InternalJob_State) Descriptor

func (InternalJob_State) Enum

func (InternalJob_State) EnumDescriptor deprecated

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

Deprecated: Use InternalJob_State.Descriptor instead.

func (InternalJob_State) Number

func (InternalJob_State) String

func (x InternalJob_State) String() string

func (InternalJob_State) Type

type InternalNotebook

type InternalNotebook struct {
	Notebook     *Notebook            `protobuf:"bytes,1,opt,name=notebook,proto3" json:"notebook,omitempty"`
	State        NotebookState        `protobuf:"varint,2,opt,name=state,proto3,enum=llmariner.workspace.server.v1.NotebookState" json:"state,omitempty"`
	QueuedAction NotebookQueuedAction `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InternalNotebook) Descriptor deprecated

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

Deprecated: Use InternalNotebook.ProtoReflect.Descriptor instead.

func (*InternalNotebook) GetNotebook

func (x *InternalNotebook) GetNotebook() *Notebook

func (*InternalNotebook) GetQueuedAction

func (x *InternalNotebook) GetQueuedAction() NotebookQueuedAction

func (*InternalNotebook) GetState

func (x *InternalNotebook) GetState() NotebookState

func (*InternalNotebook) ProtoMessage

func (*InternalNotebook) ProtoMessage()

func (*InternalNotebook) ProtoReflect

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

func (*InternalNotebook) Reset

func (x *InternalNotebook) Reset()

func (*InternalNotebook) String

func (x *InternalNotebook) String() string

type Job

type Job struct {
	Id        string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt int64      `protobuf:"varint,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Error     *Job_Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// The name of the fine-tuned model that is being created. The value will be null if the fine-tuning job is still running.
	FineTunedModel  string               `protobuf:"bytes,4,opt,name=fine_tuned_model,json=fineTunedModel,proto3" json:"fine_tuned_model,omitempty"`
	FinishedAt      int64                `protobuf:"varint,5,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	Hyperparameters *Job_Hyperparameters `protobuf:"bytes,6,opt,name=hyperparameters,proto3" json:"hyperparameters,omitempty"`
	// The base model that is being fine-tuned.
	Model          string   `protobuf:"bytes,7,opt,name=model,proto3" json:"model,omitempty"`
	Object         string   `protobuf:"bytes,8,opt,name=object,proto3" json:"object,omitempty"`
	OrganizationId string   `protobuf:"bytes,9,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	ResultFiles    []string `protobuf:"bytes,10,rep,name=result_files,json=resultFiles,proto3" json:"result_files,omitempty"`
	// The current status of the fine-tuning job, which can be either validating_files, queued, running, succeeded, failed, or cancelled.
	Status              string         `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"`
	TrainedTokens       int32          `protobuf:"varint,12,opt,name=trained_tokens,json=trainedTokens,proto3" json:"trained_tokens,omitempty"`
	TrainingFile        string         `protobuf:"bytes,13,opt,name=training_file,json=trainingFile,proto3" json:"training_file,omitempty"`
	ValidationFile      string         `protobuf:"bytes,14,opt,name=validation_file,json=validationFile,proto3" json:"validation_file,omitempty"`
	Integrations        []*Integration `protobuf:"bytes,15,rep,name=integrations,proto3" json:"integrations,omitempty"`
	Seed                int32          `protobuf:"varint,16,opt,name=seed,proto3" json:"seed,omitempty"`
	ProjectId           string         `protobuf:"bytes,17,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	KubernetesNamespace string         `protobuf:"bytes,18,opt,name=kubernetes_namespace,json=kubernetesNamespace,proto3" json:"kubernetes_namespace,omitempty"`
	// cluster_id is the ID of the cluster where he job runs.
	ClusterId         string         `protobuf:"bytes,19,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	OrganizationTitle string         `protobuf:"bytes,20,opt,name=organization_title,json=organizationTitle,proto3" json:"organization_title,omitempty"`
	ProjectTitle      string         `protobuf:"bytes,21,opt,name=project_title,json=projectTitle,proto3" json:"project_title,omitempty"`
	ClusterName       string         `protobuf:"bytes,22,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	Resources         *Job_Resources `protobuf:"bytes,23,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetClusterId

func (x *Job) GetClusterId() string

func (*Job) GetClusterName added in v1.5.0

func (x *Job) GetClusterName() string

func (*Job) GetCreatedAt

func (x *Job) GetCreatedAt() int64

func (*Job) GetError

func (x *Job) GetError() *Job_Error

func (*Job) GetFineTunedModel

func (x *Job) GetFineTunedModel() string

func (*Job) GetFinishedAt

func (x *Job) GetFinishedAt() int64

func (*Job) GetHyperparameters

func (x *Job) GetHyperparameters() *Job_Hyperparameters

func (*Job) GetId

func (x *Job) GetId() string

func (*Job) GetIntegrations

func (x *Job) GetIntegrations() []*Integration

func (*Job) GetKubernetesNamespace

func (x *Job) GetKubernetesNamespace() string

func (*Job) GetModel

func (x *Job) GetModel() string

func (*Job) GetObject

func (x *Job) GetObject() string

func (*Job) GetOrganizationId

func (x *Job) GetOrganizationId() string

func (*Job) GetOrganizationTitle added in v1.5.0

func (x *Job) GetOrganizationTitle() string

func (*Job) GetProjectId

func (x *Job) GetProjectId() string

func (*Job) GetProjectTitle added in v1.5.0

func (x *Job) GetProjectTitle() string

func (*Job) GetResources added in v1.16.0

func (x *Job) GetResources() *Job_Resources

func (*Job) GetResultFiles

func (x *Job) GetResultFiles() []string

func (*Job) GetSeed

func (x *Job) GetSeed() int32

func (*Job) GetStatus

func (x *Job) GetStatus() string

func (*Job) GetTrainedTokens

func (x *Job) GetTrainedTokens() int32

func (*Job) GetTrainingFile

func (x *Job) GetTrainingFile() string

func (*Job) GetValidationFile

func (x *Job) GetValidationFile() string

func (*Job) ProtoMessage

func (*Job) ProtoMessage()

func (*Job) ProtoReflect

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

func (*Job) Reset

func (x *Job) Reset()

func (*Job) String

func (x *Job) String() string

type JobServiceClient added in v1.5.0

type JobServiceClient interface {
	ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
}

JobServiceClient is the client API for JobService 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 NewJobServiceClient added in v1.5.0

func NewJobServiceClient(cc grpc.ClientConnInterface) JobServiceClient

type JobServiceServer added in v1.5.0

type JobServiceServer interface {
	ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	// contains filtered or unexported methods
}

JobServiceServer is the server API for JobService service. All implementations must embed UnimplementedJobServiceServer for forward compatibility

type JobWorkerServiceClient added in v1.5.0

type JobWorkerServiceClient interface {
	// UpdateClusterStatus updates the status of the cluster.
	UpdateClusterStatus(ctx context.Context, in *UpdateClusterStatusRequest, opts ...grpc.CallOption) (*UpdateClusterStatusResponse, error)
}

JobWorkerServiceClient is the client API for JobWorkerService 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 NewJobWorkerServiceClient added in v1.5.0

func NewJobWorkerServiceClient(cc grpc.ClientConnInterface) JobWorkerServiceClient

type JobWorkerServiceServer added in v1.5.0

type JobWorkerServiceServer interface {
	// UpdateClusterStatus updates the status of the cluster.
	UpdateClusterStatus(context.Context, *UpdateClusterStatusRequest) (*UpdateClusterStatusResponse, error)
	// contains filtered or unexported methods
}

JobWorkerServiceServer is the server API for JobWorkerService service. All implementations must embed UnimplementedJobWorkerServiceServer for forward compatibility

type Job_Error

type Job_Error struct {
	Code    string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Param   string `protobuf:"bytes,3,opt,name=param,proto3" json:"param,omitempty"`
	// contains filtered or unexported fields
}

func (*Job_Error) Descriptor deprecated

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

Deprecated: Use Job_Error.ProtoReflect.Descriptor instead.

func (*Job_Error) GetCode

func (x *Job_Error) GetCode() string

func (*Job_Error) GetMessage

func (x *Job_Error) GetMessage() string

func (*Job_Error) GetParam

func (x *Job_Error) GetParam() string

func (*Job_Error) ProtoMessage

func (*Job_Error) ProtoMessage()

func (*Job_Error) ProtoReflect

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

func (*Job_Error) Reset

func (x *Job_Error) Reset()

func (*Job_Error) String

func (x *Job_Error) String() string

type Job_Hyperparameters

type Job_Hyperparameters struct {

	// Note: OpenAI API supports string or interger.
	BatchSize int32 `protobuf:"varint,1,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// Note: OpenAI API supports string or number.
	LearningRateMultiplier float64 `` /* 131-byte string literal not displayed */
	// Note: OpenAI API supports string or interger.
	NEpochs int32 `protobuf:"varint,3,opt,name=n_epochs,json=nEpochs,proto3" json:"n_epochs,omitempty"`
	// contains filtered or unexported fields
}

func (*Job_Hyperparameters) Descriptor deprecated

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

Deprecated: Use Job_Hyperparameters.ProtoReflect.Descriptor instead.

func (*Job_Hyperparameters) GetBatchSize

func (x *Job_Hyperparameters) GetBatchSize() int32

func (*Job_Hyperparameters) GetLearningRateMultiplier

func (x *Job_Hyperparameters) GetLearningRateMultiplier() float64

func (*Job_Hyperparameters) GetNEpochs

func (x *Job_Hyperparameters) GetNEpochs() int32

func (*Job_Hyperparameters) ProtoMessage

func (*Job_Hyperparameters) ProtoMessage()

func (*Job_Hyperparameters) ProtoReflect

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

func (*Job_Hyperparameters) Reset

func (x *Job_Hyperparameters) Reset()

func (*Job_Hyperparameters) String

func (x *Job_Hyperparameters) String() string

type Job_Resources added in v1.16.0

type Job_Resources struct {
	GpuCount int32 `protobuf:"varint,1,opt,name=gpu_count,json=gpuCount,proto3" json:"gpu_count,omitempty"`
	// contains filtered or unexported fields
}

func (*Job_Resources) Descriptor deprecated added in v1.16.0

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

Deprecated: Use Job_Resources.ProtoReflect.Descriptor instead.

func (*Job_Resources) GetGpuCount added in v1.16.0

func (x *Job_Resources) GetGpuCount() int32

func (*Job_Resources) ProtoMessage added in v1.16.0

func (*Job_Resources) ProtoMessage()

func (*Job_Resources) ProtoReflect added in v1.16.0

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

func (*Job_Resources) Reset added in v1.16.0

func (x *Job_Resources) Reset()

func (*Job_Resources) String added in v1.16.0

func (x *Job_Resources) String() string

type ListBatchJobsRequest

type ListBatchJobsRequest struct {

	// after is the identifier for the last batch job from the previous pagination request.
	After string `protobuf:"bytes,1,opt,name=after,proto3" json:"after,omitempty"`
	// limit is the number of batch jobs to retrieve. Defaults to 20.
	Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBatchJobsRequest) Descriptor deprecated

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

Deprecated: Use ListBatchJobsRequest.ProtoReflect.Descriptor instead.

func (*ListBatchJobsRequest) GetAfter

func (x *ListBatchJobsRequest) GetAfter() string

func (*ListBatchJobsRequest) GetLimit

func (x *ListBatchJobsRequest) GetLimit() int32

func (*ListBatchJobsRequest) ProtoMessage

func (*ListBatchJobsRequest) ProtoMessage()

func (*ListBatchJobsRequest) ProtoReflect

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

func (*ListBatchJobsRequest) Reset

func (x *ListBatchJobsRequest) Reset()

func (*ListBatchJobsRequest) String

func (x *ListBatchJobsRequest) String() string

type ListBatchJobsResponse

type ListBatchJobsResponse struct {
	Jobs    []*BatchJob `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	HasMore bool        `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
	// total_items is the total number of batch jobs.
	TotalItems int32 `protobuf:"varint,3,opt,name=total_items,json=totalItems,proto3" json:"total_items,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBatchJobsResponse) Descriptor deprecated

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

Deprecated: Use ListBatchJobsResponse.ProtoReflect.Descriptor instead.

func (*ListBatchJobsResponse) GetHasMore

func (x *ListBatchJobsResponse) GetHasMore() bool

func (*ListBatchJobsResponse) GetJobs

func (x *ListBatchJobsResponse) GetJobs() []*BatchJob

func (*ListBatchJobsResponse) GetTotalItems added in v1.10.0

func (x *ListBatchJobsResponse) GetTotalItems() int32

func (*ListBatchJobsResponse) ProtoMessage

func (*ListBatchJobsResponse) ProtoMessage()

func (*ListBatchJobsResponse) ProtoReflect

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

func (*ListBatchJobsResponse) Reset

func (x *ListBatchJobsResponse) Reset()

func (*ListBatchJobsResponse) String

func (x *ListBatchJobsResponse) String() string

type ListClusterIDsRequest added in v1.6.0

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

func (*ListClusterIDsRequest) Descriptor deprecated added in v1.6.0

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

Deprecated: Use ListClusterIDsRequest.ProtoReflect.Descriptor instead.

func (*ListClusterIDsRequest) ProtoMessage added in v1.6.0

func (*ListClusterIDsRequest) ProtoMessage()

func (*ListClusterIDsRequest) ProtoReflect added in v1.6.0

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

func (*ListClusterIDsRequest) Reset added in v1.6.0

func (x *ListClusterIDsRequest) Reset()

func (*ListClusterIDsRequest) String added in v1.6.0

func (x *ListClusterIDsRequest) String() string

type ListClusterIDsResponse added in v1.6.0

type ListClusterIDsResponse struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClusterIDsResponse) Descriptor deprecated added in v1.6.0

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

Deprecated: Use ListClusterIDsResponse.ProtoReflect.Descriptor instead.

func (*ListClusterIDsResponse) GetIds added in v1.6.0

func (x *ListClusterIDsResponse) GetIds() []string

func (*ListClusterIDsResponse) ProtoMessage added in v1.6.0

func (*ListClusterIDsResponse) ProtoMessage()

func (*ListClusterIDsResponse) ProtoReflect added in v1.6.0

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

func (*ListClusterIDsResponse) Reset added in v1.6.0

func (x *ListClusterIDsResponse) Reset()

func (*ListClusterIDsResponse) String added in v1.6.0

func (x *ListClusterIDsResponse) String() string

type ListClustersRequest added in v1.5.0

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

func (*ListClustersRequest) Descriptor deprecated added in v1.5.0

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

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) ProtoMessage added in v1.5.0

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) ProtoReflect added in v1.5.0

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

func (*ListClustersRequest) Reset added in v1.5.0

func (x *ListClustersRequest) Reset()

func (*ListClustersRequest) String added in v1.5.0

func (x *ListClustersRequest) String() string

type ListClustersResponse added in v1.5.0

type ListClustersResponse struct {
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClustersResponse) Descriptor deprecated added in v1.5.0

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

Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.

func (*ListClustersResponse) GetClusters added in v1.5.0

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

func (*ListClustersResponse) ProtoMessage added in v1.5.0

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) ProtoReflect added in v1.5.0

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

func (*ListClustersResponse) Reset added in v1.5.0

func (x *ListClustersResponse) Reset()

func (*ListClustersResponse) String added in v1.5.0

func (x *ListClustersResponse) String() string

type ListJobsRequest

type ListJobsRequest struct {

	// after is the identifier for the last job from the previous pagination request.
	After string `protobuf:"bytes,1,opt,name=after,proto3" json:"after,omitempty"`
	// limit is the number of fine-tuning jobs to retrieve. Defaults to 20.
	Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsRequest) Descriptor deprecated

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

Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

func (*ListJobsRequest) GetAfter

func (x *ListJobsRequest) GetAfter() string

func (*ListJobsRequest) GetLimit

func (x *ListJobsRequest) GetLimit() int32

func (*ListJobsRequest) ProtoMessage

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect

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

func (*ListJobsRequest) Reset

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) String

func (x *ListJobsRequest) String() string

type ListJobsResponse

type ListJobsResponse struct {
	Object  string `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Data    []*Job `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	HasMore bool   `protobuf:"varint,3,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
	// total_items is the total number of batch jobs. This is not defined in the
	// OpenAI API spec, but we include here for better UX in the frontend.
	TotalItems int32 `protobuf:"varint,4,opt,name=total_items,json=totalItems,proto3" json:"total_items,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsResponse) Descriptor deprecated

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

Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.

func (*ListJobsResponse) GetData

func (x *ListJobsResponse) GetData() []*Job

func (*ListJobsResponse) GetHasMore

func (x *ListJobsResponse) GetHasMore() bool

func (*ListJobsResponse) GetObject

func (x *ListJobsResponse) GetObject() string

func (*ListJobsResponse) GetTotalItems added in v1.10.0

func (x *ListJobsResponse) GetTotalItems() int32

func (*ListJobsResponse) ProtoMessage

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) ProtoReflect

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

func (*ListJobsResponse) Reset

func (x *ListJobsResponse) Reset()

func (*ListJobsResponse) String

func (x *ListJobsResponse) String() string

type ListNotebooksRequest

type ListNotebooksRequest struct {

	// after is the identifier for the last notebook from the previous pagination request.
	After string `protobuf:"bytes,1,opt,name=after,proto3" json:"after,omitempty"`
	// limit is the number of notes to retrieve. Defaults to 20.
	Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNotebooksRequest) Descriptor deprecated

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

Deprecated: Use ListNotebooksRequest.ProtoReflect.Descriptor instead.

func (*ListNotebooksRequest) GetAfter

func (x *ListNotebooksRequest) GetAfter() string

func (*ListNotebooksRequest) GetLimit

func (x *ListNotebooksRequest) GetLimit() int32

func (*ListNotebooksRequest) ProtoMessage

func (*ListNotebooksRequest) ProtoMessage()

func (*ListNotebooksRequest) ProtoReflect

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

func (*ListNotebooksRequest) Reset

func (x *ListNotebooksRequest) Reset()

func (*ListNotebooksRequest) String

func (x *ListNotebooksRequest) String() string

type ListNotebooksResponse

type ListNotebooksResponse struct {
	Notebooks []*Notebook `protobuf:"bytes,1,rep,name=notebooks,proto3" json:"notebooks,omitempty"`
	HasMore   bool        `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
	// total_items is the total number of batch jobs.
	TotalItems int32 `protobuf:"varint,3,opt,name=total_items,json=totalItems,proto3" json:"total_items,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNotebooksResponse) Descriptor deprecated

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

Deprecated: Use ListNotebooksResponse.ProtoReflect.Descriptor instead.

func (*ListNotebooksResponse) GetHasMore

func (x *ListNotebooksResponse) GetHasMore() bool

func (*ListNotebooksResponse) GetNotebooks

func (x *ListNotebooksResponse) GetNotebooks() []*Notebook

func (*ListNotebooksResponse) GetTotalItems added in v1.10.0

func (x *ListNotebooksResponse) GetTotalItems() int32

func (*ListNotebooksResponse) ProtoMessage

func (*ListNotebooksResponse) ProtoMessage()

func (*ListNotebooksResponse) ProtoReflect

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

func (*ListNotebooksResponse) Reset

func (x *ListNotebooksResponse) Reset()

func (*ListNotebooksResponse) String

func (x *ListNotebooksResponse) String() string

type ListQueuedInternalBatchJobsRequest

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

func (*ListQueuedInternalBatchJobsRequest) Descriptor deprecated

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

Deprecated: Use ListQueuedInternalBatchJobsRequest.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalBatchJobsRequest) ProtoMessage

func (*ListQueuedInternalBatchJobsRequest) ProtoMessage()

func (*ListQueuedInternalBatchJobsRequest) ProtoReflect

func (*ListQueuedInternalBatchJobsRequest) Reset

func (*ListQueuedInternalBatchJobsRequest) String

type ListQueuedInternalBatchJobsResponse

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

func (*ListQueuedInternalBatchJobsResponse) Descriptor deprecated

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

Deprecated: Use ListQueuedInternalBatchJobsResponse.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalBatchJobsResponse) GetJobs

func (*ListQueuedInternalBatchJobsResponse) ProtoMessage

func (*ListQueuedInternalBatchJobsResponse) ProtoMessage()

func (*ListQueuedInternalBatchJobsResponse) ProtoReflect

func (*ListQueuedInternalBatchJobsResponse) Reset

func (*ListQueuedInternalBatchJobsResponse) String

type ListQueuedInternalJobsRequest

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

func (*ListQueuedInternalJobsRequest) Descriptor deprecated

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

Deprecated: Use ListQueuedInternalJobsRequest.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalJobsRequest) ProtoMessage

func (*ListQueuedInternalJobsRequest) ProtoMessage()

func (*ListQueuedInternalJobsRequest) ProtoReflect

func (*ListQueuedInternalJobsRequest) Reset

func (x *ListQueuedInternalJobsRequest) Reset()

func (*ListQueuedInternalJobsRequest) String

type ListQueuedInternalJobsResponse

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

func (*ListQueuedInternalJobsResponse) Descriptor deprecated

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

Deprecated: Use ListQueuedInternalJobsResponse.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalJobsResponse) GetJobs

func (*ListQueuedInternalJobsResponse) ProtoMessage

func (*ListQueuedInternalJobsResponse) ProtoMessage()

func (*ListQueuedInternalJobsResponse) ProtoReflect

func (*ListQueuedInternalJobsResponse) Reset

func (x *ListQueuedInternalJobsResponse) Reset()

func (*ListQueuedInternalJobsResponse) String

type ListQueuedInternalNotebooksRequest

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

func (*ListQueuedInternalNotebooksRequest) Descriptor deprecated

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

Deprecated: Use ListQueuedInternalNotebooksRequest.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalNotebooksRequest) ProtoMessage

func (*ListQueuedInternalNotebooksRequest) ProtoMessage()

func (*ListQueuedInternalNotebooksRequest) ProtoReflect

func (*ListQueuedInternalNotebooksRequest) Reset

func (*ListQueuedInternalNotebooksRequest) String

type ListQueuedInternalNotebooksResponse

type ListQueuedInternalNotebooksResponse struct {
	Notebooks []*InternalNotebook `protobuf:"bytes,1,rep,name=notebooks,proto3" json:"notebooks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueuedInternalNotebooksResponse) Descriptor deprecated

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

Deprecated: Use ListQueuedInternalNotebooksResponse.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalNotebooksResponse) GetNotebooks

func (*ListQueuedInternalNotebooksResponse) ProtoMessage

func (*ListQueuedInternalNotebooksResponse) ProtoMessage()

func (*ListQueuedInternalNotebooksResponse) ProtoReflect

func (*ListQueuedInternalNotebooksResponse) Reset

func (*ListQueuedInternalNotebooksResponse) String

type Notebook

type Notebook struct {
	Id                  string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt           int64             `protobuf:"varint,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StartedAt           int64             `protobuf:"varint,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	StoppedAt           int64             `protobuf:"varint,5,opt,name=stopped_at,json=stoppedAt,proto3" json:"stopped_at,omitempty"`
	Image               string            `protobuf:"bytes,6,opt,name=image,proto3" json:"image,omitempty"`
	Resources           *Resources        `protobuf:"bytes,7,opt,name=resources,proto3" json:"resources,omitempty"`
	Envs                map[string]string `` /* 149-byte string literal not displayed */
	Error               *Notebook_Error   `protobuf:"bytes,9,opt,name=error,proto3" json:"error,omitempty"`
	Status              string            `protobuf:"bytes,10,opt,name=status,proto3" json:"status,omitempty"`
	Token               string            `protobuf:"bytes,11,opt,name=token,proto3" json:"token,omitempty"`
	ProjectId           string            `protobuf:"bytes,12,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	OrganizationId      string            `protobuf:"bytes,14,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	KubernetesNamespace string            `protobuf:"bytes,13,opt,name=kubernetes_namespace,json=kubernetesNamespace,proto3" json:"kubernetes_namespace,omitempty"`
	// cluster_id is the ID of the cluster where the notebook runs.
	ClusterId              string  `protobuf:"bytes,19,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	OrganizationTitle      string  `protobuf:"bytes,20,opt,name=organization_title,json=organizationTitle,proto3" json:"organization_title,omitempty"`
	ProjectTitle           string  `protobuf:"bytes,21,opt,name=project_title,json=projectTitle,proto3" json:"project_title,omitempty"`
	ClusterName            string  `protobuf:"bytes,22,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	AdditionalExposedPorts []int32 `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Notebook) Descriptor deprecated

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

Deprecated: Use Notebook.ProtoReflect.Descriptor instead.

func (*Notebook) GetAdditionalExposedPorts added in v1.24.0

func (x *Notebook) GetAdditionalExposedPorts() []int32

func (*Notebook) GetClusterId

func (x *Notebook) GetClusterId() string

func (*Notebook) GetClusterName added in v1.5.0

func (x *Notebook) GetClusterName() string

func (*Notebook) GetCreatedAt

func (x *Notebook) GetCreatedAt() int64

func (*Notebook) GetEnvs

func (x *Notebook) GetEnvs() map[string]string

func (*Notebook) GetError

func (x *Notebook) GetError() *Notebook_Error

func (*Notebook) GetId

func (x *Notebook) GetId() string

func (*Notebook) GetImage

func (x *Notebook) GetImage() string

func (*Notebook) GetKubernetesNamespace

func (x *Notebook) GetKubernetesNamespace() string

func (*Notebook) GetName

func (x *Notebook) GetName() string

func (*Notebook) GetOrganizationId added in v1.5.0

func (x *Notebook) GetOrganizationId() string

func (*Notebook) GetOrganizationTitle added in v1.5.0

func (x *Notebook) GetOrganizationTitle() string

func (*Notebook) GetProjectId

func (x *Notebook) GetProjectId() string

func (*Notebook) GetProjectTitle added in v1.5.0

func (x *Notebook) GetProjectTitle() string

func (*Notebook) GetResources

func (x *Notebook) GetResources() *Resources

func (*Notebook) GetStartedAt

func (x *Notebook) GetStartedAt() int64

func (*Notebook) GetStatus

func (x *Notebook) GetStatus() string

func (*Notebook) GetStoppedAt

func (x *Notebook) GetStoppedAt() int64

func (*Notebook) GetToken

func (x *Notebook) GetToken() string

func (*Notebook) ProtoMessage

func (*Notebook) ProtoMessage()

func (*Notebook) ProtoReflect

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

func (*Notebook) Reset

func (x *Notebook) Reset()

func (*Notebook) String

func (x *Notebook) String() string

type NotebookQueuedAction

type NotebookQueuedAction int32
const (
	NotebookQueuedAction_ACTION_UNSPECIFIED NotebookQueuedAction = 0
	NotebookQueuedAction_STARTING           NotebookQueuedAction = 1
	NotebookQueuedAction_STOPPING           NotebookQueuedAction = 2
	NotebookQueuedAction_DELETING           NotebookQueuedAction = 3
	NotebookQueuedAction_REQUEUEING         NotebookQueuedAction = 4
)

func (NotebookQueuedAction) Descriptor

func (NotebookQueuedAction) Enum

func (NotebookQueuedAction) EnumDescriptor deprecated

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

Deprecated: Use NotebookQueuedAction.Descriptor instead.

func (NotebookQueuedAction) Number

func (NotebookQueuedAction) String

func (x NotebookQueuedAction) String() string

func (NotebookQueuedAction) Type

type NotebookState

type NotebookState int32
const (
	NotebookState_STATE_UNSPECIFIED NotebookState = 0
	NotebookState_QUEUED            NotebookState = 1
	NotebookState_INITIALIZING      NotebookState = 2
	NotebookState_RUNNING           NotebookState = 3
	NotebookState_STOPPED           NotebookState = 4
	NotebookState_FAILED            NotebookState = 5
	NotebookState_DELETED           NotebookState = 6
	NotebookState_REQUEUED          NotebookState = 7
)

func (NotebookState) Descriptor

func (NotebookState) Enum

func (x NotebookState) Enum() *NotebookState

func (NotebookState) EnumDescriptor deprecated

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

Deprecated: Use NotebookState.Descriptor instead.

func (NotebookState) Number

func (NotebookState) String

func (x NotebookState) String() string

func (NotebookState) Type

type Notebook_Error

type Notebook_Error struct {
	Code    string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Notebook_Error) Descriptor deprecated

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

Deprecated: Use Notebook_Error.ProtoReflect.Descriptor instead.

func (*Notebook_Error) GetCode

func (x *Notebook_Error) GetCode() string

func (*Notebook_Error) GetMessage

func (x *Notebook_Error) GetMessage() string

func (*Notebook_Error) ProtoMessage

func (*Notebook_Error) ProtoMessage()

func (*Notebook_Error) ProtoReflect

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

func (*Notebook_Error) Reset

func (x *Notebook_Error) Reset()

func (*Notebook_Error) String

func (x *Notebook_Error) String() string

type PatchKubernetesObjectRequest added in v1.5.0

type PatchKubernetesObjectRequest struct {
	Namespace string                                  `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string                                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // empty namespace means cluster-scope resource.
	Group     string                                  `protobuf:"bytes,3,opt,name=Group,proto3" json:"Group,omitempty"`
	Version   string                                  `protobuf:"bytes,4,opt,name=Version,proto3" json:"Version,omitempty"`
	Resource  string                                  `protobuf:"bytes,5,opt,name=Resource,proto3" json:"Resource,omitempty"`
	Resources *PatchKubernetesObjectRequest_Resources `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"`
	// JSON encoded object data.
	Data []byte `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchKubernetesObjectRequest) Descriptor deprecated added in v1.5.0

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

Deprecated: Use PatchKubernetesObjectRequest.ProtoReflect.Descriptor instead.

func (*PatchKubernetesObjectRequest) GetData added in v1.5.0

func (x *PatchKubernetesObjectRequest) GetData() []byte

func (*PatchKubernetesObjectRequest) GetGroup added in v1.5.0

func (x *PatchKubernetesObjectRequest) GetGroup() string

func (*PatchKubernetesObjectRequest) GetName added in v1.5.0

func (x *PatchKubernetesObjectRequest) GetName() string

func (*PatchKubernetesObjectRequest) GetNamespace added in v1.5.0

func (x *PatchKubernetesObjectRequest) GetNamespace() string

func (*PatchKubernetesObjectRequest) GetResource added in v1.5.0

func (x *PatchKubernetesObjectRequest) GetResource() string

func (*PatchKubernetesObjectRequest) GetResources added in v1.5.0

func (*PatchKubernetesObjectRequest) GetVersion added in v1.5.0

func (x *PatchKubernetesObjectRequest) GetVersion() string

func (*PatchKubernetesObjectRequest) ProtoMessage added in v1.5.0

func (*PatchKubernetesObjectRequest) ProtoMessage()

func (*PatchKubernetesObjectRequest) ProtoReflect added in v1.5.0

func (*PatchKubernetesObjectRequest) Reset added in v1.5.0

func (x *PatchKubernetesObjectRequest) Reset()

func (*PatchKubernetesObjectRequest) String added in v1.5.0

type PatchKubernetesObjectRequest_Resources added in v1.5.0

type PatchKubernetesObjectRequest_Resources struct {
	GpuLimit int32 `protobuf:"varint,1,opt,name=gpu_limit,json=gpuLimit,proto3" json:"gpu_limit,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchKubernetesObjectRequest_Resources) Descriptor deprecated added in v1.5.0

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

Deprecated: Use PatchKubernetesObjectRequest_Resources.ProtoReflect.Descriptor instead.

func (*PatchKubernetesObjectRequest_Resources) GetGpuLimit added in v1.5.0

func (*PatchKubernetesObjectRequest_Resources) ProtoMessage added in v1.5.0

func (*PatchKubernetesObjectRequest_Resources) ProtoReflect added in v1.5.0

func (*PatchKubernetesObjectRequest_Resources) Reset added in v1.5.0

func (*PatchKubernetesObjectRequest_Resources) String added in v1.5.0

type PatchKubernetesObjectResponse added in v1.5.0

type PatchKubernetesObjectResponse struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Uid       string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchKubernetesObjectResponse) Descriptor deprecated added in v1.5.0

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

Deprecated: Use PatchKubernetesObjectResponse.ProtoReflect.Descriptor instead.

func (*PatchKubernetesObjectResponse) GetClusterId added in v1.5.0

func (x *PatchKubernetesObjectResponse) GetClusterId() string

func (*PatchKubernetesObjectResponse) GetUid added in v1.5.0

func (*PatchKubernetesObjectResponse) ProtoMessage added in v1.5.0

func (*PatchKubernetesObjectResponse) ProtoMessage()

func (*PatchKubernetesObjectResponse) ProtoReflect added in v1.5.0

func (*PatchKubernetesObjectResponse) Reset added in v1.5.0

func (x *PatchKubernetesObjectResponse) Reset()

func (*PatchKubernetesObjectResponse) String added in v1.5.0

type ProvisionableResource added in v1.5.0

type ProvisionableResource struct {
	InstanceFamily string `protobuf:"bytes,1,opt,name=instance_family,json=instanceFamily,proto3" json:"instance_family,omitempty"`
	InstanceType   string `protobuf:"bytes,2,opt,name=instance_type,json=instanceType,proto3" json:"instance_type,omitempty"`
	// contains filtered or unexported fields
}

ProvisionableResource represents GPU instances that a cluster can provision (e.g., Karpenter nodepool configuration).

func (*ProvisionableResource) Descriptor deprecated added in v1.5.0

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

Deprecated: Use ProvisionableResource.ProtoReflect.Descriptor instead.

func (*ProvisionableResource) GetInstanceFamily added in v1.5.0

func (x *ProvisionableResource) GetInstanceFamily() string

func (*ProvisionableResource) GetInstanceType added in v1.5.0

func (x *ProvisionableResource) GetInstanceType() string

func (*ProvisionableResource) ProtoMessage added in v1.5.0

func (*ProvisionableResource) ProtoMessage()

func (*ProvisionableResource) ProtoReflect added in v1.5.0

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

func (*ProvisionableResource) Reset added in v1.5.0

func (x *ProvisionableResource) Reset()

func (*ProvisionableResource) String added in v1.5.0

func (x *ProvisionableResource) String() string

type PyTorchJob

type PyTorchJob struct {
	WorkerCount int32 `protobuf:"varint,1,opt,name=worker_count,json=workerCount,proto3" json:"worker_count,omitempty"`
	// contains filtered or unexported fields
}

func (*PyTorchJob) Descriptor deprecated

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

Deprecated: Use PyTorchJob.ProtoReflect.Descriptor instead.

func (*PyTorchJob) GetWorkerCount

func (x *PyTorchJob) GetWorkerCount() int32

func (*PyTorchJob) ProtoMessage

func (*PyTorchJob) ProtoMessage()

func (*PyTorchJob) ProtoReflect

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

func (*PyTorchJob) Reset

func (x *PyTorchJob) Reset()

func (*PyTorchJob) String

func (x *PyTorchJob) String() string

type Resources

type Resources struct {
	CpuMilicore      *Resources_Quantity `protobuf:"bytes,1,opt,name=cpu_milicore,json=cpuMilicore,proto3" json:"cpu_milicore,omitempty"`
	MemoryMegabytes  *Resources_Quantity `protobuf:"bytes,2,opt,name=memory_megabytes,json=memoryMegabytes,proto3" json:"memory_megabytes,omitempty"`
	StorageMegabytes *Resources_Quantity `protobuf:"bytes,3,opt,name=storage_megabytes,json=storageMegabytes,proto3" json:"storage_megabytes,omitempty"`
	GpuCount         int32               `protobuf:"varint,4,opt,name=gpu_count,json=gpuCount,proto3" json:"gpu_count,omitempty"`
	// contains filtered or unexported fields
}

func (*Resources) Descriptor deprecated

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

Deprecated: Use Resources.ProtoReflect.Descriptor instead.

func (*Resources) GetCpuMilicore

func (x *Resources) GetCpuMilicore() *Resources_Quantity

func (*Resources) GetGpuCount

func (x *Resources) GetGpuCount() int32

func (*Resources) GetMemoryMegabytes

func (x *Resources) GetMemoryMegabytes() *Resources_Quantity

func (*Resources) GetStorageMegabytes

func (x *Resources) GetStorageMegabytes() *Resources_Quantity

func (*Resources) ProtoMessage

func (*Resources) ProtoMessage()

func (*Resources) ProtoReflect

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

func (*Resources) Reset

func (x *Resources) Reset()

func (*Resources) String

func (x *Resources) String() string

type Resources_Quantity

type Resources_Quantity struct {
	Requests int32 `protobuf:"varint,1,opt,name=requests,proto3" json:"requests,omitempty"`
	Limits   int32 `protobuf:"varint,2,opt,name=limits,proto3" json:"limits,omitempty"`
	// contains filtered or unexported fields
}

func (*Resources_Quantity) Descriptor deprecated

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

Deprecated: Use Resources_Quantity.ProtoReflect.Descriptor instead.

func (*Resources_Quantity) GetLimits

func (x *Resources_Quantity) GetLimits() int32

func (*Resources_Quantity) GetRequests

func (x *Resources_Quantity) GetRequests() int32

func (*Resources_Quantity) ProtoMessage

func (*Resources_Quantity) ProtoMessage()

func (*Resources_Quantity) ProtoReflect

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

func (*Resources_Quantity) Reset

func (x *Resources_Quantity) Reset()

func (*Resources_Quantity) String

func (x *Resources_Quantity) String() string

type StartNotebookRequest

type StartNotebookRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartNotebookRequest) Descriptor deprecated

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

Deprecated: Use StartNotebookRequest.ProtoReflect.Descriptor instead.

func (*StartNotebookRequest) GetId

func (x *StartNotebookRequest) GetId() string

func (*StartNotebookRequest) ProtoMessage

func (*StartNotebookRequest) ProtoMessage()

func (*StartNotebookRequest) ProtoReflect

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

func (*StartNotebookRequest) Reset

func (x *StartNotebookRequest) Reset()

func (*StartNotebookRequest) String

func (x *StartNotebookRequest) String() string

type StopNotebookRequest

type StopNotebookRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*StopNotebookRequest) Descriptor deprecated

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

Deprecated: Use StopNotebookRequest.ProtoReflect.Descriptor instead.

func (*StopNotebookRequest) GetId

func (x *StopNotebookRequest) GetId() string

func (*StopNotebookRequest) ProtoMessage

func (*StopNotebookRequest) ProtoMessage()

func (*StopNotebookRequest) ProtoReflect

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

func (*StopNotebookRequest) Reset

func (x *StopNotebookRequest) Reset()

func (*StopNotebookRequest) String

func (x *StopNotebookRequest) String() string

type SyncerServiceClient added in v1.5.0

type SyncerServiceClient interface {
	PatchKubernetesObject(ctx context.Context, in *PatchKubernetesObjectRequest, opts ...grpc.CallOption) (*PatchKubernetesObjectResponse, error)
	DeleteKubernetesObject(ctx context.Context, in *DeleteKubernetesObjectRequest, opts ...grpc.CallOption) (*DeleteKubernetesObjectResponse, error)
	ListClusterIDs(ctx context.Context, in *ListClusterIDsRequest, opts ...grpc.CallOption) (*ListClusterIDsResponse, error)
}

SyncerServiceClient is the client API for SyncerService 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 NewSyncerServiceClient added in v1.5.0

func NewSyncerServiceClient(cc grpc.ClientConnInterface) SyncerServiceClient

type SyncerServiceServer added in v1.5.0

type SyncerServiceServer interface {
	PatchKubernetesObject(context.Context, *PatchKubernetesObjectRequest) (*PatchKubernetesObjectResponse, error)
	DeleteKubernetesObject(context.Context, *DeleteKubernetesObjectRequest) (*DeleteKubernetesObjectResponse, error)
	ListClusterIDs(context.Context, *ListClusterIDsRequest) (*ListClusterIDsResponse, error)
	// contains filtered or unexported methods
}

SyncerServiceServer is the server API for SyncerService service. All implementations must embed UnimplementedSyncerServiceServer for forward compatibility

type UnimplementedBatchServiceServer

type UnimplementedBatchServiceServer struct {
}

UnimplementedBatchServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBatchServiceServer) CancelBatchJob

func (UnimplementedBatchServiceServer) CreateBatchJob

func (UnimplementedBatchServiceServer) DeleteBatchJob

func (UnimplementedBatchServiceServer) GetBatchJob

func (UnimplementedBatchServiceServer) ListBatchJobs

type UnimplementedBatchWorkerServiceServer

type UnimplementedBatchWorkerServiceServer struct {
}

UnimplementedBatchWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBatchWorkerServiceServer) GetInternalBatchJob

func (UnimplementedBatchWorkerServiceServer) UpdateBatchJobState

type UnimplementedFineTuningServiceServer

type UnimplementedFineTuningServiceServer struct {
}

UnimplementedFineTuningServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFineTuningServiceServer) CancelJob

func (UnimplementedFineTuningServiceServer) CreateJob

func (UnimplementedFineTuningServiceServer) GetJob

func (UnimplementedFineTuningServiceServer) ListJobs

type UnimplementedFineTuningWorkerServiceServer

type UnimplementedFineTuningWorkerServiceServer struct {
}

UnimplementedFineTuningWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFineTuningWorkerServiceServer) GetInternalJob

func (UnimplementedFineTuningWorkerServiceServer) ListQueuedInternalJobs

func (UnimplementedFineTuningWorkerServiceServer) UpdateJobPhase

type UnimplementedJobServiceServer added in v1.5.0

type UnimplementedJobServiceServer struct {
}

UnimplementedJobServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedJobServiceServer) ListClusters added in v1.5.0

type UnimplementedJobWorkerServiceServer added in v1.5.0

type UnimplementedJobWorkerServiceServer struct {
}

UnimplementedJobWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedJobWorkerServiceServer) UpdateClusterStatus added in v1.5.0

type UnimplementedSyncerServiceServer added in v1.5.0

type UnimplementedSyncerServiceServer struct {
}

UnimplementedSyncerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSyncerServiceServer) DeleteKubernetesObject added in v1.5.0

func (UnimplementedSyncerServiceServer) ListClusterIDs added in v1.6.0

func (UnimplementedSyncerServiceServer) PatchKubernetesObject added in v1.5.0

type UnimplementedWorkspaceServiceServer

type UnimplementedWorkspaceServiceServer struct {
}

UnimplementedWorkspaceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkspaceServiceServer) CreateNotebook

func (UnimplementedWorkspaceServiceServer) DeleteNotebook

func (UnimplementedWorkspaceServiceServer) GetNotebook

func (UnimplementedWorkspaceServiceServer) ListNotebooks

func (UnimplementedWorkspaceServiceServer) StartNotebook

func (UnimplementedWorkspaceServiceServer) StopNotebook

type UnimplementedWorkspaceWorkerServiceServer

type UnimplementedWorkspaceWorkerServiceServer struct {
}

UnimplementedWorkspaceWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkspaceWorkerServiceServer) UpdateNotebookState

type UnsafeBatchServiceServer

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

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

type UnsafeBatchWorkerServiceServer

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

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

type UnsafeFineTuningServiceServer

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

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

type UnsafeFineTuningWorkerServiceServer

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

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

type UnsafeJobServiceServer added in v1.5.0

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

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

type UnsafeJobWorkerServiceServer added in v1.5.0

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

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

type UnsafeSyncerServiceServer added in v1.5.0

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

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

type UnsafeWorkspaceServiceServer

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

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

type UnsafeWorkspaceWorkerServiceServer

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

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

type UpdateBatchJobStateRequest

type UpdateBatchJobStateRequest struct {
	Id    string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State InternalBatchJob_State `protobuf:"varint,2,opt,name=state,proto3,enum=llmariner.batch.server.v1.InternalBatchJob_State" json:"state,omitempty"`
	// currently only used for FAILED state.
	Reason  string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBatchJobStateRequest) Descriptor deprecated

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

Deprecated: Use UpdateBatchJobStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateBatchJobStateRequest) GetId

func (*UpdateBatchJobStateRequest) GetMessage

func (x *UpdateBatchJobStateRequest) GetMessage() string

func (*UpdateBatchJobStateRequest) GetReason

func (x *UpdateBatchJobStateRequest) GetReason() string

func (*UpdateBatchJobStateRequest) GetState

func (*UpdateBatchJobStateRequest) ProtoMessage

func (*UpdateBatchJobStateRequest) ProtoMessage()

func (*UpdateBatchJobStateRequest) ProtoReflect

func (*UpdateBatchJobStateRequest) Reset

func (x *UpdateBatchJobStateRequest) Reset()

func (*UpdateBatchJobStateRequest) String

func (x *UpdateBatchJobStateRequest) String() string

type UpdateBatchJobStateResponse

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

func (*UpdateBatchJobStateResponse) Descriptor deprecated

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

Deprecated: Use UpdateBatchJobStateResponse.ProtoReflect.Descriptor instead.

func (*UpdateBatchJobStateResponse) ProtoMessage

func (*UpdateBatchJobStateResponse) ProtoMessage()

func (*UpdateBatchJobStateResponse) ProtoReflect

func (*UpdateBatchJobStateResponse) Reset

func (x *UpdateBatchJobStateResponse) Reset()

func (*UpdateBatchJobStateResponse) String

func (x *UpdateBatchJobStateResponse) String() string

type UpdateClusterStatusRequest added in v1.5.0

type UpdateClusterStatusRequest struct {
	ClusterStatus *ClusterStatus `protobuf:"bytes,1,opt,name=cluster_status,json=clusterStatus,proto3" json:"cluster_status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateClusterStatusRequest) Descriptor deprecated added in v1.5.0

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

Deprecated: Use UpdateClusterStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateClusterStatusRequest) GetClusterStatus added in v1.5.0

func (x *UpdateClusterStatusRequest) GetClusterStatus() *ClusterStatus

func (*UpdateClusterStatusRequest) ProtoMessage added in v1.5.0

func (*UpdateClusterStatusRequest) ProtoMessage()

func (*UpdateClusterStatusRequest) ProtoReflect added in v1.5.0

func (*UpdateClusterStatusRequest) Reset added in v1.5.0

func (x *UpdateClusterStatusRequest) Reset()

func (*UpdateClusterStatusRequest) String added in v1.5.0

func (x *UpdateClusterStatusRequest) String() string

type UpdateClusterStatusResponse added in v1.5.0

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

func (*UpdateClusterStatusResponse) Descriptor deprecated added in v1.5.0

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

Deprecated: Use UpdateClusterStatusResponse.ProtoReflect.Descriptor instead.

func (*UpdateClusterStatusResponse) ProtoMessage added in v1.5.0

func (*UpdateClusterStatusResponse) ProtoMessage()

func (*UpdateClusterStatusResponse) ProtoReflect added in v1.5.0

func (*UpdateClusterStatusResponse) Reset added in v1.5.0

func (x *UpdateClusterStatusResponse) Reset()

func (*UpdateClusterStatusResponse) String added in v1.5.0

func (x *UpdateClusterStatusResponse) String() string

type UpdateJobPhaseRequest

type UpdateJobPhaseRequest struct {
	Id    string                      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Phase UpdateJobPhaseRequest_Phase `` /* 129-byte string literal not displayed */
	// message describing the details of the job phase. currently only used for failed jobs.
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// model_id is optional.
	ModelId string `protobuf:"bytes,4,opt,name=model_id,json=modelId,proto3" json:"model_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateJobPhaseRequest) Descriptor deprecated

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

Deprecated: Use UpdateJobPhaseRequest.ProtoReflect.Descriptor instead.

func (*UpdateJobPhaseRequest) GetId

func (x *UpdateJobPhaseRequest) GetId() string

func (*UpdateJobPhaseRequest) GetMessage

func (x *UpdateJobPhaseRequest) GetMessage() string

func (*UpdateJobPhaseRequest) GetModelId

func (x *UpdateJobPhaseRequest) GetModelId() string

func (*UpdateJobPhaseRequest) GetPhase

func (*UpdateJobPhaseRequest) ProtoMessage

func (*UpdateJobPhaseRequest) ProtoMessage()

func (*UpdateJobPhaseRequest) ProtoReflect

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

func (*UpdateJobPhaseRequest) Reset

func (x *UpdateJobPhaseRequest) Reset()

func (*UpdateJobPhaseRequest) String

func (x *UpdateJobPhaseRequest) String() string

type UpdateJobPhaseRequest_Phase

type UpdateJobPhaseRequest_Phase int32
const (
	UpdateJobPhaseRequest_PHASE_UNSPECIFIED UpdateJobPhaseRequest_Phase = 0
	UpdateJobPhaseRequest_PREPROCESSED      UpdateJobPhaseRequest_Phase = 1
	UpdateJobPhaseRequest_JOB_CREATED       UpdateJobPhaseRequest_Phase = 2
	UpdateJobPhaseRequest_FINETUNED         UpdateJobPhaseRequest_Phase = 3
	UpdateJobPhaseRequest_FAILED            UpdateJobPhaseRequest_Phase = 4
	UpdateJobPhaseRequest_RECREATE          UpdateJobPhaseRequest_Phase = 5
	UpdateJobPhaseRequest_CANCELED          UpdateJobPhaseRequest_Phase = 6
)

func (UpdateJobPhaseRequest_Phase) Descriptor

func (UpdateJobPhaseRequest_Phase) Enum

func (UpdateJobPhaseRequest_Phase) EnumDescriptor deprecated

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

Deprecated: Use UpdateJobPhaseRequest_Phase.Descriptor instead.

func (UpdateJobPhaseRequest_Phase) Number

func (UpdateJobPhaseRequest_Phase) String

func (UpdateJobPhaseRequest_Phase) Type

type UpdateJobPhaseResponse

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

func (*UpdateJobPhaseResponse) Descriptor deprecated

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

Deprecated: Use UpdateJobPhaseResponse.ProtoReflect.Descriptor instead.

func (*UpdateJobPhaseResponse) ProtoMessage

func (*UpdateJobPhaseResponse) ProtoMessage()

func (*UpdateJobPhaseResponse) ProtoReflect

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

func (*UpdateJobPhaseResponse) Reset

func (x *UpdateJobPhaseResponse) Reset()

func (*UpdateJobPhaseResponse) String

func (x *UpdateJobPhaseResponse) String() string

type UpdateNotebookStateRequest

type UpdateNotebookStateRequest struct {
	Id     string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State  NotebookState `protobuf:"varint,2,opt,name=state,proto3,enum=llmariner.workspace.server.v1.NotebookState" json:"state,omitempty"`
	Reason string        `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNotebookStateRequest) Descriptor deprecated

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

Deprecated: Use UpdateNotebookStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateNotebookStateRequest) GetId

func (*UpdateNotebookStateRequest) GetReason added in v1.18.0

func (x *UpdateNotebookStateRequest) GetReason() string

func (*UpdateNotebookStateRequest) GetState

func (*UpdateNotebookStateRequest) ProtoMessage

func (*UpdateNotebookStateRequest) ProtoMessage()

func (*UpdateNotebookStateRequest) ProtoReflect

func (*UpdateNotebookStateRequest) Reset

func (x *UpdateNotebookStateRequest) Reset()

func (*UpdateNotebookStateRequest) String

func (x *UpdateNotebookStateRequest) String() string

type UpdateNotebookStateResponse

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

func (*UpdateNotebookStateResponse) Descriptor deprecated

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

Deprecated: Use UpdateNotebookStateResponse.ProtoReflect.Descriptor instead.

func (*UpdateNotebookStateResponse) ProtoMessage

func (*UpdateNotebookStateResponse) ProtoMessage()

func (*UpdateNotebookStateResponse) ProtoReflect

func (*UpdateNotebookStateResponse) Reset

func (x *UpdateNotebookStateResponse) Reset()

func (*UpdateNotebookStateResponse) String

func (x *UpdateNotebookStateResponse) String() string

type WorkspaceServiceClient

type WorkspaceServiceClient interface {
	CreateNotebook(ctx context.Context, in *CreateNotebookRequest, opts ...grpc.CallOption) (*Notebook, error)
	ListNotebooks(ctx context.Context, in *ListNotebooksRequest, opts ...grpc.CallOption) (*ListNotebooksResponse, error)
	GetNotebook(ctx context.Context, in *GetNotebookRequest, opts ...grpc.CallOption) (*Notebook, error)
	DeleteNotebook(ctx context.Context, in *DeleteNotebookRequest, opts ...grpc.CallOption) (*DeleteNotebookResponse, error)
	StopNotebook(ctx context.Context, in *StopNotebookRequest, opts ...grpc.CallOption) (*Notebook, error)
	StartNotebook(ctx context.Context, in *StartNotebookRequest, opts ...grpc.CallOption) (*Notebook, error)
}

WorkspaceServiceClient is the client API for WorkspaceService 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.

type WorkspaceServiceServer

type WorkspaceServiceServer interface {
	CreateNotebook(context.Context, *CreateNotebookRequest) (*Notebook, error)
	ListNotebooks(context.Context, *ListNotebooksRequest) (*ListNotebooksResponse, error)
	GetNotebook(context.Context, *GetNotebookRequest) (*Notebook, error)
	DeleteNotebook(context.Context, *DeleteNotebookRequest) (*DeleteNotebookResponse, error)
	StopNotebook(context.Context, *StopNotebookRequest) (*Notebook, error)
	StartNotebook(context.Context, *StartNotebookRequest) (*Notebook, error)
	// contains filtered or unexported methods
}

WorkspaceServiceServer is the server API for WorkspaceService service. All implementations must embed UnimplementedWorkspaceServiceServer for forward compatibility

type WorkspaceWorkerServiceClient

type WorkspaceWorkerServiceClient interface {
	ListQueuedInternalNotebooks(ctx context.Context, in *ListQueuedInternalNotebooksRequest, opts ...grpc.CallOption) (*ListQueuedInternalNotebooksResponse, error)
	UpdateNotebookState(ctx context.Context, in *UpdateNotebookStateRequest, opts ...grpc.CallOption) (*UpdateNotebookStateResponse, error)
}

WorkspaceWorkerServiceClient is the client API for WorkspaceWorkerService 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.

type WorkspaceWorkerServiceServer

type WorkspaceWorkerServiceServer interface {
	ListQueuedInternalNotebooks(context.Context, *ListQueuedInternalNotebooksRequest) (*ListQueuedInternalNotebooksResponse, error)
	UpdateNotebookState(context.Context, *UpdateNotebookStateRequest) (*UpdateNotebookStateResponse, error)
	// contains filtered or unexported methods
}

WorkspaceWorkerServiceServer is the server API for WorkspaceWorkerService service. All implementations must embed UnimplementedWorkspaceWorkerServiceServer for forward compatibility

Jump to

Keyboard shortcuts

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