example_basics

var DB *gorm.DB

var Messages_en_US = &Messages{
	Admin:   "Admin",
	Welcome: "Welcome",
}

var Messages_ja_JP = &Messages{
	Admin:   "管理システム",
	Welcome: "ようこそ",
}

var Messages_ja_JP_ModelsI18nModuleKey = &Messages_ModelsI18nModuleKey{
	Homes:             "ホーム",
	Videos:            "ビデオ",
	VideosName:        "ビデオの名前",
	VideosDescription: "ビデオの説明",
}

var Messages_zh_CN = &Messages{
	Admin:   "管理系统",
	Welcome: "欢迎",
}

var Messages_zh_CN_ModelsI18nModuleKey = &Messages_ModelsI18nModuleKey{
	Homes:             "主页",
	Videos:            "视频",
	VideosName:        "视频名称",
	VideosDescription: "视频描述",
}

var Que = &mock.QueueMock{
	AddFunc: func(ctx context.Context, job worker.QueJobInterface) error {
		jobInfo, err := job.GetJobInfo()

		if err != nil {
			return err
		}
		if scheduler, ok := jobInfo.Argument.(worker.Scheduler); ok && scheduler.GetScheduleTime() != nil {
			job.SetStatus(worker.JobStatusScheduled)
			go func() {
				time.Sleep(scheduler.GetScheduleTime().Sub(time.Now()))
				ConsumeQueItem(job)
			}()
		} else {
			go func() {
				ConsumeQueItem(job)
			}()
		}
		return nil
	},
	KillFunc: func(ctx context.Context, job worker.QueJobInterface) error {
		return job.SetStatus(worker.JobStatusKilled)
	},
	ListenFunc: func(jobDefs []*worker.QorJobDefinition, getJob func(qorJobID uint) (worker.QueJobInterface, error)) error {
		return nil
	},
	RemoveFunc: func(ctx context.Context, job worker.QueJobInterface) error {
		return job.SetStatus(worker.JobStatusCancelled)
	},
}