v1

package
v0.164.0 Latest Latest
Warning

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

 Go to latest Published: Jun 20, 2024 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.

Index

Constants

View Source 
const (
	FineTuningService_CreateJob_FullMethodName = "/llmoperator.fine_tuning.server.v1.FineTuningService/CreateJob"
	FineTuningService_ListJobs_FullMethodName  = "/llmoperator.fine_tuning.server.v1.FineTuningService/ListJobs"
	FineTuningService_GetJob_FullMethodName    = "/llmoperator.fine_tuning.server.v1.FineTuningService/GetJob"
	FineTuningService_CancelJob_FullMethodName = "/llmoperator.fine_tuning.server.v1.FineTuningService/CancelJob"
)
View Source 
const (
	FineTuningWorkerService_ListQueuedInternalJobs_FullMethodName = "/llmoperator.fine_tuning.server.v1.FineTuningWorkerService/ListQueuedInternalJobs"
	FineTuningWorkerService_GetInternalJob_FullMethodName         = "/llmoperator.fine_tuning.server.v1.FineTuningWorkerService/GetInternalJob"
	FineTuningWorkerService_UpdateJobPhase_FullMethodName         = "/llmoperator.fine_tuning.server.v1.FineTuningWorkerService/UpdateJobPhase"
)
View Source 
const (
	WorkspaceService_CreateNotebook_FullMethodName = "/llmoperator.workspace.server.v1.WorkspaceService/CreateNotebook"
	WorkspaceService_ListNotebooks_FullMethodName  = "/llmoperator.workspace.server.v1.WorkspaceService/ListNotebooks"
	WorkspaceService_GetNotebook_FullMethodName    = "/llmoperator.workspace.server.v1.WorkspaceService/GetNotebook"
	WorkspaceService_DeleteNotebook_FullMethodName = "/llmoperator.workspace.server.v1.WorkspaceService/DeleteNotebook"
	WorkspaceService_StopNotebook_FullMethodName   = "/llmoperator.workspace.server.v1.WorkspaceService/StopNotebook"
	WorkspaceService_StartNotebook_FullMethodName  = "/llmoperator.workspace.server.v1.WorkspaceService/StartNotebook"
)
View Source 
const (
	WorkspaceWorkerService_ListQueuedInternalNotebooks_FullMethodName = "/llmoperator.workspace.server.v1.WorkspaceWorkerService/ListQueuedInternalNotebooks"
	WorkspaceWorkerService_UpdateNotebookState_FullMethodName         = "/llmoperator.workspace.server.v1.WorkspaceWorkerService/UpdateNotebookState"
)

Variables

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

Enum value maps for InternalJob_State.

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

Enum value maps for UpdateJobPhaseRequest_Phase.

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

Enum value maps for NotebookState.

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

Enum value maps for NotebookQueuedAction.

View Source 
var File_api_v1_job_manager_service_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_workspace_service_proto protoreflect.FileDescriptor
View Source 
var FineTuningService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmoperator.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/job_manager_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: "llmoperator.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/job_manager_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 WorkspaceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmoperator.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: "llmoperator.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 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 added in v0.120.0 

func RegisterFineTuningWorkerServiceServer(s grpc.ServiceRegistrar, srv FineTuningWorkerServiceServer)

func RegisterWorkspaceServiceHandler added in v0.86.0 

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 added in v0.86.0 

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 added in v0.86.0 

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 added in v0.86.0 

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 added in v0.86.0 

func RegisterWorkspaceServiceServer(s grpc.ServiceRegistrar, srv WorkspaceServiceServer)

func RegisterWorkspaceWorkerServiceServer added in v0.124.0 

func RegisterWorkspaceWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkspaceWorkerServiceServer)

Types

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 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"`
	// 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 added in v0.121.0 

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

func (*CreateJobRequest) GetModel 

func (x *CreateJobRequest) GetModel() string

func (*CreateJobRequest) GetSeed added in v0.121.0 

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 added in v0.59.0 

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 added in v0.59.0 

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

Deprecated: Use CreateJobRequest_Hyperparameters.ProtoReflect.Descriptor instead.

func (*CreateJobRequest_Hyperparameters) GetBatchSize added in v0.59.0 

func (x *CreateJobRequest_Hyperparameters) GetBatchSize() int32

func (*CreateJobRequest_Hyperparameters) GetLearningRateMultiplier added in v0.59.0 

func (x *CreateJobRequest_Hyperparameters) GetLearningRateMultiplier() float64

func (*CreateJobRequest_Hyperparameters) GetNEpochs added in v0.59.0 

func (x *CreateJobRequest_Hyperparameters) GetNEpochs() int32

func (*CreateJobRequest_Hyperparameters) ProtoMessage added in v0.59.0 

func (*CreateJobRequest_Hyperparameters) ProtoMessage()

func (*CreateJobRequest_Hyperparameters) ProtoReflect added in v0.59.0 

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

func (*CreateJobRequest_Hyperparameters) Reset added in v0.59.0 

func (x *CreateJobRequest_Hyperparameters) Reset()

func (*CreateJobRequest_Hyperparameters) String added in v0.59.0 

