v1

package
v0.209.0 Latest Latest
Warning

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

 Go to latest Published: Oct 1, 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: "llmariner.batch.server.v1.BatchService",
	HandlerType: (*BatchServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateBatchJob",
			Handler:    _BatchService_CreateBatchJob_Handler,
		},
		{
			MethodName: "ListBatchJobs",
			Handler:    _BatchService_ListBatchJobs_Handler,
		},
		{
			MethodName: "GetBatchJob",
			Handler:    _BatchService_GetBatchJob_Handler,
		},
		{
			MethodName: "CancelBatchJob",
			Handler:    _BatchService_CancelBatchJob_Handler,
		},
		{
			MethodName: "DeleteBatchJob",
			Handler:    _BatchService_DeleteBatchJob_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/batch_service.proto",
}

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

View Source 
var BatchWorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.batch.server.v1.BatchWorkerService",
	HandlerType: (*BatchWorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListQueuedInternalBatchJobs",
			Handler:    _BatchWorkerService_ListQueuedInternalBatchJobs_Handler,
		},
		{
			MethodName: "GetInternalBatchJob",
			Handler:    _BatchWorkerService_GetInternalBatchJob_Handler,
		},
		{
			MethodName: "UpdateBatchJobState",
			Handler:    _BatchWorkerService_UpdateBatchJobState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/batch_service.proto",
}

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

