ddl: rename sharding_metadata_cache

Rename sharding_metadata_cache to router_metadata_cache to distinct it
from storage_metadata_hash.

Part of #212

Author: DifferentialOrange

crud/common/sharding/router_metadata_cache.lua

@@ -0,0 +1,22 @@
+local fiber = require('fiber')
+
+local router_metadata_cache = {}
+
+router_metadata_cache.SHARDING_KEY_MAP_NAME = "sharding_key_as_index_obj_map"
+router_metadata_cache.SHARDING_FUNC_MAP_NAME = "sharding_func_map"
+router_metadata_cache[router_metadata_cache.SHARDING_KEY_MAP_NAME] = nil
+router_metadata_cache[router_metadata_cache.SHARDING_FUNC_MAP_NAME] = nil
+router_metadata_cache.fetch_lock = fiber.channel(1)
+router_metadata_cache.is_part_of_pk = {}
+
+function router_metadata_cache.drop_caches()
+    router_metadata_cache[router_metadata_cache.SHARDING_KEY_MAP_NAME] = nil
+    router_metadata_cache[router_metadata_cache.SHARDING_FUNC_MAP_NAME] = nil
+    if router_metadata_cache.fetch_lock ~= nil then
+        router_metadata_cache.fetch_lock:close()
+    end
+    router_metadata_cache.fetch_lock = fiber.channel(1)
+    router_metadata_cache.is_part_of_pk = {}
+end
+
+return router_metadata_cache

crud/common/sharding/sharding_func.lua

@@ -2,7 +2,7 @@ local errors = require('errors')
 local log = require('log')
 
 local dev_checks = require('crud.common.dev_checks')
-local cache = require('crud.common.sharding.sharding_metadata_cache')
+local cache = require('crud.common.sharding.router_metadata_cache')
 local utils = require('crud.common.utils')
 
 local ShardingFuncError = errors.new_class('ShardingFuncError',  {capture_stack = false})

crud/common/sharding/sharding_key.lua

@@ -2,7 +2,7 @@ local errors = require('errors')
 local log = require('log')
 
 local dev_checks = require('crud.common.dev_checks')
-local cache = require('crud.common.sharding.sharding_metadata_cache')
+local cache = require('crud.common.sharding.router_metadata_cache')
 local utils = require('crud.common.utils')
 
 local ShardingKeyError = errors.new_class("ShardingKeyError", {capture_stack = false})

crud/common/sharding/sharding_metadata.lua

@@ -4,7 +4,7 @@ local errors = require('errors')
 local call = require('crud.common.call')
 local const = require('crud.common.const')
 local dev_checks = require('crud.common.dev_checks')
-local cache = require('crud.common.sharding.sharding_metadata_cache')
+local cache = require('crud.common.sharding.router_metadata_cache')
 local storage_cache = require('crud.common.sharding.storage_metadata_cache')
 local sharding_func = require('crud.common.sharding.sharding_func')
 local sharding_key = require('crud.common.sharding.sharding_key')

crud/common/sharding/sharding_metadata_cache.lua

@@ -334,7 +334,7 @@ end
 
 function helpers.get_sharding_key_cache(cluster)
     return cluster.main_server.net_box:eval([[
-        local sharding_metadata_cache = require('crud.common.sharding.sharding_metadata_cache')
+        local sharding_metadata_cache = require('crud.common.sharding.router_metadata_cache')
 
         return sharding_metadata_cache[sharding_metadata_cache.SHARDING_KEY_MAP_NAME]
     ]])
@@ -362,7 +362,7 @@ end
 -- but not the cache itself
 function helpers.get_sharding_func_cache_size(cluster)
     return cluster.main_server.net_box:eval([[
-        local sharding_metadata_cache = require('crud.common.sharding.sharding_metadata_cache')
+        local sharding_metadata_cache = require('crud.common.sharding.router_metadata_cache')
 
         local cache, err = sharding_metadata_cache[sharding_metadata_cache.SHARDING_FUNC_MAP_NAME]
         if cache == nil then

test/helper.lua

@@ -3,7 +3,7 @@ local ffi = require('ffi')
 local sharding_metadata_module = require('crud.common.sharding.sharding_metadata')
 local sharding_key_module = require('crud.common.sharding.sharding_key')
 local sharding_func_module = require('crud.common.sharding.sharding_func')
-local cache = require('crud.common.sharding.sharding_metadata_cache')
+local cache = require('crud.common.sharding.router_metadata_cache')
 local utils = require('crud.common.utils')
 
 local helpers = require('test.helper')