Method ReplaceEntityPools

cache/entity_cache.go:165–195

(entityID string, pools []params.Pool)

}

func (e *EntityCache) ReplaceEntityPools(entityID string, pools []params.Pool) {
	e.mux.Lock()
	defer e.mux.Unlock()

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

	// Remove all old pools from the global map.
	for oldPoolID := range cache.Pools {
		delete(e.pools, oldPoolID)
	}

	// Add the new set.
	poolsByID := map[string]struct{}{}
	for _, pool := range pools {
		poolEntity, err := pool.GetEntity()
		if err != nil || poolEntity.ID != entityID {
			continue
		}
		e.pools[pool.ID] = pool
		// map the pool ID to the entity. We have to do an extra lookup
		// in the pools map, but it makes it easier to lookup just pools later
		// when we want to find the pool for the instance.
		poolsByID[pool.ID] = struct{}{}
	}

	cache.Pools = poolsByID
	e.entities[entityID] = cache
}

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