View Source 
var File_api_v1_batch_service_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_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: "llmariner.fine_tuning.server.v1.FineTuningService",
	HandlerType: (*FineTuningServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateJob",
			Handler:    _FineTuningService_CreateJob_Handler,
		},
		{
			MethodName: "ListJobs",
			Handler:    _FineTuningService_ListJobs_Handler,
		},
		{
			MethodName: "GetJob",
			Handler:    _FineTuningService_GetJob_Handler,
		},
		{
			MethodName: "CancelJob",
			Handler:    _FineTuningService_CancelJob_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/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: "llmariner.fine_tuning.server.v1.FineTuningWorkerService",
	HandlerType: (*FineTuningWorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListQueuedInternalJobs",
			Handler:    _FineTuningWorkerService_ListQueuedInternalJobs_Handler,
		},
		{
			MethodName: "GetInternalJob",
			Handler:    _FineTuningWorkerService_GetInternalJob_Handler,
		},
		{
			MethodName: "UpdateJobPhase",
			Handler:    _FineTuningWorkerService_UpdateJobPhase_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/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: "llmariner.workspace.server.v1.WorkspaceService",
	HandlerType: (*WorkspaceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateNotebook",
			Handler:    _WorkspaceService_CreateNotebook_Handler,
		},
		{
			MethodName: "ListNotebooks",
			Handler:    _WorkspaceService_ListNotebooks_Handler,
		},
		{
			MethodName: "GetNotebook",
			Handler:    _WorkspaceService_GetNotebook_Handler,
		},
		{
			MethodName: "DeleteNotebook",
			Handler:    _WorkspaceService_DeleteNotebook_Handler,
		},
		{
			MethodName: "StopNotebook",
			Handler:    _WorkspaceService_StopNotebook_Handler,
		},
		{
			MethodName: "StartNotebook",
			Handler:    _WorkspaceService_StartNotebook_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/workspace_service.proto",
}

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

View Source 
var WorkspaceWorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.workspace.server.v1.WorkspaceWorkerService",
	HandlerType: (*WorkspaceWorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListQueuedInternalNotebooks",
			Handler:    _WorkspaceWorkerService_ListQueuedInternalNotebooks_Handler,
		},
		{
			MethodName: "UpdateNotebookState",
			Handler:    _WorkspaceWorkerService_UpdateNotebookState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/workspace_service.proto",
}

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

Functions

func RegisterBatchServiceHandler 

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

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

func RegisterBatchServiceHandlerClient 

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

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

func RegisterBatchServiceHandlerFromEndpoint 

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

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

func RegisterBatchServiceHandlerServer 

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

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

func RegisterBatchServiceServer 

func RegisterBatchServiceServer(s grpc.ServiceRegistrar, srv BatchServiceServer)

func RegisterBatchWorkerServiceServer 

func RegisterBatchWorkerServiceServer(s grpc.ServiceRegistrar, srv BatchWorkerServiceServer)

func RegisterFineTuningServiceHandler 

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

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

func RegisterFineTuningServiceHandlerClient 

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

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

func RegisterFineTuningServiceHandlerFromEndpoint 

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

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

func RegisterFineTuningServiceHandlerServer 

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

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

func RegisterFineTuningServiceServer 

func RegisterFineTuningServiceServer(s grpc.ServiceRegistrar, srv FineTuningServiceServer)

func RegisterFineTuningWorkerServiceServer 

func RegisterFineTuningWorkerServiceServer(s grpc.ServiceRegistrar, srv FineTuningWorkerServiceServer)

func RegisterWorkspaceServiceHandler 

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

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

func RegisterWorkspaceServiceHandlerClient 

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

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

func RegisterWorkspaceServiceHandlerFromEndpoint 

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

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

func RegisterWorkspaceServiceHandlerServer 

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

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

func RegisterWorkspaceServiceServer 

func RegisterWorkspaceServiceServer(s grpc.ServiceRegistrar, srv WorkspaceServiceServer)

func RegisterWorkspaceWorkerServiceServer 

func RegisterWorkspaceWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkspaceWorkerServiceServer)

Types

type BatchJob 

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

func (*BatchJob) Descriptor deprecated 

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

Deprecated: Use BatchJob.ProtoReflect.Descriptor instead.

func (*BatchJob) GetClusterId 

func (x *BatchJob) GetClusterId() string

func (*BatchJob) GetCommand 

func (x *BatchJob) GetCommand() string

func (*BatchJob) GetCreatedAt 

func (x *BatchJob) GetCreatedAt() int64

func (*BatchJob) GetDataFiles 

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

func (*BatchJob) GetEnvs 

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

func (*BatchJob) GetError 

func (x *BatchJob) GetError() *BatchJob_Error

func (*BatchJob) GetFinishedAt 

func (x *BatchJob) GetFinishedAt() int64

func (*BatchJob) GetId 

func (x *BatchJob) GetId() string

func (*BatchJob) GetImage 

func (x *BatchJob) GetImage() string

func (*BatchJob) GetKind 

func (x *BatchJob) GetKind() *BatchJob_Kind

func (*BatchJob) GetKubernetesNamespace 

func (x *BatchJob) GetKubernetesNamespace() string

func (*BatchJob) GetProjectId 

func (x *BatchJob) GetProjectId() string

func (*BatchJob) GetResources 

func (x *BatchJob) GetResources() *BatchJob_Resources

func (*BatchJob) GetStatus 

func (x *BatchJob) GetStatus() string

func (*BatchJob) ProtoMessage 

func (*BatchJob) ProtoMessage()

func (*BatchJob) ProtoReflect 

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

func (*BatchJob) Reset 

func (x *BatchJob) Reset()

func (*BatchJob) String 

func (x *BatchJob) String() string

type BatchJob_Error 

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

func (*BatchJob_Error) Descriptor deprecated 

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

Deprecated: Use BatchJob_Error.ProtoReflect.Descriptor instead.

func (*BatchJob_Error) GetCode 

func (x *BatchJob_Error) GetCode() string

func (*BatchJob_Error) GetMessage 

func (x *BatchJob_Error) GetMessage() string

func (*BatchJob_Error) ProtoMessage 

func (*BatchJob_Error) ProtoMessage()

func (*BatchJob_Error) ProtoReflect 

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

func (*BatchJob_Error) Reset 

func (x *BatchJob_Error) Reset()

func (*BatchJob_Error) String 

func (x *BatchJob_Error) String() string

type BatchJob_Kind 

type BatchJob_Kind struct {

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

func (*BatchJob_Kind) Descriptor deprecated 

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

Deprecated: Use BatchJob_Kind.ProtoReflect.Descriptor instead.

func (*BatchJob_Kind) GetKind 

func (m *BatchJob_Kind) GetKind() isBatchJob_Kind_Kind

func (*BatchJob_Kind) GetPytorch 

func (x *BatchJob_Kind) GetPytorch() *PyTorchJob

func (*BatchJob_Kind) ProtoMessage 

func (*BatchJob_Kind) ProtoMessage()

func (*BatchJob_Kind) ProtoReflect 

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

func (*BatchJob_Kind) Reset 

func (x *BatchJob_Kind) Reset()

func (*BatchJob_Kind) String 

func (x *BatchJob_Kind) String() string

type BatchJob_Kind_Pytorch 

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

type BatchJob_Resources 

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

func (*BatchJob_Resources) Descriptor deprecated 

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

Deprecated: Use BatchJob_Resources.ProtoReflect.Descriptor instead.

func (*BatchJob_Resources) GetGpuCount 

func (x *BatchJob_Resources) GetGpuCount() int32

func (*BatchJob_Resources) ProtoMessage 

func (*BatchJob_Resources) ProtoMessage()

func (*BatchJob_Resources) ProtoReflect 

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

func (*BatchJob_Resources) Reset 

func (x *BatchJob_Resources) Reset()

func (*BatchJob_Resources) String 

func (x *BatchJob_Resources) String() string

type BatchServiceClient 

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

BatchServiceClient is the client API for BatchService service.

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

func NewBatchServiceClient 

func NewBatchServiceClient(cc grpc.ClientConnInterface) BatchServiceClient

type BatchServiceServer 

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

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

type BatchWorkerServiceClient 

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

BatchWorkerServiceClient is the client API for BatchWorkerService service.

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

func NewBatchWorkerServiceClient 

func NewBatchWorkerServiceClient(cc grpc.ClientConnInterface) BatchWorkerServiceClient

type BatchWorkerServiceServer 

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

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

type CancelBatchJobRequest 

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

func (*CancelBatchJobRequest) Descriptor deprecated 

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

Deprecated: Use CancelBatchJobRequest.ProtoReflect.Descriptor instead.

func (*CancelBatchJobRequest) GetId 

func (x *CancelBatchJobRequest) GetId() string

func (*CancelBatchJobRequest) ProtoMessage 

func (*CancelBatchJobRequest) ProtoMessage()

func (*CancelBatchJobRequest) ProtoReflect 

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

func (*CancelBatchJobRequest) Reset 

func (x *CancelBatchJobRequest) Reset()

func (*CancelBatchJobRequest) String 

func (x *CancelBatchJobRequest) String() string

type CancelJobRequest 

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

func (*CancelJobRequest) Descriptor deprecated 

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

Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.

func (*CancelJobRequest) GetId 

func (x *CancelJobRequest) GetId() string

func (*CancelJobRequest) ProtoMessage 

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) ProtoReflect 

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

func (*CancelJobRequest) Reset 

func (x *CancelJobRequest) Reset()

func (*CancelJobRequest) String 

func (x *CancelJobRequest) String() string

type CreateBatchJobRequest 

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

func (*CreateBatchJobRequest) Descriptor deprecated 

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

Deprecated: Use CreateBatchJobRequest.ProtoReflect.Descriptor instead.

func (*CreateBatchJobRequest) GetCommand 

func (x *CreateBatchJobRequest) GetCommand() string

func (*CreateBatchJobRequest) GetDataFiles 

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

func (*CreateBatchJobRequest) GetEnvs 

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

func (*CreateBatchJobRequest) GetImage 

func (x *CreateBatchJobRequest) GetImage() string

func (*CreateBatchJobRequest) GetKind 

func (x *CreateBatchJobRequest) GetKind() *BatchJob_Kind

func (*CreateBatchJobRequest) GetResources 

func (x *CreateBatchJobRequest) GetResources() *BatchJob_Resources

func (*CreateBatchJobRequest) GetScripts 

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

func (*CreateBatchJobRequest) ProtoMessage 

func (*CreateBatchJobRequest) ProtoMessage()

func (*CreateBatchJobRequest) ProtoReflect 

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

func (*CreateBatchJobRequest) Reset 

func (x *CreateBatchJobRequest) Reset()

func (*CreateBatchJobRequest) String 

func (x *CreateBatchJobRequest) String() string

type CreateJobRequest 

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

func (*CreateJobRequest) Descriptor deprecated 

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

Deprecated: Use CreateJobRequest.ProtoReflect.Descriptor instead.

func (*CreateJobRequest) GetHyperparameters 

func (x *CreateJobRequest) GetHyperparameters() *CreateJobRequest_Hyperparameters

func (*CreateJobRequest) GetIntegrations 

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

func (*CreateJobRequest) GetModel 

func (x *CreateJobRequest) GetModel() string

func (*CreateJobRequest) GetSeed 

func (x *CreateJobRequest) GetSeed() int32

func (*CreateJobRequest) GetSuffix 

func (x *CreateJobRequest) GetSuffix() string

func (*CreateJobRequest) GetTrainingFile 

func (x *CreateJobRequest) GetTrainingFile() string

func (*CreateJobRequest) GetValidationFile 

func (x *CreateJobRequest) GetValidationFile() string

func (*CreateJobRequest) ProtoMessage 

func (*CreateJobRequest) ProtoMessage()

func (*CreateJobRequest) ProtoReflect 

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

func (*CreateJobRequest) Reset 

func (x *CreateJobRequest) Reset()

func (*CreateJobRequest) String 

func (x *CreateJobRequest) String() string

type CreateJobRequest_Hyperparameters 

type CreateJobRequest_Hyperparameters struct {

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

func (*CreateJobRequest_Hyperparameters) Descriptor deprecated 

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

Deprecated: Use CreateJobRequest_Hyperparameters.ProtoReflect.Descriptor instead.

func (*CreateJobRequest_Hyperparameters) GetBatchSize 

func (x *CreateJobRequest_Hyperparameters) GetBatchSize() int32

func (*CreateJobRequest_Hyperparameters) GetLearningRateMultiplier 

func (x *CreateJobRequest_Hyperparameters) GetLearningRateMultiplier() float64

func (*CreateJobRequest_Hyperparameters) GetNEpochs 

func (x *CreateJobRequest_Hyperparameters) GetNEpochs() int32

func (*CreateJobRequest_Hyperparameters) ProtoMessage 

func (*CreateJobRequest_Hyperparameters) ProtoMessage()

func (*CreateJobRequest_Hyperparameters) ProtoReflect 

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

func (*CreateJobRequest_Hyperparameters) Reset 

func (x *CreateJobRequest_Hyperparameters) Reset()

func (*CreateJobRequest_Hyperparameters) String 

func (x *CreateJobRequest_Hyperparameters) String() string

type CreateNotebookRequest 

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

func (*CreateNotebookRequest) Descriptor deprecated 

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

Deprecated: Use CreateNotebookRequest.ProtoReflect.Descriptor instead.

func (*CreateNotebookRequest) GetEnvs 

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

func (*CreateNotebookRequest) GetImage 

func (x *CreateNotebookRequest) GetImage() *CreateNotebookRequest_Image

func (*CreateNotebookRequest) GetName 

func (x *CreateNotebookRequest) GetName() string

func (*CreateNotebookRequest) GetResources 

func (x *CreateNotebookRequest) GetResources() *Resources

func (*CreateNotebookRequest) ProtoMessage 

func (*CreateNotebookRequest) ProtoMessage()

func (*CreateNotebookRequest) ProtoReflect 

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

func (*CreateNotebookRequest) Reset 

func (x *CreateNotebookRequest) Reset()

func (*CreateNotebookRequest) String 

func (x *CreateNotebookRequest) String() string

type CreateNotebookRequest_Image 

type CreateNotebookRequest_Image struct {

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

func (*CreateNotebookRequest_Image) Descriptor deprecated 

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

Deprecated: Use CreateNotebookRequest_Image.ProtoReflect.Descriptor instead.

func (*CreateNotebookRequest_Image) GetImage 

func (m *CreateNotebookRequest_Image) GetImage() isCreateNotebookRequest_Image_Image

func (*CreateNotebookRequest_Image) GetType 

func (x *CreateNotebookRequest_Image) GetType() string

func (*CreateNotebookRequest_Image) GetUri 

func (x *CreateNotebookRequest_Image) GetUri() string

func (*CreateNotebookRequest_Image) ProtoMessage 

func (*CreateNotebookRequest_Image) ProtoMessage()

func (*CreateNotebookRequest_Image) ProtoReflect 

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

func (*CreateNotebookRequest_Image) Reset 

func (x *CreateNotebookRequest_Image) Reset()

func (*CreateNotebookRequest_Image) String 

func (x *CreateNotebookRequest_Image) String() string

type CreateNotebookRequest_Image_Type 

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

type CreateNotebookRequest_Image_Uri 

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

type DeleteBatchJobRequest 

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

func (*DeleteBatchJobRequest) Descriptor deprecated 

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

Deprecated: Use DeleteBatchJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteBatchJobRequest) GetId 

func (x *DeleteBatchJobRequest) GetId() string

func (*DeleteBatchJobRequest) ProtoMessage 

func (*DeleteBatchJobRequest) ProtoMessage()

func (*DeleteBatchJobRequest) ProtoReflect 

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

func (*DeleteBatchJobRequest) Reset 

func (x *DeleteBatchJobRequest) Reset()

func (*DeleteBatchJobRequest) String 

func (x *DeleteBatchJobRequest) String() string

type DeleteNotebookRequest 

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

func (*DeleteNotebookRequest) Descriptor deprecated 

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

Deprecated: Use DeleteNotebookRequest.ProtoReflect.Descriptor instead.

func (*DeleteNotebookRequest) GetId 

func (x *DeleteNotebookRequest) GetId() string

func (*DeleteNotebookRequest) ProtoMessage 

func (*DeleteNotebookRequest) ProtoMessage()

func (*DeleteNotebookRequest) ProtoReflect 

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

func (*DeleteNotebookRequest) Reset 

func (x *DeleteNotebookRequest) Reset()

func (*DeleteNotebookRequest) String 

func (x *DeleteNotebookRequest) String() string

type DeleteNotebookResponse 

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

func (*DeleteNotebookResponse) Descriptor deprecated 

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

Deprecated: Use DeleteNotebookResponse.ProtoReflect.Descriptor instead.

func (*DeleteNotebookResponse) ProtoMessage 

func (*DeleteNotebookResponse) ProtoMessage()

func (*DeleteNotebookResponse) ProtoReflect 

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

func (*DeleteNotebookResponse) Reset 

func (x *DeleteNotebookResponse) Reset()

func (*DeleteNotebookResponse) String 

func (x *DeleteNotebookResponse) String() string

type FineTuningServiceClient 

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

FineTuningServiceClient is the client API for FineTuningService service.

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

func NewFineTuningServiceClient 

func NewFineTuningServiceClient(cc grpc.ClientConnInterface) FineTuningServiceClient

type FineTuningServiceServer 

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

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

type FineTuningWorkerServiceClient 

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 

func NewFineTuningWorkerServiceClient(cc grpc.ClientConnInterface) FineTuningWorkerServiceClient

type FineTuningWorkerServiceServer 

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

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

type GetBatchJobRequest 

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

func (*GetBatchJobRequest) Descriptor deprecated 

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

Deprecated: Use GetBatchJobRequest.ProtoReflect.Descriptor instead.

func (*GetBatchJobRequest) GetId 

func (x *GetBatchJobRequest) GetId() string

func (*GetBatchJobRequest) ProtoMessage 

func (*GetBatchJobRequest) ProtoMessage()

func (*GetBatchJobRequest) ProtoReflect 

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

func (*GetBatchJobRequest) Reset 

func (x *GetBatchJobRequest) Reset()

func (*GetBatchJobRequest) String 

func (x *GetBatchJobRequest) String() string

type GetInternalBatchJobRequest 

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

func (*GetInternalBatchJobRequest) Descriptor deprecated 

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

Deprecated: Use GetInternalBatchJobRequest.ProtoReflect.Descriptor instead.

func (*GetInternalBatchJobRequest) GetId 

func (x *GetInternalBatchJobRequest) GetId() string

func (*GetInternalBatchJobRequest) ProtoMessage 

func (*GetInternalBatchJobRequest) ProtoMessage()

func (*GetInternalBatchJobRequest) ProtoReflect 

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

func (*GetInternalBatchJobRequest) Reset 

func (x *GetInternalBatchJobRequest) Reset()

func (*GetInternalBatchJobRequest) String 

func (x *GetInternalBatchJobRequest) String() string

type GetInternalJobRequest 

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

func (*GetInternalJobRequest) Descriptor deprecated 

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

Deprecated: Use GetInternalJobRequest.ProtoReflect.Descriptor instead.

func (*GetInternalJobRequest) GetId 

func (x *GetInternalJobRequest) GetId() string

func (*GetInternalJobRequest) ProtoMessage 

func (*GetInternalJobRequest) ProtoMessage()

func (*GetInternalJobRequest) ProtoReflect 

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

func (*GetInternalJobRequest) Reset 

func (x *GetInternalJobRequest) Reset()

func (*GetInternalJobRequest) String 

func (x *GetInternalJobRequest) String() string

type GetJobRequest 

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

func (*GetJobRequest) Descriptor deprecated 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetId 

func (x *GetJobRequest) GetId() string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect 

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

func (*GetJobRequest) Reset 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (x *GetJobRequest) String() string

type GetNotebookRequest 

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

func (*GetNotebookRequest) Descriptor deprecated 

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

Deprecated: Use GetNotebookRequest.ProtoReflect.Descriptor instead.

func (*GetNotebookRequest) GetId 

func (x *GetNotebookRequest) GetId() string

func (*GetNotebookRequest) ProtoMessage 

func (*GetNotebookRequest) ProtoMessage()

func (*GetNotebookRequest) ProtoReflect 

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

func (*GetNotebookRequest) Reset 

func (x *GetNotebookRequest) Reset()

func (*GetNotebookRequest) String 

func (x *GetNotebookRequest) String() string

type Integration 

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

func (*Integration) Descriptor deprecated 

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

Deprecated: Use Integration.ProtoReflect.Descriptor instead.

func (*Integration) GetType 

func (x *Integration) GetType() string

func (*Integration) GetWandb 

func (x *Integration) GetWandb() *Integration_Wandb

func (*Integration) ProtoMessage 

func (*Integration) ProtoMessage()

func (*Integration) ProtoReflect 

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

func (*Integration) Reset 

func (x *Integration) Reset()

func (*Integration) String 

func (x *Integration) String() string

type Integration_Wandb 

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

func (*Integration_Wandb) Descriptor deprecated 

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

Deprecated: Use Integration_Wandb.ProtoReflect.Descriptor instead.

func (*Integration_Wandb) GetEntity 

func (x *Integration_Wandb) GetEntity() string

func (*Integration_Wandb) GetName 

func (x *Integration_Wandb) GetName() string

func (*Integration_Wandb) GetProject 

func (x *Integration_Wandb) GetProject() string

func (*Integration_Wandb) GetTags 

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

func (*Integration_Wandb) ProtoMessage 

func (*Integration_Wandb) ProtoMessage()

func (*Integration_Wandb) ProtoReflect 

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

func (*Integration_Wandb) Reset 

func (x *Integration_Wandb) Reset()

func (*Integration_Wandb) String 

func (x *Integration_Wandb) String() string

type InternalBatchJob 

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

func (*InternalBatchJob) Descriptor deprecated 

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

Deprecated: Use InternalBatchJob.ProtoReflect.Descriptor instead.

func (*InternalBatchJob) GetJob 

func (x *InternalBatchJob) GetJob() *BatchJob

func (*InternalBatchJob) GetQueuedAction 

func (x *InternalBatchJob) GetQueuedAction() InternalBatchJob_Action

func (*InternalBatchJob) GetState 

func (x *InternalBatchJob) GetState() InternalBatchJob_State

func (*InternalBatchJob) ProtoMessage 

func (*InternalBatchJob) ProtoMessage()

func (*InternalBatchJob) ProtoReflect 

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

func (*InternalBatchJob) Reset 

func (x *InternalBatchJob) Reset()

func (*InternalBatchJob) String 

func (x *InternalBatchJob) String() string

type InternalBatchJob_Action 

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

func (InternalBatchJob_Action) Descriptor 

func (InternalBatchJob_Action) Descriptor() protoreflect.EnumDescriptor

func (InternalBatchJob_Action) Enum 

func (x InternalBatchJob_Action) Enum() *InternalBatchJob_Action

func (InternalBatchJob_Action) EnumDescriptor deprecated 

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

Deprecated: Use InternalBatchJob_Action.Descriptor instead.

func (InternalBatchJob_Action) Number 

func (x InternalBatchJob_Action) Number() protoreflect.EnumNumber

func (InternalBatchJob_Action) String 

func (x InternalBatchJob_Action) String() string

func (InternalBatchJob_Action) Type 

func (InternalBatchJob_Action) Type() protoreflect.EnumType

type InternalBatchJob_State 

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

func (InternalBatchJob_State) Descriptor 

func (InternalBatchJob_State) Descriptor() protoreflect.EnumDescriptor

func (InternalBatchJob_State) Enum 

func (x InternalBatchJob_State) Enum() *InternalBatchJob_State

func (InternalBatchJob_State) EnumDescriptor deprecated 

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

Deprecated: Use InternalBatchJob_State.Descriptor instead.

func (InternalBatchJob_State) Number 

func (x InternalBatchJob_State) Number() protoreflect.EnumNumber

func (InternalBatchJob_State) String 

func (x InternalBatchJob_State) String() string

func (InternalBatchJob_State) Type 

func (InternalBatchJob_State) Type() protoreflect.EnumType

type InternalJob 

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

func (*InternalJob) Descriptor deprecated 

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

Deprecated: Use InternalJob.ProtoReflect.Descriptor instead.

func (*InternalJob) GetJob 

func (x *InternalJob) GetJob() *Job

func (*InternalJob) GetOutputModelId 

func (x *InternalJob) GetOutputModelId() string

func (*InternalJob) GetQueuedAction 

func (x *InternalJob) GetQueuedAction() InternalJob_Action

func (*InternalJob) GetState 

func (x *InternalJob) GetState() InternalJob_State

func (*InternalJob) GetSuffix 

func (x *InternalJob) GetSuffix() string

func (*InternalJob) ProtoMessage 

func (*InternalJob) ProtoMessage()

func (*InternalJob) ProtoReflect 

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

func (*InternalJob) Reset 

func (x *InternalJob) Reset()

func (*InternalJob) String 

func (x *InternalJob) String() string

type InternalJob_Action 

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

func (InternalJob_Action) Descriptor 

func (InternalJob_Action) Descriptor() protoreflect.EnumDescriptor

func (InternalJob_Action) Enum 

func (x InternalJob_Action) Enum() *InternalJob_Action

func (InternalJob_Action) EnumDescriptor deprecated 

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

Deprecated: Use InternalJob_Action.Descriptor instead.

func (InternalJob_Action) Number 

func (x InternalJob_Action) Number() protoreflect.EnumNumber

func (InternalJob_Action) String 

func (x InternalJob_Action) String() string

func (InternalJob_Action) Type 

func (InternalJob_Action) Type() protoreflect.EnumType

type InternalJob_State 

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

func (InternalJob_State) Descriptor 

func (InternalJob_State) Descriptor() protoreflect.EnumDescriptor

func (InternalJob_State) Enum 

func (x InternalJob_State) Enum() *InternalJob_State

func (InternalJob_State) EnumDescriptor deprecated 

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

Deprecated: Use InternalJob_State.Descriptor instead.

func (InternalJob_State) Number 

func (x InternalJob_State) Number() protoreflect.EnumNumber

func (InternalJob_State) String 

func (x InternalJob_State) String() string

func (InternalJob_State) Type 

func (InternalJob_State) Type() protoreflect.EnumType

type InternalNotebook 

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

func (*InternalNotebook) Descriptor deprecated 

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

Deprecated: Use InternalNotebook.ProtoReflect.Descriptor instead.

func (*InternalNotebook) GetNotebook 

func (x *InternalNotebook) GetNotebook() *Notebook

func (*InternalNotebook) GetQueuedAction 

func (x *InternalNotebook) GetQueuedAction() NotebookQueuedAction

func (*InternalNotebook) GetState 

func (x *InternalNotebook) GetState() NotebookState

func (*InternalNotebook) ProtoMessage 

func (*InternalNotebook) ProtoMessage()

func (*InternalNotebook) ProtoReflect 

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

func (*InternalNotebook) Reset 

func (x *InternalNotebook) Reset()

func (*InternalNotebook) String 

func (x *InternalNotebook) String() string

type Job 

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

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetClusterId 

func (x *Job) GetClusterId() string

func (*Job) GetCreatedAt 

func (x *Job) GetCreatedAt() int64

func (*Job) GetError 

func (x *Job) GetError() *Job_Error

func (*Job) GetFineTunedModel 

func (x *Job) GetFineTunedModel() string

func (*Job) GetFinishedAt 

func (x *Job) GetFinishedAt() int64

func (*Job) GetHyperparameters 

func (x *Job) GetHyperparameters() *Job_Hyperparameters

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetIntegrations 

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

func (*Job) GetKubernetesNamespace 

func (x *Job) GetKubernetesNamespace() string

func (*Job) GetModel 

func (x *Job) GetModel() string

func (*Job) GetObject 

func (x *Job) GetObject() string

func (*Job) GetOrganizationId 

func (x *Job) GetOrganizationId() string

func (*Job) GetProjectId 

func (x *Job) GetProjectId() string

func (*Job) GetResultFiles 

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

func (*Job) GetSeed 

func (x *Job) GetSeed() int32

func (*Job) GetStatus 

func (x *Job) GetStatus() string

func (*Job) GetTrainedTokens 

func (x *Job) GetTrainedTokens() int32

func (*Job) GetTrainingFile 

func (x *Job) GetTrainingFile() string

func (*Job) GetValidationFile 

func (x *Job) GetValidationFile() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type Job_Error 

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

func (*Job_Error) Descriptor deprecated 

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

Deprecated: Use Job_Error.ProtoReflect.Descriptor instead.

func (*Job_Error) GetCode 

func (x *Job_Error) GetCode() string

func (*Job_Error) GetMessage 

func (x *Job_Error) GetMessage() string

func (*Job_Error) GetParam 

func (x *Job_Error) GetParam() string

func (*Job_Error) ProtoMessage 

func (*Job_Error) ProtoMessage()

func (*Job_Error) ProtoReflect 

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

func (*Job_Error) Reset 

func (x *Job_Error) Reset()

func (*Job_Error) String 

func (x *Job_Error) String() string

type Job_Hyperparameters 

type Job_Hyperparameters struct {

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

func (*Job_Hyperparameters) Descriptor deprecated 

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

Deprecated: Use Job_Hyperparameters.ProtoReflect.Descriptor instead.

func (*Job_Hyperparameters) GetBatchSize 

func (x *Job_Hyperparameters) GetBatchSize() int32

func (*Job_Hyperparameters) GetLearningRateMultiplier 

func (x *Job_Hyperparameters) GetLearningRateMultiplier() float64

func (*Job_Hyperparameters) GetNEpochs 

func (x *Job_Hyperparameters) GetNEpochs() int32

func (*Job_Hyperparameters) ProtoMessage 

func (*Job_Hyperparameters) ProtoMessage()

func (*Job_Hyperparameters) ProtoReflect 

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

func (*Job_Hyperparameters) Reset 

func (x *Job_Hyperparameters) Reset()

func (*Job_Hyperparameters) String 

func (x *Job_Hyperparameters) String() string

type ListBatchJobsRequest 

type ListBatchJobsRequest struct {

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

func (*ListBatchJobsRequest) Descriptor deprecated 

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

Deprecated: Use ListBatchJobsRequest.ProtoReflect.Descriptor instead.

func (*ListBatchJobsRequest) GetAfter 

func (x *ListBatchJobsRequest) GetAfter() string

func (*ListBatchJobsRequest) GetLimit 

func (x *ListBatchJobsRequest) GetLimit() int32

func (*ListBatchJobsRequest) ProtoMessage 

func (*ListBatchJobsRequest) ProtoMessage()

func (*ListBatchJobsRequest) ProtoReflect 

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

func (*ListBatchJobsRequest) Reset 

func (x *ListBatchJobsRequest) Reset()

func (*ListBatchJobsRequest) String 

func (x *ListBatchJobsRequest) String() string

type ListBatchJobsResponse 

type ListBatchJobsResponse struct {
	Jobs    []*BatchJob `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	HasMore bool        `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBatchJobsResponse) Descriptor deprecated 

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

Deprecated: Use ListBatchJobsResponse.ProtoReflect.Descriptor instead.

func (*ListBatchJobsResponse) GetHasMore 

func (x *ListBatchJobsResponse) GetHasMore() bool

func (*ListBatchJobsResponse) GetJobs 

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

func (*ListBatchJobsResponse) ProtoMessage 

func (*ListBatchJobsResponse) ProtoMessage()

func (*ListBatchJobsResponse) ProtoReflect 

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

func (*ListBatchJobsResponse) Reset 

func (x *ListBatchJobsResponse) Reset()

func (*ListBatchJobsResponse) String 

func (x *ListBatchJobsResponse) String() string

type 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 

type ListNotebooksRequest struct {

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

func (*ListNotebooksRequest) Descriptor deprecated 

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

Deprecated: Use ListNotebooksRequest.ProtoReflect.Descriptor instead.

func (*ListNotebooksRequest) GetAfter 

func (x *ListNotebooksRequest) GetAfter() string

func (*ListNotebooksRequest) GetLimit 

func (x *ListNotebooksRequest) GetLimit() int32

func (*ListNotebooksRequest) ProtoMessage 

func (*ListNotebooksRequest) ProtoMessage()

func (*ListNotebooksRequest) ProtoReflect 

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

func (*ListNotebooksRequest) Reset 

func (x *ListNotebooksRequest) Reset()

func (*ListNotebooksRequest) String 

func (x *ListNotebooksRequest) String() string

type ListNotebooksResponse 

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

func (*ListNotebooksResponse) Descriptor deprecated 

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

Deprecated: Use ListNotebooksResponse.ProtoReflect.Descriptor instead.

func (*ListNotebooksResponse) GetHasMore 

func (x *ListNotebooksResponse) GetHasMore() bool

func (*ListNotebooksResponse) GetNotebooks 

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

func (*ListNotebooksResponse) ProtoMessage 

func (*ListNotebooksResponse) ProtoMessage()

func (*ListNotebooksResponse) ProtoReflect 

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

func (*ListNotebooksResponse) Reset 

func (x *ListNotebooksResponse) Reset()

func (*ListNotebooksResponse) String 

func (x *ListNotebooksResponse) String() string

type ListQueuedInternalBatchJobsRequest 

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

func (*ListQueuedInternalBatchJobsRequest) Descriptor deprecated 

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

Deprecated: Use ListQueuedInternalBatchJobsRequest.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalBatchJobsRequest) ProtoMessage 

func (*ListQueuedInternalBatchJobsRequest) ProtoMessage()

func (*ListQueuedInternalBatchJobsRequest) ProtoReflect 

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

func (*ListQueuedInternalBatchJobsRequest) Reset 

func (x *ListQueuedInternalBatchJobsRequest) Reset()

func (*ListQueuedInternalBatchJobsRequest) String 

func (x *ListQueuedInternalBatchJobsRequest) String() string

type ListQueuedInternalBatchJobsResponse 

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

func (*ListQueuedInternalBatchJobsResponse) Descriptor deprecated 

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

Deprecated: Use ListQueuedInternalBatchJobsResponse.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalBatchJobsResponse) GetJobs 

func (x *ListQueuedInternalBatchJobsResponse) GetJobs() []*InternalBatchJob

func (*ListQueuedInternalBatchJobsResponse) ProtoMessage 

func (*ListQueuedInternalBatchJobsResponse) ProtoMessage()

func (*ListQueuedInternalBatchJobsResponse) ProtoReflect 

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

func (*ListQueuedInternalBatchJobsResponse) Reset 

func (x *ListQueuedInternalBatchJobsResponse) Reset()

func (*ListQueuedInternalBatchJobsResponse) String 

func (x *ListQueuedInternalBatchJobsResponse) String() string

type ListQueuedInternalJobsRequest 

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

func (*ListQueuedInternalJobsRequest) Descriptor deprecated 

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

Deprecated: Use ListQueuedInternalJobsRequest.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalJobsRequest) ProtoMessage 

func (*ListQueuedInternalJobsRequest) ProtoMessage()

func (*ListQueuedInternalJobsRequest) ProtoReflect 

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

func (*ListQueuedInternalJobsRequest) Reset 

func (x *ListQueuedInternalJobsRequest) Reset()

func (*ListQueuedInternalJobsRequest) String 

func (x *ListQueuedInternalJobsRequest) String() string

type ListQueuedInternalJobsResponse 

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

func (*ListQueuedInternalJobsResponse) Descriptor deprecated 

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

Deprecated: Use ListQueuedInternalJobsResponse.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalJobsResponse) GetJobs 

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

func (*ListQueuedInternalJobsResponse) ProtoMessage 

func (*ListQueuedInternalJobsResponse) ProtoMessage()

func (*ListQueuedInternalJobsResponse) ProtoReflect 

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

func (*ListQueuedInternalJobsResponse) Reset 

func (x *ListQueuedInternalJobsResponse) Reset()

func (*ListQueuedInternalJobsResponse) String 

func (x *ListQueuedInternalJobsResponse) String() string

type ListQueuedInternalNotebooksRequest 

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

func (*ListQueuedInternalNotebooksRequest) Descriptor deprecated 

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

Deprecated: Use ListQueuedInternalNotebooksRequest.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalNotebooksRequest) ProtoMessage 

