biz

Documentation

Index

• type ExecTaskReply
• type ExecTaskReplyFunc
• type Task
• type TaskFactory
• type TaskUseCase
  • func NewTaskUseCase(config *conf.Config, factory TaskFactory) *TaskUseCase
  • func (uc *TaskUseCase) CancelExecTask(uuid string)
  • func (uc *TaskUseCase) ExecTask(ctx kratosx.Context, task *Task, fn ExecTaskReplyFunc) error

Types

type ExecTaskReply

type ExecTaskReply struct {
	Type    string `json:"type"`
	Content string `json:"content"`
	Time    uint32 `json:"time"`
}

type ExecTaskReplyFunc

type ExecTaskReplyFunc func(*ExecTaskReply) error

type Task

type Task struct {
	Id            uint32
	Uuid          string
	Type          string
	Value         string
	ExpectCode    uint32
	RetryCount    uint32
	RetryWaitTime uint32
	MaxExecTime   uint32
}

type TaskFactory

type TaskFactory interface {
	ExecTask(ctx kratosx.Context, task *Task, fn ExecTaskReplyFunc) error
	CancelExecTask(uuid string)
}

type TaskUseCase

type TaskUseCase struct {
	// contains filtered or unexported fields
}

func NewTaskUseCase

func NewTaskUseCase(config *conf.Config, factory TaskFactory) *TaskUseCase

func (*TaskUseCase) CancelExecTask

func (uc *TaskUseCase) CancelExecTask(uuid string)

func (*TaskUseCase) ExecTask

func (uc *TaskUseCase) ExecTask(ctx kratosx.Context, task *Task, fn ExecTaskReplyFunc) error