v1

package
v0.200.0 Latest Latest
Warning

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

Go to latest
Published: Sep 26, 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.

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",
	}
	NotebookState_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"QUEUED":            1,
		"INITIALIZING":      2,
		"RUNNING":           3,
		"STOPPED":           4,
		"FAILED":            5,
		"DELETED":           6,
	}
)

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 BatchService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmoperator.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: "llmoperator.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_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 RegisterBatchServiceHandler added in v0.174.0

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

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

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

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

func RegisterBatchServiceServer(s grpc.ServiceRegistrar, srv BatchServiceServer)

func RegisterBatchWorkerServiceServer added in v0.179.0

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

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

func (*BatchJob) Descriptor deprecated added in v0.174.0

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

Deprecated: Use BatchJob.ProtoReflect.Descriptor instead.

func (*BatchJob) GetClusterId added in v0.179.0

func (x *BatchJob) GetClusterId() string

func (*BatchJob) GetCommand added in v0.174.0

func (x *BatchJob) GetCommand() string

func (*BatchJob) GetCreatedAt added in v0.174.0

func (x *BatchJob) GetCreatedAt() int64

func (*BatchJob) GetDataFiles added in v0.174.0

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

func (*BatchJob) GetEnvs added in v0.174.0

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

func (*BatchJob) GetError added in v0.174.0

func (x *BatchJob) GetError() *BatchJob_Error

func (*BatchJob) GetFinishedAt added in v0.174.0

func (x *BatchJob) GetFinishedAt() int64

func (*BatchJob) GetId added in v0.174.0

func (x *BatchJob) GetId() string

func (*BatchJob) GetImage added in v0.174.0

func (x *BatchJob) GetImage() string

func (*BatchJob) GetKind added in v0.184.0

func (x *BatchJob) GetKind() *BatchJob_Kind

func (*BatchJob) GetKubernetesNamespace added in v0.179.0

func (x *BatchJob) GetKubernetesNamespace() string

func (*BatchJob) GetProjectId added in v0.179.0

func (x *BatchJob) GetProjectId() string

func (*BatchJob) GetResources added in v0.174.0

func (x *BatchJob) GetResources() *BatchJob_Resources

func (*BatchJob) GetStatus added in v0.174.0

func (x *BatchJob) GetStatus() string

func (*BatchJob) ProtoMessage added in v0.174.0

func (*BatchJob) ProtoMessage()

func (*BatchJob) ProtoReflect added in v0.174.0

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

func (*BatchJob) Reset added in v0.174.0

func (x *BatchJob) Reset()

func (*BatchJob) String added in v0.174.0

func (x *BatchJob) String() string

type BatchJob_Error added in v0.174.0

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

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

Deprecated: Use BatchJob_Error.ProtoReflect.Descriptor instead.

func (*BatchJob_Error) GetCode added in v0.174.0

func (x *BatchJob_Error) GetCode() string

func (*BatchJob_Error) GetMessage added in v0.174.0

func (x *BatchJob_Error) GetMessage() string

func (*BatchJob_Error) ProtoMessage added in v0.174.0

func (*BatchJob_Error) ProtoMessage()

func (*BatchJob_Error) ProtoReflect added in v0.174.0

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

func (*BatchJob_Error) Reset added in v0.174.0

func (x *BatchJob_Error) Reset()

func (*BatchJob_Error) String added in v0.174.0

func (x *BatchJob_Error) String() string

type BatchJob_Kind added in v0.184.0

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

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

Deprecated: Use BatchJob_Kind.ProtoReflect.Descriptor instead.

func (*BatchJob_Kind) GetKind added in v0.184.0

func (m *BatchJob_Kind) GetKind() isBatchJob_Kind_Kind

func (*BatchJob_Kind) GetPytorch added in v0.184.0

func (x *BatchJob_Kind) GetPytorch() *PyTorchJob

func (*BatchJob_Kind) ProtoMessage added in v0.184.0

func (*BatchJob_Kind) ProtoMessage()

func (*BatchJob_Kind) ProtoReflect added in v0.184.0

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

func (*BatchJob_Kind) Reset added in v0.184.0

func (x *BatchJob_Kind) Reset()

func (*BatchJob_Kind) String added in v0.184.0

func (x *BatchJob_Kind) String() string

type BatchJob_Kind_Pytorch added in v0.184.0

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

type BatchJob_Resources added in v0.174.0

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

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

Deprecated: Use BatchJob_Resources.ProtoReflect.Descriptor instead.

func (*BatchJob_Resources) GetGpuCount added in v0.174.0