func (*ListQueuedInternalNotebooksRequest) ProtoMessage()

func (*ListQueuedInternalNotebooksRequest) ProtoReflect 

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

func (*ListQueuedInternalNotebooksRequest) Reset 

func (x *ListQueuedInternalNotebooksRequest) Reset()

func (*ListQueuedInternalNotebooksRequest) String 

func (x *ListQueuedInternalNotebooksRequest) String() string

type ListQueuedInternalNotebooksResponse 

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

func (*ListQueuedInternalNotebooksResponse) Descriptor deprecated 

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

Deprecated: Use ListQueuedInternalNotebooksResponse.ProtoReflect.Descriptor instead.

func (*ListQueuedInternalNotebooksResponse) GetNotebooks 

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

func (*ListQueuedInternalNotebooksResponse) ProtoMessage 

func (*ListQueuedInternalNotebooksResponse) ProtoMessage()

func (*ListQueuedInternalNotebooksResponse) ProtoReflect 

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

func (*ListQueuedInternalNotebooksResponse) Reset 

func (x *ListQueuedInternalNotebooksResponse) Reset()

func (*ListQueuedInternalNotebooksResponse) String 

func (x *ListQueuedInternalNotebooksResponse) String() string

type Notebook 

type Notebook struct {
	Id        string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt int64             `protobuf:"varint,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StartedAt int64             `protobuf:"varint,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	StoppedAt int64             `protobuf:"varint,5,opt,name=stopped_at,json=stoppedAt,proto3" json:"stopped_at,omitempty"`
	Image     string            `protobuf:"bytes,6,opt,name=image,proto3" json:"image,omitempty"`
	Resources *Resources        `protobuf:"bytes,7,opt,name=resources,proto3" json:"resources,omitempty"`
	Envs      map[string]string `` /* 149-byte string literal not displayed */
	Error     *Notebook_Error   `protobuf:"bytes,9,opt,name=error,proto3" json:"error,omitempty"`
	Status    string            `protobuf:"bytes,10,opt,name=status,proto3" json:"status,omitempty"`
	// 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 

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

Deprecated: Use Notebook.ProtoReflect.Descriptor instead.

func (*Notebook) GetClusterId 

func (x *Notebook) GetClusterId() string

func (*Notebook) GetCreatedAt 

func (x *Notebook) GetCreatedAt() int64

func (*Notebook) GetEnvs 

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

func (*Notebook) GetError 

func (x *Notebook) GetError() *Notebook_Error

func (*Notebook) GetId 

func (x *Notebook) GetId() string

func (*Notebook) GetImage 

func (x *Notebook) GetImage() string

func (*Notebook) GetKubernetesNamespace 

func (x *Notebook) GetKubernetesNamespace() string

func (*Notebook) GetName 

func (x *Notebook) GetName() string

func (*Notebook) GetProjectId 

func (x *Notebook) GetProjectId() string

func (*Notebook) GetResources 

func (x *Notebook) GetResources() *Resources

func (*Notebook) GetStartedAt 

func (x *Notebook) GetStartedAt() int64

func (*Notebook) GetStatus 

func (x *Notebook) GetStatus() string

func (*Notebook) GetStoppedAt 

func (x *Notebook) GetStoppedAt() int64

func (*Notebook) GetToken 

func (x *Notebook) GetToken() string

func (*Notebook) ProtoMessage 

func (*Notebook) ProtoMessage()

func (*Notebook) ProtoReflect 

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

func (*Notebook) Reset 

func (x *Notebook) Reset()

func (*Notebook) String 

func (x *Notebook) String() string

type NotebookQueuedAction 

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

func (NotebookQueuedAction) Descriptor 

func (NotebookQueuedAction) Descriptor() protoreflect.EnumDescriptor

func (NotebookQueuedAction) Enum 

func (x NotebookQueuedAction) Enum() *NotebookQueuedAction

func (NotebookQueuedAction) EnumDescriptor deprecated 

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

Deprecated: Use NotebookQueuedAction.Descriptor instead.

func (NotebookQueuedAction) Number 

func (x NotebookQueuedAction) Number() protoreflect.EnumNumber

func (NotebookQueuedAction) String 

func (x NotebookQueuedAction) String() string

func (NotebookQueuedAction) Type 

func (NotebookQueuedAction) Type() protoreflect.EnumType

type NotebookState 

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

func (NotebookState) Descriptor 

func (NotebookState) Descriptor() protoreflect.EnumDescriptor

func (NotebookState) Enum 

func (x NotebookState) Enum() *NotebookState

func (NotebookState) EnumDescriptor deprecated 

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

Deprecated: Use NotebookState.Descriptor instead.

func (NotebookState) Number 

func (x NotebookState) Number() protoreflect.EnumNumber

func (NotebookState) String 

func (x NotebookState) String() string

func (NotebookState) Type 

func (NotebookState) Type() protoreflect.EnumType

type Notebook_Error 

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

func (*Notebook_Error) Descriptor deprecated 

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

Deprecated: Use Notebook_Error.ProtoReflect.Descriptor instead.

func (*Notebook_Error) GetCode 

func (x *Notebook_Error) GetCode() string

func (*Notebook_Error) GetMessage 

func (x *Notebook_Error) GetMessage() string

func (*Notebook_Error) ProtoMessage 

func (*Notebook_Error) ProtoMessage()

func (*Notebook_Error) ProtoReflect 

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

func (*Notebook_Error) Reset 

func (x *Notebook_Error) Reset()

func (*Notebook_Error) String 

func (x *Notebook_Error) String() string

type PyTorchJob 

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

func (*PyTorchJob) Descriptor deprecated 

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

Deprecated: Use PyTorchJob.ProtoReflect.Descriptor instead.

func (*PyTorchJob) GetWorkerCount 

func (x *PyTorchJob) GetWorkerCount() int32

func (*PyTorchJob) ProtoMessage 

func (*PyTorchJob) ProtoMessage()

func (*PyTorchJob) ProtoReflect 

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

func (*PyTorchJob) Reset 

func (x *PyTorchJob) Reset()

func (*PyTorchJob) String 

func (x *PyTorchJob) String() string

type Resources 

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

func (*Resources) Descriptor deprecated 

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

Deprecated: Use Resources.ProtoReflect.Descriptor instead.

func (*Resources) GetCpuMilicore 

func (x *Resources) GetCpuMilicore() *Resources_Quantity

func (*Resources) GetGpuCount 

func (x *Resources) GetGpuCount() int32

func (*Resources) GetMemoryMegabytes 

func (x *Resources) GetMemoryMegabytes() *Resources_Quantity

func (*Resources) GetStorageMegabytes 

func (x *Resources) GetStorageMegabytes() *Resources_Quantity

func (*Resources) ProtoMessage 

func (*Resources) ProtoMessage()

func (*Resources) ProtoReflect 

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

func (*Resources) Reset 

func (x *Resources) Reset()

func (*Resources) String 

func (x *Resources) String() string

type Resources_Quantity 

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

func (*Resources_Quantity) Descriptor deprecated 

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

Deprecated: Use Resources_Quantity.ProtoReflect.Descriptor instead.

func (*Resources_Quantity) GetLimits 

func (x *Resources_Quantity) GetLimits() int32

func (*Resources_Quantity) GetRequests 

func (x *Resources_Quantity) GetRequests() int32

func (*Resources_Quantity) ProtoMessage 

func (*Resources_Quantity) ProtoMessage()

func (*Resources_Quantity) ProtoReflect 

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

func (*Resources_Quantity) Reset 

func (x *Resources_Quantity) Reset()

func (*Resources_Quantity) String 

func (x *Resources_Quantity) String() string

type StartNotebookRequest 

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

func (*StartNotebookRequest) Descriptor deprecated 

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

Deprecated: Use StartNotebookRequest.ProtoReflect.Descriptor instead.

func (*StartNotebookRequest) GetId 

func (x *StartNotebookRequest) GetId() string

func (*StartNotebookRequest) ProtoMessage 

func (*StartNotebookRequest) ProtoMessage()

func (*StartNotebookRequest) ProtoReflect 

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

func (*StartNotebookRequest) Reset 

func (x *StartNotebookRequest) Reset()

func (*StartNotebookRequest) String 

func (x *StartNotebookRequest) String() string

type StopNotebookRequest 

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

func (*StopNotebookRequest) Descriptor deprecated 

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

Deprecated: Use StopNotebookRequest.ProtoReflect.Descriptor instead.

func (*StopNotebookRequest) GetId 

func (x *StopNotebookRequest) GetId() string

func (*StopNotebookRequest) ProtoMessage 

func (*StopNotebookRequest) ProtoMessage()

func (*StopNotebookRequest) ProtoReflect 

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

func (*StopNotebookRequest) Reset 

func (x *StopNotebookRequest) Reset()

func (*StopNotebookRequest) String 

func (x *StopNotebookRequest) String() string

type UnimplementedBatchServiceServer 

type UnimplementedBatchServiceServer struct {
}

UnimplementedBatchServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBatchServiceServer) CancelBatchJob 

