legacy

package
v0.212.0 Latest Latest
Warning

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

 Go to latest Published: Oct 2, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BatchWorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmoperator.batch.server.v1.BatchWorkerService",
	HandlerType: (*BatchWorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListQueuedInternalBatchJobs",
			Handler:    _BatchWorkerService_ListQueuedInternalBatchJobs_Handler,
		},
		{
			MethodName: "GetInternalBatchJob",
			Handler:    _BatchWorkerService_GetInternalBatchJob_Handler,
		},
		{
			MethodName: "UpdateBatchJobState",
			Handler:    _BatchWorkerService_UpdateBatchJobState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/legacy/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_legacy_batch_service_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_legacy_job_manager_service_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_legacy_workspace_service_proto protoreflect.FileDescriptor
View Source 
var FineTuningWorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmoperator.fine_tuning.server.v1.FineTuningWorkerService",
	HandlerType: (*FineTuningWorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListQueuedInternalJobs",
			Handler:    _FineTuningWorkerService_ListQueuedInternalJobs_Handler,
		},
		{
			MethodName: "GetInternalJob",
			Handler:    _FineTuningWorkerService_GetInternalJob_Handler,
		},
		{
			MethodName: "UpdateJobPhase",
			Handler:    _FineTuningWorkerService_UpdateJobPhase_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/legacy/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 WorkspaceWorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmoperator.workspace.server.v1.WorkspaceWorkerService",
	HandlerType: (*WorkspaceWorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListQueuedInternalNotebooks",
			Handler:    _WorkspaceWorkerService_ListQueuedInternalNotebooks_Handler,
		},
		{
			MethodName: "UpdateNotebookState",
			Handler:    _WorkspaceWorkerService_UpdateNotebookState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/legacy/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 RegisterBatchWorkerServiceServer 

func RegisterBatchWorkerServiceServer(s grpc.ServiceRegistrar, srv BatchWorkerServiceServer)

func RegisterFineTuningWorkerServiceServer 

func RegisterFineTuningWorkerServiceServer(s grpc.ServiceRegistrar, srv FineTuningWorkerServiceServer)

func RegisterWorkspaceWorkerServiceServer 

func RegisterWorkspaceWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkspaceWorkerServiceServer)

Types

type BatchWorkerServiceClient 

type BatchWorkerServiceClient interface {
	ListQueuedInternalBatchJobs(ctx context.Context, in *v1.ListQueuedInternalBatchJobsRequest, opts ...grpc.CallOption) (*v1.ListQueuedInternalBatchJobsResponse, error)
	GetInternalBatchJob(ctx context.Context, in *v1.GetInternalBatchJobRequest, opts ...grpc.CallOption) (*v1.InternalBatchJob, error)
	UpdateBatchJobState(ctx context.Context, in *v1.UpdateBatchJobStateRequest, opts ...grpc.CallOption) (*v1.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, *v1.ListQueuedInternalBatchJobsRequest) (*v1.ListQueuedInternalBatchJobsResponse, error)
	GetInternalBatchJob(context.Context, *v1.GetInternalBatchJobRequest) (*v1.InternalBatchJob, error)
	UpdateBatchJobState(context.Context, *v1.UpdateBatchJobStateRequest) (*v1.UpdateBatchJobStateResponse, error)
	// contains filtered or unexported methods
}

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

type FineTuningWorkerServiceClient 

type FineTuningWorkerServiceClient interface {
	ListQueuedInternalJobs(ctx context.Context, in *v1.ListQueuedInternalJobsRequest, opts ...grpc.CallOption) (*v1.ListQueuedInternalJobsResponse, error)
	GetInternalJob(ctx context.Context, in *v1.GetInternalJobRequest, opts ...grpc.CallOption) (*v1.InternalJob, error)
	// UpdateJobPhase updates the job status depending on the phase.
	UpdateJobPhase(ctx context.Context, in *v1.UpdateJobPhaseRequest, opts ...grpc.CallOption) (*v1.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, *v1.ListQueuedInternalJobsRequest) (*v1.ListQueuedInternalJobsResponse, error)
	GetInternalJob(context.Context, *v1.GetInternalJobRequest) (*v1.InternalJob, error)
	// UpdateJobPhase updates the job status depending on the phase.
	UpdateJobPhase(context.Context, *v1.UpdateJobPhaseRequest) (*v1.UpdateJobPhaseResponse, error)
	// contains filtered or unexported methods
}

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

type UnimplementedBatchWorkerServiceServer 

type UnimplementedBatchWorkerServiceServer struct {
}

UnimplementedBatchWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBatchWorkerServiceServer) GetInternalBatchJob 

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

func (UnimplementedBatchWorkerServiceServer) ListQueuedInternalBatchJobs 

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

func (UnimplementedBatchWorkerServiceServer) UpdateBatchJobState 

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

type UnimplementedFineTuningWorkerServiceServer 

type UnimplementedFineTuningWorkerServiceServer struct {
}

UnimplementedFineTuningWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFineTuningWorkerServiceServer) GetInternalJob 

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

func (UnimplementedFineTuningWorkerServiceServer) ListQueuedInternalJobs 

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

func (UnimplementedFineTuningWorkerServiceServer) UpdateJobPhase 

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

type UnimplementedWorkspaceWorkerServiceServer 

type UnimplementedWorkspaceWorkerServiceServer struct {
}

UnimplementedWorkspaceWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkspaceWorkerServiceServer) ListQueuedInternalNotebooks 

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

func (UnimplementedWorkspaceWorkerServiceServer) UpdateNotebookState 

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

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 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 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 WorkspaceWorkerServiceClient 

type WorkspaceWorkerServiceClient interface {
	ListQueuedInternalNotebooks(ctx context.Context, in *v1.ListQueuedInternalNotebooksRequest, opts ...grpc.CallOption) (*v1.ListQueuedInternalNotebooksResponse, error)
	UpdateNotebookState(ctx context.Context, in *v1.UpdateNotebookStateRequest, opts ...grpc.CallOption) (*v1.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, *v1.ListQueuedInternalNotebooksRequest) (*v1.ListQueuedInternalNotebooksResponse, error)
	UpdateNotebookState(context.Context, *v1.UpdateNotebookStateRequest) (*v1.UpdateNotebookStateResponse, error)
	// contains filtered or unexported methods
}

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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