func (x *CreateJobRequest_Hyperparameters) String() string

type CreateNotebookRequest added in v0.86.0 

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 */
	// contains filtered or unexported fields
}

func (*CreateNotebookRequest) Descriptor deprecated added in v0.86.0 

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

Deprecated: Use CreateNotebookRequest.ProtoReflect.Descriptor instead.

func (*CreateNotebookRequest) GetEnvs added in v0.86.0 

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

func (*CreateNotebookRequest) GetImage added in v0.86.0 

func (x *CreateNotebookRequest) GetImage() *CreateNotebookRequest_Image

func (*CreateNotebookRequest) GetName added in v0.86.0 

func (x *CreateNotebookRequest) GetName() string

func (*CreateNotebookRequest) GetResources added in v0.86.0 

func (x *CreateNotebookRequest) GetResources() *Resources

func (*CreateNotebookRequest) ProtoMessage added in v0.86.0 

func (*CreateNotebookRequest) ProtoMessage()

func (*CreateNotebookRequest) ProtoReflect added in v0.86.0 

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

func (*CreateNotebookRequest) Reset added in v0.86.0 

func (x *CreateNotebookRequest) Reset()

func (*CreateNotebookRequest) String added in v0.86.0 

func (x *CreateNotebookRequest) String() string

type CreateNotebookRequest_Image added in v0.86.0 

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 added in v0.86.0 

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

Deprecated: Use CreateNotebookRequest_Image.ProtoReflect.Descriptor instead.

func (*CreateNotebookRequest_Image) GetImage added in v0.86.0 

func (m *CreateNotebookRequest_Image) GetImage() isCreateNotebookRequest_Image_Image

func (*CreateNotebookRequest_Image) GetType added in v0.86.0 

func (x *CreateNotebookRequest_Image) GetType() string

func (*CreateNotebookRequest_Image) GetUri added in v0.86.0 

func (x *CreateNotebookRequest_Image) GetUri() string

func (*CreateNotebookRequest_Image) ProtoMessage added in v0.86.0 

func (*CreateNotebookRequest_Image) ProtoMessage()

func (*CreateNotebookRequest_Image) ProtoReflect added in v0.86.0 

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

func (*CreateNotebookRequest_Image) Reset added in v0.86.0 

func (x *CreateNotebookRequest_Image) Reset()

func (*CreateNotebookRequest_Image) String added in v0.86.0 

func (x *CreateNotebookRequest_Image) String() string

type CreateNotebookRequest_Image_Type added in v0.86.0 

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

type CreateNotebookRequest_Image_Uri added in v0.86.0 

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

type DeleteNotebookRequest added in v0.86.0 

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

func (*DeleteNotebookRequest) Descriptor deprecated added in v0.86.0 

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

Deprecated: Use DeleteNotebookRequest.ProtoReflect.Descriptor instead.

func (*DeleteNotebookRequest) GetId added in v0.86.0 

func (x *DeleteNotebookRequest) GetId() string

func (*DeleteNotebookRequest) ProtoMessage added in v0.86.0 

func (*DeleteNotebookRequest) ProtoMessage()

func (*DeleteNotebookRequest) ProtoReflect added in v0.86.0 

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

func (*DeleteNotebookRequest) Reset added in v0.86.0 

func (x *DeleteNotebookRequest) Reset()

func (*DeleteNotebookRequest) String added in v0.86.0 

func (x *DeleteNotebookRequest) String() string

type DeleteNotebookResponse added in v0.86.0 

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

func (*DeleteNotebookResponse) Descriptor deprecated added in v0.86.0 

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

Deprecated: Use DeleteNotebookResponse.ProtoReflect.Descriptor instead.

func (*DeleteNotebookResponse) ProtoMessage added in v0.86.0 

func (*DeleteNotebookResponse) ProtoMessage()

func (*DeleteNotebookResponse) ProtoReflect added in v0.86.0 

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

func (*DeleteNotebookResponse) Reset added in v0.86.0 

func (x *DeleteNotebookResponse) Reset()

func (*DeleteNotebookResponse) String added in v0.86.0 

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.

func NewFineTuningServiceClient 

func NewFineTuningServiceClient(cc grpc.ClientConnInterface) FineTuningServiceClient

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 added in v0.120.0 

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.

func NewFineTuningWorkerServiceClient added in v0.120.0 

func NewFineTuningWorkerServiceClient(cc grpc.ClientConnInterface) FineTuningWorkerServiceClient

type FineTuningWorkerServiceServer added in v0.120.0 

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 GetInternalJobRequest added in v0.120.0 

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

func (*GetInternalJobRequest) Descriptor deprecated added in v0.120.0 

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

Deprecated: Use GetInternalJobRequest.ProtoReflect.Descriptor instead.

func (*GetInternalJobRequest) GetId added in v0.120.0 

func (x *GetInternalJobRequest) GetId() string

func (*GetInternalJobRequest) ProtoMessage added in v0.120.0 

func (*GetInternalJobRequest) ProtoMessage()

func (*GetInternalJobRequest) ProtoReflect added in v0.120.0 

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

func (*GetInternalJobRequest) Reset added in v0.120.0 