func (UnimplementedBatchServiceServer) CancelBatchJob(context.Context, *CancelBatchJobRequest) (*BatchJob, error)

func (UnimplementedBatchServiceServer) CreateBatchJob 

func (UnimplementedBatchServiceServer) CreateBatchJob(context.Context, *CreateBatchJobRequest) (*BatchJob, error)

func (UnimplementedBatchServiceServer) DeleteBatchJob 

func (UnimplementedBatchServiceServer) DeleteBatchJob(context.Context, *DeleteBatchJobRequest) (*BatchJob, error)

func (UnimplementedBatchServiceServer) GetBatchJob 

func (UnimplementedBatchServiceServer) GetBatchJob(context.Context, *GetBatchJobRequest) (*BatchJob, error)

func (UnimplementedBatchServiceServer) ListBatchJobs 

func (UnimplementedBatchServiceServer) ListBatchJobs(context.Context, *ListBatchJobsRequest) (*ListBatchJobsResponse, error)

type UnimplementedBatchWorkerServiceServer 

type UnimplementedBatchWorkerServiceServer struct {
}

UnimplementedBatchWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBatchWorkerServiceServer) GetInternalBatchJob 

func (UnimplementedBatchWorkerServiceServer) GetInternalBatchJob(context.Context, *GetInternalBatchJobRequest) (*InternalBatchJob, error)

