service

package

v0.0.0-...-14e102d Latest Latest Go to latest Published: Oct 1, 2025 License: GPL-3.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Service struct {
	pb.UnimplementedTaskServiceServer
	// contains filtered or unexported fields
}

func New(app *app.App) *Service

func (srv *Service) CancelTask(ctx context.Context, in *pb.CancelTaskRequest) (*pb.CancelTaskResponse, error)

func (srv *Service) CreatePersistTask(ctx context.Context, req *pb.CreatePersistTaskRequest) (*pb.CreatePersistTaskResponse, error)

func (srv *Service) DeletePersistTask(ctx context.Context, req *pb.DeletePersistTaskRequest) (*pb.DeletePersistTaskResponse, error)

func (srv *Service) ExecutePersistTask(ctx context.Context, req *pb.ExecutePersistTaskRequest) (*pb.ExecutePersistTaskResponse, error)

func (srv *Service) ListPersistTasks(ctx context.Context, req *pb.ListPersistTasksRequest) (*pb.ListPersistTasksResponse, error)

func (srv *Service) ListTasks(ctx context.Context, in *pb.ListTasksRequest) (*pb.ListTasksResponse, error)

TODO: 持久化任务信息

func (srv *Service) Register(grpc *grpc.Server)

func (srv *Service) RegisterGateway(ctx context.Context, mux *runtime.ServeMux, e *echo.Echo)

func (srv *Service) RemoveTask(ctx context.Context, in *pb.RemoveTaskRequest) (*pb.RemoveTaskResponse, error)

func (srv *Service) RetryTask(ctx context.Context, in *pb.RetryTaskRequest) (*pb.RetryTaskResponse, error)

func (srv *Service) TestPersistTask(ctx context.Context, req *pb.TestPersistTaskRequest) (*pb.TestPersistTaskResponse, error)

func (srv *Service) UpdatePersistTask(ctx context.Context, req *pb.UpdatePersistTaskRequest) (*pb.UpdatePersistTaskResponse, error)