func (x *GetInternalJobRequest) Reset()

func (*GetInternalJobRequest) String added in v0.120.0 

func (x *GetInternalJobRequest) String() string

type GetJobRequest added in v0.76.0 

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

func (*GetJobRequest) Descriptor deprecated added in v0.76.0 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetId added in v0.76.0 

func (x *GetJobRequest) GetId() string

func (*GetJobRequest) ProtoMessage added in v0.76.0 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect added in v0.76.0 

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

func (*GetJobRequest) Reset added in v0.76.0 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String added in v0.76.0 

func (x *GetJobRequest) String() string

type GetNotebookRequest added in v0.86.0 

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

func (*GetNotebookRequest) Descriptor deprecated added in v0.86.0 

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

Deprecated: Use GetNotebookRequest.ProtoReflect.Descriptor instead.

func (*GetNotebookRequest) GetId added in v0.86.0 

func (x *GetNotebookRequest) GetId() string

func (*GetNotebookRequest) ProtoMessage added in v0.86.0 

func (*GetNotebookRequest) ProtoMessage()

func (*GetNotebookRequest) ProtoReflect added in v0.86.0 

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

func (*GetNotebookRequest) Reset added in v0.86.0 

func (x *GetNotebookRequest) Reset()

func (*GetNotebookRequest) String added in v0.86.0 

func (x *GetNotebookRequest) String() string

type Integration added in v0.121.0 

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 added in v0.121.0 

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

Deprecated: Use Integration.ProtoReflect.Descriptor instead.

func (*Integration) GetType added in v0.121.0 

func (x *Integration) GetType() string

func (*Integration) GetWandb added in v0.121.0 

func (x *Integration) GetWandb() *Integration_Wandb

func (*Integration) ProtoMessage added in v0.121.0 

func (*Integration) ProtoMessage()

func (*Integration) ProtoReflect added in v0.121.0 

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

func (*Integration) Reset added in v0.121.0 

func (x *Integration) Reset()

func (*Integration) String added in v0.121.0 

func (x *Integration) String() string

type Integration_Wandb added in v0.121.0 

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 added in v0.121.0 

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

Deprecated: Use Integration_Wandb.ProtoReflect.Descriptor instead.

func (*Integration_Wandb) GetEntity added in v0.121.0 

func (x *Integration_Wandb) GetEntity() string

func (*Integration_Wandb) GetName added in v0.121.0 

func (x *Integration_Wandb) GetName() string

func (*Integration_Wandb) GetProject added in v0.121.0 

func (x *Integration_Wandb) GetProject() string

func (*Integration_Wandb) GetTags added in v0.121.0 

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

func (*Integration_Wandb) ProtoMessage added in v0.121.0 

func (*Integration_Wandb) ProtoMessage()

func (*Integration_Wandb) ProtoReflect added in v0.121.0 

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

func (*Integration_Wandb) Reset added in v0.121.0 

func (x *Integration_Wandb) Reset()

func (*Integration_Wandb) String added in v0.121.0 

func (x *Integration_Wandb) String() string

type InternalJob added in v0.120.0 

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=llmoperator.fine_tuning.server.v1.InternalJob_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*InternalJob) Descriptor deprecated added in v0.120.0 

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

Deprecated: Use InternalJob.ProtoReflect.Descriptor instead.

func (*InternalJob) GetJob added in v0.120.0 

func (x *InternalJob) GetJob() *Job

func (*InternalJob) GetOutputModelId added in v0.120.0 

func (x *InternalJob) GetOutputModelId() string

func (*InternalJob) GetState added in v0.120.0 

func (x *InternalJob) GetState() InternalJob_State

func (*InternalJob) GetSuffix added in v0.120.0 

func (x *InternalJob) GetSuffix() string

func (*InternalJob) ProtoMessage added in v0.120.0 

func (*InternalJob) ProtoMessage()

func (*InternalJob) ProtoReflect added in v0.120.0 

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

func (*InternalJob) Reset added in v0.120.0 

func (x *InternalJob) Reset()

func (*InternalJob) String added in v0.120.0 

func (x *InternalJob) String() string

type InternalJob_State added in v0.130.0 

