FranklinWH-Toolbox/service/task/plugin/inspector.go

package task_pg

import (
	"github.com/hibiken/asynq"
)

type InspectorManager struct {
	redisOpt  asynq.RedisClientOpt
	inspector *asynq.Inspector
}

func NewInspectorManager(redisOpt asynq.RedisClientOpt) *InspectorManager {
	return &InspectorManager{
		redisOpt:  redisOpt,
		inspector: asynq.NewInspector(redisOpt),
	}
}

// GetInspector 获取底层 Asynq Inspector
func (im *InspectorManager) GetInspector() *asynq.Inspector {
	return im.inspector
}