Documentation ¶
Index ¶
- type ProcessTask
- func (t ProcessTask) Process(ctx context.Context, taskInfo domain.TaskInfo) error
- func (t ProcessTask) Queue(ctx context.Context, task *domain.TaskInfo) error
- func (t ProcessTask) ScriptExec(ctx context.Context, task *domain.TaskInfo) error
- func (t ProcessTask) SqlExec(ctx context.Context, task *domain.TaskInfo) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProcessTask ¶
type ProcessTask struct { logx.Logger TaskSend sqlFunc.TaskSendFunc // contains filtered or unexported fields }
func NewProcessTask ¶
func NewProcessTask(ctx context.Context, svcCtx *svc.ServiceContext, TaskSend sqlFunc.TaskSendFunc) *ProcessTask
func (ProcessTask) ScriptExec ¶
Click to show internal directories.
Click to hide internal directories.