func (UnimplementedBatchWorkerServiceServer) ListQueuedInternalBatchJobs 

func (UnimplementedBatchWorkerServiceServer) ListQueuedInternalBatchJobs(context.Context, *ListQueuedInternalBatchJobsRequest) (*ListQueuedInternalBatchJobsResponse, error)

func (UnimplementedBatchWorkerServiceServer) UpdateBatchJobState 

func (UnimplementedBatchWorkerServiceServer) UpdateBatchJobState(context.Context, *UpdateBatchJobStateRequest) (*UpdateBatchJobStateResponse, error)

type UnimplementedFineTuningServiceServer 

type UnimplementedFineTuningServiceServer struct {
}

UnimplementedFineTuningServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFineTuningServiceServer) CancelJob 

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

func (UnimplementedFineTuningServiceServer) CreateJob 

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

func (UnimplementedFineTuningServiceServer) GetJob 

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

func (UnimplementedFineTuningServiceServer) ListJobs 

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

type UnimplementedFineTuningWorkerServiceServer 

type UnimplementedFineTuningWorkerServiceServer struct {
}

UnimplementedFineTuningWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFineTuningWorkerServiceServer) GetInternalJob 

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

func (UnimplementedFineTuningWorkerServiceServer) ListQueuedInternalJobs 

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

