service

Documentation

Index

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

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 ExecTaskRequest

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

type Task

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

func NewTask

func NewTask(config *conf.Config, factory TaskFactory) *Task

func (*Task) CancelExecTask

func (uc *Task) CancelExecTask(uuid string)

func (*Task) ExecTask

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

type TaskFactory

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