Method ReplaceEntityScaleSets

cache/entity_cache.go:197–224

(entityID string, scaleSets []params.ScaleSet)

}

func (e *EntityCache) ReplaceEntityScaleSets(entityID string, scaleSets []params.ScaleSet) {
	e.mux.Lock()
	defer e.mux.Unlock()

	cache, ok := e.entities[entityID]
	if !ok {
		return
	}

	// Remove all old scale sets from the global map.
	for oldScaleSetID := range cache.ScaleSets {
		delete(e.scalesets, oldScaleSetID)
	}

	// Add the new set.
	scaleSetsByID := map[uint]struct{}{}
	for _, scaleSet := range scaleSets {
		scaleSetEntity, err := scaleSet.GetEntity()
		if err != nil || scaleSetEntity.ID != entityID {
			continue
		}
		e.scalesets[scaleSet.ID] = scaleSet
		scaleSetsByID[scaleSet.ID] = struct{}{}
	}

	cache.ScaleSets = scaleSetsByID
	e.entities[entityID] = cache
}

func (e *EntityCache) DeleteEntity(entityID string) {
	e.mux.Lock()