From 2a480c2135a1e48723262ba07d50a2e3369f6f50 Mon Sep 17 00:00:00 2001 From: guoyuqi Date: Wed, 28 Oct 2026 17:38:05 +0800 Subject: [PATCH] feat(container): add image update checks with scheduling and task logs --- .../api/v2/container_image_check_update.go | 43 ++ agent/app/dto/container.go | 17 +- .../app/model/container_image_check_update.go | 20 + agent/app/service/container.go | 23 ++ .../service/container_image_check_update.go | 379 ++++++++++++++++++ agent/app/service/container_update.go | 5 + agent/cron/cron.go | 6 +- .../cron/job/container_image_check_update.go | 24 ++ agent/i18n/lang/en.yaml | 11 + agent/i18n/lang/es-ES.yaml | 11 + agent/i18n/lang/fa.yaml | 11 + agent/i18n/lang/ja.yaml | 11 + agent/i18n/lang/ko.yaml | 11 + agent/i18n/lang/lo.yaml | 11 + agent/i18n/lang/ms.yaml | 11 + agent/i18n/lang/pt-BR.yaml | 11 + agent/i18n/lang/ru.yaml | 11 + agent/i18n/lang/tr.yaml | 11 + agent/i18n/lang/zh-Hant.yaml | 11 + agent/i18n/lang/zh.yaml | 11 + agent/init/migration/migrate.go | 1 + .../container_image_check_update.go | 17 + agent/router/ro_container.go | 3 + agent/utils/dockerhub/client.go | 266 ++++++++++++ frontend/src/api/interface/container.ts | 3 + frontend/src/api/modules/container.ts | 30 ++ .../table/TableOperationActions.vue | 13 +- frontend/src/components/table/shared.ts | 1 + frontend/src/lang/modules/en.ts | 8 + frontend/src/lang/modules/es-es.ts | 8 + frontend/src/lang/modules/fa.ts | 8 + frontend/src/lang/modules/ja.ts | 7 + frontend/src/lang/modules/ko.ts | 7 + frontend/src/lang/modules/lo.ts | 7 + frontend/src/lang/modules/ms.ts | 8 + frontend/src/lang/modules/pt-br.ts | 8 + frontend/src/lang/modules/ru.ts | 8 + frontend/src/lang/modules/tr.ts | 8 + frontend/src/lang/modules/zh-Hant.ts | 7 + frontend/src/lang/modules/zh.ts | 7 + .../src/views/container/container/index.vue | 143 ++++++- .../container/container/upgrade/index.vue | 5 +- 42 files changed, 1208 insertions(+), 14 deletions(-) create mode 100644 agent/app/api/v2/container_image_check_update.go create mode 100644 agent/app/model/container_image_check_update.go create mode 100644 agent/app/service/container_image_check_update.go create mode 100644 agent/cron/job/container_image_check_update.go create mode 100644 agent/init/migration/migrations/container_image_check_update.go create mode 100644 agent/utils/dockerhub/client.go diff --git a/agent/app/api/v2/container_image_check_update.go b/agent/app/api/v2/container_image_check_update.go new file mode 100644 index 000000000..7e5d4c14a --- /dev/null +++ b/agent/app/api/v2/container_image_check_update.go @@ -0,0 +1,43 @@ +package v2 + +import ( + "github.com/1Panel-dev/1Panel/agent/app/api/v2/helper" + "github.com/1Panel-dev/1Panel/agent/app/service" + "github.com/gin-gonic/gin" +) + +func (b *BaseApi) GetContainerImageCheckUpdateStatus(c *gin.Context) { + status, err := service.GetContainerImageCheckUpdateStatus() + if err != nil { + helper.InternalServer(c, err) + return + } + helper.SuccessWithData(c, status) +} +func (b *BaseApi) ContainerImageCheckUpdate(c *gin.Context) { + taskID, err := service.StartContainerImageCheckUpdate() + if err != nil { + helper.InternalServer(c, err) + return + } + status, err := service.GetContainerImageCheckUpdateStatus() + if err != nil { + helper.InternalServer(c, err) + return + } + status.TaskID = taskID + helper.SuccessWithData(c, status) +} +func (b *BaseApi) SetContainerImageCheckUpdateSchedule(c *gin.Context) { + var req struct { + Enabled *bool `json:"enabled" validate:"required"` + } + if err := helper.CheckBindAndValidate(&req, c); err != nil { + return + } + if err := service.SetContainerImageCheckUpdateSchedule(*req.Enabled); err != nil { + helper.InternalServer(c, err) + return + } + b.GetContainerImageCheckUpdateStatus(c) +} diff --git a/agent/app/dto/container.go b/agent/app/dto/container.go index e3d1502d4..cfb6d7bae 100644 --- a/agent/app/dto/container.go +++ b/agent/app/dto/container.go @@ -21,13 +21,16 @@ type InspectReq struct { } type ContainerInfo struct { - ContainerID string `json:"containerID"` - Name string `json:"name"` - ImageId string `json:"imageID"` - ImageName string `json:"imageName"` - CreateTime string `json:"createTime"` - State string `json:"state"` - RunTime string `json:"runTime"` + LatestVersion string `json:"latestVersion"` + TargetImage string `json:"targetImage"` + HasUpdate bool `json:"hasUpdate"` + ContainerID string `json:"containerID"` + Name string `json:"name"` + ImageId string `json:"imageID"` + ImageName string `json:"imageName"` + CreateTime string `json:"createTime"` + State string `json:"state"` + RunTime string `json:"runTime"` Network []string `json:"network"` Ports []string `json:"ports"` diff --git a/agent/app/model/container_image_check_update.go b/agent/app/model/container_image_check_update.go new file mode 100644 index 000000000..c7f715532 --- /dev/null +++ b/agent/app/model/container_image_check_update.go @@ -0,0 +1,20 @@ +package model + +import "time" + +// ContainerImageCheckUpdate is a cache tied to the exact image used by a container. +type ContainerImageCheckUpdate struct { + ContainerID string `gorm:"primaryKey" json:"containerID"` + ImageID string `json:"imageID"` + ImageName string `json:"imageName"` + LatestVersion string `json:"latestVersion"` + TargetImage string `json:"targetImage"` + TargetImageID string `json:"-"` + HasUpdate bool `gorm:"not null;default:false" json:"hasUpdate"` + CheckedAt time.Time `json:"checkedAt"` + CheckStatus string `json:"checkStatus"` + CheckError string `json:"checkError"` +} + +// TableName preserves the table created by the original migration. +func (ContainerImageCheckUpdate) TableName() string { return "container_image_updates" } diff --git a/agent/app/service/container.go b/agent/app/service/container.go index 0d823f411..642bb3405 100644 --- a/agent/app/service/container.go +++ b/agent/app/service/container.go @@ -140,6 +140,29 @@ func (u *ContainerService) Page(ctx context.Context, req dto.PageContainer) (int backData = records[start:end] } + // Batch-load persisted checks; never contact Docker Hub while rendering the list. + ids := make([]string, 0, len(backData)) + for _, row := range backData { + ids = append(ids, row.ContainerID) + } + if len(ids) > 0 { + var checks []model.ContainerImageCheckUpdate + if err := global.DB.Where("container_id IN ?", ids).Find(&checks).Error; err != nil { + return 0, nil, err + } + byID := make(map[string]model.ContainerImageCheckUpdate, len(checks)) + for _, check := range checks { + byID[check.ContainerID] = check + } + for i := range backData { + check, ok := byID[backData[i].ContainerID] + if ok && sameContainerImage(check.ImageID, backData[i].ImageId) && check.ImageName == backData[i].ImageName { + backData[i].LatestVersion = check.LatestVersion + backData[i].TargetImage = check.TargetImage + backData[i].HasUpdate = check.HasUpdate + } + } + } for i := 0; i < len(backData); i++ { install, _ := appInstallRepo.GetFirst(appInstallRepo.WithContainerName(backData[i].Name)) if install.ID > 0 { diff --git a/agent/app/service/container_image_check_update.go b/agent/app/service/container_image_check_update.go new file mode 100644 index 000000000..4d8c87d13 --- /dev/null +++ b/agent/app/service/container_image_check_update.go @@ -0,0 +1,379 @@ +package service + +import ( + "context" + "fmt" + "io" + "strings" + "sync" + "time" + + "github.com/1Panel-dev/1Panel/agent/app/model" + "github.com/1Panel-dev/1Panel/agent/app/task" + "github.com/1Panel-dev/1Panel/agent/global" + "github.com/1Panel-dev/1Panel/agent/i18n" + "github.com/1Panel-dev/1Panel/agent/utils/docker" + "github.com/1Panel-dev/1Panel/agent/utils/dockerhub" + "github.com/docker/cli/cli/config" + "github.com/docker/docker/api/types/container" + "github.com/docker/docker/api/types/image" + "github.com/docker/docker/client" + "github.com/docker/docker/errdefs" + "gorm.io/gorm" + "gorm.io/gorm/clause" +) + +const imageCheckUpdateSetting = "ContainerImageUpdateEnabled" + +type ImageCheckUpdateStatus struct { + TaskID string `json:"taskID"` + Enabled bool `json:"enabled"` + Running bool `json:"running"` + Checked int `json:"checked"` + Updates int `json:"updates"` + Failed int `json:"failed"` + Skipped int `json:"skipped"` + Error string `json:"error"` + FinishedAt int64 `json:"finishedAt"` +} + +var imageCheckUpdateState struct { + sync.Mutex + status ImageCheckUpdateStatus +} + +func GetContainerImageCheckUpdateStatus() (ImageCheckUpdateStatus, error) { + var setting model.Setting + if err := global.DB.Where("key = ?", imageCheckUpdateSetting).First(&setting).Error; err != nil { + return ImageCheckUpdateStatus{}, err + } + imageCheckUpdateState.Lock() + defer imageCheckUpdateState.Unlock() + status := imageCheckUpdateState.status + status.Enabled = setting.Value == "Enable" + return status, nil +} +func SetContainerImageCheckUpdateSchedule(enabled bool) error { + value := "Disable" + if enabled { + value = "Enable" + } + return global.DB.Model(&model.Setting{}).Where("key = ?", imageCheckUpdateSetting).Update("value", value).Error +} + +// StartContainerImageCheckUpdate coalesces manual and scheduled runs on this node. +func StartContainerImageCheckUpdate() (string, error) { + imageCheckUpdateState.Lock() + defer imageCheckUpdateState.Unlock() + if imageCheckUpdateState.status.Running { + return imageCheckUpdateState.status.TaskID, nil + } + taskItem, err := task.NewTask(i18n.GetMsgByKey("ContainerImageCheckUpdate"), task.TaskScan, task.TaskScopeImage, "", 0) + if err != nil { + return "", err + } + // Persist before returning the ID so the log drawer can immediately find it. + if err := global.TaskDB.Save(taskItem.Task).Error; err != nil { + _ = taskItem.Logger.Out.(io.Closer).Close() + taskItem.DeleteLogFile() + if cancel, ok := global.LoadTaskCancel(taskItem.TaskID); ok { + cancel() + } + global.RemoveTaskCancel(taskItem.TaskID) + return "", err + } + imageCheckUpdateState.status = ImageCheckUpdateStatus{Running: true, TaskID: taskItem.TaskID} + go func() { + result := ImageCheckUpdateStatus{TaskID: taskItem.TaskID} + defer func() { + result.FinishedAt = time.Now().UnixMilli() + imageCheckUpdateState.Lock() + imageCheckUpdateState.status = result + imageCheckUpdateState.Unlock() + }() + // The action owns its deadline so the task runner waits for cleanup and logs. + taskItem.AddSubTaskWithOps(i18n.GetMsgByKey("ContainerImageCheckUpdate"), func(t *task.Task) (err error) { + defer func() { + if recovered := recover(); recovered != nil { + err = fmt.Errorf("image update check failed: %v", recovered) + } + t.Log(i18n.GetMsgWithMap("ContainerImageCheckSummary", map[string]interface{}{ + "checked": result.Checked, "updates": result.Updates, "failed": result.Failed, "skipped": result.Skipped, + })) + }() + ctx, cancel := context.WithTimeout(t.TaskCtx, 30*time.Minute) + defer cancel() + if err = runContainerImageCheckUpdate(ctx, &result, t.Log); err != nil { + return err + } + if result.Failed > 0 { + return fmt.Errorf("%s", i18n.GetMsgWithMap("ContainerImageCheckFailures", map[string]interface{}{"count": result.Failed})) + } + return nil + }, nil, 0, 0) + if err := taskItem.Execute(); err != nil { + result.Error = err.Error() + global.LOG.Errorf("container image check: %s", err) + } + }() + return taskItem.TaskID, nil +} + +// These caches live only for one check. Remote results do not depend on a +// container's local image ID, which is compared separately for every baseline. +type imageCheckUpdateRepository struct { + client imageCheckUpdateHubClient + err error + tags []string + tagsLoaded bool + tagsErr error +} +type imageCheckUpdateTargetKey struct { + repository, tag string + platform dockerhub.Platform +} +type imageCheckUpdateTargetResult struct { + target dockerhub.Target + compatible bool + err error +} +type imageCheckUpdateResult struct { + record model.ContainerImageCheckUpdate + err error +} +type imageCheckUpdateCache struct { + username, password string + repositories map[string]*imageCheckUpdateRepository + targets map[imageCheckUpdateTargetKey]imageCheckUpdateTargetResult +} + +func runContainerImageCheckUpdate(ctx context.Context, result *ImageCheckUpdateStatus, logger func(string)) error { + log := func(key string, values map[string]interface{}) { + if logger != nil { + logger(i18n.GetMsgWithMap(key, values)) + } + } + cli, err := newImageCheckUpdateDockerClient() + if err != nil { + return err + } + defer cli.Close() + containers, err := cli.ContainerList(ctx, container.ListOptions{All: true}) + if err != nil { + return err + } + log("ContainerImageCheckScope", map[string]interface{}{"count": len(containers)}) + // Load old results once, rather than issuing one SELECT for every failed check. + var previousRows []model.ContainerImageCheckUpdate + if err := global.DB.WithContext(ctx).Find(&previousRows).Error; err != nil { + return err + } + previous := make(map[string]model.ContainerImageCheckUpdate, len(previousRows)) + for _, row := range previousRows { + previous[row.ContainerID] = row + } + cache := imageCheckUpdateCache{repositories: map[string]*imageCheckUpdateRepository{}, targets: map[imageCheckUpdateTargetKey]imageCheckUpdateTargetResult{}} + cfg := config.LoadDefaultConfigFile(io.Discard) + if cfg != nil { + for _, host := range []string{"https://index.docker.io/v1/", "docker.io", "registry-1.docker.io"} { + auth, e := cfg.GetAuthConfig(host) + if e == nil && auth.Username != "" { + cache.username, cache.password = auth.Username, auth.Password + break + } + } + } + checks := map[string]imageCheckUpdateResult{} + ids := make([]string, 0, len(containers)) + names := make(map[string]string, len(containers)) + pending := make([]model.ContainerImageCheckUpdate, 0, 100) + for _, item := range containers { + if err := ctx.Err(); err != nil { + return err + } + ids = append(ids, item.ID) + name := item.ID + if len(item.Names) > 0 { + name = strings.TrimPrefix(item.Names[0], "/") + } + names[item.ID] = name + log("ContainerImageCheckItem", map[string]interface{}{"name": name, "image": item.Image}) + repository, tag, supported := dockerhub.Reference(item.Image) + key := repository + ":" + tag + "@" + item.ImageID + entry, found := checks[key] + if !found { + entry.record, entry.err = checkContainerImageUpdate(ctx, cli, item, repository, tag, supported, &cache) + checks[key] = entry + } + record := entry.record + record.ContainerID, record.ImageName = item.ID, item.Image + if entry.err != nil { + record.CheckStatus, record.CheckError = "failed", entry.err.Error() + old := previous[item.ID] + if old.ImageID == item.ImageID && old.ImageName == item.Image { + record.LatestVersion, record.TargetImage, record.TargetImageID, record.HasUpdate = old.LatestVersion, old.TargetImage, old.TargetImageID, old.HasUpdate + } + } + pending = append(pending, record) + if len(pending) == 100 { + if err := saveContainerImageCheckUpdates(ctx, cli, pending, names, result, log); err != nil { + return err + } + pending = pending[:0] + } + } + if err := saveContainerImageCheckUpdates(ctx, cli, pending, names, result, log); err != nil { + return err + } + query := global.DB.WithContext(ctx).Where("1 = 1") + if len(ids) > 0 { + query = query.Where("container_id NOT IN ?", ids) + } + return query.Delete(&model.ContainerImageCheckUpdate{}).Error +} + +func checkContainerImageUpdate(ctx context.Context, cli imageCheckUpdateDockerClient, item container.Summary, repository, tag string, supported bool, cache *imageCheckUpdateCache) (model.ContainerImageCheckUpdate, error) { + record := model.ContainerImageCheckUpdate{ImageID: item.ImageID, ImageName: item.Image, CheckStatus: "success", CheckedAt: time.Now()} + if !supported { + record.CheckStatus = "skipped" + return record, nil + } + inspected, err := cli.ImageInspect(ctx, item.ImageID) + if err != nil { + return record, err + } + repo, loaded := cache.repositories[repository] + if !loaded { + repo = &imageCheckUpdateRepository{} + repo.client, repo.err = newImageCheckUpdateHubClient(ctx, repository, cache.username, cache.password) + cache.repositories[repository] = repo + } + if repo.err != nil { + return record, repo.err + } + if dockerhub.NeedsTags(tag) { + if !repo.tagsLoaded { + repo.tags, repo.tagsErr = repo.client.Tags(ctx) + repo.tagsLoaded = true + } + if repo.tagsErr != nil { + return record, repo.tagsErr + } + } + platform := dockerhub.Platform{OS: inspected.Os, Architecture: inspected.Architecture, Variant: inspected.Variant} + for _, candidate := range dockerhub.Candidates(tag, repo.tags) { + key := imageCheckUpdateTargetKey{repository: repository, tag: candidate, platform: platform} + remote, loaded := cache.targets[key] + if !loaded { + remote.target, remote.compatible, remote.err = repo.client.Resolve(ctx, candidate, platform) + cache.targets[key] = remote + } + if remote.err != nil { + return record, remote.err + } + if !remote.compatible { + continue + } + record.LatestVersion = remote.target.Tag + record.TargetImage = "docker.io/" + repository + ":" + remote.target.Tag + record.TargetImageID = remote.target.ConfigDigest + record.HasUpdate = remote.target.Tag != tag || remote.target.ConfigDigest != inspected.ID + return record, nil + } + return record, fmt.Errorf("no compatible image for %s/%s", platform.OS, platform.Architecture) +} + +// Revalidate immediately before each small write batch. Never hold a database +// transaction open while waiting for Docker or Docker Hub. +func saveContainerImageCheckUpdates(ctx context.Context, cli imageCheckUpdateDockerClient, pending []model.ContainerImageCheckUpdate, names map[string]string, result *ImageCheckUpdateStatus, log func(string, map[string]interface{})) error { + records := make([]model.ContainerImageCheckUpdate, 0, len(pending)) + for _, record := range pending { + current, err := cli.ContainerInspect(ctx, record.ContainerID) + if err != nil && !errdefs.IsNotFound(err) { + return err + } + if err != nil || current.Image != record.ImageID { + result.Skipped++ + log("ContainerImageCheckChanged", map[string]interface{}{"name": names[record.ContainerID]}) + continue + } + records = append(records, record) + } + if len(records) == 0 { + return nil + } + if err := global.DB.WithContext(ctx).Clauses(clause.OnConflict{UpdateAll: true}).CreateInBatches(&records, 100).Error; err != nil { + return err + } + // Count and announce only results that were successfully persisted. + for _, record := range records { + values := map[string]interface{}{"name": names[record.ContainerID], "image": record.ImageName} + switch record.CheckStatus { + case "failed": + result.Failed++ + values["error"] = record.CheckError + log("ContainerImageCheckFailed", values) + case "skipped": + result.Skipped++ + log("ContainerImageCheckSkipped", values) + default: + result.Checked++ + if record.HasUpdate { + result.Updates++ + values["target"] = record.TargetImage + log("ContainerImageCheckAvailable", values) + } else { + log("ContainerImageCheckCurrent", values) + } + } + } + return nil +} + +// sameContainerImage guards cached results after external image changes. +func sameContainerImage(stored, displayed string) bool { + return strings.TrimPrefix(stored, "sha256:") == strings.TrimPrefix(displayed, "sha256:") +} + +// Reconcile only after Docker confirms the replacement container uses the target. +func reconcileContainerImageCheckUpdate(oldID, newID, imageID, imageName string) error { + return global.DB.Transaction(func(tx *gorm.DB) error { + var previous model.ContainerImageCheckUpdate + if err := tx.Where("container_id = ?", oldID).Find(&previous).Error; err != nil { + return err + } + if previous.ContainerID == "" { + return nil + } + if err := tx.Where("container_id = ?", oldID).Delete(&model.ContainerImageCheckUpdate{}).Error; err != nil { + return err + } + if previous.TargetImageID != imageID { + return nil + } + previous.ContainerID = newID + previous.ImageID = imageID + previous.ImageName = imageName + previous.HasUpdate = false + previous.CheckStatus = "success" + previous.CheckError = "" + previous.CheckedAt = time.Now() + return tx.Clauses(clause.OnConflict{UpdateAll: true}).Create(&previous).Error + }) +} + +type imageCheckUpdateDockerClient interface { + ContainerList(context.Context, container.ListOptions) ([]container.Summary, error) + ContainerInspect(context.Context, string) (container.InspectResponse, error) + ImageInspect(context.Context, string, ...client.ImageInspectOption) (image.InspectResponse, error) + Close() error +} +type imageCheckUpdateHubClient interface { + Tags(context.Context) ([]string, error) + Resolve(context.Context, string, dockerhub.Platform) (dockerhub.Target, bool, error) +} + +var newImageCheckUpdateDockerClient = func() (imageCheckUpdateDockerClient, error) { return docker.NewDockerClient() } +var newImageCheckUpdateHubClient = func(ctx context.Context, repository, username, password string) (imageCheckUpdateHubClient, error) { + return dockerhub.New(ctx, repository, username, password) +} diff --git a/agent/app/service/container_update.go b/agent/app/service/container_update.go index 8e6e4e4a4..9e12f573b 100644 --- a/agent/app/service/container_update.go +++ b/agent/app/service/container_update.go @@ -152,6 +152,11 @@ func (u *ContainerService) ContainerUpgrade(req dto.ContainerUpgrade) error { upgradeErrors = append(upgradeErrors, upgradeErr) return upgradeErr } + if updated, inspectErr := client.ContainerInspect(ctx, item); inspectErr == nil { + if cacheErr := reconcileContainerImageCheckUpdate(oldContainer.ID, updated.ID, updated.Image, updated.Config.Image); cacheErr != nil { + global.LOG.Warnf("refresh container image update state: %v", cacheErr) + } + } if cleanupErr != nil { t.Log(i18n.GetWithNameAndErr("ContainerCleanupWarning", containerSwitchBackupName(oldContainer.ID), cleanupErr)) } diff --git a/agent/cron/cron.go b/agent/cron/cron.go index 402cba256..5b554c2b5 100644 --- a/agent/cron/cron.go +++ b/agent/cron/cron.go @@ -77,7 +77,11 @@ func Run() { global.LOG.Errorf("generate random hour failed: %v", err) hourRand = big.NewInt(0) } - if _, err := global.Cron.AddJob(fmt.Sprintf("%v %v * * *", minuteRand.Int64(), hourRand.Int64()), job.NewAppStoreJob()); err != nil { + appSyncSchedule := fmt.Sprintf("%v %v * * *", minuteRand.Int64(), hourRand.Int64()) + if _, err := global.Cron.AddJob(appSyncSchedule, job.NewContainerImageCheckUpdateJob()); err != nil { + global.LOG.Errorf("cannot add container image update cron job: %v", err) + } + if _, err := global.Cron.AddJob(appSyncSchedule, job.NewAppStoreJob()); err != nil { global.LOG.Errorf("can not add appstore corn job: %s", err.Error()) } if _, err := global.Cron.AddJob("0 3 */31 * *", job.NewBackupJob()); err != nil { diff --git a/agent/cron/job/container_image_check_update.go b/agent/cron/job/container_image_check_update.go new file mode 100644 index 000000000..d0edd0e3f --- /dev/null +++ b/agent/cron/job/container_image_check_update.go @@ -0,0 +1,24 @@ +package job + +import ( + "github.com/1Panel-dev/1Panel/agent/app/service" + "github.com/1Panel-dev/1Panel/agent/global" +) + +type containerImageCheckUpdate struct{} + +func NewContainerImageCheckUpdateJob() *containerImageCheckUpdate { + return &containerImageCheckUpdate{} +} +func (j *containerImageCheckUpdate) Run() { + status, err := service.GetContainerImageCheckUpdateStatus() + if err != nil { + global.LOG.Errorf("load container image update schedule: %v", err) + return + } + if status.Enabled { + if _, err := service.StartContainerImageCheckUpdate(); err != nil { + global.LOG.Errorf("start container image update check: %v", err) + } + } +} diff --git a/agent/i18n/lang/en.yaml b/agent/i18n/lang/en.yaml index 4e29cdfc5..de9fa92b9 100644 --- a/agent/i18n/lang/en.yaml +++ b/agent/i18n/lang/en.yaml @@ -800,3 +800,14 @@ ErrFeishuUpgradeBackup: "A full application backup is required for the Feishu co ErrFeishuUpgradeMounts: "These mounts cannot be fully backed up or restored. Use standard data mounts inside the application directory." AgentFeishuRecoveryDisabled: "Gateway recovered with Feishu disabled; the original configuration backup is retained." + +ContainerImageCheckUpdate: "Check for image updates" +ContainerImageCheckScope: "Checking all {{ .count }} containers on this node, regardless of pagination or filters" +ContainerImageCheckItem: "Checking container {{ .name }}, image {{ .image }}" +ContainerImageCheckFailed: "Container {{ .name }} check failed: {{ .error }}; retaining previous results matching the current image" +ContainerImageCheckSkipped: "Skipping {{ .name }}: not a tagged Docker Hub image, a local image, or pinned digest" +ContainerImageCheckAvailable: "Container {{ .name }} has an update: {{ .image }} -> {{ .target }}" +ContainerImageCheckCurrent: "No update found for container {{ .name }}" +ContainerImageCheckChanged: "Container {{ .name }} was removed or its image changed; result was not saved" +ContainerImageCheckSummary: "Check finished: {{ .checked }} checked, {{ .updates }} upgradable, {{ .failed }} failed, {{ .skipped }} skipped" +ContainerImageCheckFailures: "{{ .count }} container checks failed; see the task log" diff --git a/agent/i18n/lang/es-ES.yaml b/agent/i18n/lang/es-ES.yaml index 05e44451d..94021ce4f 100644 --- a/agent/i18n/lang/es-ES.yaml +++ b/agent/i18n/lang/es-ES.yaml @@ -800,3 +800,14 @@ ErrFeishuUpgradeBackup: "La actualización de compatibilidad de Feishu requiere ErrFeishuUpgradeMounts: "Estos montajes no permiten una copia y restauración completas. Use los montajes de datos estándar dentro del directorio de la aplicación." AgentFeishuRecoveryDisabled: "Puerta de enlace recuperada con Feishu desactivado; se conserva la copia de configuración original." + +ContainerImageCheckUpdate: "Buscar actualizaciones de imágenes" +ContainerImageCheckScope: "Comprobando los {{ .count }} contenedores de este nodo, sin aplicar paginación ni filtros" +ContainerImageCheckItem: "Comprobando el contenedor {{ .name }}, imagen {{ .image }}" +ContainerImageCheckFailed: "Error al comprobar el contenedor {{ .name }}: {{ .error }}; se conservan los resultados anteriores correspondientes a la imagen actual" +ContainerImageCheckSkipped: "Se omite {{ .name }}: no es una imagen de Docker Hub con etiqueta, es una imagen local o tiene un digest fijo" +ContainerImageCheckAvailable: "El contenedor {{ .name }} tiene una actualización: {{ .image }} → {{ .target }}" +ContainerImageCheckCurrent: "No se encontraron actualizaciones para el contenedor {{ .name }}" +ContainerImageCheckChanged: "El contenedor {{ .name }} se eliminó o su imagen cambió; no se guardó el resultado" +ContainerImageCheckSummary: "Comprobación finalizada: comprobados {{ .checked }}, actualizables {{ .updates }}, fallidos {{ .failed }}, omitidos {{ .skipped }}" +ContainerImageCheckFailures: "Falló la comprobación de {{ .count }} contenedores; consulte el registro de la tarea" diff --git a/agent/i18n/lang/fa.yaml b/agent/i18n/lang/fa.yaml index 8011e3b16..6edda8b19 100644 --- a/agent/i18n/lang/fa.yaml +++ b/agent/i18n/lang/fa.yaml @@ -801,3 +801,14 @@ ErrFeishuUpgradeBackup: "ارتقای سازگاری Feishu به پشتیبان ErrFeishuUpgradeMounts: "این اتصال‌های ذخیره‌سازی کاملاً قابل پشتیبان‌گیری و بازیابی نیستند. از مسیرهای استاندارد داده در پوشه برنامه استفاده کنید." AgentFeishuRecoveryDisabled: "دروازه بازیابی شد و Feishu غیرفعال است؛ پشتیبان تنظیمات اصلی حفظ شد." + +ContainerImageCheckUpdate: "بررسی به‌روزرسانی ایمیج‌ها" +ContainerImageCheckScope: "در حال بررسی همه {{ .count }} کانتینر این گره، بدون توجه به صفحه‌بندی و فیلترها" +ContainerImageCheckItem: "در حال بررسی کانتینر {{ .name }}، ایمیج {{ .image }}" +ContainerImageCheckFailed: "بررسی کانتینر {{ .name }} ناموفق بود: {{ .error }}؛ نتایج قبلیِ منطبق با ایمیج فعلی حفظ می‌شوند" +ContainerImageCheckSkipped: "کانتینر {{ .name }} رد شد: ایمیج تگ‌دار Docker Hub نیست، ایمیج محلی است یا digest ثابت دارد" +ContainerImageCheckAvailable: "برای کانتینر {{ .name }} به‌روزرسانی موجود است: {{ .image }} → {{ .target }}" +ContainerImageCheckCurrent: "به‌روزرسانی برای کانتینر {{ .name }} یافت نشد" +ContainerImageCheckChanged: "کانتینر {{ .name }} حذف شده یا ایمیج آن تغییر کرده است؛ نتیجه ذخیره نشد" +ContainerImageCheckSummary: "بررسی پایان یافت: بررسی‌شده {{ .checked }}، قابل ارتقا {{ .updates }}، ناموفق {{ .failed }}، ردشده {{ .skipped }}" +ContainerImageCheckFailures: "بررسی {{ .count }} کانتینر ناموفق بود؛ گزارش وظیفه را مشاهده کنید" diff --git a/agent/i18n/lang/ja.yaml b/agent/i18n/lang/ja.yaml index 127078b53..fd3d9ed3b 100644 --- a/agent/i18n/lang/ja.yaml +++ b/agent/i18n/lang/ja.yaml @@ -800,3 +800,14 @@ ErrFeishuUpgradeBackup: "Feishu 互換更新にはアプリ全体のバックア ErrFeishuUpgradeMounts: "現在のマウントは完全なバックアップ・復元に対応しません。アプリディレクトリ内の標準データマウントを使用してください。" AgentFeishuRecoveryDisabled: "ゲートウェイを復旧しました。Feishu は無効のままで、元の設定のバックアップは保持しています。" + +ContainerImageCheckUpdate: "イメージの更新を確認" +ContainerImageCheckScope: "ページ分割やフィルターに関係なく、このノードの全 {{ .count }} コンテナを確認します" +ContainerImageCheckItem: "コンテナ {{ .name }}、イメージ {{ .image }} を確認しています" +ContainerImageCheckFailed: "コンテナ {{ .name }} の確認に失敗しました：{{ .error }}。現在のイメージに対応する前回の結果を保持します" +ContainerImageCheckSkipped: "{{ .name }} をスキップ：タグ付きの Docker Hub イメージではないか、ローカルイメージまたは digest 固定のイメージです" +ContainerImageCheckAvailable: "コンテナ {{ .name }} は更新可能です：{{ .image }} → {{ .target }}" +ContainerImageCheckCurrent: "コンテナ {{ .name }} の更新は見つかりませんでした" +ContainerImageCheckChanged: "コンテナ {{ .name }} が削除されたか、イメージが変更されたため、結果は保存されませんでした" +ContainerImageCheckSummary: "確認終了：成功 {{ .checked }}、更新可能 {{ .updates }}、失敗 {{ .failed }}、スキップ {{ .skipped }}" +ContainerImageCheckFailures: "{{ .count }} コンテナの確認に失敗しました。タスクログを確認してください" diff --git a/agent/i18n/lang/ko.yaml b/agent/i18n/lang/ko.yaml index 68706ecaa..140746d4e 100644 --- a/agent/i18n/lang/ko.yaml +++ b/agent/i18n/lang/ko.yaml @@ -800,3 +800,14 @@ ErrFeishuUpgradeBackup: "Feishu 호환 업그레이드에는 전체 앱 백업 ErrFeishuUpgradeMounts: "현재 마운트는 전체 백업 및 복원을 지원하지 않습니다. 앱 디렉터리 내부의 표준 데이터 마운트를 사용하세요." AgentFeishuRecoveryDisabled: "게이트웨이가 복구되었습니다. Feishu는 비활성 상태이며 원본 설정 백업은 유지됩니다." + +ContainerImageCheckUpdate: "이미지 업데이트 확인" +ContainerImageCheckScope: "페이지 및 필터와 관계없이 현재 노드의 모든 컨테이너 {{ .count }}개를 확인합니다" +ContainerImageCheckItem: "컨테이너 {{ .name }}, 이미지 {{ .image }} 확인 중" +ContainerImageCheckFailed: "컨테이너 {{ .name }} 확인 실패: {{ .error }}. 현재 이미지와 일치하는 이전 결과를 유지합니다" +ContainerImageCheckSkipped: "{{ .name }} 건너뜀: 태그가 있는 Docker Hub 이미지가 아니거나 로컬 이미지 또는 digest가 고정된 이미지입니다" +ContainerImageCheckAvailable: "컨테이너 {{ .name }} 업데이트 가능: {{ .image }} → {{ .target }}" +ContainerImageCheckCurrent: "컨테이너 {{ .name }}의 업데이트를 찾지 못했습니다" +ContainerImageCheckChanged: "컨테이너 {{ .name }}이 삭제되었거나 이미지가 변경되어 결과를 저장하지 않았습니다" +ContainerImageCheckSummary: "확인 종료: 성공 {{ .checked }}, 업데이트 가능 {{ .updates }}, 실패 {{ .failed }}, 건너뜀 {{ .skipped }}" +ContainerImageCheckFailures: "컨테이너 {{ .count }}개 확인에 실패했습니다. 작업 로그를 확인하세요" diff --git a/agent/i18n/lang/lo.yaml b/agent/i18n/lang/lo.yaml index 8c8cdf978..fe3a0d091 100644 --- a/agent/i18n/lang/lo.yaml +++ b/agent/i18n/lang/lo.yaml @@ -791,3 +791,14 @@ ErrFeishuUpgradeBackup: "ການອັບເກຣດ Feishu ຕ້ອງສ ErrFeishuUpgradeMounts: "ຈຸດເຊື່ອມຂໍ້ມູນນີ້ບໍ່ສາມາດສຳຮອງແລະກູ້ຄືນທັງໝົດໄດ້. ໃຊ້ຈຸດເຊື່ອມມາດຕະຖານພາຍໃນໂຟນເດີແອັບ." AgentFeishuRecoveryDisabled: "ເກດເວກູ້ຄືນແລ້ວ ແຕ່ Feishu ຍັງປິດ; ສຳຮອງການຕັ້ງຄ່າເດີມຍັງຖືກເກັບໄວ້." + +ContainerImageCheckUpdate: "ກວດສອບການອັບເດດອິມເມຈ" +ContainerImageCheckScope: "ກຳລັງກວດສອບທັງໝົດ {{ .count }} ຄອນເທນເນີໃນໂນດນີ້ ໂດຍບໍ່ຂຶ້ນກັບການແບ່ງໜ້າ ຫຼື ຕົວກອງ" +ContainerImageCheckItem: "ກຳລັງກວດສອບຄອນເທນເນີ {{ .name }}, ອິມເມຈ {{ .image }}" +ContainerImageCheckFailed: "ກວດສອບຄອນເທນເນີ {{ .name }} ລົ້ມເຫຼວ: {{ .error }}; ເກັບຜົນກ່ອນໜ້າທີ່ກົງກັບອິມເມຈປັດຈຸບັນໄວ້" +ContainerImageCheckSkipped: "ຂ້າມ {{ .name }}: ບໍ່ແມ່ນອິມເມຈ Docker Hub ທີ່ມີແທັກ, ເປັນອິມເມຈພາຍໃນ ຫຼື ກຳນົດ digest ຄົງທີ່" +ContainerImageCheckAvailable: "ຄອນເທນເນີ {{ .name }} ມີອັບເດດ: {{ .image }} → {{ .target }}" +ContainerImageCheckCurrent: "ບໍ່ພົບອັບເດດສຳລັບຄອນເທນເນີ {{ .name }}" +ContainerImageCheckChanged: "ຄອນເທນເນີ {{ .name }} ຖືກລຶບ ຫຼື ອິມເມຈປ່ຽນແປງ; ບໍ່ໄດ້ບັນທຶກຜົນ" +ContainerImageCheckSummary: "ກວດສອບສິ້ນສຸດ: ກວດແລ້ວ {{ .checked }}, ອັບເກຣດໄດ້ {{ .updates }}, ລົ້ມເຫຼວ {{ .failed }}, ຂ້າມ {{ .skipped }}" +ContainerImageCheckFailures: "ກວດສອບ {{ .count }} ຄອນເທນເນີລົ້ມເຫຼວ; ກະລຸນາເບິ່ງບັນທຶກວຽກ" diff --git a/agent/i18n/lang/ms.yaml b/agent/i18n/lang/ms.yaml index ebb057ab1..9a9ba805f 100644 --- a/agent/i18n/lang/ms.yaml +++ b/agent/i18n/lang/ms.yaml @@ -800,3 +800,14 @@ ErrFeishuUpgradeBackup: "Naik taraf keserasian Feishu memerlukan sandaran aplika ErrFeishuUpgradeMounts: "Lekapan ini tidak boleh disandar dan dipulihkan sepenuhnya. Gunakan lekapan data standard dalam direktori aplikasi." AgentFeishuRecoveryDisabled: "Gerbang dipulihkan dengan Feishu dinyahaktifkan; sandaran konfigurasi asal dikekalkan." + +ContainerImageCheckUpdate: "Semak kemas kini imej" +ContainerImageCheckScope: "Menyemak kesemua {{ .count }} kontena pada nod ini tanpa mengira pembahagian halaman atau penapis" +ContainerImageCheckItem: "Menyemak kontena {{ .name }}, imej {{ .image }}" +ContainerImageCheckFailed: "Semakan kontena {{ .name }} gagal: {{ .error }}; keputusan terdahulu yang sepadan dengan imej semasa dikekalkan" +ContainerImageCheckSkipped: "Melangkau {{ .name }}: bukan imej Docker Hub bertag, imej setempat atau digest ditetapkan" +ContainerImageCheckAvailable: "Kontena {{ .name }} mempunyai kemas kini: {{ .image }} → {{ .target }}" +ContainerImageCheckCurrent: "Tiada kemas kini ditemui untuk kontena {{ .name }}" +ContainerImageCheckChanged: "Kontena {{ .name }} telah dipadam atau imejnya berubah; keputusan tidak disimpan" +ContainerImageCheckSummary: "Semakan selesai: disemak {{ .checked }}, boleh dikemas kini {{ .updates }}, gagal {{ .failed }}, dilangkau {{ .skipped }}" +ContainerImageCheckFailures: "Semakan {{ .count }} kontena gagal; lihat log tugas" diff --git a/agent/i18n/lang/pt-BR.yaml b/agent/i18n/lang/pt-BR.yaml index 680c79373..028fdf272 100644 --- a/agent/i18n/lang/pt-BR.yaml +++ b/agent/i18n/lang/pt-BR.yaml @@ -800,3 +800,14 @@ ErrFeishuUpgradeBackup: "A atualização de compatibilidade do Feishu exige back ErrFeishuUpgradeMounts: "Estas montagens não permitem backup e restauração completos. Use montagens de dados padrão dentro do diretório do aplicativo." AgentFeishuRecoveryDisabled: "Gateway recuperado com Feishu desativado; o backup da configuração original foi mantido." + +ContainerImageCheckUpdate: "Verificar atualizações de imagens" +ContainerImageCheckScope: "Verificando todos os {{ .count }} contêineres deste nó, independentemente da paginação e dos filtros" +ContainerImageCheckItem: "Verificando o contêiner {{ .name }}, imagem {{ .image }}" +ContainerImageCheckFailed: "Falha ao verificar o contêiner {{ .name }}: {{ .error }}; os resultados anteriores correspondentes à imagem atual serão mantidos" +ContainerImageCheckSkipped: "Ignorando {{ .name }}: não é uma imagem do Docker Hub com tag, é uma imagem local ou tem digest fixo" +ContainerImageCheckAvailable: "O contêiner {{ .name }} tem uma atualização: {{ .image }} → {{ .target }}" +ContainerImageCheckCurrent: "Nenhuma atualização encontrada para o contêiner {{ .name }}" +ContainerImageCheckChanged: "O contêiner {{ .name }} foi removido ou sua imagem mudou; o resultado não foi salvo" +ContainerImageCheckSummary: "Verificação concluída: verificados {{ .checked }}, atualizáveis {{ .updates }}, falhas {{ .failed }}, ignorados {{ .skipped }}" +ContainerImageCheckFailures: "Falha na verificação de {{ .count }} contêineres; consulte o log da tarefa" diff --git a/agent/i18n/lang/ru.yaml b/agent/i18n/lang/ru.yaml index 9dd2c58ed..58dcb2393 100644 --- a/agent/i18n/lang/ru.yaml +++ b/agent/i18n/lang/ru.yaml @@ -800,3 +800,14 @@ ErrFeishuUpgradeBackup: "Для обновления совместимости ErrFeishuUpgradeMounts: "Эти монтирования не поддерживают полное резервное копирование и восстановление. Используйте стандартные данные внутри каталога приложения." AgentFeishuRecoveryDisabled: "Шлюз восстановлен, Feishu отключён; исходная резервная копия конфигурации сохранена." + +ContainerImageCheckUpdate: "Проверить обновления образов" +ContainerImageCheckScope: "Проверка всех контейнеров на текущем узле ({{ .count }}) независимо от страниц и фильтров" +ContainerImageCheckItem: "Проверка контейнера {{ .name }}, образ {{ .image }}" +ContainerImageCheckFailed: "Ошибка проверки контейнера {{ .name }}: {{ .error }}; сохранены предыдущие результаты, соответствующие текущему образу" +ContainerImageCheckSkipped: "Пропуск {{ .name }}: это не образ Docker Hub с тегом, локальный образ или образ с фиксированным digest" +ContainerImageCheckAvailable: "Доступно обновление контейнера {{ .name }}: {{ .image }} → {{ .target }}" +ContainerImageCheckCurrent: "Обновлений для контейнера {{ .name }} не найдено" +ContainerImageCheckChanged: "Контейнер {{ .name }} удалён или его образ изменился; результат не сохранён" +ContainerImageCheckSummary: "Проверка завершена: проверено {{ .checked }}, доступны обновления {{ .updates }}, ошибок {{ .failed }}, пропущено {{ .skipped }}" +ContainerImageCheckFailures: "Не удалось проверить контейнеры: {{ .count }}. Подробности в журнале задачи" diff --git a/agent/i18n/lang/tr.yaml b/agent/i18n/lang/tr.yaml index fd16d7cda..671863b9b 100644 --- a/agent/i18n/lang/tr.yaml +++ b/agent/i18n/lang/tr.yaml @@ -800,3 +800,14 @@ ErrFeishuUpgradeBackup: "Feishu uyumluluk yükseltmesi tam uygulama yedeği gere ErrFeishuUpgradeMounts: "Bu bağlamalar tam yedeklenip geri yüklenemiyor. Uygulama dizinindeki standart veri bağlamalarını kullanın." AgentFeishuRecoveryDisabled: "Ağ geçidi kurtarıldı, Feishu kapalı; özgün yapılandırma yedeği korundu." + +ContainerImageCheckUpdate: "İmaj güncellemelerini denetle" +ContainerImageCheckScope: "Sayfalama ve filtrelerden bağımsız olarak bu düğümdeki {{ .count }} konteynerin tümü denetleniyor" +ContainerImageCheckItem: "Konteyner {{ .name }}, imaj {{ .image }} denetleniyor" +ContainerImageCheckFailed: "{{ .name }} konteyneri denetlenemedi: {{ .error }}; mevcut imajla eşleşen önceki sonuçlar korunuyor" +ContainerImageCheckSkipped: "{{ .name }} atlanıyor: etiketli bir Docker Hub imajı değil, yerel bir imaj veya digest değeri sabitlenmiş" +ContainerImageCheckAvailable: "{{ .name }} konteyneri için güncelleme mevcut: {{ .image }} → {{ .target }}" +ContainerImageCheckCurrent: "{{ .name }} konteyneri için güncelleme bulunamadı" +ContainerImageCheckChanged: "{{ .name }} konteyneri silindi veya imajı değişti; sonuç kaydedilmedi" +ContainerImageCheckSummary: "Denetim tamamlandı: denetlenen {{ .checked }}, güncellenebilir {{ .updates }}, başarısız {{ .failed }}, atlanan {{ .skipped }}" +ContainerImageCheckFailures: "{{ .count }} konteyner denetlenemedi; görev günlüğünü inceleyin" diff --git a/agent/i18n/lang/zh-Hant.yaml b/agent/i18n/lang/zh-Hant.yaml index 8fdb70743..98066c5ae 100644 --- a/agent/i18n/lang/zh-Hant.yaml +++ b/agent/i18n/lang/zh-Hant.yaml @@ -800,3 +800,14 @@ ErrFeishuUpgradeBackup: "飛書相容升級必須開啟完整應用程式備份 ErrFeishuUpgradeMounts: "目前掛載無法完整備份或還原，請使用應用程式目錄內的標準資料掛載。" AgentFeishuRecoveryDisabled: "閘道已恢復，飛書保持停用；原設定備份已保留。" + +ContainerImageCheckUpdate: "檢查更新映像" +ContainerImageCheckScope: "檢查目前節點全部 {{ .count }} 個容器，不受分頁和篩選影響" +ContainerImageCheckItem: "檢查容器 {{ .name }}，映像 {{ .image }}" +ContainerImageCheckFailed: "容器 {{ .name }} 檢查失敗：{{ .error }}；保留符合目前映像的上次結果" +ContainerImageCheckSkipped: "略過 {{ .name }}：非 Docker Hub 標籤映像、本機映像或固定 digest" +ContainerImageCheckAvailable: "容器 {{ .name }} 可升級：{{ .image }} → {{ .target }}" +ContainerImageCheckCurrent: "容器 {{ .name }} 未發現更新" +ContainerImageCheckChanged: "容器 {{ .name }} 已刪除或映像已變更，未儲存本次結果" +ContainerImageCheckSummary: "檢查結束：成功 {{ .checked }}，可升級 {{ .updates }}，失敗 {{ .failed }}，略過 {{ .skipped }}" +ContainerImageCheckFailures: "{{ .count }} 個容器檢查失敗，請查看任務日誌" diff --git a/agent/i18n/lang/zh.yaml b/agent/i18n/lang/zh.yaml index 2e1504ea1..2ba5baa46 100644 --- a/agent/i18n/lang/zh.yaml +++ b/agent/i18n/lang/zh.yaml @@ -800,3 +800,14 @@ ErrFeishuUpgradeBackup: "飞书兼容升级必须开启完整应用备份。" ErrFeishuUpgradeMounts: "当前挂载无法完整备份或恢复，请使用应用目录内的标准数据挂载后重试。" AgentFeishuRecoveryDisabled: "网关已恢复，飞书保持停用；原配置备份已保留。" + +ContainerImageCheckUpdate: "检查更新镜像" +ContainerImageCheckScope: "检查当前节点全部 {{ .count }} 个容器，不受分页和筛选影响" +ContainerImageCheckItem: "检查容器 {{ .name }}，镜像 {{ .image }}" +ContainerImageCheckFailed: "容器 {{ .name }} 检查失败：{{ .error }}；保留匹配当前镜像的上次结果" +ContainerImageCheckSkipped: "跳过 {{ .name }}：非 Docker Hub 标签镜像、本地镜像或固定 digest" +ContainerImageCheckAvailable: "容器 {{ .name }} 可升级：{{ .image }} → {{ .target }}" +ContainerImageCheckCurrent: "容器 {{ .name }} 未发现更新" +ContainerImageCheckChanged: "容器 {{ .name }} 已删除或镜像发生变化，未保存本次结果" +ContainerImageCheckSummary: "检查结束：成功 {{ .checked }}，可升级 {{ .updates }}，失败 {{ .failed }}，跳过 {{ .skipped }}" +ContainerImageCheckFailures: "{{ .count }} 个容器检查失败，请查看任务日志" diff --git a/agent/init/migration/migrate.go b/agent/init/migration/migrate.go index b075fe247..69a5587ed 100644 --- a/agent/init/migration/migrate.go +++ b/agent/init/migration/migrate.go @@ -119,6 +119,7 @@ func agentDBMigrations() []*gormigrate.Migration { migrations.AddQuickDirectory, migrations.AddLocalModelAccountLink, migrations.AddOllamaModelAccountSync, + migrations.AddContainerImageCheckUpdates, } } diff --git a/agent/init/migration/migrations/container_image_check_update.go b/agent/init/migration/migrations/container_image_check_update.go new file mode 100644 index 000000000..fd16f8d2c --- /dev/null +++ b/agent/init/migration/migrations/container_image_check_update.go @@ -0,0 +1,17 @@ +package migrations + +import ( + "github.com/1Panel-dev/1Panel/agent/app/model" + "github.com/go-gormigrate/gormigrate/v2" + "gorm.io/gorm" +) + +var AddContainerImageCheckUpdates = &gormigrate.Migration{ + ID: "20261028-container-image-updates", + Migrate: func(tx *gorm.DB) error { + if err := tx.AutoMigrate(&model.ContainerImageCheckUpdate{}); err != nil { + return err + } + return tx.Where("key = ?", "ContainerImageUpdateEnabled").FirstOrCreate(&model.Setting{Key: "ContainerImageUpdateEnabled", Value: "Disable"}).Error + }, +} diff --git a/agent/router/ro_container.go b/agent/router/ro_container.go index 8a715a18c..b8da50cdf 100644 --- a/agent/router/ro_container.go +++ b/agent/router/ro_container.go @@ -16,6 +16,9 @@ func (s *ContainerRouter) InitRouter(Router *gin.RouterGroup) { baRouter.POST("", baseApi.ContainerCreate) baRouter.POST("/update", baseApi.ContainerUpdate) baRouter.POST("/upgrade", baseApi.ContainerUpgrade) + baRouter.GET("/image-updates", baseApi.GetContainerImageCheckUpdateStatus) + baRouter.POST("/image-updates/check", baseApi.ContainerImageCheckUpdate) + baRouter.POST("/image-updates/schedule", baseApi.SetContainerImageCheckUpdateSchedule) baRouter.POST("/info", baseApi.ContainerInfo) baRouter.POST("/search", baseApi.SearchContainer) baRouter.POST("/list", baseApi.ListContainer) diff --git a/agent/utils/dockerhub/client.go b/agent/utils/dockerhub/client.go new file mode 100644 index 000000000..deaa532be --- /dev/null +++ b/agent/utils/dockerhub/client.go @@ -0,0 +1,266 @@ +// Package dockerhub checks Docker Hub metadata without downloading image layers. +package dockerhub + +import ( + "context" + "encoding/json" + "fmt" + "io" + "net/http" + "net/url" + "regexp" + "sort" + "strconv" + "strings" + "time" + + "github.com/distribution/reference" +) + +const registryURL = "https://registry-1.docker.io" + +// Reference only accepts tagged Docker Hub references. Digest pins are intentional. +func Reference(raw string) (string, string, bool) { + if strings.HasPrefix(raw, "sha256:") { + return "", "", false + } + ref, err := reference.ParseNormalizedNamed(raw) + if err != nil || reference.Domain(ref) != "docker.io" { + return "", "", false + } + if _, pinned := ref.(reference.Digested); pinned { + return "", "", false + } + tagged := reference.TagNameOnly(ref).(reference.NamedTagged) + return reference.Path(ref), tagged.Tag(), true +} + +type Client struct { + HTTP *http.Client + repository string + token string +} + +type Platform struct{ OS, Architecture, Variant string } +type Target struct{ Tag, Digest, ConfigDigest string } + +func New(ctx context.Context, repository, username, password string) (*Client, error) { + c := &Client{HTTP: &http.Client{Timeout: 30 * time.Second}, repository: repository} + endpoint := "https://auth.docker.io/token?service=registry.docker.io&scope=" + url.QueryEscape("repository:"+repository+":pull") + req, err := http.NewRequestWithContext(ctx, http.MethodGet, endpoint, nil) + if err != nil { + return nil, err + } + if username != "" { + req.SetBasicAuth(username, password) + } + resp, err := c.HTTP.Do(req) + if err != nil { + return nil, err + } + defer resp.Body.Close() + if resp.StatusCode != http.StatusOK { + return nil, fmt.Errorf("Docker Hub authentication: HTTP %d", resp.StatusCode) + } + var body struct { + Token string `json:"token"` + AccessToken string `json:"access_token"` + } + if err := json.NewDecoder(io.LimitReader(resp.Body, 1<<20)).Decode(&body); err != nil { + return nil, err + } + c.token = body.Token + if c.token == "" { + c.token = body.AccessToken + } + if c.token == "" { + return nil, fmt.Errorf("Docker Hub returned an empty token") + } + return c, nil +} + +func (c *Client) get(ctx context.Context, endpoint string, result interface{}) (http.Header, error) { + req, err := http.NewRequestWithContext(ctx, http.MethodGet, endpoint, nil) + if err != nil { + return nil, err + } + req.Header.Set("Authorization", "Bearer "+c.token) + req.Header.Set("Accept", "application/vnd.oci.image.index.v1+json, application/vnd.docker.distribution.manifest.list.v2+json, application/vnd.oci.image.manifest.v1+json, application/vnd.docker.distribution.manifest.v2+json") + resp, err := c.HTTP.Do(req) + if err != nil { + return nil, err + } + defer resp.Body.Close() + if resp.StatusCode != http.StatusOK { + return nil, fmt.Errorf("Docker Hub metadata: HTTP %d", resp.StatusCode) + } + err = json.NewDecoder(io.LimitReader(resp.Body, 16<<20)).Decode(result) + return resp.Header, err +} + +func (c *Client) Tags(ctx context.Context) ([]string, error) { + endpoint := registryURL + "/v2/" + c.repository + "/tags/list?n=1000" + var tags []string + for page := 0; page < 100; page++ { + var body struct { + Tags []string `json:"tags"` + } + headers, err := c.get(ctx, endpoint, &body) + if err != nil { + return nil, err + } + tags = append(tags, body.Tags...) + link := headers.Get("Link") + if link == "" { + return tags, nil + } + start, end := strings.Index(link, "<"), strings.Index(link, ">") + if start < 0 || end <= start { + return nil, fmt.Errorf("invalid Docker Hub pagination") + } + base, _ := url.Parse(registryURL) + next, err := base.Parse(link[start+1 : end]) + if err != nil || next.Scheme != "https" || next.Host != base.Host || next.Path != "/v2/"+c.repository+"/tags/list" { + return nil, fmt.Errorf("invalid Docker Hub pagination URL") + } + endpoint = next.String() + } + return nil, fmt.Errorf("Docker Hub tag pagination limit exceeded") +} + +type manifest struct { + Config struct { + Digest string `json:"digest"` + } `json:"config"` + Manifests []struct { + Digest string `json:"digest"` + Platform struct { + OS string `json:"os"` + Architecture string `json:"architecture"` + Variant string `json:"variant"` + } `json:"platform"` + } `json:"manifests"` +} + +func (c *Client) Resolve(ctx context.Context, tag string, platform Platform) (Target, bool, error) { + var m manifest + headers, err := c.get(ctx, registryURL+"/v2/"+c.repository+"/manifests/"+url.PathEscape(tag), &m) + if err != nil { + return Target{}, false, err + } + digest := headers.Get("Docker-Content-Digest") + if len(m.Manifests) > 0 { + digest = "" + for _, item := range m.Manifests { + if item.Platform.OS == platform.OS && item.Platform.Architecture == platform.Architecture && normalizedVariant(platform.Architecture, item.Platform.Variant) == normalizedVariant(platform.Architecture, platform.Variant) { + digest = item.Digest + break + } + } + if digest == "" { + return Target{}, false, nil + } + m = manifest{} + if _, err := c.get(ctx, registryURL+"/v2/"+c.repository+"/manifests/"+url.PathEscape(digest), &m); err != nil { + return Target{}, false, err + } + } + if m.Config.Digest == "" { + return Target{}, false, fmt.Errorf("unsupported Docker Hub manifest") + } + // Validate single-platform manifests too; the config digest is the Docker Image ID. + var config struct { + OS string `json:"os"` + Architecture string `json:"architecture"` + Variant string `json:"variant"` + } + if _, err := c.get(ctx, registryURL+"/v2/"+c.repository+"/blobs/"+url.PathEscape(m.Config.Digest), &config); err != nil { + return Target{}, false, err + } + if config.OS != platform.OS || config.Architecture != platform.Architecture || (platform.Variant != "" && config.Variant != "" && config.Variant != platform.Variant) { + return Target{}, false, nil + } + return Target{Tag: tag, Digest: digest, ConfigDigest: m.Config.Digest}, true, nil +} + +var versionPattern = regexp.MustCompile(`^v?(\d+)\.(\d+)(?:\.(\d+))?(-[a-zA-Z][a-zA-Z0-9_.-]*)?$`) +var prereleasePattern = regexp.MustCompile(`(?i)(^|[-_.])(alpha|beta|rc|dev|nightly|edge|test|unstable|preview)([0-9_.-]|$)`) + +type version struct { + numbers [3]uint64 + parts int + variant string +} + +func parseVersion(tag string) (version, bool) { + m := versionPattern.FindStringSubmatch(tag) + if m == nil || prereleasePattern.MatchString(m[4]) { + return version{}, false + } + v := version{parts: 2, variant: m[4]} + for i := 0; i < 3; i++ { + if m[i+1] != "" { + n, err := strconv.ParseUint(m[i+1], 10, 64) + if err != nil { + return version{}, false + } + v.numbers[i] = n + } + } + if m[3] != "" { + v.parts = 3 + } + return v, true +} +func greater(a, b version) bool { + for i := 0; i < 3; i++ { + if a.numbers[i] != b.numbers[i] { + return a.numbers[i] > b.numbers[i] + } + } + return false +} + +// Candidates preserves the current tag's variant and precision. Unknown/floating +// tags are checked only for content changes, never guessed from upload dates. +func Candidates(current string, tags []string) []string { + baseline, ok := parseVersion(current) + if !ok { + return []string{current} + } + type candidate struct { + tag string + version version + } + candidates := []candidate{} + seen := map[string]bool{} + for _, tag := range tags { + v, valid := parseVersion(tag) + if valid && v.parts == baseline.parts && v.variant == baseline.variant && greater(v, baseline) && !seen[tag] { + candidates = append(candidates, candidate{tag: tag, version: v}) + seen[tag] = true + } + } + sort.Slice(candidates, func(i, j int) bool { + a, b := candidates[i], candidates[j] + if a.version.numbers == b.version.numbers { + return a.tag < b.tag + } + return greater(a.version, b.version) + }) + result := make([]string, 0, len(candidates)+1) + for _, candidate := range candidates { + result = append(result, candidate.tag) + } + + return append(result, current) +} + +func NeedsTags(tag string) bool { _, ok := parseVersion(tag); return ok } + +func normalizedVariant(architecture, variant string) string { + if architecture == "arm64" && variant == "" { + return "v8" + } + return variant +} diff --git a/frontend/src/api/interface/container.ts b/frontend/src/api/interface/container.ts index cb1f65718..5b4cc0086 100644 --- a/frontend/src/api/interface/container.ts +++ b/frontend/src/api/interface/container.ts @@ -136,6 +136,9 @@ export namespace Container { mode: string; } export interface ContainerInfo { + latestVersion?: string; + targetImage?: string; + hasUpdate?: boolean; containerID: string; name: string; imageName: string; diff --git a/frontend/src/api/modules/container.ts b/frontend/src/api/modules/container.ts index 7a48f2ab1..3e7c05588 100644 --- a/frontend/src/api/modules/container.ts +++ b/frontend/src/api/modules/container.ts @@ -285,3 +285,33 @@ export const updateIpv6Option = (fixedCidrV6: string, ip6Tables: boolean, experi export const updateDaemonJsonByfile = (params: Container.DaemonJsonUpdateByFile) => { return http.post(`/containers/daemonjson/update/byfile`, params, TimeoutEnum.T_3M); }; + +export interface ContainerImageCheckUpdateStatus { + taskID: string; + enabled: boolean; + running: boolean; + checked: number; + updates: number; + failed: number; + skipped: number; + error: string; + finishedAt: number; +} +export const getContainerImageCheckUpdateStatus = (node: string, signal?: AbortSignal) => + http.get( + '/containers/image-updates', + {}, + { headers: { CurrentNode: node }, signal }, + ); +export const runContainerImageCheckUpdate = (node: string) => + http.postWithConfig( + '/containers/image-updates/check', + {}, + { headers: { CurrentNode: node } }, + ); +export const setContainerImageCheckUpdateSchedule = (enabled: boolean, node: string) => + http.postWithConfig( + '/containers/image-updates/schedule', + { enabled }, + { headers: { CurrentNode: node } }, + ); diff --git a/frontend/src/components/table/TableOperationActions.vue b/frontend/src/components/table/TableOperationActions.vue index 13eb2de68..25d710ac4 100644 --- a/frontend/src/components/table/TableOperationActions.vue +++ b/frontend/src/components/table/TableOperationActions.vue @@ -13,14 +13,16 @@ @click.stop="handleButtonClick(button)" > - {{ button.label }} + + {{ button.label }} + - {{ t('fu.table.more') }} + {{ t('fu.table.more') }} @@ -75,6 +79,9 @@ const actions = computed(() => { }; }); +const hasDot = (button: FuTableOperationButton) => + typeof button.dot === 'function' ? button.dot(props.row) : Boolean(button.dot); + const handleButtonClick = (button: FuTableOperationButton) => { if (!isOperationDisabled(button, props.row)) { button.click?.(props.row); diff --git a/frontend/src/components/table/shared.ts b/frontend/src/components/table/shared.ts index 2f4f09820..69eac5a1c 100644 --- a/frontend/src/components/table/shared.ts +++ b/frontend/src/components/table/shared.ts @@ -23,6 +23,7 @@ export interface FuTableOperationButton { type?: string; icon?: any; divided?: boolean; + dot?: boolean | ((row: Row) => boolean); } export const FU_TABLE_STORAGE_PREFIX = 'FU-T-'; diff --git a/frontend/src/lang/modules/en.ts b/frontend/src/lang/modules/en.ts index d1f1f780c..110792977 100644 --- a/frontend/src/lang/modules/en.ts +++ b/frontend/src/lang/modules/en.ts @@ -2095,6 +2095,14 @@ const message = { missing: 'Missing', }, container: { + imageCheckUpdates: 'Check for image updates', + imageCheckUpdateNow: 'Check now', + imageCheckUpdateSchedule: 'Scheduled checks', + imageCheckUpdateDisable: 'Disable scheduled checks', + imageCheckUpdateStarted: 'Checking images used by all containers on this node', + imageCheckUpdateResult: + 'Check complete: {checked} checked, {updates} upgradable, {failed} failed, {skipped} skipped', + createByCommand: 'Create by command', importContainerBackupTip: 'Import container backup file, only .tar.gz is supported', importComposeBackupTip: 'Import compose backup file, only .tar.gz is supported', diff --git a/frontend/src/lang/modules/es-es.ts b/frontend/src/lang/modules/es-es.ts index 0685b1640..7625af235 100644 --- a/frontend/src/lang/modules/es-es.ts +++ b/frontend/src/lang/modules/es-es.ts @@ -2113,6 +2113,14 @@ const message = { missing: 'No existe', }, container: { + imageCheckUpdates: 'Buscar actualizaciones de imágenes', + imageCheckUpdateNow: 'Comprobar ahora', + imageCheckUpdateSchedule: 'Comprobación programada', + imageCheckUpdateDisable: 'Desactivar comprobación programada', + imageCheckUpdateStarted: 'Buscando actualizaciones de las imágenes de todos los contenedores de este nodo', + imageCheckUpdateResult: + 'Comprobación finalizada: comprobados {checked}, actualizables {updates}, fallidos {failed}, omitidos {skipped}', + createByCommand: 'Crear por comando', importContainerBackupTip: 'Importar archivo de copia de seguridad de contenedor, solo se admite .tar.gz', importComposeBackupTip: 'Importar archivo de copia de seguridad de compose, solo se admite .tar.gz', diff --git a/frontend/src/lang/modules/fa.ts b/frontend/src/lang/modules/fa.ts index 59d6c03b4..d24b3c9b4 100644 --- a/frontend/src/lang/modules/fa.ts +++ b/frontend/src/lang/modules/fa.ts @@ -2074,6 +2074,14 @@ const message = { missing: 'ناموجود', }, container: { + imageCheckUpdates: 'بررسی به‌روزرسانی ایمیج‌ها', + imageCheckUpdateNow: 'بررسی اکنون', + imageCheckUpdateSchedule: 'بررسی زمان‌بندی‌شده', + imageCheckUpdateDisable: 'غیرفعال‌کردن بررسی زمان‌بندی‌شده', + imageCheckUpdateStarted: 'در حال بررسی به‌روزرسانی ایمیج‌های همه کانتینرهای این گره', + imageCheckUpdateResult: + 'بررسی پایان یافت: بررسی‌شده {checked}، قابل ارتقا {updates}، ناموفق {failed}، ردشده {skipped}', + createByCommand: 'ایجاد با دستور', importContainerBackupTip: 'واردات فایل پشتیبان کانتینر، فقط .tar.gz پشتیبانی می‌شود', importComposeBackupTip: 'واردات فایل پشتیبان compose، فقط .tar.gz پشتیبانی می‌شود', diff --git a/frontend/src/lang/modules/ja.ts b/frontend/src/lang/modules/ja.ts index 410e93c98..e5f927b18 100644 --- a/frontend/src/lang/modules/ja.ts +++ b/frontend/src/lang/modules/ja.ts @@ -2079,6 +2079,13 @@ const message = { missing: '存在しない', }, container: { + imageCheckUpdates: 'イメージの更新を確認', + imageCheckUpdateNow: '今すぐ確認', + imageCheckUpdateSchedule: '定期チェック', + imageCheckUpdateDisable: '定期チェックを無効にする', + imageCheckUpdateStarted: 'このノードのすべてのコンテナで使用されているイメージの更新を確認しています', + imageCheckUpdateResult: '確認完了：成功 {checked}、更新可能 {updates}、失敗 {failed}、スキップ {skipped}', + createByCommand: 'コマンドで作成', importContainerBackupTip: 'コンテナバックアップファイルをインポートします。.tar.gz のみ対応です', importComposeBackupTip: 'Compose バックアップファイルをインポートします。.tar.gz のみ対応です', diff --git a/frontend/src/lang/modules/ko.ts b/frontend/src/lang/modules/ko.ts index 58be9b425..cd66325a8 100644 --- a/frontend/src/lang/modules/ko.ts +++ b/frontend/src/lang/modules/ko.ts @@ -2055,6 +2055,13 @@ const message = { missing: '없음', }, container: { + imageCheckUpdates: '이미지 업데이트 확인', + imageCheckUpdateNow: '지금 확인', + imageCheckUpdateSchedule: '정기 확인', + imageCheckUpdateDisable: '정기 확인 끄기', + imageCheckUpdateStarted: '현재 노드의 모든 컨테이너에서 사용하는 이미지의 업데이트를 확인하고 있습니다', + imageCheckUpdateResult: '확인 완료: 성공 {checked}, 업데이트 가능 {updates}, 실패 {failed}, 건너뜀 {skipped}', + createByCommand: '명령으로 생성', importContainerBackupTip: '컨테이너 백업 파일 가져오기, .tar.gz 형식만 지원합니다', importComposeBackupTip: 'Compose 백업 파일 가져오기, .tar.gz 형식만 지원합니다', diff --git a/frontend/src/lang/modules/lo.ts b/frontend/src/lang/modules/lo.ts index bb71e8bb6..f5ad7eeb2 100644 --- a/frontend/src/lang/modules/lo.ts +++ b/frontend/src/lang/modules/lo.ts @@ -2041,6 +2041,13 @@ const message = { missing: 'ບໍ່ມີ', }, container: { + imageCheckUpdates: 'ກວດສອບການອັບເດດອິມເມຈ', + imageCheckUpdateNow: 'ກວດສອບຕອນນີ້', + imageCheckUpdateSchedule: 'ກວດສອບຕາມຕາຕະລາງ', + imageCheckUpdateDisable: 'ປິດການກວດສອບຕາມຕາຕະລາງ', + imageCheckUpdateStarted: 'ກຳລັງກວດສອບການອັບເດດອິມເມຈຂອງທຸກຄອນເທນເນີໃນໂນດນີ້', + imageCheckUpdateResult: 'ກວດສອບສຳເລັດ: ກວດແລ້ວ {checked}, ອັບເກຣດໄດ້ {updates}, ລົ້ມເຫຼວ {failed}, ຂ້າມ {skipped}', + createByCommand: 'ສ້າງດ້ວຍຄຳສັ່ງ', importContainerBackupTip: 'ນຳເຂົ້າໄຟລ໌ສຳຮອງຄອນເທນເນີ, ຮອງຮັບສະເພາະ .tar.gz', importComposeBackupTip: 'ນຳເຂົ້າໄຟລ໌ສຳຮອງ compose, ຮອງຮັບສະເພາະ .tar.gz', diff --git a/frontend/src/lang/modules/ms.ts b/frontend/src/lang/modules/ms.ts index 137757338..bf138c114 100644 --- a/frontend/src/lang/modules/ms.ts +++ b/frontend/src/lang/modules/ms.ts @@ -2110,6 +2110,14 @@ const message = { missing: 'Tiada', }, container: { + imageCheckUpdates: 'Semak kemas kini imej', + imageCheckUpdateNow: 'Semak sekarang', + imageCheckUpdateSchedule: 'Semakan berjadual', + imageCheckUpdateDisable: 'Matikan semakan berjadual', + imageCheckUpdateStarted: 'Menyemak kemas kini imej yang digunakan oleh semua kontena pada nod ini', + imageCheckUpdateResult: + 'Semakan selesai: disemak {checked}, boleh dikemas kini {updates}, gagal {failed}, dilangkau {skipped}', + createByCommand: 'Cipta melalui perintah', importContainerBackupTip: 'Import fail sandaran kontena, hanya format .tar.gz disokong', importComposeBackupTip: 'Import fail sandaran compose, hanya format .tar.gz disokong', diff --git a/frontend/src/lang/modules/pt-br.ts b/frontend/src/lang/modules/pt-br.ts index e058b31f0..cb24a951d 100644 --- a/frontend/src/lang/modules/pt-br.ts +++ b/frontend/src/lang/modules/pt-br.ts @@ -2112,6 +2112,14 @@ const message = { missing: 'Não existe', }, container: { + imageCheckUpdates: 'Verificar atualizações de imagens', + imageCheckUpdateNow: 'Verificar agora', + imageCheckUpdateSchedule: 'Verificação agendada', + imageCheckUpdateDisable: 'Desativar verificação agendada', + imageCheckUpdateStarted: 'Verificando atualizações das imagens de todos os contêineres deste nó', + imageCheckUpdateResult: + 'Verificação concluída: verificados {checked}, atualizáveis {updates}, falhas {failed}, ignorados {skipped}', + createByCommand: 'Criar por comando', importContainerBackupTip: 'Importar arquivo de backup de contêiner, apenas .tar.gz é suportado', importComposeBackupTip: 'Importar arquivo de backup de compose, apenas .tar.gz é suportado', diff --git a/frontend/src/lang/modules/ru.ts b/frontend/src/lang/modules/ru.ts index 97cd621f3..8d096bf7c 100644 --- a/frontend/src/lang/modules/ru.ts +++ b/frontend/src/lang/modules/ru.ts @@ -2105,6 +2105,14 @@ const message = { missing: 'Отсутствует', }, container: { + imageCheckUpdates: 'Проверить обновления образов', + imageCheckUpdateNow: 'Проверить сейчас', + imageCheckUpdateSchedule: 'Проверка по расписанию', + imageCheckUpdateDisable: 'Отключить проверку по расписанию', + imageCheckUpdateStarted: 'Проверка обновлений образов всех контейнеров на текущем узле', + imageCheckUpdateResult: + 'Проверка завершена: проверено {checked}, доступны обновления {updates}, ошибок {failed}, пропущено {skipped}', + createByCommand: 'Создать с помощью команды', importContainerBackupTip: 'Импорт файла резервной копии контейнера, поддерживается только .tar.gz', importComposeBackupTip: 'Импорт файла резервной копии compose, поддерживается только .tar.gz', diff --git a/frontend/src/lang/modules/tr.ts b/frontend/src/lang/modules/tr.ts index 0f2d9981d..c1c27b024 100644 --- a/frontend/src/lang/modules/tr.ts +++ b/frontend/src/lang/modules/tr.ts @@ -2110,6 +2110,14 @@ const message = { missing: 'Mevcut değil', }, container: { + imageCheckUpdates: 'İmaj güncellemelerini denetle', + imageCheckUpdateNow: 'Şimdi denetle', + imageCheckUpdateSchedule: 'Zamanlanmış denetim', + imageCheckUpdateDisable: 'Zamanlanmış denetimi kapat', + imageCheckUpdateStarted: 'Bu düğümdeki tüm konteynerlerin imaj güncellemeleri denetleniyor', + imageCheckUpdateResult: + 'Denetim tamamlandı: denetlenen {checked}, güncellenebilir {updates}, başarısız {failed}, atlanan {skipped}', + createByCommand: 'Komutla oluştur', importContainerBackupTip: 'Konteyner yedek dosyasını içe aktar, yalnızca .tar.gz desteklenir', importComposeBackupTip: 'Compose yedek dosyasını içe aktar, yalnızca .tar.gz desteklenir', diff --git a/frontend/src/lang/modules/zh-Hant.ts b/frontend/src/lang/modules/zh-Hant.ts index a4c89852a..1430de983 100644 --- a/frontend/src/lang/modules/zh-Hant.ts +++ b/frontend/src/lang/modules/zh-Hant.ts @@ -1979,6 +1979,13 @@ const message = { missing: '不存在', }, container: { + imageCheckUpdates: '檢查更新映像', + imageCheckUpdateNow: '立即檢查', + imageCheckUpdateSchedule: '定時檢查', + imageCheckUpdateDisable: '關閉定時檢查', + imageCheckUpdateStarted: '已開始檢查目前節點全部容器的映像更新', + imageCheckUpdateResult: '檢查完成：成功 {checked}，可升級 {updates}，失敗 {failed}，略過 {skipped}', + createByCommand: '指令建立', importContainerBackupTip: '匯入容器備份檔案，僅支援 .tar.gz 格式', importComposeBackupTip: '匯入編排備份檔案，僅支援 .tar.gz 格式', diff --git a/frontend/src/lang/modules/zh.ts b/frontend/src/lang/modules/zh.ts index 15b731471..9389e2409 100644 --- a/frontend/src/lang/modules/zh.ts +++ b/frontend/src/lang/modules/zh.ts @@ -1988,6 +1988,13 @@ const message = { missing: '不存在', }, container: { + imageCheckUpdates: '检查更新镜像', + imageCheckUpdateNow: '立即检查', + imageCheckUpdateSchedule: '定时检查', + imageCheckUpdateDisable: '关闭定时检查', + imageCheckUpdateStarted: '已开始检查当前节点全部容器的镜像更新', + imageCheckUpdateResult: '检查完成：成功 {checked}，可升级 {updates}，失败 {failed}，跳过 {skipped}', + createByCommand: '命令创建', importContainerBackupTip: '导入容器备份文件，仅支持 .tar.gz 格式', importComposeBackupTip: '导入编排备份文件，仅支持 .tar.gz 格式', diff --git a/frontend/src/views/container/container/index.vue b/frontend/src/views/container/container/index.vue index e80bea076..8c455492d 100644 --- a/frontend/src/views/container/container/index.vue +++ b/frontend/src/views/container/container/index.vue @@ -31,6 +31,34 @@ {{ $t('container.containerPrune') }} + + + {{ $t('container.imageCheckUpdates') }} + + + +