type InternalJob_State int32
const (
	InternalJob_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 added in v0.130.0 

func (InternalJob_State) Descriptor() protoreflect.EnumDescriptor

func (InternalJob_State) Enum added in v0.130.0 

func (x InternalJob_State) Enum() *InternalJob_State

func (InternalJob_State) EnumDescriptor deprecated added in v0.130.0 

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

Deprecated: Use InternalJob_State.Descriptor instead.

func (InternalJob_State) Number added in v0.130.0 

func (x InternalJob_State) Number() protoreflect.EnumNumber

func (InternalJob_State) String added in v0.130.0 

func (x InternalJob_State) String() string

func (InternalJob_State) Type added in v0.130.0 

func (InternalJob_State) Type() protoreflect.EnumType

type InternalNotebook added in v0.124.0 

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=llmoperator.workspace.server.v1.NotebookState" json:"state,omitempty"`
	QueuedAction NotebookQueuedAction `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InternalNotebook) Descriptor deprecated added in v0.124.0 

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

Deprecated: Use InternalNotebook.ProtoReflect.Descriptor instead.

func (*InternalNotebook) GetNotebook added in v0.124.0 

func (x *InternalNotebook) GetNotebook() *Notebook

func (*InternalNotebook) GetQueuedAction added in v0.124.0 

func (x *InternalNotebook) GetQueuedAction() NotebookQueuedAction

func (*InternalNotebook) GetState added in v0.124.0 

func (x *InternalNotebook) GetState() NotebookState

func (*InternalNotebook) ProtoMessage added in v0.124.0 

func (*InternalNotebook) ProtoMessage()

func (*InternalNotebook) ProtoReflect added in v0.124.0 

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

func (*InternalNotebook) Reset added in v0.124.0 

func (x *InternalNotebook) Reset()

func (*InternalNotebook) String added in v0.124.0 

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"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetClusterId added in v0.143.0 

func (x *Job) GetClusterId() 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 added in v0.121.0 

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

func (*Job) GetKubernetesNamespace added in v0.97.0 

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) GetProjectId added in v0.97.0 

func (x *Job) GetProjectId() string

func (*Job) GetResultFiles 

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

func (*Job) GetSeed added in v0.121.0 

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 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 added in v0.59.0 

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 added in v0.59.0 

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

Deprecated: Use Job_Hyperparameters.ProtoReflect.Descriptor instead.

func (*Job_Hyperparameters) GetBatchSize added in v0.61.0 

func (x *Job_Hyperparameters) GetBatchSize() int32

func (*Job_Hyperparameters) GetLearningRateMultiplier added in v0.61.0 

func (x *Job_Hyperparameters) GetLearningRateMultiplier() float64

func (*Job_Hyperparameters) GetNEpochs added in v0.59.0 

func (x *Job_Hyperparameters) GetNEpochs() int32

func (*Job_Hyperparameters) ProtoMessage added in v0.59.0 

func (*Job_Hyperparameters) ProtoMessage()

func (*Job_Hyperparameters) ProtoReflect added in v0.59.0 

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

func (*Job_Hyperparameters) Reset added in v0.59.0 

func (x *Job_Hyperparameters) Reset()

func (*Job_Hyperparameters) String added in v0.59.0 

func (x *Job_Hyperparameters) 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"`
	// 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) 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 added in v0.86.0 

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 added in v0.86.0 

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

Deprecated: Use ListNotebooksRequest.ProtoReflect.Descriptor instead.

func (*ListNotebooksRequest) GetAfter added in v0.96.0 

func (x *ListNotebooksRequest) GetAfter() string

func (*ListNotebooksRequest) GetLimit added in v0.96.0 

func (x *ListNotebooksRequest) GetLimit() int32

func (*ListNotebooksRequest) ProtoMessage added in v0.86.0 

func (*ListNotebooksRequest) ProtoMessage()

func (*ListNotebooksRequest) ProtoReflect added in v0.86.0 

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

func (*ListNotebooksRequest) Reset added in v0.86.0 

func (x *ListNotebooksRequest) Reset()

func (*ListNotebooksRequest) String added in v0.86.0 

func (x *ListNotebooksRequest) String() string

type ListNotebooksResponse added in v0.86.0 

type ListNotebooksResponse struct {
	Notebooks []*Notebook `protobuf:"bytes,1,rep,name=notebooks,proto3" json:"notebooks,omitempty"`
	HasMore   bool        `protobuf:"varint,3,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNotebooksResponse) Descriptor deprecated added in v0.86.0 

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

Deprecated: Use ListNotebooksResponse.ProtoReflect.Descriptor instead.

func (*ListNotebooksResponse) GetHasMore added in v0.96.0 

func (x *ListNotebooksResponse) GetHasMore() bool

func (*ListNotebooksResponse) GetNotebooks added in v0.86.0 

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

func (*ListNotebooksResponse) ProtoMessage added in v0.86.0 

func (*ListNotebooksResponse) ProtoMessage()

func (*ListNotebooksResponse) ProtoReflect added in v0.86.0 

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

func (*ListNotebooksResponse) Reset added in v0.86.0 

func (x *ListNotebooksResponse) Reset()

func (*ListNotebooksResponse) String added in v0.86.0 

func (x *ListNotebooksResponse) String() string

type ListQueuedInternalJobsRequest added in v0.120.0 

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

func (*ListQueuedInternalJobsRequest) Descriptor deprecated added in v0.120.0 

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

Deprecated: Use ListQueuedInternalJobsRequest.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalJobsRequest) ProtoMessage added in v0.120.0 

func (*ListQueuedInternalJobsRequest) ProtoMessage()

func (*ListQueuedInternalJobsRequest) ProtoReflect added in v0.120.0 

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

func (*ListQueuedInternalJobsRequest) Reset added in v0.120.0 

func (x *ListQueuedInternalJobsRequest) Reset()

func (*ListQueuedInternalJobsRequest) String added in v0.120.0 

func (x *ListQueuedInternalJobsRequest) String() string

type ListQueuedInternalJobsResponse added in v0.120.0 

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

func (*ListQueuedInternalJobsResponse) Descriptor deprecated added in v0.120.0 

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

Deprecated: Use ListQueuedInternalJobsResponse.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalJobsResponse) GetJobs added in v0.120.0 

func (x *ListQueuedInternalJobsResponse) GetJobs() []*InternalJob

func (*ListQueuedInternalJobsResponse) ProtoMessage added in v0.120.0 

func (*ListQueuedInternalJobsResponse) ProtoMessage()

func (*ListQueuedInternalJobsResponse) ProtoReflect added in v0.120.0 

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

func (*ListQueuedInternalJobsResponse) Reset added in v0.120.0 

func (x *ListQueuedInternalJobsResponse) Reset()

func (*ListQueuedInternalJobsResponse) String added in v0.120.0 

func (x *ListQueuedInternalJobsResponse) String() string

type ListQueuedInternalNotebooksRequest added in v0.124.0 

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

func (*ListQueuedInternalNotebooksRequest) Descriptor deprecated added in v0.124.0 

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

Deprecated: Use ListQueuedInternalNotebooksRequest.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalNotebooksRequest) ProtoMessage added in v0.124.0 

func (*ListQueuedInternalNotebooksRequest) ProtoMessage()

func (*ListQueuedInternalNotebooksRequest) ProtoReflect added in v0.124.0 

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

func (*ListQueuedInternalNotebooksRequest) Reset added in v0.124.0 

func (x *ListQueuedInternalNotebooksRequest) Reset()

func (*ListQueuedInternalNotebooksRequest) String added in v0.124.0 

func (x *ListQueuedInternalNotebooksRequest) String() string

type ListQueuedInternalNotebooksResponse added in v0.124.0 

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

func (*ListQueuedInternalNotebooksResponse) Descriptor deprecated added in v0.124.0 

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

Deprecated: Use ListQueuedInternalNotebooksResponse.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalNotebooksResponse) GetNotebooks added in v0.124.0 

func (x *ListQueuedInternalNotebooksResponse) GetNotebooks() []*InternalNotebook

func (*ListQueuedInternalNotebooksResponse) ProtoMessage added in v0.124.0 

func (*ListQueuedInternalNotebooksResponse) ProtoMessage()

func (*ListQueuedInternalNotebooksResponse) ProtoReflect added in v0.124.0 

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

func (*ListQueuedInternalNotebooksResponse) Reset added in v0.124.0 

func (x *ListQueuedInternalNotebooksResponse) Reset()

func (*ListQueuedInternalNotebooksResponse) String added in v0.124.0 

func (x *ListQueuedInternalNotebooksResponse) String() string

type Notebook added in v0.86.0 

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"`
	// this field is populated only when a new notebook is created.
	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"`
	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"`
	// contains filtered or unexported fields
}

func (*Notebook) Descriptor deprecated added in v0.86.0 

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

Deprecated: Use Notebook.ProtoReflect.Descriptor instead.

func (*Notebook) GetClusterId added in v0.143.0 

func (x *Notebook) GetClusterId() string

func (*Notebook) GetCreatedAt added in v0.86.0 

func (x *Notebook) GetCreatedAt() int64

func (*Notebook) GetEnvs added in v0.86.0 

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

func (*Notebook) GetError added in v0.86.0 

func (x *Notebook) GetError() *Notebook_Error

func (*Notebook) GetId added in v0.86.0 

func (x *Notebook) GetId() string

func (*Notebook) GetImage added in v0.86.0 

func (x *Notebook) GetImage() string

func (*Notebook) GetKubernetesNamespace added in v0.123.0 

func (x *Notebook) GetKubernetesNamespace() string

func (*Notebook) GetName added in v0.86.0 

func (x *Notebook) GetName() string

func (*Notebook) GetProjectId added in v0.123.0 

func (x *Notebook) GetProjectId() string

func (*Notebook) GetResources added in v0.86.0 

func (x *Notebook) GetResources() *Resources

func (*Notebook) GetStartedAt added in v0.86.0 

func (x *Notebook) GetStartedAt() int64

func (*Notebook) GetStatus added in v0.86.0 

func (x *Notebook) GetStatus() string

func (*Notebook) GetStoppedAt added in v0.86.0 

func (x *Notebook) GetStoppedAt() int64

func (*Notebook) GetToken added in v0.116.0 

func (x *Notebook) GetToken() string

func (*Notebook) ProtoMessage added in v0.86.0 

func (*Notebook) ProtoMessage()

func (*Notebook) ProtoReflect added in v0.86.0 

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

func (*Notebook) Reset added in v0.86.0 

func (x *Notebook) Reset()

func (*Notebook) String added in v0.86.0 

func (x *Notebook) String() string

type NotebookQueuedAction added in v0.124.0 

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

func (NotebookQueuedAction) Descriptor added in v0.124.0 

func (NotebookQueuedAction) Descriptor() protoreflect.EnumDescriptor

func (NotebookQueuedAction) Enum added in v0.124.0 

func (x NotebookQueuedAction) Enum() *NotebookQueuedAction

func (NotebookQueuedAction) EnumDescriptor deprecated added in v0.124.0 

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

Deprecated: Use NotebookQueuedAction.Descriptor instead.

func (NotebookQueuedAction) Number added in v0.124.0 

func (x NotebookQueuedAction) Number() protoreflect.EnumNumber

func (NotebookQueuedAction) String added in v0.124.0 

func (x NotebookQueuedAction) String() string

func (NotebookQueuedAction) Type added in v0.124.0 

func (NotebookQueuedAction) Type() protoreflect.EnumType

type NotebookState added in v0.124.0 

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

func (NotebookState) Descriptor added in v0.124.0 

func (NotebookState) Descriptor() protoreflect.EnumDescriptor

func (NotebookState) Enum added in v0.124.0 

func (x NotebookState) Enum() *NotebookState

func (NotebookState) EnumDescriptor deprecated added in v0.124.0 

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

Deprecated: Use NotebookState.Descriptor instead.

func (NotebookState) Number added in v0.124.0 

func (x NotebookState) Number() protoreflect.EnumNumber

func (NotebookState) String added in v0.124.0 

func (x NotebookState) String() string

func (NotebookState) Type added in v0.124.0 

func (NotebookState) Type() protoreflect.EnumType

type Notebook_Error added in v0.86.0 

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 added in v0.86.0 

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

Deprecated: Use Notebook_Error.ProtoReflect.Descriptor instead.

func (*Notebook_Error) GetCode added in v0.86.0 

func (x *Notebook_Error) GetCode() string

func (*Notebook_Error) GetMessage added in v0.86.0 

func (x *Notebook_Error) GetMessage() string

func (*Notebook_Error) ProtoMessage added in v0.86.0 

func (*Notebook_Error) ProtoMessage()

func (*Notebook_Error) ProtoReflect added in v0.86.0 

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

func (*Notebook_Error) Reset added in v0.86.0 

func (x *Notebook_Error) Reset()

func (*Notebook_Error) String added in v0.86.0 

func (x *Notebook_Error) String() string

type Resources added in v0.86.0 

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 added in v0.86.0 

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

Deprecated: Use Resources.ProtoReflect.Descriptor instead.

func (*Resources) GetCpuMilicore added in v0.86.0 

func (x *Resources) GetCpuMilicore() *Resources_Quantity

func (*Resources) GetGpuCount added in v0.86.0 

func (x *Resources) GetGpuCount() int32

func (*Resources) GetMemoryMegabytes added in v0.86.0 

func (x *Resources) GetMemoryMegabytes() *Resources_Quantity

func (*Resources) GetStorageMegabytes added in v0.86.0 

func (x *Resources) GetStorageMegabytes() *Resources_Quantity

func (*Resources) ProtoMessage added in v0.86.0 

func (*Resources) ProtoMessage()

func (*Resources) ProtoReflect added in v0.86.0 

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

func (*Resources) Reset added in v0.86.0 

func (x *Resources) Reset()

func (*Resources) String added in v0.86.0 

func (x *Resources) String() string

type Resources_Quantity added in v0.86.0 

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 added in v0.86.0 

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

Deprecated: Use Resources_Quantity.ProtoReflect.Descriptor instead.

func (*Resources_Quantity) GetLimits added in v0.86.0 

func (x *Resources_Quantity) GetLimits() int32

func (*Resources_Quantity) GetRequests added in v0.86.0 

func (x *Resources_Quantity) GetRequests() int32

func (*Resources_Quantity) ProtoMessage added in v0.86.0 

func (*Resources_Quantity) ProtoMessage()

func (*Resources_Quantity) ProtoReflect added in v0.86.0 

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

func (*Resources_Quantity) Reset added in v0.86.0 

func (x *Resources_Quantity) Reset()

func (*Resources_Quantity) String added in v0.86.0 

func (x *Resources_Quantity) String() string

type StartNotebookRequest added in v0.86.0 

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

func (*StartNotebookRequest) Descriptor deprecated added in v0.86.0 

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

Deprecated: Use StartNotebookRequest.ProtoReflect.Descriptor instead.

func (*StartNotebookRequest) GetId added in v0.86.0 

func (x *StartNotebookRequest) GetId() string

func (*StartNotebookRequest) ProtoMessage added in v0.86.0 

func (*StartNotebookRequest) ProtoMessage()

func (*StartNotebookRequest) ProtoReflect added in v0.86.0 

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

func (*StartNotebookRequest) Reset added in v0.86.0 

func (x *StartNotebookRequest) Reset()

func (*StartNotebookRequest) String added in v0.86.0 

func (x *StartNotebookRequest) String() string

type StopNotebookRequest added in v0.86.0 

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

func (*StopNotebookRequest) Descriptor deprecated added in v0.86.0 

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

Deprecated: Use StopNotebookRequest.ProtoReflect.Descriptor instead.

func (*StopNotebookRequest) GetId added in v0.86.0 

func (x *StopNotebookRequest) GetId() string

func (*StopNotebookRequest) ProtoMessage added in v0.86.0 

func (*StopNotebookRequest) ProtoMessage()

func (*StopNotebookRequest) ProtoReflect added in v0.86.0 

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

func (*StopNotebookRequest) Reset added in v0.86.0 

func (x *StopNotebookRequest) Reset()

func (*StopNotebookRequest) String added in v0.86.0 

func (x *StopNotebookRequest) String() string

type UnimplementedFineTuningServiceServer 

type UnimplementedFineTuningServiceServer struct {
}

UnimplementedFineTuningServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFineTuningServiceServer) CancelJob 

