369
}
370
371
>
func (m *metadataImpl) RegisterMetadataChangeCallback(callbackId any, cb CallbackFn) {
metadata.go
372
>
m.clusterCallbackLock.Lock()
373
>
m.clusterChangeCallback[callbackId] = cb
374
>
m.clusterCallbackLock.Unlock()
375
>
376
>
oldEntries := make(map[string]*ClusterInformation)
377
>
newEntries := make(map[string]*ClusterInformation)
378
>
m.clusterLock.RLock()
379
>
for clusterName, clusterInfo := range m.clusterInfo {
380
>
oldEntries[clusterName] = nil
381
>
newEntries[clusterName] = ShallowCopyClusterInformation(&clusterInfo)
382
>
}
383
>
m.clusterLock.RUnlock()
384
>
cb(oldEntries, newEntries)
385
}
386