repository

Documentation

Index

• type TaskRepository
  • func NewTaskRepository(dao dao.TaskDAO) TaskRepository

Types

type TaskRepository

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)
	ListTasksByCtime(ctx context.Context, offset, limit int64, ctime int64) ([]domain.Task, error)
	TotalByCtime(ctx context.Context, ctime int64) (int64, error)
}

func NewTaskRepository

func NewTaskRepository(dao dao.TaskDAO) TaskRepository