func (UnimplementedFineTuningWorkerServiceServer) UpdateJobPhase 

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

type UnimplementedWorkspaceServiceServer 

type UnimplementedWorkspaceServiceServer struct {
}

UnimplementedWorkspaceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkspaceServiceServer) CreateNotebook 

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

func (UnimplementedWorkspaceServiceServer) DeleteNotebook 

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

func (UnimplementedWorkspaceServiceServer) GetNotebook 

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

func (UnimplementedWorkspaceServiceServer) ListNotebooks 

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

func (UnimplementedWorkspaceServiceServer) StartNotebook 

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

func (UnimplementedWorkspaceServiceServer) StopNotebook 

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

type UnimplementedWorkspaceWorkerServiceServer 

type UnimplementedWorkspaceWorkerServiceServer struct {
}

UnimplementedWorkspaceWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkspaceWorkerServiceServer) ListQueuedInternalNotebooks 

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

func (UnimplementedWorkspaceWorkerServiceServer) UpdateNotebookState 

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

type UnsafeBatchServiceServer 

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

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

type UnsafeBatchWorkerServiceServer 

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

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

type UnsafeFineTuningServiceServer 

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

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

type UnsafeFineTuningWorkerServiceServer 

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

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

type UnsafeWorkspaceServiceServer 

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

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

