job

Documentation

Index

• Variables
• func GetSyncIPFSRecords()
• func StartAsynqServer()
• func SyncShedulers(ctx context.Context, sCli api.Scheduler, cid string, size int64, owner string, ...) ([]string, error)
• func SyncShedulersAsset()
• type AssetUploadNotifyReq

Variables

var (
	DefaultAreaId            = "Asia-China-Guangdong-Shenzhen"
	SchedulerConfigKeyPrefix = "TITAN::SCHEDULERCFG"
)

var MonitorHandler *asynqmon.HTTPHandler

Functions

func GetSyncIPFSRecords

func GetSyncIPFSRecords()

GetSyncIPFSRecords 获取ipfs上传完成的信息

func StartAsynqServer

func StartAsynqServer()

StartAsynqServer 启动 asynq 服务端

func SyncShedulers

func SyncShedulers(ctx context.Context, sCli api.Scheduler, cid string, size int64, owner string, areaIds []string) ([]string, error)

SyncShedulers 同步调度器数据

func SyncShedulersAsset

func SyncShedulersAsset()

SyncShedulersAsset 同步调度器文件

Types

type AssetUploadNotifyReq

type AssetUploadNotifyReq struct {
	ExtraID  string // 外部文件ID
	TenantID string // 租户ID
	UserID   string // 上传者ID

	AssetName      string
	AssetCID       string
	AssetType      string
	AssetSize      int64
	GroupID        int64
	CreatedTime    time.Time
	AssetDirectUrl string
}