repository

type TaskRepository interface {
	CreateTask(ctx context.Context, req domain.Task) (int64, error)
	FindByProcessInstId(ctx context.Context, processInstId int, nodeId string) (domain.Task, error)
	FindOrCreate(ctx context.Context, req domain.Task) (domain.Task, error)
	FindById(ctx context.Context, id int64) (domain.Task, error)
	UpdateTask(ctx context.Context, req domain.Task) (int64, error)
	UpdateTaskStatus(ctx context.Context, req domain.TaskResult) (int64, error)
	UpdateVariables(ctx context.Context, id int64, variables []domain.Variables) (int64, error)
	ListTask(ctx context.Context, offset, limit int64) ([]domain.Task, error)
	ListTaskByStatus(ctx context.Context, offset, limit int64, status uint8) ([]domain.Task, error)
	Total(ctx context.Context, status uint8) (int64, error)
	UpdateArgs(ctx context.Context, id int64, args map[string]interface{}) (int64, error)
	ListSuccessTasksByCtime(ctx context.Context, offset, limit int64, ctime int64) ([]domain.Task, error)
	TotalByCtime(ctx context.Context, ctime int64) (int64, error)
	FindTaskResult(ctx context.Context, instanceId int, nodeId string) (domain.Task, error)
	ListTaskByInstanceId(ctx context.Context, offset, limit int64, instanceId int) ([]domain.Task, error)
	TotalByInstanceId(ctx context.Context, instanceId int) (int64, error)
}