func (UnimplementedFineTuningServiceServer) CancelJob(context.Context, *CancelJobRequest) (*Job, error)

func (UnimplementedFineTuningServiceServer) CreateJob 

func (UnimplementedFineTuningServiceServer) CreateJob(context.Context, *CreateJobRequest) (*Job, error)

func (UnimplementedFineTuningServiceServer) GetJob added in v0.77.0 

func (UnimplementedFineTuningServiceServer) GetJob(context.Context, *GetJobRequest) (*Job, error)

func (UnimplementedFineTuningServiceServer) ListJobs 

func (UnimplementedFineTuningServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)

type UnimplementedFineTuningWorkerServiceServer added in v0.120.0 

type UnimplementedFineTuningWorkerServiceServer struct {
}

UnimplementedFineTuningWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFineTuningWorkerServiceServer) GetInternalJob added in v0.120.0 

func (UnimplementedFineTuningWorkerServiceServer) GetInternalJob(context.Context, *GetInternalJobRequest) (*InternalJob, error)

func (UnimplementedFineTuningWorkerServiceServer) ListQueuedInternalJobs added in v0.120.0 

func (UnimplementedFineTuningWorkerServiceServer) ListQueuedInternalJobs(context.Context, *ListQueuedInternalJobsRequest) (*ListQueuedInternalJobsResponse, error)