type UnsafeWorkspaceWorkerServiceServer 

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

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

type UpdateBatchJobStateRequest 

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

func (*UpdateBatchJobStateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateBatchJobStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateBatchJobStateRequest) GetId 

func (x *UpdateBatchJobStateRequest) GetId() string

func (*UpdateBatchJobStateRequest) GetMessage 

func (x *UpdateBatchJobStateRequest) GetMessage() string

func (*UpdateBatchJobStateRequest) GetReason 

func (x *UpdateBatchJobStateRequest) GetReason() string

func (*UpdateBatchJobStateRequest) GetState 

func (x *UpdateBatchJobStateRequest) GetState() InternalBatchJob_State

func (*UpdateBatchJobStateRequest) ProtoMessage 

func (*UpdateBatchJobStateRequest) ProtoMessage()

func (*UpdateBatchJobStateRequest) ProtoReflect 

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

func (*UpdateBatchJobStateRequest) Reset 

func (x *UpdateBatchJobStateRequest) Reset()

func (*UpdateBatchJobStateRequest) String 

func (x *UpdateBatchJobStateRequest) String() string

type UpdateBatchJobStateResponse 

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

func (*UpdateBatchJobStateResponse) Descriptor deprecated 

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

Deprecated: Use UpdateBatchJobStateResponse.ProtoReflect.Descriptor instead.

