platformpb

package
v0.0.0-...-568411c Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_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 {
	ListVtables(ctx context.Context, in *vtable.ListVtablesRequest, opts ...grpc.CallOption) (*vtable.ListVtablesResponse, error)
	CreateOrUpdateCronJob(ctx context.Context, in *cron.CreateOrUpdateCronJobRequest, opts ...grpc.CallOption) (*cron.CreateOrUpdateCronJobResponse, error)
	ListCronJobs(ctx context.Context, in *cron.ListCronJobsRequest, opts ...grpc.CallOption) (*cron.ListCronJobsResponse, error)
	DeleteCronJob(ctx context.Context, in *cron.DeleteCronJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetFurnaceStatus(ctx context.Context, in *furnacestatus.GetStatusRequest, opts ...grpc.CallOption) (*furnacestatus.GetStatusResponse, error)
	CreateVtables(ctx context.Context, in *vtable.CreateVtablesRequest, opts ...grpc.CallOption) (*vtable.CreateVtablesResponse, error)
	// 用于前端查询的grpcgw service
	Factor3SVerifyQuery(ctx context.Context, in *online_service.Factor3SVerifyRequest, opts ...grpc.CallOption) (*online_service.Factor3SVerifyResponse, error)
	// Deprecated: Do not use.
	// 用于前端部署三要素server的grpcgw service -- 不再使用，统一使用take action
	Factor3SVerifyMysqlDeploy(ctx context.Context, in *service.GrpcGWDeployRequest, opts ...grpc.CallOption) (*service.GrpcGWDeployResponse, error)
	// 获取服务信息
	//
	// 根据在线服务ID，从中心节点返回服务的具体信息。
	GetService(ctx context.Context, in *online_service1.GetServiceRequest, opts ...grpc.CallOption) (*online_service1.GetServiceResponse, error)
	// 创建在线服务
	//
	// 根据请求中的在线服务具体信息，向对应的中心节点创建在线服务。
	CreateService(ctx context.Context, in *online_service1.CreateServiceRequest, opts ...grpc.CallOption) (*online_service1.CreateServiceResponse, error)
	// 更新在线服务
	//
	// 在对应的中心节点更新在线服务。
	UpdateService(ctx context.Context, in *online_service1.UpdateServiceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// 获取服务列表
	//
	// 返回符合条件的在线服务列表。
	GetServices(ctx context.Context, in *online_service1.GetServicesRequest, opts ...grpc.CallOption) (*online_service1.GetServicesResponse, error)
	// 删除在线服务
	//
	// 在对应的中心节点删除在线服务。
	DeleteService(ctx context.Context, in *online_service1.DeleteServiceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// 操作在线服务
	//
	// 对在线服务执行相应的操作动作。
	ServiceTakeAction(ctx context.Context, in *online_service1.ServiceTakeActionRequest, opts ...grpc.CallOption) (*online_service1.ServiceTakeActionResponse, error)
	// 获取在线服务使用量
	//
	// 返回符合过滤条件的在线服务的使用量。
	GetServiceUsages(ctx context.Context, in *online_service1.GetServiceUsageRequest, opts ...grpc.CallOption) (*online_service1.GetServiceUsageResponse, error)
	// 模型服务在线预测
	//
	// 根据服务ID和相应的预测请求，返回模型预测结果。
	OnlinePredict(ctx context.Context, in *online_service1.PredictRequest, opts ...grpc.CallOption) (*online_service1.PredictResponse, error)
	// 获取Features配置
	//
	// 获取各个Features的配置情况
	GetFeatures(ctx context.Context, in *feature.GetFeaturesRequest, opts ...grpc.CallOption) (*feature.GetFeaturesResponse, error)
	// 获取不需要login的Features的配置情况
	GetBeforeLoginFeatures(ctx context.Context, in *feature.GetFeaturesRequest, opts ...grpc.CallOption) (*feature.GetBeforeLoginFeaturesResponse, error)
	// 获取任务列表
	//
	// 根据过滤条件，返回符合条件的任务列表。
	GetTasks(ctx context.Context, in *task.GetTasksRequest, opts ...grpc.CallOption) (*task1.GetTasksResponse, error)
	// 运行任务
	//
	// 请求Tusita对执行某个任务草稿，在离线任务被发布前调用。
	ActionOnTask(ctx context.Context, in *task1.ActionOnTaskRequest, opts ...grpc.CallOption) (*task.ActionOnTaskResponse, error)
	// 简易运行任务
	//
	// 与`POST /api/task/draft/run`的区别在于
	// 1. action限制: 仅支持edit和run
	// 2. 我方party的数据表: 支持根据filePath参数创建vtable后回填对应算子的input.vtableID
	RunTaskDraftEasier(ctx context.Context, in *task1.ActionOnTaskRequest, opts ...grpc.CallOption) (*task.ActionOnTaskResponse, error)
	// 获取在线服务配置
	//
	// 给定模型id和版本，从中获得在线服务的配置。
	GetOnlineBlockFromModel(ctx context.Context, in *online_service1.GetOnlineBlockFromModelRequest, opts ...grpc.CallOption) (*online_service1.GetOnlineBlockFromModelResponse, error)
	// 回应申请
	//
	// 向中心节点发送对某个申请的回应操作。
	ApplicationTakeAction(ctx context.Context, in *apl.AplTakeActionRequest, opts ...grpc.CallOption) (*emptypb.Empty, 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 {
	ListVtables(context.Context, *vtable.ListVtablesRequest) (*vtable.ListVtablesResponse, error)
	CreateOrUpdateCronJob(context.Context, *cron.CreateOrUpdateCronJobRequest) (*cron.CreateOrUpdateCronJobResponse, error)
	ListCronJobs(context.Context, *cron.ListCronJobsRequest) (*cron.ListCronJobsResponse, error)
	DeleteCronJob(context.Context, *cron.DeleteCronJobRequest) (*emptypb.Empty, error)
	GetFurnaceStatus(context.Context, *furnacestatus.GetStatusRequest) (*furnacestatus.GetStatusResponse, error)
	CreateVtables(context.Context, *vtable.CreateVtablesRequest) (*vtable.CreateVtablesResponse, error)
	// 用于前端查询的grpcgw service
	Factor3SVerifyQuery(context.Context, *online_service.Factor3SVerifyRequest) (*online_service.Factor3SVerifyResponse, error)
	// Deprecated: Do not use.
	// 用于前端部署三要素server的grpcgw service -- 不再使用，统一使用take action
	Factor3SVerifyMysqlDeploy(context.Context, *service.GrpcGWDeployRequest) (*service.GrpcGWDeployResponse, error)
	// 获取服务信息
	//
	// 根据在线服务ID，从中心节点返回服务的具体信息。
	GetService(context.Context, *online_service1.GetServiceRequest) (*online_service1.GetServiceResponse, error)
	// 创建在线服务
	//
	// 根据请求中的在线服务具体信息，向对应的中心节点创建在线服务。
	CreateService(context.Context, *online_service1.CreateServiceRequest) (*online_service1.CreateServiceResponse, error)
	// 更新在线服务
	//
	// 在对应的中心节点更新在线服务。
	UpdateService(context.Context, *online_service1.UpdateServiceRequest) (*emptypb.Empty, error)
	// 获取服务列表
	//
	// 返回符合条件的在线服务列表。
	GetServices(context.Context, *online_service1.GetServicesRequest) (*online_service1.GetServicesResponse, error)
	// 删除在线服务
	//
	// 在对应的中心节点删除在线服务。
	DeleteService(context.Context, *online_service1.DeleteServiceRequest) (*emptypb.Empty, error)
	// 操作在线服务
	//
	// 对在线服务执行相应的操作动作。
	ServiceTakeAction(context.Context, *online_service1.ServiceTakeActionRequest) (*online_service1.ServiceTakeActionResponse, error)
	// 获取在线服务使用量
	//
	// 返回符合过滤条件的在线服务的使用量。
	GetServiceUsages(context.Context, *online_service1.GetServiceUsageRequest) (*online_service1.GetServiceUsageResponse, error)
	// 模型服务在线预测
	//
	// 根据服务ID和相应的预测请求，返回模型预测结果。
	OnlinePredict(context.Context, *online_service1.PredictRequest) (*online_service1.PredictResponse, error)
	// 获取Features配置
	//
	// 获取各个Features的配置情况
	GetFeatures(context.Context, *feature.GetFeaturesRequest) (*feature.GetFeaturesResponse, error)
	// 获取不需要login的Features的配置情况
	GetBeforeLoginFeatures(context.Context, *feature.GetFeaturesRequest) (*feature.GetBeforeLoginFeaturesResponse, error)
	// 获取任务列表
	//
	// 根据过滤条件，返回符合条件的任务列表。
	GetTasks(context.Context, *task.GetTasksRequest) (*task1.GetTasksResponse, error)
	// 运行任务
	//
	// 请求Tusita对执行某个任务草稿，在离线任务被发布前调用。
	ActionOnTask(context.Context, *task1.ActionOnTaskRequest) (*task.ActionOnTaskResponse, error)
	// 简易运行任务
	//
	// 与`POST /api/task/draft/run`的区别在于
	// 1. action限制: 仅支持edit和run
	// 2. 我方party的数据表: 支持根据filePath参数创建vtable后回填对应算子的input.vtableID
	RunTaskDraftEasier(context.Context, *task1.ActionOnTaskRequest) (*task.ActionOnTaskResponse, error)
	// 获取在线服务配置
	//
	// 给定模型id和版本，从中获得在线服务的配置。
	GetOnlineBlockFromModel(context.Context, *online_service1.GetOnlineBlockFromModelRequest) (*online_service1.GetOnlineBlockFromModelResponse, error)
	// 回应申请
	//
	// 向中心节点发送对某个申请的回应操作。
	ApplicationTakeAction(context.Context, *apl.AplTakeActionRequest) (*emptypb.Empty, 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 

func (*UnimplementedFurnaceServer) ActionOnTask(context.Context, *task1.ActionOnTaskRequest) (*task.ActionOnTaskResponse, error)

func (*UnimplementedFurnaceServer) ApplicationTakeAction 

func (*UnimplementedFurnaceServer) ApplicationTakeAction(context.Context, *apl.AplTakeActionRequest) (*emptypb.Empty, error)

func (*UnimplementedFurnaceServer) CreateOrUpdateCronJob 

func (*UnimplementedFurnaceServer) CreateOrUpdateCronJob(context.Context, *cron.CreateOrUpdateCronJobRequest) (*cron.CreateOrUpdateCronJobResponse, error)

func (*UnimplementedFurnaceServer) CreateService 

func (*UnimplementedFurnaceServer) CreateService(context.Context, *online_service1.CreateServiceRequest) (*online_service1.CreateServiceResponse, error)

func (*UnimplementedFurnaceServer) CreateVtables 

func (*UnimplementedFurnaceServer) CreateVtables(context.Context, *vtable.CreateVtablesRequest) (*vtable.CreateVtablesResponse, error)

func (*UnimplementedFurnaceServer) DeleteCronJob 

func (*UnimplementedFurnaceServer) DeleteCronJob(context.Context, *cron.DeleteCronJobRequest) (*emptypb.Empty, error)

func (*UnimplementedFurnaceServer) DeleteService 

func (*UnimplementedFurnaceServer) DeleteService(context.Context, *online_service1.DeleteServiceRequest) (*emptypb.Empty, error)

func (*UnimplementedFurnaceServer) Factor3SVerifyMysqlDeploy 

func (*UnimplementedFurnaceServer) Factor3SVerifyMysqlDeploy(context.Context, *service.GrpcGWDeployRequest) (*service.GrpcGWDeployResponse, error)

func (*UnimplementedFurnaceServer) Factor3SVerifyQuery 

func (*UnimplementedFurnaceServer) Factor3SVerifyQuery(context.Context, *online_service.Factor3SVerifyRequest) (*online_service.Factor3SVerifyResponse, error)

func (*UnimplementedFurnaceServer) GetBeforeLoginFeatures 

func (*UnimplementedFurnaceServer) GetBeforeLoginFeatures(context.Context, *feature.GetFeaturesRequest) (*feature.GetBeforeLoginFeaturesResponse, error)

func (*UnimplementedFurnaceServer) GetFeatures 

func (*UnimplementedFurnaceServer) GetFeatures(context.Context, *feature.GetFeaturesRequest) (*feature.GetFeaturesResponse, error)

func (*UnimplementedFurnaceServer) GetFurnaceStatus 

func (*UnimplementedFurnaceServer) GetFurnaceStatus(context.Context, *furnacestatus.GetStatusRequest) (*furnacestatus.GetStatusResponse, error)

func (*UnimplementedFurnaceServer) GetOnlineBlockFromModel 

func (*UnimplementedFurnaceServer) GetOnlineBlockFromModel(context.Context, *online_service1.GetOnlineBlockFromModelRequest) (*online_service1.GetOnlineBlockFromModelResponse, error)

func (*UnimplementedFurnaceServer) GetService 

func (*UnimplementedFurnaceServer) GetService(context.Context, *online_service1.GetServiceRequest) (*online_service1.GetServiceResponse, error)

func (*UnimplementedFurnaceServer) GetServiceUsages 

func (*UnimplementedFurnaceServer) GetServiceUsages(context.Context, *online_service1.GetServiceUsageRequest) (*online_service1.GetServiceUsageResponse, error)

func (*UnimplementedFurnaceServer) GetServices 

func (*UnimplementedFurnaceServer) GetServices(context.Context, *online_service1.GetServicesRequest) (*online_service1.GetServicesResponse, error)

func (*UnimplementedFurnaceServer) GetTasks 

func (*UnimplementedFurnaceServer) GetTasks(context.Context, *task.GetTasksRequest) (*task1.GetTasksResponse, error)

func (*UnimplementedFurnaceServer) ListCronJobs 

func (*UnimplementedFurnaceServer) ListCronJobs(context.Context, *cron.ListCronJobsRequest) (*cron.ListCronJobsResponse, error)

func (*UnimplementedFurnaceServer) ListVtables 

func (*UnimplementedFurnaceServer) ListVtables(context.Context, *vtable.ListVtablesRequest) (*vtable.ListVtablesResponse, error)

func (*UnimplementedFurnaceServer) OnlinePredict 

func (*UnimplementedFurnaceServer) OnlinePredict(context.Context, *online_service1.PredictRequest) (*online_service1.PredictResponse, error)

func (*UnimplementedFurnaceServer) RunTaskDraftEasier 

func (*UnimplementedFurnaceServer) RunTaskDraftEasier(context.Context, *task1.ActionOnTaskRequest) (*task.ActionOnTaskResponse, error)

func (*UnimplementedFurnaceServer) ServiceTakeAction 

func (*UnimplementedFurnaceServer) ServiceTakeAction(context.Context, *online_service1.ServiceTakeActionRequest) (*online_service1.ServiceTakeActionResponse, error)

func (*UnimplementedFurnaceServer) UpdateService 

func (*UnimplementedFurnaceServer) UpdateService(context.Context, *online_service1.UpdateServiceRequest) (*emptypb.Empty, error)

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.