func (x *BatchJob_Resources) GetGpuCount() int32

func (*BatchJob_Resources) ProtoMessage added in v0.174.0

func (*BatchJob_Resources) ProtoMessage()

func (*BatchJob_Resources) ProtoReflect added in v0.174.0

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

func (*BatchJob_Resources) Reset added in v0.174.0

func (x *BatchJob_Resources) Reset()

func (*BatchJob_Resources) String added in v0.174.0

func (x *BatchJob_Resources) String() string

type BatchServiceClient added in v0.174.0

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.

func NewBatchServiceClient added in v0.174.0

func NewBatchServiceClient(cc grpc.ClientConnInterface) BatchServiceClient

type BatchServiceServer added in v0.174.0

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

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.

func NewBatchWorkerServiceClient added in v0.179.0

func NewBatchWorkerServiceClient(cc grpc.ClientConnInterface) BatchWorkerServiceClient

type BatchWorkerServiceServer added in v0.179.0

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

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

func (*CancelBatchJobRequest) Descriptor deprecated added in v0.174.0

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

Deprecated: Use CancelBatchJobRequest.ProtoReflect.Descriptor instead.

func (*CancelBatchJobRequest) GetId added in v0.174.0

func (x *CancelBatchJobRequest) GetId() string

func (*CancelBatchJobRequest) ProtoMessage added in v0.174.0

func (*CancelBatchJobRequest) ProtoMessage()

func (*CancelBatchJobRequest) ProtoReflect added in v0.174.0

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

func (*CancelBatchJobRequest) Reset added in v0.174.0

func (x *CancelBatchJobRequest) Reset()

func (*CancelBatchJobRequest) String added in v0.174.0

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

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

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

Deprecated: Use CreateBatchJobRequest.ProtoReflect.Descriptor instead.

func (*CreateBatchJobRequest) GetCommand added in v0.174.0

func (x *CreateBatchJobRequest) GetCommand() string

func (*CreateBatchJobRequest) GetDataFiles added in v0.174.0

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

func (*CreateBatchJobRequest) GetEnvs added in v0.174.0

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

func (*CreateBatchJobRequest) GetImage added in v0.174.0

func (x *CreateBatchJobRequest) GetImage() string

func (*CreateBatchJobRequest) GetKind added in v0.184.0

func (x *CreateBatchJobRequest) GetKind() *BatchJob_Kind

func (*CreateBatchJobRequest) GetResources added in v0.174.0

func (x *CreateBatchJobRequest) GetResources() *BatchJob_Resources

func (*CreateBatchJobRequest) GetScripts added in v0.174.0

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

func (*CreateBatchJobRequest) ProtoMessage added in v0.174.0

func (*CreateBatchJobRequest) ProtoMessage()

func (*CreateBatchJobRequest) ProtoReflect added in v0.174.0

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

func (*CreateBatchJobRequest) Reset added in v0.174.0

func (x *CreateBatchJobRequest) Reset()

func (*CreateBatchJobRequest) String added in v0.174.0

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"`
	// 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 (*CreateJobRequest_Hyperparameters) Reset added in v0.59.0

