Sharded cluster with crud

Author: andreyaksenov

doc/code_snippets/snippets/sharding/instances.enabled/sharded_cluster_crud/README.md

@@ -0,0 +1,26 @@
+# Sharded cluster with CRUD
+
+```shell
+$ tt build sharded_cluster_crud
+```
+
+Example requests:
+
+```lua
+crud.insert('bands', {1, box.NULL, 'Roxette', 1986})
+```
+
+```lua
+crud.insert_many('bands', {
+    { 1, box.NULL, 'Roxette', 1986 },
+    { 2, box.NULL, 'Scorpions', 1965 },
+    { 3, box.NULL, 'Ace of Base', 1987 },
+    { 4, box.NULL, 'The Beatles', 1960 },
+    { 5, box.NULL, 'Pink Floyd', 1965 },
+    { 6, box.NULL, 'The Rolling Stones', 1962 },
+    { 7, box.NULL, 'The Doors', 1965 },
+    { 8, box.NULL, 'Nirvana', 1987 },
+    { 9, box.NULL, 'Led Zeppelin', 1968 },
+    { 10, box.NULL, 'Queen', 1970 },
+})
+```

doc/code_snippets/snippets/sharding/instances.enabled/sharded_cluster_crud/config.yaml

@@ -0,0 +1,60 @@
+credentials:
+  users:
+    replicator:
+      password: 'topsecret'
+      roles: [replication]
+    storage:
+      password: 'secret'
+      roles: [sharding]
+
+iproto:
+  advertise:
+    peer:
+      login: replicator
+    sharding:
+      login: storage
+
+sharding:
+  bucket_count: 1000
+
+groups:
+  storages:
+    roles: [storage]
+    sharding:
+      roles: [storage]
+    replication:
+      failover: manual
+    replicasets:
+      storage-a:
+        leader: storage-a-001
+        instances:
+          storage-a-001:
+            iproto:
+              listen:
+              - uri: '127.0.0.1:3301'
+          storage-a-002:
+            iproto:
+              listen:
+              - uri: '127.0.0.1:3302'
+      storage-b:
+        leader: storage-b-001
+        instances:
+          storage-b-001:
+            iproto:
+              listen:
+              - uri: '127.0.0.1:3303'
+          storage-b-002:
+            iproto:
+              listen:
+              - uri: '127.0.0.1:3304'
+  routers:
+    roles: [router]
+    sharding:
+      roles: [router]
+    replicasets:
+      router-a:
+        instances:
+          router-a-001:
+            iproto:
+              listen:
+              - uri: '127.0.0.1:3300'

doc/code_snippets/snippets/sharding/instances.enabled/sharded_cluster_crud/instances.yaml

@@ -0,0 +1,5 @@
+storage-a-001:
+storage-a-002:
+storage-b-001:
+storage-b-002:
+router-a-001:

doc/code_snippets/snippets/sharding/instances.enabled/sharded_cluster_crud/router.lua

@@ -0,0 +1,39 @@
+local vshard = require('vshard')
+local crud = require('crud')
+local log = require('log')
+local fiber = require('fiber')
+
+local M = {}
+
+function M.validate()
+end
+
+function M.bootstrap_f()
+    for i = 1, 10 do
+        local rc, err = vshard.router.bootstrap()
+        log.info("Attempt to bootstrap vshard cluster")
+        log.info(rc)
+        if rc == nil then
+            if string.find(tostring(err), "is already bootstrapped") ~= nil then
+                break
+            end
+            log.info(err)
+        end
+        if rc ~= nil then
+            break
+        end
+        fiber.sleep(1)
+    end
+end
+
+function M.apply(cfg)
+    M.bootstrap_fiber = fiber.create(M.bootstrap_f, cfg)
+
+    crud.init_router()
+end
+
+function M.stop()
+    crud.stop_router()
+end
+
+return M

doc/code_snippets/snippets/sharding/instances.enabled/sharded_cluster_crud/sharded_cluster_crud-scm-1.rockspec

@@ -0,0 +1,13 @@
+package = 'sharded_cluster_crud'
+version = 'scm-1'
+source  = {
+    url = '/dev/null',
+}
+
+dependencies = {
+    'vshard == 0.1.26',
+    'crud == 1.4.3'
+}
+build = {
+    type = 'none';
+}

doc/code_snippets/snippets/sharding/instances.enabled/sharded_cluster_crud/storage.lua

@@ -0,0 +1,30 @@
+local crud = require('crud')
+
+local M = {}
+
+function M.validate()
+end
+
+function M.apply()
+    crud.init_storage()
+    if box.info.ro ~= true then
+        box.schema.create_space('bands', {
+            format = {
+                { name = 'id', type = 'unsigned' },
+                { name = 'bucket_id', type = 'unsigned' },
+                { name = 'band_name', type = 'string' },
+                { name = 'year', type = 'unsigned' }
+            },
+            if_not_exists = true
+        })
+        box.space.bands:create_index('id', { parts = { 'id' }, if_not_exists = true })
+        box.space.bands:create_index('bucket_id', { parts = { 'bucket_id' }, unique = false, if_not_exists = true })
+    end
+end
+
+function M.stop()
+    crud.stop_storage()
+end
+
+return M
+