Help us shape the future of Go! Take the 2026 Go Developer Survey

admin

package
v0.1.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 29, 2026 License: MIT Imports: 48 Imported by: 0

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 (
	// MqttMessageRetentionTaskName 是 MQTT 消息保留清理任务的稳定调用目标。
	MqttMessageRetentionTaskName = "system.admin.MqttMessageRetention"
)
View Source 
const (
	// TableArchiveTaskName 是表归档任务的稳定调用目标。
	TableArchiveTaskName = "system.admin.BaseTableArchive"
)
View Source 
const (
	// TableBackupTaskName 是数据库表备份任务的稳定调用目标。
	TableBackupTaskName = "system.admin.BaseTableBackup"
)
View Source 
const WorkflowScriptRetryTaskName = "system.admin.WorkflowScriptRetry"

WorkflowScriptRetryTaskName 是工作流脚本恢复任务的稳定调用目标。

View Source 
const (
	// WorkflowTimeoutTaskName 是工作流超时催办任务的稳定调用目标。
	WorkflowTimeoutTaskName = "system.admin.WorkflowTimeout"
)

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) Exec added in v0.0.29 

func (t *BaseI18nTask) Exec(ctx context.Context, _ map[string]string) ([]string, error)

Exec 扫描所有资源并补齐缺失的机器译文。

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) Exec added in v0.0.32 

func (t *BaseLogFallbackTask) Exec(ctx context.Context, _ map[string]string) ([]string, error)

Exec 扫描日志入库回退文件并重新写入待处理事件。

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 创建消息投递恢复任务。

func (*MessageDispatchTask) Exec added in v0.0.30 

func (t *MessageDispatchTask) Exec(ctx context.Context, _ map[string]string) ([]string, error)

Exec 扫描并重新入队需要继续处理的消息投递任务。

type MqttMessageRetentionTask added in v0.0.96 

type MqttMessageRetentionTask struct {
	// contains filtered or unexported fields
}

MqttMessageRetentionTask 清理超过默认保留周期的 MQTT 消息记录。

func NewMqttMessageRetentionTask added in v0.0.96 

func NewMqttMessageRetentionTask(mqttMessageRepository *data.MqttMessageRepository) *MqttMessageRetentionTask

NewMqttMessageRetentionTask 创建 MQTT 消息保留清理任务。

func (*MqttMessageRetentionTask) Exec added in v0.0.96 

func (t *MqttMessageRetentionTask) Exec(ctx context.Context, _ map[string]string) ([]string, error)

Exec 批量删除超过 30 天的 MQTT 消息记录。

func (*MqttMessageRetentionTask) Task added in v0.0.96 

func (t *MqttMessageRetentionTask) Task() cron.Task

Task 返回交由 base_job 调度的任务定义。

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) Exec added in v0.0.32 

func (t *TableArchiveTask) Exec(ctx context.Context, _ map[string]string) ([]string, error)

Exec 执行所有启用的表归档配置。

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) Exec added in v0.0.32 

func (t *TableBackupTask) Exec(ctx context.Context, _ map[string]string) ([]string, error)

Exec 执行所有启用的数据库备份配置。

func (*TableBackupTask) Task added in v0.0.32 

func (t *TableBackupTask) Task() cron.Task

Task 返回交由 base_job 调度的任务定义。

type WorkflowScriptRetryTask added in v0.1.0 

type WorkflowScriptRetryTask struct {
	// contains filtered or unexported fields
}

WorkflowScriptRetryTask 恢复待执行、失败退避到期和租约过期的工作流脚本。

func NewWorkflowScriptRetryTask added in v0.1.0 

func NewWorkflowScriptRetryTask(instanceCase *biz.WorkflowInstanceCase) *WorkflowScriptRetryTask

NewWorkflowScriptRetryTask 创建工作流脚本恢复任务。

func (*WorkflowScriptRetryTask) Exec added in v0.1.0 

func (t *WorkflowScriptRetryTask) Exec(ctx context.Context, _ map[string]string) ([]string, error)

Exec 执行一次工作流脚本恢复扫描。

type WorkflowTimeoutTask added in v0.1.0 

type WorkflowTimeoutTask struct {
	// contains filtered or unexported fields
}

WorkflowTimeoutTask 扫描超时未处理的审批待办，催办提醒办理人并升级提醒申请人。

func NewWorkflowTimeoutTask added in v0.1.0 

func NewWorkflowTimeoutTask(instanceCase *biz.WorkflowInstanceCase) *WorkflowTimeoutTask

NewWorkflowTimeoutTask 创建工作流超时催办任务。

func (*WorkflowTimeoutTask) Exec added in v0.1.0 

func (t *WorkflowTimeoutTask) Exec(ctx context.Context, _ map[string]string) ([]string, error)

Exec 执行一次工作流超时催办扫描。

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.