karmada-io
/
karmada
mirror of https://github.com/karmada-io/karmada.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

go1.19: change some atomic.Value to atomic.Bool 

Signed-off-by: chaunceyjiang <chaunceyjiang@gmail.com>
This commit is contained in:
chaunceyjiang 2022-11-30 10:53:48 +08:00
parent 84b971a501
commit 05a235caa2
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/resourceinterpreter/configurableinterpreter/configmanager/manager.go
View File

@ -32,7 +32,7 @@ type ConfigManager interface {
// interpreterConfigManager collects the resource interpreter customization.
type interpreterConfigManager struct {
initialSynced *atomic.Value
initialSynced *atomic.Bool
lister cache.GenericLister
configuration *atomic.Value
}
@ -44,7 +44,7 @@ func (configManager *interpreterConfigManager) LuaScriptAccessors() map[schema.G
// HasSynced returns true when the cache is synced.
func (configManager *interpreterConfigManager) HasSynced() bool {
if configManager.initialSynced.Load().(bool) {
if configManager.initialSynced.Load() {
return true
}
@ -64,7 +64,7 @@ func (configManager *interpreterConfigManager) HasSynced() bool {
// the configurations in the cache.
func NewInterpreterConfigManager(informer genericmanager.SingleClusterInformerManager) ConfigManager {
manager := &interpreterConfigManager{
initialSynced: &atomic.Value{},
initialSynced: &atomic.Bool{},
configuration: &atomic.Value{},
}
manager.configuration.Store(make(map[schema.GroupVersionKind]CustomAccessor))

6
pkg/resourceinterpreter/customizedinterpreter/configmanager/manager.go
View File

@ -33,7 +33,7 @@ type ConfigManager interface {
type interpreterConfigManager struct {
configuration *atomic.Value
lister cache.GenericLister
initialSynced *atomic.Value
initialSynced *atomic.Bool
}
// HookAccessors return all configured resource interpreter webhook.
@ -43,7 +43,7 @@ func (m *interpreterConfigManager) HookAccessors() []WebhookAccessor {
// HasSynced return true when the manager is synced with existing configuration.
func (m *interpreterConfigManager) HasSynced() bool {
if m.initialSynced.Load().(bool) {
if m.initialSynced.Load() {
return true
}
@ -64,7 +64,7 @@ func NewExploreConfigManager(inform genericmanager.SingleClusterInformerManager)
manager := &interpreterConfigManager{
configuration: &atomic.Value{},
lister: inform.Lister(resourceExploringWebhookConfigurationsGVR),
initialSynced: &atomic.Value{},
initialSynced: &atomic.Bool{},
}
manager.configuration.Store([]WebhookAccessor{})