aiforge/modules/labelmsg/redismsgsender.go

package labelmsg

import (
	"code.gitea.io/gitea/modules/log"
)

// 方法名
const (
	LabelTaskName           = "LabelRedisQueue"
	LabelDatasetDeleteQueue = "LabelDatasetDeleteQueue"
	DecompressOBSTaskName   = "LabelDecompressOBSQueue"
)

func SendAddAttachToLabelSys(attach string) error {

	redisclient := Get()

	//记得销毁本次链连接
	defer redisclient.Close()

	_, err := redisclient.Do("Publish", LabelTaskName, attach)
	if err != nil {
		log.Critical("redis Publish failed.")
	}

	log.Info("LabelRedisQueue(%s) success", attach)

	return nil
}

func SendDeleteAttachToLabelSys(attach string) error {

	redisclient := Get()

	//记得销毁本次链连接
	defer redisclient.Close()

	_, err := redisclient.Do("Publish", LabelDatasetDeleteQueue, attach)
	if err != nil {
		log.Critical("redis Publish failed.")
	}

	log.Info("LabelDatasetDeleteQueue(%s) success", attach)

	return nil
}

func SendDecompressAttachToLabelOBS(attach string) error {

	redisclient := Get()
	//记得销毁本次链连接
	defer redisclient.Close()

	_, err := redisclient.Do("Publish", DecompressOBSTaskName, attach)
	if err != nil {
		log.Critical("redis Publish failed.")
	}

	log.Info("LabelDecompressOBSQueue(%s) success", attach)
	return nil
}