func (UnimplementedFineTuningWorkerServiceServer) UpdateJobPhase added in v0.120.0 

func (UnimplementedFineTuningWorkerServiceServer) UpdateJobPhase(context.Context, *UpdateJobPhaseRequest) (*UpdateJobPhaseResponse, error)

type UnimplementedWorkspaceServiceServer added in v0.86.0 

type UnimplementedWorkspaceServiceServer struct {
}

UnimplementedWorkspaceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkspaceServiceServer) CreateNotebook added in v0.86.0 

func (UnimplementedWorkspaceServiceServer) CreateNotebook(context.Context, *CreateNotebookRequest) (*Notebook, error)

func (UnimplementedWorkspaceServiceServer) DeleteNotebook added in v0.86.0 

func (UnimplementedWorkspaceServiceServer) DeleteNotebook(context.Context, *DeleteNotebookRequest) (*DeleteNotebookResponse, error)

func (UnimplementedWorkspaceServiceServer) GetNotebook added in v0.86.0 

func (UnimplementedWorkspaceServiceServer) GetNotebook(context.Context, *GetNotebookRequest) (*Notebook, error)

func (UnimplementedWorkspaceServiceServer) ListNotebooks added in v0.86.0 

func (UnimplementedWorkspaceServiceServer) ListNotebooks(context.Context, *ListNotebooksRequest) (*ListNotebooksResponse, error)