func (*UpdateBatchJobStateResponse) ProtoMessage 

func (*UpdateBatchJobStateResponse) ProtoMessage()

func (*UpdateBatchJobStateResponse) ProtoReflect 

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

func (*UpdateBatchJobStateResponse) Reset 

func (x *UpdateBatchJobStateResponse) Reset()

func (*UpdateBatchJobStateResponse) String 

func (x *UpdateBatchJobStateResponse) String() string

type UpdateJobPhaseRequest 

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

func (*UpdateJobPhaseRequest) Descriptor deprecated 

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

Deprecated: Use UpdateJobPhaseRequest.ProtoReflect.Descriptor instead.

func (*UpdateJobPhaseRequest) GetId 

func (x *UpdateJobPhaseRequest) GetId() string

func (*UpdateJobPhaseRequest) GetMessage 

func (x *UpdateJobPhaseRequest) GetMessage() string

func (*UpdateJobPhaseRequest) GetModelId 

func (x *UpdateJobPhaseRequest) GetModelId() string

func (*UpdateJobPhaseRequest) GetPhase 

func (x *UpdateJobPhaseRequest) GetPhase() UpdateJobPhaseRequest_Phase

func (*UpdateJobPhaseRequest) ProtoMessage 

func (*UpdateJobPhaseRequest) ProtoMessage()

func (*UpdateJobPhaseRequest) ProtoReflect 

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

func (*UpdateJobPhaseRequest) Reset 

func (x *UpdateJobPhaseRequest) Reset()

func (*UpdateJobPhaseRequest) String 

func (x *UpdateJobPhaseRequest) String() string

type UpdateJobPhaseRequest_Phase 

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

func (UpdateJobPhaseRequest_Phase) Descriptor 

func (UpdateJobPhaseRequest_Phase) Descriptor() protoreflect.EnumDescriptor

func (UpdateJobPhaseRequest_Phase) Enum 

func (x UpdateJobPhaseRequest_Phase) Enum() *UpdateJobPhaseRequest_Phase

func (UpdateJobPhaseRequest_Phase) EnumDescriptor deprecated 

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

Deprecated: Use UpdateJobPhaseRequest_Phase.Descriptor instead.

func (UpdateJobPhaseRequest_Phase) Number 

func (x UpdateJobPhaseRequest_Phase) Number() protoreflect.EnumNumber

func (UpdateJobPhaseRequest_Phase) String 

func (x UpdateJobPhaseRequest_Phase) String() string

func (UpdateJobPhaseRequest_Phase) Type 

func (UpdateJobPhaseRequest_Phase) Type() protoreflect.EnumType

type UpdateJobPhaseResponse 

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

func (*UpdateJobPhaseResponse) Descriptor deprecated 

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

Deprecated: Use UpdateJobPhaseResponse.ProtoReflect.Descriptor instead.

func (*UpdateJobPhaseResponse) ProtoMessage 

func (*UpdateJobPhaseResponse) ProtoMessage()

func (*UpdateJobPhaseResponse) ProtoReflect 

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

func (*UpdateJobPhaseResponse) Reset 

func (x *UpdateJobPhaseResponse) Reset()

func (*UpdateJobPhaseResponse) String 

func (x *UpdateJobPhaseResponse) String() string

type UpdateNotebookStateRequest 

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

func (*UpdateNotebookStateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateNotebookStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateNotebookStateRequest) GetId 

func (x *UpdateNotebookStateRequest) GetId() string

func (*UpdateNotebookStateRequest) GetState 

func (x *UpdateNotebookStateRequest) GetState() NotebookState

func (*UpdateNotebookStateRequest) ProtoMessage 

func (*UpdateNotebookStateRequest) ProtoMessage()

func (*UpdateNotebookStateRequest) ProtoReflect 

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

func (*UpdateNotebookStateRequest) Reset 

func (x *UpdateNotebookStateRequest) Reset()

func (*UpdateNotebookStateRequest) String 

func (x *UpdateNotebookStateRequest) String() string

type UpdateNotebookStateResponse 

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

func (*UpdateNotebookStateResponse) Descriptor deprecated 

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

Deprecated: Use UpdateNotebookStateResponse.ProtoReflect.Descriptor instead.

func (*UpdateNotebookStateResponse) ProtoMessage 

func (*UpdateNotebookStateResponse) ProtoMessage()

func (*UpdateNotebookStateResponse) ProtoReflect 

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

func (*UpdateNotebookStateResponse) Reset 

func (x *UpdateNotebookStateResponse) Reset()

func (*UpdateNotebookStateResponse) String 

func (x *UpdateNotebookStateResponse) String() string

type WorkspaceServiceClient 

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

WorkspaceServiceClient is the client API for WorkspaceService service.

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

func NewWorkspaceServiceClient 

func NewWorkspaceServiceClient(cc grpc.ClientConnInterface) WorkspaceServiceClient

type WorkspaceServiceServer 

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

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

type WorkspaceWorkerServiceClient 

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

WorkspaceWorkerServiceClient is the client API for WorkspaceWorkerService service.

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

func NewWorkspaceWorkerServiceClient 

func NewWorkspaceWorkerServiceClient(cc grpc.ClientConnInterface) WorkspaceWorkerServiceClient

type WorkspaceWorkerServiceServer 

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

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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