func (*CreateJobRequest_Hyperparameters) String added in v0.59.0

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 (*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 (*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 DeleteBatchJobRequest added in v0.183.0

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

func (*DeleteBatchJobRequest) Descriptor deprecated added in v0.183.0

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

Deprecated: Use DeleteBatchJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteBatchJobRequest) GetId added in v0.183.0

func (x *DeleteBatchJobRequest) GetId() string

func (*DeleteBatchJobRequest) ProtoMessage added in v0.183.0

func (*DeleteBatchJobRequest) ProtoMessage()

func (*DeleteBatchJobRequest) ProtoReflect added in v0.183.0

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

func (*DeleteBatchJobRequest) Reset added in v0.183.0

func (x *DeleteBatchJobRequest) Reset()

func (*DeleteBatchJobRequest) String added in v0.183.0

func (x *DeleteBatchJobRequest) String() string

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.

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

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

func (*GetBatchJobRequest) Descriptor deprecated added in v0.174.0

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

Deprecated: Use GetBatchJobRequest.ProtoReflect.Descriptor instead.

func (*GetBatchJobRequest) GetId added in v0.174.0

func (x *GetBatchJobRequest) GetId() string

func (*GetBatchJobRequest) ProtoMessage added in v0.174.0

func (*GetBatchJobRequest) ProtoMessage()

func (*GetBatchJobRequest) ProtoReflect added in v0.174.0

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

func (*GetBatchJobRequest) Reset added in v0.174.0

func (x *GetBatchJobRequest) Reset()

func (*GetBatchJobRequest) String added in v0.174.0

func (x *GetBatchJobRequest) String() string

type GetInternalBatchJobRequest added in v0.179.0

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

func (*GetInternalBatchJobRequest) Descriptor deprecated added in v0.179.0

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

Deprecated: Use GetInternalBatchJobRequest.ProtoReflect.Descriptor instead.

func (*GetInternalBatchJobRequest) GetId added in v0.179.0

func (*GetInternalBatchJobRequest) ProtoMessage added in v0.179.0

func (*GetInternalBatchJobRequest) ProtoMessage()

func (*GetInternalBatchJobRequest) ProtoReflect added in v0.179.0

func (*GetInternalBatchJobRequest) Reset added in v0.179.0

func (x *GetInternalBatchJobRequest) Reset()

func (*GetInternalBatchJobRequest) String added in v0.179.0

func (x *GetInternalBatchJobRequest) String() string

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

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

func (*InternalBatchJob) Descriptor deprecated added in v0.179.0

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

Deprecated: Use InternalBatchJob.ProtoReflect.Descriptor instead.

func (*InternalBatchJob) GetJob added in v0.179.0

func (x *InternalBatchJob) GetJob() *BatchJob

func (*InternalBatchJob) GetQueuedAction added in v0.179.0

func (x *InternalBatchJob) GetQueuedAction() InternalBatchJob_Action

func (*InternalBatchJob) GetState added in v0.179.0

func (*InternalBatchJob) ProtoMessage added in v0.179.0

func (*InternalBatchJob) ProtoMessage()

func (*InternalBatchJob) ProtoReflect added in v0.179.0

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

func (*InternalBatchJob) Reset added in v0.179.0

func (x *InternalBatchJob) Reset()

func (*InternalBatchJob) String added in v0.179.0

func (x *InternalBatchJob) String() string

type InternalBatchJob_Action added in v0.179.0

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

func (InternalBatchJob_Action) Enum added in v0.179.0

func (InternalBatchJob_Action) EnumDescriptor deprecated added in v0.179.0

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

Deprecated: Use InternalBatchJob_Action.Descriptor instead.

func (InternalBatchJob_Action) Number added in v0.179.0

func (InternalBatchJob_Action) String added in v0.179.0

func (x InternalBatchJob_Action) String() string

func (InternalBatchJob_Action) Type added in v0.179.0

type InternalBatchJob_State added in v0.179.0

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

func (InternalBatchJob_State) Enum added in v0.179.0

func (InternalBatchJob_State) EnumDescriptor deprecated added in v0.179.0

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

Deprecated: Use InternalBatchJob_State.Descriptor instead.

func (InternalBatchJob_State) Number added in v0.179.0

func (InternalBatchJob_State) String added in v0.179.0

func (x InternalBatchJob_State) String() string

func (InternalBatchJob_State) Type added in v0.179.0

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"`
	QueuedAction InternalJob_Action `` /* 156-byte string literal not displayed */
	// 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) GetQueuedAction added in v0.185.0

func (x *InternalJob) GetQueuedAction() InternalJob_Action

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

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

func (InternalJob_Action) Enum added in v0.185.0

func (InternalJob_Action) EnumDescriptor deprecated added in v0.185.0

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

Deprecated: Use InternalJob_Action.Descriptor instead.

func (InternalJob_Action) Number added in v0.185.0

func (InternalJob_Action) String added in v0.185.0

func (x InternalJob_Action) String() string

func (InternalJob_Action) Type added in v0.185.0

type InternalJob_State added in v0.130.0

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

func (InternalJob_State) Enum added in v0.130.0

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 (InternalJob_State) String added in v0.130.0

func (x InternalJob_State) String() string

func (InternalJob_State) Type added in v0.130.0

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

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

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

Deprecated: Use ListBatchJobsRequest.ProtoReflect.Descriptor instead.

func (*ListBatchJobsRequest) GetAfter added in v0.174.0

func (x *ListBatchJobsRequest) GetAfter() string

func (*ListBatchJobsRequest) GetLimit added in v0.174.0

func (x *ListBatchJobsRequest) GetLimit() int32

func (*ListBatchJobsRequest) ProtoMessage added in v0.174.0

func (*ListBatchJobsRequest) ProtoMessage()

func (*ListBatchJobsRequest) ProtoReflect added in v0.174.0

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

func (*ListBatchJobsRequest) Reset added in v0.174.0

func (x *ListBatchJobsRequest) Reset()

func (*ListBatchJobsRequest) String added in v0.174.0

func (x *ListBatchJobsRequest) String() string

type ListBatchJobsResponse added in v0.174.0

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

func (*ListBatchJobsResponse) Descriptor deprecated added in v0.174.0

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

Deprecated: Use ListBatchJobsResponse.ProtoReflect.Descriptor instead.

func (*ListBatchJobsResponse) GetHasMore added in v0.175.0

func (x *ListBatchJobsResponse) GetHasMore() bool

func (*ListBatchJobsResponse) GetJobs added in v0.174.0

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

func (*ListBatchJobsResponse) ProtoMessage added in v0.174.0

func (*ListBatchJobsResponse) ProtoMessage()

func (*ListBatchJobsResponse) ProtoReflect added in v0.174.0

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

func (*ListBatchJobsResponse) Reset added in v0.174.0

func (x *ListBatchJobsResponse) Reset()

func (*ListBatchJobsResponse) String added in v0.174.0

func (x *ListBatchJobsResponse) 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 ListQueuedInternalBatchJobsRequest added in v0.179.0

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

func (*ListQueuedInternalBatchJobsRequest) Descriptor deprecated added in v0.179.0

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

Deprecated: Use ListQueuedInternalBatchJobsRequest.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalBatchJobsRequest) ProtoMessage added in v0.179.0

