Files
yatm/apis/job_next.go
2023-10-12 22:54:07 +08:00

16 lines
322 B
Go

package apis
import (
"context"
"github.com/samuelncui/yatm/entity"
)
func (api *API) JobDispatch(ctx context.Context, req *entity.JobDispatchRequest) (*entity.JobDispatchReply, error) {
if err := api.exe.Dispatch(ctx, req.Id, req.Param); err != nil {
return nil, err
}
return &entity.JobDispatchReply{}, nil
}