Skip to content

fix: 修复集群切换为共享集群时缓存未刷新导致的操作报错 #3839

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
yuyudeqiu wants to merge 2 commits into
base: master
Choose a base branch
from
Open

fix: 修复集群切换为共享集群时缓存未刷新导致的操作报错 #3839

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
1119105
feat: add bypass cache fallback for cluster validation in factory
yuyudeqiu May 13, 2026
1b58e41
fix(cluster): update cache with Set instead of Add to ensure refresh
yuyudeqiu May 13, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 7 additions & 0 deletions bcs-services/bcs-project-manager/internal/actions/namespace/factory.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -58,6 +58,13 @@ func (f *NamespaceFactory) Action(ctx context.Context, clusterID, projectIDOrCod
logging.Error("get project from db failed, err: %s", err.Error())
return nil, err
}
// 若缓存信息校验失败，则绕过缓存重新拉取一次，防止集群状态刚切换时产生误判
if cluster.GetProjectID() != project.ProjectID && !cluster.GetIsShared() {
if freshCluster, err := clustermanager.GetCluster(ctx, clusterID, false); err == nil && freshCluster != nil {
cluster = freshCluster
}
}

if cluster.GetProjectID() != project.ProjectID {
if cluster.GetIsShared() {
return shared.NewSharedNamespaceAction(f.model), nil
Expand Down
2 changes: 1 addition & 1 deletion bcs-services/bcs-project-manager/internal/component/clustermanager/client.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ func GetCluster(ctx context.Context, clusterID string, isCache bool) (*clusterma
logging.Error("get cluster from cluster manager failed, msg: %s", resp.GetMessage())
return nil, errors.New(resp.GetMessage())
}
_ = c.Add(fmt.Sprintf(CacheKeyClusterPrefix, clusterID), resp.GetData(), 5*time.Minute)
c.Set(fmt.Sprintf(CacheKeyClusterPrefix, clusterID), resp.GetData(), 5*time.Minute)
return resp.GetData(), nil
}

Expand Down
Loading