func (UnimplementedWorkspaceServiceServer) StartNotebook added in v0.86.0 

func (UnimplementedWorkspaceServiceServer) StartNotebook(context.Context, *StartNotebookRequest) (*Notebook, error)

func (UnimplementedWorkspaceServiceServer) StopNotebook added in v0.86.0 

func (UnimplementedWorkspaceServiceServer) StopNotebook(context.Context, *StopNotebookRequest) (*Notebook, error)

type UnimplementedWorkspaceWorkerServiceServer added in v0.124.0 

type UnimplementedWorkspaceWorkerServiceServer struct {
}

UnimplementedWorkspaceWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkspaceWorkerServiceServer) ListQueuedInternalNotebooks added in v0.124.0 

func (UnimplementedWorkspaceWorkerServiceServer) ListQueuedInternalNotebooks(context.Context, *ListQueuedInternalNotebooksRequest) (*ListQueuedInternalNotebooksResponse, error)

func (UnimplementedWorkspaceWorkerServiceServer) UpdateNotebookState added in v0.124.0 

func (UnimplementedWorkspaceWorkerServiceServer) UpdateNotebookState(context.Context, *UpdateNotebookStateRequest) (*UpdateNotebookStateResponse, error)

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 added in v0.120.0 

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 UnsafeWorkspaceServiceServer added in v0.86.0 

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 added in v0.124.0 

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 UpdateJobPhaseRequest added in v0.120.0 