func (*ListQueuedInternalBatchJobsRequest) ProtoMessage()

func (*ListQueuedInternalBatchJobsRequest) ProtoReflect added in v0.179.0

func (*ListQueuedInternalBatchJobsRequest) Reset added in v0.179.0

func (*ListQueuedInternalBatchJobsRequest) String added in v0.179.0

type ListQueuedInternalBatchJobsResponse added in v0.179.0

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

func (*ListQueuedInternalBatchJobsResponse) Descriptor deprecated added in v0.179.0

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

Deprecated: Use ListQueuedInternalBatchJobsResponse.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalBatchJobsResponse) GetJobs added in v0.179.0

func (*ListQueuedInternalBatchJobsResponse) ProtoMessage added in v0.179.0

func (*ListQueuedInternalBatchJobsResponse) ProtoMessage()

func (*ListQueuedInternalBatchJobsResponse) ProtoReflect added in v0.179.0

func (*ListQueuedInternalBatchJobsResponse) Reset added in v0.179.0

func (*ListQueuedInternalBatchJobsResponse) String added in v0.179.0

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 (*ListQueuedInternalJobsRequest) Reset added in v0.120.0

func (x *ListQueuedInternalJobsRequest) Reset()

func (*ListQueuedInternalJobsRequest) String added in v0.120.0

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 (*ListQueuedInternalJobsResponse) ProtoMessage added in v0.120.0

func (*ListQueuedInternalJobsResponse) ProtoMessage()

func (*ListQueuedInternalJobsResponse) ProtoReflect added in v0.120.0

func (*ListQueuedInternalJobsResponse) Reset added in v0.120.0

func (x *ListQueuedInternalJobsResponse) Reset()

func (*ListQueuedInternalJobsResponse) String added in v0.120.0

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 (*ListQueuedInternalNotebooksRequest) Reset added in v0.124.0

func (*ListQueuedInternalNotebooksRequest) String added in v0.124.0

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 (*ListQueuedInternalNotebooksResponse) ProtoMessage added in v0.124.0

func (*ListQueuedInternalNotebooksResponse) ProtoMessage()

func (*ListQueuedInternalNotebooksResponse) ProtoReflect added in v0.124.0

func (*ListQueuedInternalNotebooksResponse) Reset added in v0.124.0

func (*ListQueuedInternalNotebooksResponse) String added in v0.124.0

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

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 (NotebookQueuedAction) String added in v0.124.0

func (x NotebookQueuedAction) String() string

func (NotebookQueuedAction) Type added in v0.124.0

type NotebookState added in v0.124.0

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
)

func (NotebookState) Descriptor added in v0.124.0

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 (NotebookState) String added in v0.124.0

func (x NotebookState) String() string

func (NotebookState) Type added in v0.124.0

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

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

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

Deprecated: Use PyTorchJob.ProtoReflect.Descriptor instead.

func (*PyTorchJob) GetWorkerCount added in v0.184.0

func (x *PyTorchJob) GetWorkerCount() int32

func (*PyTorchJob) ProtoMessage added in v0.184.0

func (*PyTorchJob) ProtoMessage()

func (*PyTorchJob) ProtoReflect added in v0.184.0

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

