Documentation
¶
Index ¶
Constants ¶
View Source
const (
// BaseI18nTaskName 是统一机器翻译任务的稳定调用目标。
BaseI18nTaskName = "system.admin.BaseI18n"
)
View Source
const (
// BaseLogFallbackTaskName 是日志入库回退任务的稳定调用目标。
BaseLogFallbackTaskName = "system.admin.BaseLogFallback"
)
View Source
const (
// MessageDispatchTaskName 是消息投递恢复任务的稳定调用目标。
MessageDispatchTaskName = "system.admin.BaseMessageDispatch"
)
View Source
const (
// TableArchiveTaskName 是表归档任务的稳定调用目标。
TableArchiveTaskName = "system.admin.BaseTableArchive"
)
View Source
const (
// TableBackupTaskName 是数据库表备份任务的稳定调用目标。
TableBackupTaskName = "system.admin.BaseTableBackup"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseI18nTask ¶ added in v0.0.29
type BaseI18nTask struct {
// contains filtered or unexported fields
}
BaseI18nTask 执行菜单、字典、字典项、系统配置和定时任务的机器翻译任务。
func NewBaseI18nTask ¶ added in v0.0.29
func NewBaseI18nTask( i18nCase *biz.BaseI18nCase, menuRepo *data.BaseMenuRepository, dictRepo *data.BaseDictRepository, dictItemRepo *data.BaseDictItemRepository, configRepo *data.BaseConfigRepository, jobRepo *data.BaseJobRepository, ) *BaseI18nTask
NewBaseI18nTask 创建统一机器翻译任务执行器。
func (*BaseI18nTask) Task ¶ added in v0.0.29
func (t *BaseI18nTask) Task() cronTransport.Task
Task 返回交由 base_job 统一调度的任务定义。
type BaseLogFallbackTask ¶ added in v0.0.32
type BaseLogFallbackTask struct {
// contains filtered or unexported fields
}
BaseLogFallbackTask 将日志入库回退文件中的事件重新写入对应日志表。
func NewBaseLogFallbackTask ¶ added in v0.0.32
func NewBaseLogFallbackTask( baseCase *biz.BaseCase, loginRepo *data.BaseLoginLogRepository, operationRepo *data.BaseOperationLogRepository, dataAccessRepo *data.BaseDataAccessLogRepository, permissionRepo *data.BasePermissionLogRepository, ) *BaseLogFallbackTask
NewBaseLogFallbackTask 创建日志入库回退任务。
func (*BaseLogFallbackTask) Task ¶ added in v0.0.32
func (t *BaseLogFallbackTask) Task() cron.Task
Task 返回交由 base_job 调度的任务定义。
type MessageDispatchTask ¶ added in v0.0.30
type MessageDispatchTask struct {
// contains filtered or unexported fields
}
MessageDispatchTask 恢复到期定时消息和遗漏的 Redis Streams 投递任务。
func NewMessageDispatchTask ¶ added in v0.0.30
func NewMessageDispatchTask(baseMessageCase *biz.BaseMessageCase) *MessageDispatchTask
NewMessageDispatchTask 创建消息投递恢复任务。
type TableArchiveTask ¶ added in v0.0.32
type TableArchiveTask struct {
// contains filtered or unexported fields
}
TableArchiveTask 按归档配置将当前数据源中的历史表数据保存到内部归档表或 OSS。
func NewTableArchiveTask ¶ added in v0.0.32
func NewTableArchiveTask(baseCase *coreBiz.BaseCase, archiveRepo *data.BaseTableArchiveRepository, recordRepo *data.BaseTableArchiveRecordRepository) *TableArchiveTask
NewTableArchiveTask 创建表归档任务。
func (*TableArchiveTask) Task ¶ added in v0.0.32
func (t *TableArchiveTask) Task() cron.Task
Task 返回交由 base_job 调度的任务定义。
type TableBackupTask ¶ added in v0.0.32
type TableBackupTask struct {
// contains filtered or unexported fields
}
TableBackupTask 按备份配置对命名数据源执行加密全量备份并上传 OSS。
func NewTableBackupTask ¶ added in v0.0.32
func NewTableBackupTask(baseCase *biz.BaseCase, backupRepo *data.BaseTableBackupRepository, recordRepo *data.BaseTableBackupRecordRepository) *TableBackupTask
NewTableBackupTask 创建数据库表备份任务。
func (*TableBackupTask) Task ¶ added in v0.0.32
func (t *TableBackupTask) Task() cron.Task
Task 返回交由 base_job 调度的任务定义。
Source Files
Click to show internal directories.
Click to hide internal directories.