internal: use vshard router object

This patch is the groundwork for vshard groups and custom routers
support.

Test runs have shown that this patch do not affects the performance of
crud requests.

Part of #44

Author: DifferentialOrange

crud/borders.lua

@@ -75,7 +75,9 @@ local function call_get_border_on_router(border_name, space_name, index_name, op
 
     opts = opts or {}
 
-    local space = utils.get_space(space_name, vshard.router.routeall())
+    local vshard_router = vshard.router.static
+    local replicasets = vshard_router:routeall()
+    local space = utils.get_space(space_name, replicasets)
     if space == nil then
         return nil, BorderError:new("Space %q doesn't exist", space_name), const.NEED_SCHEMA_RELOAD
     end
@@ -98,7 +100,6 @@ local function call_get_border_on_router(border_name, space_name, index_name, op
     local cmp_key_parts = utils.merge_primary_key_parts(index.parts, primary_index.parts)
     local field_names = utils.enrich_field_names_with_cmp_key(opts.fields, cmp_key_parts, space:format())
 
-    local replicasets = vshard.router.routeall()
     local call_opts = {
         mode = 'read',
         replicasets = replicasets,

crud/common/call.lua

@@ -48,7 +48,8 @@ local function wrap_vshard_err(err, func_name, replicaset_uuid, bucket_id)
     end
 
     if replicaset_uuid == nil then
-        local replicaset, _ = vshard.router.route(bucket_id)
+        local vshard_router = vshard.router.static
+        local replicaset, _ = vshard_router:route(bucket_id)
         if replicaset == nil then
             return CallError:new(
                 "Function returned an error, but we couldn't figure out the replicaset: %s", err
@@ -150,7 +151,8 @@ function call.single(bucket_id, func_name, func_args, opts)
 
     local timeout = opts.timeout or const.DEFAULT_VSHARD_CALL_TIMEOUT
 
-    local res, err = vshard.router[vshard_call_name](bucket_id, func_name, func_args, {
+    local vshard_router = vshard.router.static
+    local res, err = vshard_router[vshard_call_name](vshard_router, bucket_id, func_name, func_args, {
         timeout = timeout,
     })
 
@@ -172,7 +174,8 @@ function call.any(func_name, func_args, opts)
 
     local timeout = opts.timeout or const.DEFAULT_VSHARD_CALL_TIMEOUT
 
-    local replicasets, err = vshard.router.routeall()
+    local vshard_router = vshard.router.static
+    local replicasets, err = vshard_router:routeall()
     if replicasets == nil then
         return nil, CallError:new("Failed to get all replicasets: %s", err.err)
     end

crud/common/map_call_cases/base_iter.lua

@@ -30,8 +30,9 @@ function BaseIterator:new(opts)
     if opts.replicasets ~= nil then
         replicasets = opts.replicasets
     else
-        replicasets, err = vshard.router.routeall()
-        if replicasets == nil then
+        local vshard_router = vshard.router.static
+        replicasets, err = vshard_router:routeall()
+        if err ~= nil then
             return nil, GetReplicasetsError:new("Failed to get all replicasets: %s", err.err)
         end
     end

crud/common/schema.lua

@@ -91,7 +91,8 @@ function schema.wrap_func_reload(func, ...)
             break
         end
 
-        local ok, reload_schema_err = reload_schema(vshard.router.routeall())
+        local vshard_router = vshard.router.static
+        local ok, reload_schema_err = reload_schema(vshard_router:routeall())
         if not ok then
             log.warn("Failed to reload schema: %s", reload_schema_err)
             break

crud/common/sharding/init.lua

@@ -14,7 +14,8 @@ local sharding_utils = require('crud.common.sharding.utils')
 local sharding = {}
 
 function sharding.get_replicasets_by_bucket_id(bucket_id)
-    local replicaset, err = vshard.router.route(bucket_id)
+    local vshard_router = vshard.router.static
+    local replicaset, err = vshard_router:route(bucket_id)
     if replicaset == nil then
         return nil, GetReplicasetsError:new("Failed to get replicaset for bucket_id %s: %s", bucket_id, err.err)
     end
@@ -43,7 +44,7 @@ function sharding.key_get_bucket_id(space_name, key, specified_bucket_id)
         }
     end
 
-    return { bucket_id = vshard.router.bucket_id_strcrc32(key) }
+    return { bucket_id = vshard_router:bucket_id_strcrc32(key) }
 end
 
 function sharding.tuple_get_bucket_id(tuple, space, specified_bucket_id)
@@ -241,7 +242,8 @@ function sharding.split_tuples_by_replicaset(tuples, space, opts)
             skip_sharding_hash_check = false
         end
 
-        local replicaset, err = vshard.router.route(sharding_data.bucket_id)
+        local vshard_router = vshard.router.static
+        local replicaset, err = vshard_router:route(sharding_data.bucket_id)
         if replicaset == nil then
             return nil, GetReplicasetsError:new(
                     "Failed to get replicaset for bucket_id %s: %s",

crud/common/utils.lua

@@ -634,7 +634,8 @@ function utils.cut_rows(rows, metadata, field_names)
 end
 
 local function flatten_obj(space_name, obj)
-    local space_format, err = utils.get_space_format(space_name, vshard.router.routeall())
+    local vshard_router = vshard.router.static
+    local space_format, err = utils.get_space_format(space_name, vshard_router:routeall())
     if err ~= nil then
         return nil, FlattenError:new("Failed to get space format: %s", err), const.NEED_SCHEMA_RELOAD
     end
@@ -760,7 +761,8 @@ end
 --
 -- @return a table of storage states by replica uuid.
 function utils.storage_info(opts)
-    local replicasets, err = vshard.router.routeall()
+    local vshard_router = vshard.router.static
+    local replicasets, err = vshard_router:routeall()
     if replicasets == nil then
         return nil, StorageInfoError:new("Failed to get all replicasets: %s", err.err)
     end

crud/count.lua

@@ -134,7 +134,8 @@ local function call_count_on_router(space_name, user_conditions, opts)
         return nil, CountError:new("Failed to parse conditions: %s", err)
     end
 
-    local replicasets, err = vshard.router.routeall()
+    local vshard_router = vshard.router.static
+    local replicasets, err = vshard_router:routeall()
     if err ~= nil then
         return nil, CountError:new("Failed to get all replicasets: %s", err)
     end

crud/delete.lua

@@ -64,7 +64,8 @@ local function call_delete_on_router(space_name, key, opts)
 
     opts = opts or {}
 
-    local space = utils.get_space(space_name, vshard.router.routeall())
+    local vshard_router = vshard.router.static
+    local space = utils.get_space(space_name, vshard_router:routeall())
     if space == nil then
         return nil, DeleteError:new("Space %q doesn't exist", space_name), const.NEED_SCHEMA_RELOAD
     end

crud/get.lua

@@ -67,7 +67,8 @@ local function call_get_on_router(space_name, key, opts)
 
     opts = opts or {}
 
-    local space = utils.get_space(space_name, vshard.router.routeall())
+    local vshard_router = vshard.router.static
+    local space = utils.get_space(space_name, vshard_router:routeall())
     if space == nil then
         return nil, GetError:new("Space %q doesn't exist", space_name), const.NEED_SCHEMA_RELOAD
     end

crud/insert.lua

@@ -66,7 +66,8 @@ local function call_insert_on_router(space_name, original_tuple, opts)
 
     opts = opts or {}
 
-    local space = utils.get_space(space_name, vshard.router.routeall())
+    local vshard_router = vshard.router.static
+    local space = utils.get_space(space_name, vshard_router:routeall())
     if space == nil then
         return nil, InsertError:new("Space %q doesn't exist", space_name), const.NEED_SCHEMA_RELOAD
     end