type UpdateJobPhaseRequest struct {
	Id    string                      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Phase UpdateJobPhaseRequest_Phase `` /* 131-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 added in v0.120.0 

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

Deprecated: Use UpdateJobPhaseRequest.ProtoReflect.Descriptor instead.

func (*UpdateJobPhaseRequest) GetId added in v0.120.0 

func (x *UpdateJobPhaseRequest) GetId() string

func (*UpdateJobPhaseRequest) GetMessage added in v0.120.0 

func (x *UpdateJobPhaseRequest) GetMessage() string

func (*UpdateJobPhaseRequest) GetModelId added in v0.120.0 

func (x *UpdateJobPhaseRequest) GetModelId() string

func (*UpdateJobPhaseRequest) GetPhase added in v0.120.0 

func (x *UpdateJobPhaseRequest) GetPhase() UpdateJobPhaseRequest_Phase

func (*UpdateJobPhaseRequest) ProtoMessage added in v0.120.0 

func (*UpdateJobPhaseRequest) ProtoMessage()

func (*UpdateJobPhaseRequest) ProtoReflect added in v0.120.0 

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

func (*UpdateJobPhaseRequest) Reset added in v0.120.0 

func (x *UpdateJobPhaseRequest) Reset()

func (*UpdateJobPhaseRequest) String added in v0.120.0 

func (x *UpdateJobPhaseRequest) String() string

type UpdateJobPhaseRequest_Phase added in v0.130.0 

type UpdateJobPhaseRequest_Phase int32
const (
	UpdateJobPhaseRequest_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_REQUEUE      UpdateJobPhaseRequest_Phase = 5
)

func (UpdateJobPhaseRequest_Phase) Descriptor added in v0.130.0 

func (UpdateJobPhaseRequest_Phase) Descriptor() protoreflect.EnumDescriptor

func (UpdateJobPhaseRequest_Phase) Enum added in v0.130.0 

func (x UpdateJobPhaseRequest_Phase) Enum() *UpdateJobPhaseRequest_Phase

func (UpdateJobPhaseRequest_Phase) EnumDescriptor deprecated added in v0.130.0 

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

Deprecated: Use UpdateJobPhaseRequest_Phase.Descriptor instead.

func (UpdateJobPhaseRequest_Phase) Number added in v0.130.0 

func (x UpdateJobPhaseRequest_Phase) Number() protoreflect.EnumNumber

func (UpdateJobPhaseRequest_Phase) String added in v0.130.0 

func (x UpdateJobPhaseRequest_Phase) String() string

func (UpdateJobPhaseRequest_Phase) Type added in v0.130.0 

func (UpdateJobPhaseRequest_Phase) Type() protoreflect.EnumType

type UpdateJobPhaseResponse added in v0.120.0 

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

func (*UpdateJobPhaseResponse) Descriptor deprecated added in v0.120.0 

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

Deprecated: Use UpdateJobPhaseResponse.ProtoReflect.Descriptor instead.

func (*UpdateJobPhaseResponse) ProtoMessage added in v0.120.0 

func (*UpdateJobPhaseResponse) ProtoMessage()

func (*UpdateJobPhaseResponse) ProtoReflect added in v0.120.0 

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

func (*UpdateJobPhaseResponse) Reset added in v0.120.0 

func (x *UpdateJobPhaseResponse) Reset()

func (*UpdateJobPhaseResponse) String added in v0.120.0 

func (x *UpdateJobPhaseResponse) String() string

type UpdateNotebookStateRequest added in v0.124.0 

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=llmoperator.workspace.server.v1.NotebookState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNotebookStateRequest) Descriptor deprecated added in v0.124.0 

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

Deprecated: Use UpdateNotebookStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateNotebookStateRequest) GetId added in v0.124.0 

func (x *UpdateNotebookStateRequest) GetId() string

func (*UpdateNotebookStateRequest) GetState added in v0.124.0 

func (x *UpdateNotebookStateRequest) GetState() NotebookState

func (*UpdateNotebookStateRequest) ProtoMessage added in v0.124.0 

func (*UpdateNotebookStateRequest) ProtoMessage()

func (*UpdateNotebookStateRequest) ProtoReflect added in v0.124.0 

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

func (*UpdateNotebookStateRequest) Reset added in v0.124.0 

func (x *UpdateNotebookStateRequest) Reset()

func (*UpdateNotebookStateRequest) String added in v0.124.0 

func (x *UpdateNotebookStateRequest) String() string

type UpdateNotebookStateResponse added in v0.124.0 

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

func (*UpdateNotebookStateResponse) Descriptor deprecated added in v0.124.0 

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

Deprecated: Use UpdateNotebookStateResponse.ProtoReflect.Descriptor instead.

func (*UpdateNotebookStateResponse) ProtoMessage added in v0.124.0 

func (*UpdateNotebookStateResponse) ProtoMessage()

func (*UpdateNotebookStateResponse) ProtoReflect added in v0.124.0 

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

func (*UpdateNotebookStateResponse) Reset added in v0.124.0 

func (x *UpdateNotebookStateResponse) Reset()

func (*UpdateNotebookStateResponse) String added in v0.124.0 

func (x *UpdateNotebookStateResponse) String() string

type WorkspaceServiceClient added in v0.86.0 

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.

func NewWorkspaceServiceClient added in v0.86.0 

func NewWorkspaceServiceClient(cc grpc.ClientConnInterface) WorkspaceServiceClient

type WorkspaceServiceServer added in v0.86.0 

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 added in v0.124.0 

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.

func NewWorkspaceWorkerServiceClient added in v0.124.0 

func NewWorkspaceWorkerServiceClient(cc grpc.ClientConnInterface) WorkspaceWorkerServiceClient

type WorkspaceWorkerServiceServer added in v0.124.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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