func (*PyTorchJob) Reset added in v0.184.0

func (x *PyTorchJob) Reset()

func (*PyTorchJob) String added in v0.184.0

func (x *PyTorchJob) 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 UnimplementedBatchServiceServer added in v0.174.0

type UnimplementedBatchServiceServer struct {
}

UnimplementedBatchServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBatchServiceServer) CancelBatchJob added in v0.174.0

func (UnimplementedBatchServiceServer) CreateBatchJob added in v0.174.0

func (UnimplementedBatchServiceServer) DeleteBatchJob added in v0.183.0

func (UnimplementedBatchServiceServer) GetBatchJob added in v0.174.0

func (UnimplementedBatchServiceServer) ListBatchJobs added in v0.174.0

type UnimplementedBatchWorkerServiceServer added in v0.179.0

type UnimplementedBatchWorkerServiceServer struct {
}

UnimplementedBatchWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBatchWorkerServiceServer) GetInternalBatchJob added in v0.179.0

func (UnimplementedBatchWorkerServiceServer) ListQueuedInternalBatchJobs added in v0.179.0

func (UnimplementedBatchWorkerServiceServer) UpdateBatchJobState added in v0.179.0

type UnimplementedFineTuningServiceServer

type UnimplementedFineTuningServiceServer struct {
}

UnimplementedFineTuningServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFineTuningServiceServer) CancelJob

func (UnimplementedFineTuningServiceServer) CreateJob

func (UnimplementedFineTuningServiceServer) GetJob added in v0.77.0

func (UnimplementedFineTuningServiceServer) ListJobs

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

func (UnimplementedFineTuningWorkerServiceServer) UpdateJobPhase added in v0.120.0

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

func (UnimplementedWorkspaceServiceServer) GetNotebook added in v0.86.0

func (UnimplementedWorkspaceServiceServer) ListNotebooks added in v0.86.0

func (UnimplementedWorkspaceServiceServer) StartNotebook added in v0.86.0

func (UnimplementedWorkspaceServiceServer) StopNotebook added in v0.86.0

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

type UnsafeBatchServiceServer added in v0.174.0

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

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

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=llmoperator.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 added in v0.179.0

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

Deprecated: Use UpdateBatchJobStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateBatchJobStateRequest) GetId added in v0.179.0

func (*UpdateBatchJobStateRequest) GetMessage added in v0.179.0

func (x *UpdateBatchJobStateRequest) GetMessage() string

func (*UpdateBatchJobStateRequest) GetReason added in v0.179.0

func (x *UpdateBatchJobStateRequest) GetReason() string

func (*UpdateBatchJobStateRequest) GetState added in v0.179.0

func (*UpdateBatchJobStateRequest) ProtoMessage added in v0.179.0

func (*UpdateBatchJobStateRequest) ProtoMessage()

func (*UpdateBatchJobStateRequest) ProtoReflect added in v0.179.0

func (*UpdateBatchJobStateRequest) Reset added in v0.179.0

func (x *UpdateBatchJobStateRequest) Reset()

func (*UpdateBatchJobStateRequest) String added in v0.179.0

func (x *UpdateBatchJobStateRequest) String() string

type UpdateBatchJobStateResponse added in v0.179.0

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

func (*UpdateBatchJobStateResponse) Descriptor deprecated added in v0.179.0

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

Deprecated: Use UpdateBatchJobStateResponse.ProtoReflect.Descriptor instead.

func (*UpdateBatchJobStateResponse) ProtoMessage added in v0.179.0

func (*UpdateBatchJobStateResponse) ProtoMessage()

func (*UpdateBatchJobStateResponse) ProtoReflect added in v0.179.0

func (*UpdateBatchJobStateResponse) Reset added in v0.179.0

func (x *UpdateBatchJobStateResponse) Reset()

func (*UpdateBatchJobStateResponse) String added in v0.179.0

func (x *UpdateBatchJobStateResponse) String() string

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 (*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_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 added in v0.130.0

func (UpdateJobPhaseRequest_Phase) Enum added in v0.130.0

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 (UpdateJobPhaseRequest_Phase) String added in v0.130.0

func (UpdateJobPhaseRequest_Phase) Type added in v0.130.0

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 (*UpdateNotebookStateRequest) GetState added in v0.124.0

func (*UpdateNotebookStateRequest) ProtoMessage added in v0.124.0

func (*UpdateNotebookStateRequest) ProtoMessage()

func (*UpdateNotebookStateRequest) ProtoReflect added in v0.124.0

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 (*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

Jump to

Keyboard shortcuts

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