Skip to content

Commit de58f4e

Browse files
committed
Replace sharding methods in new directory sharding
Since this patch presents the implementation of support of DDL sharding function, the number of files associated with sharding will increase in the `common` folder. Therefore, a separate directory was created for files containing methods for working with sharding. Part of #237
1 parent 76e3374 commit de58f4e

File tree

13 files changed

+18
-18
lines changed

13 files changed

+18
-18
lines changed

crud/common/sharding.lua renamed to crud/common/sharding/init.lua

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ local errors = require('errors')
44
local BucketIDError = errors.new_class("BucketIDError", {capture_stack = false})
55

66
local utils = require('crud.common.utils')
7-
local sharding_key_module = require('crud.common.sharding_key')
7+
local sharding_key_module = require('crud.common.sharding.sharding_key')
88

99
local sharding = {}
1010

crud/common/sharding_key.lua renamed to crud/common/sharding/sharding_key.lua

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ local errors = require('errors')
44
local call = require('crud.common.call')
55
local const = require('crud.common.const')
66
local dev_checks = require('crud.common.dev_checks')
7-
local cache = require('crud.common.sharding_key_cache')
7+
local cache = require('crud.common.sharding.sharding_key_cache')
88
local utils = require('crud.common.utils')
99

1010
local ShardingKeyError = errors.new_class("ShardingKeyError", {capture_stack = false})
File renamed without changes.

crud/delete.lua

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@ local vshard = require('vshard')
44

55
local call = require('crud.common.call')
66
local utils = require('crud.common.utils')
7-
local sharding = require('crud.common.sharding')
8-
local sharding_key_module = require('crud.common.sharding_key')
7+
local sharding = require('crud.common.sharding.init')
8+
local sharding_key_module = require('crud.common.sharding.sharding_key')
99
local dev_checks = require('crud.common.dev_checks')
1010
local schema = require('crud.common.schema')
1111

crud/get.lua

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@ local vshard = require('vshard')
44

55
local call = require('crud.common.call')
66
local utils = require('crud.common.utils')
7-
local sharding = require('crud.common.sharding')
8-
local sharding_key_module = require('crud.common.sharding_key')
7+
local sharding = require('crud.common.sharding.init')
8+
local sharding_key_module = require('crud.common.sharding.sharding_key')
99
local dev_checks = require('crud.common.dev_checks')
1010
local schema = require('crud.common.schema')
1111

crud/insert.lua

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ local vshard = require('vshard')
44

55
local call = require('crud.common.call')
66
local utils = require('crud.common.utils')
7-
local sharding = require('crud.common.sharding')
7+
local sharding = require('crud.common.sharding.init')
88
local dev_checks = require('crud.common.dev_checks')
99
local schema = require('crud.common.schema')
1010

crud/replace.lua

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ local vshard = require('vshard')
44

55
local call = require('crud.common.call')
66
local utils = require('crud.common.utils')
7-
local sharding = require('crud.common.sharding')
7+
local sharding = require('crud.common.sharding.init')
88
local dev_checks = require('crud.common.dev_checks')
99
local schema = require('crud.common.schema')
1010

crud/select/compat/select.lua

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,11 +3,11 @@ local errors = require('errors')
33
local vshard = require('vshard')
44

55
local utils = require('crud.common.utils')
6-
local sharding = require('crud.common.sharding')
6+
local sharding = require('crud.common.sharding.init')
77
local dev_checks = require('crud.common.dev_checks')
88
local common = require('crud.select.compat.common')
99
local schema = require('crud.common.schema')
10-
local sharding_key_module = require('crud.common.sharding_key')
10+
local sharding_key_module = require('crud.common.sharding.sharding_key')
1111

1212
local compare_conditions = require('crud.compare.conditions')
1313
local select_plan = require('crud.select.plan')

crud/select/compat/select_old.lua

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,10 +5,10 @@ local fun = require('fun')
55

66
local call = require('crud.common.call')
77
local utils = require('crud.common.utils')
8-
local sharding = require('crud.common.sharding')
8+
local sharding = require('crud.common.sharding.init')
99
local dev_checks = require('crud.common.dev_checks')
1010
local schema = require('crud.common.schema')
11-
local sharding_key_module = require('crud.common.sharding_key')
11+
local sharding_key_module = require('crud.common.sharding.sharding_key')
1212

1313
local compare_conditions = require('crud.compare.conditions')
1414
local select_plan = require('crud.select.plan')

crud/update.lua

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@ local vshard = require('vshard')
44

55
local call = require('crud.common.call')
66
local utils = require('crud.common.utils')
7-
local sharding = require('crud.common.sharding')
8-
local sharding_key_module = require('crud.common.sharding_key')
7+
local sharding = require('crud.common.sharding.init')
8+
local sharding_key_module = require('crud.common.sharding.sharding_key')
99
local dev_checks = require('crud.common.dev_checks')
1010
local schema = require('crud.common.schema')
1111

0 commit comments

Comments
 (0)