platformpb

package
v2.6.0 Latest Latest
Warning

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

Go to latest
Published: Mar 7, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_sudo_mpc_virtual_service_platform_service_furnace_proto protoreflect.FileDescriptor

Functions

func RegisterFurnaceServer

func RegisterFurnaceServer(s *grpc.Server, srv FurnaceServer)

Types

type FurnaceClient

type FurnaceClient interface {
	// 获得Coordinator列表
	//
	// 获取本方加入的所有Coordinator列表。
	GetCoordinators(ctx context.Context, in *party.PartyQueryOption, opts ...grpc.CallOption) (*party.GetPartiesResponse, error)
	Echo(ctx context.Context, in *misc.EchoRequest, opts ...grpc.CallOption) (*misc.EchoResponse, error)
	ListVtables(ctx context.Context, in *vtable.ListVtablesRequest, opts ...grpc.CallOption) (*vtable.ListVtablesResponse, error)
	CreateVtable(ctx context.Context, in *vtable.CreateVtableRequest, opts ...grpc.CallOption) (*vtable.CreateVtableResponse, error)
	AttachVtableToProject(ctx context.Context, in *vtable.AttachVtableToProjectRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DetachVtableToProject(ctx context.Context, in *vtable.DetachVtableToProjectRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteVtable(ctx context.Context, in *vtable.DeleteVtableRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// 更新Vtable信息
	//
	// 根据请求详情,更新vtable的具体信息记录。
	UpdateVtable(ctx context.Context, in *vtable.UpdateVtableRequest, opts ...grpc.CallOption) (*vtable.UpdateVtableResponse, error)
	// 刷新Vtable信息
	//
	// 根据Vtable指向的数据的实际情况,刷新Vtable的信息。
	SyncVtable(ctx context.Context, in *vtable.SyncVtableRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// 获取vtable可见信息
	//
	// 返回请求用户对vtable可见的具体信息。
	GetVisibleVtableColumns(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*vtable.VtableColumnsVisibilitySetting, error)
	// 获取原始数据
	//
	// 给定vtable和相关信息,返回vtable的原始数据和相关元数据。
	GetVtableRawData(ctx context.Context, in *vtable.GetVtableRawDataRequest, opts ...grpc.CallOption) (*vtable.GetVtableRawDataResponse, error)
	GetAllDataSources(ctx context.Context, in *datasource.GetAllDataSourcesRequest, opts ...grpc.CallOption) (*datasource.GetAllDataSourcesResponse, error)
	SendFileToDataSource(ctx context.Context, in *datasource.SendFileToDataSourceRequest, opts ...grpc.CallOption) (*datasource.SendFileToDataSourceResponse, error)
	// 分配资源
	//
	// 通常由Coordinator发起请求,向某个计算方为某个计算任务预留相应的计算资源。
	AllocatePartyResource(ctx context.Context, in *resource.AllocatePartyResourceRequest, opts ...grpc.CallOption) (*resource.AllocatePartyResourceResponse, error)
	ReleasePartyResource(ctx context.Context, in *resource.ReleasePartyResourceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeployPartyResource(ctx context.Context, in *resource.DeployPartyResourceRequest, opts ...grpc.CallOption) (*resource.DeployPartyResourceResponse, error)
	GetPartyResourceStatus(ctx context.Context, in *resource.GetPartyResourceStatusRequest, opts ...grpc.CallOption) (*resource.GetPartyResourceStatusResponse, error)
	UpdatePartyResourceStatus(ctx context.Context, in *resource.UpdatePartyResourceStatusRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	FinishPartyBlock(ctx context.Context, in *resource.FinishPartyBlockRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetDataSources(ctx context.Context, in *datasource.GetDataSourcesRequest, opts ...grpc.CallOption) (*datasource.GetDataSourcesResponse, error)
	CreateDataSource(ctx context.Context, in *datasource.CreateDataSourceRequest, opts ...grpc.CallOption) (*datasource.CreateDataSourceResponse, error)
	UpdateDataSource(ctx context.Context, in *datasource.UpdateDataSourceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteDataSource(ctx context.Context, in *datasource.DeleteDataSourceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ShowDatabases(ctx context.Context, in *datasource.ShowDatabasesRequest, opts ...grpc.CallOption) (*datasource.ShowDatabasesResponse, error)
	ShowTables(ctx context.Context, in *datasource.ShowTablesRequest, opts ...grpc.CallOption) (*datasource.ShowTablesResponse, error)
	DescTable(ctx context.Context, in *datasource.DescTableRequest, opts ...grpc.CallOption) (*datasource.DescTableResponse, error)
	// 获取文件列表
	//
	// 给定数据源和文件路径,返回该路径下的文件列表,以及列表中各文件的详细信息。
	WalkDir(ctx context.Context, in *protobuf.WalkDirRequest, opts ...grpc.CallOption) (*protobuf.WalkDirResponse, error)
	// 获取文件详情
	//
	// 给定数据源和文件路径,返回文件的详细情况,如大小、行数等。
	DescFileNode(ctx context.Context, in *datasource.DescFileNodeRequest, opts ...grpc.CallOption) (*protobuf.DescFileNodeResponse, error)
	CreatePirServerService(ctx context.Context, in *pir.CreateServerServiceRequest, opts ...grpc.CallOption) (*pir.CreateServerServiceResponse, error)
	UpdatePirServerService(ctx context.Context, in *pir.UpdateServerServiceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetPirServerServices(ctx context.Context, in *pir.GetServerServicesRequest, opts ...grpc.CallOption) (*pir.GetServerServicesResponse, error)
	DeletePirServerService(ctx context.Context, in *pir.DeleteServerServiceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PirServerServiceTakeAction(ctx context.Context, in *pir.ServerServiceTakeActionRequest, opts ...grpc.CallOption) (*pir.ServerServiceTakeActionResponse, error)
	CreatePirServerToken(ctx context.Context, in *token.GenerateTokenForPartyRequest, opts ...grpc.CallOption) (*token.GenerateTokenForPartyResponse, error)
	GetPirServerToken(ctx context.Context, in *token.GetPartyTokenRequest, opts ...grpc.CallOption) (*token.GetPartyTokenResponse, error)
	EnablePirServerToken(ctx context.Context, in *token.ActionOnPirServerToken, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CreatePirClientService(ctx context.Context, in *pir.CreatePirClientServiceRequest, opts ...grpc.CallOption) (*pir.CreatePirClientServiceResponse, error)
	UpdatePirClientService(ctx context.Context, in *pir.UpdatePirClientServiceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetPirClientServices(ctx context.Context, in *pir.GetPirClientServicesRequst, opts ...grpc.CallOption) (*pir.GetPirClientServicesResponse, error)
	DeletePirClientService(ctx context.Context, in *pir.DeleteClientServiceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PirClientServiceTakeAction(ctx context.Context, in *pir.ClientServiceTakeActionRequest, opts ...grpc.CallOption) (*pir.ClientServiceTakeActionResponse, error)
	GetPirServerUsages(ctx context.Context, in *pir.GetServerUsagesRequest, opts ...grpc.CallOption) (*pir.GetServerUsagesResponse, error)
	GetPirClientUsages(ctx context.Context, in *pir.GetClientUsagesRequest, opts ...grpc.CallOption) (*pir.GetClientUsagesResponse, error)
	PirRequest(ctx context.Context, in *pir.PirRequest, opts ...grpc.CallOption) (*pir.PirResponse, error)
	UpsertUsageNotifyReceiver(ctx context.Context, in *api_usage.UpsertAPIUsageReceiverRequest, opts ...grpc.CallOption) (*api_usage.UpsertAPIUsageReceiverResponse, error)
	ListAPIUsages(ctx context.Context, in *api_usage.ListAPIUsagesRequest, opts ...grpc.CallOption) (*api_usage.ListAPIUsagesResponse, error)
	// 更新在线服务server端输入数据
	UpdateServerData(ctx context.Context, in *pir.UpdateServerDataRequest, opts ...grpc.CallOption) (*pir.UpdateServerDataResponse, error)
	// 获取任务列表
	//
	// 根据过滤条件,返回符合条件的任务列表。
	GetTasks(ctx context.Context, in *task.GetTasksRequest, opts ...grpc.CallOption) (*task.GetTasksResponse, error)
	// 提交任务
	//
	// 请求中包含任务配置等详细信息,向Coordinator提交任务;任务提交成功后Coordinator就会返回response。
	ActionOnTask(ctx context.Context, in *task.ActionOnTaskRequest, opts ...grpc.CallOption) (*task.ActionOnTaskResponse, error)
	// 获取计算阶段输出
	//
	// 获取计算阶段的输出结果,以vtable形式返回。
	GetStageOutputs(ctx context.Context, in *task.GetStageOutputRequest, opts ...grpc.CallOption) (*task.GetStageOutputResponse, error)
}

FurnaceClient is the client API for Furnace service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFurnaceClient

func NewFurnaceClient(cc grpc.ClientConnInterface) FurnaceClient

type FurnaceServer

type FurnaceServer interface {
	// 获得Coordinator列表
	//
	// 获取本方加入的所有Coordinator列表。
	GetCoordinators(context.Context, *party.PartyQueryOption) (*party.GetPartiesResponse, error)
	Echo(context.Context, *misc.EchoRequest) (*misc.EchoResponse, error)
	ListVtables(context.Context, *vtable.ListVtablesRequest) (*vtable.ListVtablesResponse, error)
	CreateVtable(context.Context, *vtable.CreateVtableRequest) (*vtable.CreateVtableResponse, error)
	AttachVtableToProject(context.Context, *vtable.AttachVtableToProjectRequest) (*emptypb.Empty, error)
	DetachVtableToProject(context.Context, *vtable.DetachVtableToProjectRequest) (*emptypb.Empty, error)
	DeleteVtable(context.Context, *vtable.DeleteVtableRequest) (*emptypb.Empty, error)
	// 更新Vtable信息
	//
	// 根据请求详情,更新vtable的具体信息记录。
	UpdateVtable(context.Context, *vtable.UpdateVtableRequest) (*vtable.UpdateVtableResponse, error)
	// 刷新Vtable信息
	//
	// 根据Vtable指向的数据的实际情况,刷新Vtable的信息。
	SyncVtable(context.Context, *vtable.SyncVtableRequest) (*emptypb.Empty, error)
	// 获取vtable可见信息
	//
	// 返回请求用户对vtable可见的具体信息。
	GetVisibleVtableColumns(context.Context, *emptypb.Empty) (*vtable.VtableColumnsVisibilitySetting, error)
	// 获取原始数据
	//
	// 给定vtable和相关信息,返回vtable的原始数据和相关元数据。
	GetVtableRawData(context.Context, *vtable.GetVtableRawDataRequest) (*vtable.GetVtableRawDataResponse, error)
	GetAllDataSources(context.Context, *datasource.GetAllDataSourcesRequest) (*datasource.GetAllDataSourcesResponse, error)
	SendFileToDataSource(context.Context, *datasource.SendFileToDataSourceRequest) (*datasource.SendFileToDataSourceResponse, error)
	// 分配资源
	//
	// 通常由Coordinator发起请求,向某个计算方为某个计算任务预留相应的计算资源。
	AllocatePartyResource(context.Context, *resource.AllocatePartyResourceRequest) (*resource.AllocatePartyResourceResponse, error)
	ReleasePartyResource(context.Context, *resource.ReleasePartyResourceRequest) (*emptypb.Empty, error)
	DeployPartyResource(context.Context, *resource.DeployPartyResourceRequest) (*resource.DeployPartyResourceResponse, error)
	GetPartyResourceStatus(context.Context, *resource.GetPartyResourceStatusRequest) (*resource.GetPartyResourceStatusResponse, error)
	UpdatePartyResourceStatus(context.Context, *resource.UpdatePartyResourceStatusRequest) (*emptypb.Empty, error)
	FinishPartyBlock(context.Context, *resource.FinishPartyBlockRequest) (*emptypb.Empty, error)
	GetDataSources(context.Context, *datasource.GetDataSourcesRequest) (*datasource.GetDataSourcesResponse, error)
	CreateDataSource(context.Context, *datasource.CreateDataSourceRequest) (*datasource.CreateDataSourceResponse, error)
	UpdateDataSource(context.Context, *datasource.UpdateDataSourceRequest) (*emptypb.Empty, error)
	DeleteDataSource(context.Context, *datasource.DeleteDataSourceRequest) (*emptypb.Empty, error)
	ShowDatabases(context.Context, *datasource.ShowDatabasesRequest) (*datasource.ShowDatabasesResponse, error)
	ShowTables(context.Context, *datasource.ShowTablesRequest) (*datasource.ShowTablesResponse, error)
	DescTable(context.Context, *datasource.DescTableRequest) (*datasource.DescTableResponse, error)
	// 获取文件列表
	//
	// 给定数据源和文件路径,返回该路径下的文件列表,以及列表中各文件的详细信息。
	WalkDir(context.Context, *protobuf.WalkDirRequest) (*protobuf.WalkDirResponse, error)
	// 获取文件详情
	//
	// 给定数据源和文件路径,返回文件的详细情况,如大小、行数等。
	DescFileNode(context.Context, *datasource.DescFileNodeRequest) (*protobuf.DescFileNodeResponse, error)
	CreatePirServerService(context.Context, *pir.CreateServerServiceRequest) (*pir.CreateServerServiceResponse, error)
	UpdatePirServerService(context.Context, *pir.UpdateServerServiceRequest) (*emptypb.Empty, error)
	GetPirServerServices(context.Context, *pir.GetServerServicesRequest) (*pir.GetServerServicesResponse, error)
	DeletePirServerService(context.Context, *pir.DeleteServerServiceRequest) (*emptypb.Empty, error)
	PirServerServiceTakeAction(context.Context, *pir.ServerServiceTakeActionRequest) (*pir.ServerServiceTakeActionResponse, error)
	CreatePirServerToken(context.Context, *token.GenerateTokenForPartyRequest) (*token.GenerateTokenForPartyResponse, error)
	GetPirServerToken(context.Context, *token.GetPartyTokenRequest) (*token.GetPartyTokenResponse, error)
	EnablePirServerToken(context.Context, *token.ActionOnPirServerToken) (*emptypb.Empty, error)
	CreatePirClientService(context.Context, *pir.CreatePirClientServiceRequest) (*pir.CreatePirClientServiceResponse, error)
	UpdatePirClientService(context.Context, *pir.UpdatePirClientServiceRequest) (*emptypb.Empty, error)
	GetPirClientServices(context.Context, *pir.GetPirClientServicesRequst) (*pir.GetPirClientServicesResponse, error)
	DeletePirClientService(context.Context, *pir.DeleteClientServiceRequest) (*emptypb.Empty, error)
	PirClientServiceTakeAction(context.Context, *pir.ClientServiceTakeActionRequest) (*pir.ClientServiceTakeActionResponse, error)
	GetPirServerUsages(context.Context, *pir.GetServerUsagesRequest) (*pir.GetServerUsagesResponse, error)
	GetPirClientUsages(context.Context, *pir.GetClientUsagesRequest) (*pir.GetClientUsagesResponse, error)
	PirRequest(context.Context, *pir.PirRequest) (*pir.PirResponse, error)
	UpsertUsageNotifyReceiver(context.Context, *api_usage.UpsertAPIUsageReceiverRequest) (*api_usage.UpsertAPIUsageReceiverResponse, error)
	ListAPIUsages(context.Context, *api_usage.ListAPIUsagesRequest) (*api_usage.ListAPIUsagesResponse, error)
	// 更新在线服务server端输入数据
	UpdateServerData(context.Context, *pir.UpdateServerDataRequest) (*pir.UpdateServerDataResponse, error)
	// 获取任务列表
	//
	// 根据过滤条件,返回符合条件的任务列表。
	GetTasks(context.Context, *task.GetTasksRequest) (*task.GetTasksResponse, error)
	// 提交任务
	//
	// 请求中包含任务配置等详细信息,向Coordinator提交任务;任务提交成功后Coordinator就会返回response。
	ActionOnTask(context.Context, *task.ActionOnTaskRequest) (*task.ActionOnTaskResponse, error)
	// 获取计算阶段输出
	//
	// 获取计算阶段的输出结果,以vtable形式返回。
	GetStageOutputs(context.Context, *task.GetStageOutputRequest) (*task.GetStageOutputResponse, error)
}

FurnaceServer is the server API for Furnace service.

type UnimplementedFurnaceServer

type UnimplementedFurnaceServer struct {
}

UnimplementedFurnaceServer can be embedded to have forward compatible implementations.

func (*UnimplementedFurnaceServer) ActionOnTask added in v2.2.0

func (*UnimplementedFurnaceServer) AttachVtableToProject

func (*UnimplementedFurnaceServer) CreateVtable

func (*UnimplementedFurnaceServer) DeleteDataSource

func (*UnimplementedFurnaceServer) DeletePirClientService

func (*UnimplementedFurnaceServer) DeletePirServerService

func (*UnimplementedFurnaceServer) DeleteVtable

func (*UnimplementedFurnaceServer) DetachVtableToProject

func (*UnimplementedFurnaceServer) Echo

func (*UnimplementedFurnaceServer) EnablePirServerToken

func (*UnimplementedFurnaceServer) FinishPartyBlock

func (*UnimplementedFurnaceServer) GetCoordinators added in v2.2.0

func (*UnimplementedFurnaceServer) GetPirClientUsages

func (*UnimplementedFurnaceServer) GetPirServerServices

func (*UnimplementedFurnaceServer) GetPirServerToken

func (*UnimplementedFurnaceServer) GetPirServerUsages

func (*UnimplementedFurnaceServer) GetStageOutputs added in v2.2.0

func (*UnimplementedFurnaceServer) GetTasks

func (*UnimplementedFurnaceServer) GetVisibleVtableColumns

func (*UnimplementedFurnaceServer) ListVtables

func (*UnimplementedFurnaceServer) PirRequest

func (*UnimplementedFurnaceServer) ReleasePartyResource

func (*UnimplementedFurnaceServer) SyncVtable

func (*UnimplementedFurnaceServer) UpdateDataSource

func (*UnimplementedFurnaceServer) UpdatePartyResourceStatus

func (*UnimplementedFurnaceServer) UpdatePirClientService

func (*UnimplementedFurnaceServer) UpdatePirServerService

func (*UnimplementedFurnaceServer) UpdateServerData

func (*UnimplementedFurnaceServer) UpdateVtable

func (*UnimplementedFurnaceServer) WalkDir

Jump to

Keyboard shortcuts

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