config.lua

#!/usr/bin/env tarantool

require('strict').on()

local uuid = require('uuid')
local vshard = require 'vshard'

-- Get instance name
local NAME = os.getenv("TEST_TNT_WORK_DIR")
local fiber = require('fiber')

-- Check if we are running under test-run
if os.getenv('ADMIN') then
    test_run = require('test_run').new()
    require('console').listen(os.getenv('ADMIN'))
end

-- Call a configuration provider
local cfg = {
     sharding = {
          ['cbf06940-0790-498b-948d-042b62cf3d29'] = { -- replicaset #1
              replicas = {
                  ['8a274925-a26d-47fc-9e1b-af88ce939412'] = {
                      uri = 'storage:storage@127.0.0.1:3301',
                      name = 'storage_1_a',
                      master = true,
                  },
                  ['3de2e3e1-9ebe-4d0d-abb1-26d301b84633'] = {
                      uri = 'storage:storage@127.0.0.1:3302',
                      name = 'storage_1_b'
                  },
              },
          }, -- replicaset #1
          ['ac522f65-aa94-4134-9f64-51ee384f1a54'] = { -- replicaset #2
              replicas = {
                 ['1e02ae8a-afc0-4e91-ba34-843a356b8ed7'] = {
                     uri = 'storage:storage@127.0.0.1:3303',
                     name = 'storage_2_a',
                     master = true,
                 },
                 ['001688c3-66f8-4a31-8e19-036c17d489c2'] = {
                      uri = 'storage:storage@127.0.0.1:3304',
                      name = 'storage_2_b'
                 }
              },
          }, -- replicaset #2
     }, -- sharding
     replication_connect_quorum = 0, -- its oke if we havent some replicas
}


-- Name to uuid map
local names = {
    ['storage_1_a'] = '8a274925-a26d-47fc-9e1b-af88ce939412',
    ['storage_1_b'] = '3de2e3e1-9ebe-4d0d-abb1-26d301b84633',
    ['storage_1_c'] = '3de2e3e1-9ebe-4d0d-abb1-26d301b84635',
    ['storage_2_a'] = '1e02ae8a-afc0-4e91-ba34-843a356b8ed7',
    ['storage_2_b'] = '001688c3-66f8-4a31-8e19-036c17d489c2',
}

replicasets = {'cbf06940-0790-498b-948d-042b62cf3d29',
               'ac522f65-aa94-4134-9f64-51ee384f1a54'}



rawset(_G, 'vshard', vshard) -- set as global variable

-- Если мы являемся роутером, то применяем другой конфиг
if NAME == "router" then
    cfg.listen = "0.0.0.0:12000"
    cfg['bucket_count'] = 100
    local router = vshard.router.new('router', cfg)
    rawset(_G, 'router', router) -- set as global variable

    local api = {}
    rawset(_G, 'api', api)

    router:bootstrap({timeout = 4, if_not_bootstrapped = true})

    function api.add_product(product)
        local bucket_id = router:bucket_id_strcrc32(product.id)
        product.bucket_id = bucket_id

        return router:call(bucket_id, 'write', 'product_add', {product})
    end

    function api.get_product(req)
        local bucket_id = router:bucket_id_strcrc32(req.id)

        return router:call(bucket_id, 'read', 'product_get', {req})
    end
else
    vshard.storage.cfg(cfg, names[NAME])

    -- everything below is copypasted from storage.lua in vshard example:
    -- https://github.com/tarantool/vshard/blob/dfa2cc8a2aff221d5f421298851a9a229b2e0434/example/storage.lua
    box.once("testapp:schema:1", function()
        local customer = box.schema.space.create('customer')
        customer:format({
            {'customer_id', 'unsigned'},
            {'bucket_id', 'unsigned'},
            {'name', 'string'},
        })
        customer:create_index('customer_id', {parts = {'customer_id'}})
        customer:create_index('bucket_id', {parts = {'bucket_id'}, unique = false})

        -- create products for easy bench
        local products = box.schema.space.create('products')
        products:format({
            {'id', 'uuid'},
            {'bucket_id', 'unsigned'},
            {'name', 'string'},
            {'count', 'unsigned'},
        })
        products:create_index('id', {parts = {'id'}})
        products:create_index('bucket_id', {parts = {'bucket_id'}, unique = false})


        local account = box.schema.space.create('account')
        account:format({
            {'account_id', 'unsigned'},
            {'customer_id', 'unsigned'},
            {'bucket_id', 'unsigned'},
            {'balance', 'unsigned'},
            {'name', 'string'},
        })
        account:create_index('account_id', {parts = {'account_id'}})
        account:create_index('customer_id', {parts = {'customer_id'}, unique = false})
        account:create_index('bucket_id', {parts = {'bucket_id'}, unique = false})
        box.snapshot()

        box.schema.func.create('customer_lookup')
        box.schema.role.grant('public', 'execute', 'function', 'customer_lookup')
        box.schema.func.create('customer_add')
        box.schema.role.grant('public', 'execute', 'function', 'customer_add')
        box.schema.func.create('echo')
        box.schema.role.grant('public', 'execute', 'function', 'echo')
        box.schema.func.create('sleep')
        box.schema.role.grant('public', 'execute', 'function', 'sleep')
        box.schema.func.create('raise_luajit_error')
        box.schema.role.grant('public', 'execute', 'function', 'raise_luajit_error')
        box.schema.func.create('raise_client_error')
        box.schema.role.grant('public', 'execute', 'function', 'raise_client_error')

        box.schema.user.grant('storage', 'super')
        box.schema.user.create('tarantool')
        box.schema.user.grant('tarantool', 'super')
    end)


    local function insert_customer(customer)
        box.space.customer:insert({customer.customer_id, customer.bucket_id, customer.name})
        for _, account in ipairs(customer.accounts) do
            box.space.account:insert({
                account.account_id,
                customer.customer_id,
                customer.bucket_id,
                0,
                account.name
            })
        end
    end

    function customer_add(customer)
        local ares = box.atomic(insert_customer, customer)

        return {res = ares }
    end

    function customer_lookup(customer_id)
        if type(customer_id) ~= 'number' then
            error('Usage: customer_lookup(customer_id)')
        end

        local customer = box.space.customer:get(customer_id)
        if customer == nil then
            return nil
        end
        customer = {
            customer_id = customer.customer_id;
            name = customer.name;
        }
        local accounts = {}
        for _, account in box.space.account.index.customer_id:pairs(customer_id) do
            table.insert(accounts, {
                account_id = account.account_id;
                name = account.name;
                balance = account.balance;
            })
        end
        customer.accounts = accounts;
        return customer, {test=123}
    end

    function echo(...)
        return ...
    end

    function sleep(time)
        fiber.sleep(time)
        return true
    end

    function raise_luajit_error()
        assert(1 == 2)
    end

    function raise_client_error()
        box.error(box.error.UNKNOWN)
    end

    -- product_add - simple add some product to storage
    function product_add(product)
        local id = uuid.fromstr(product.id)

        box.space.products:insert({ id, product.bucket_id, product.name, product.count})

        return true
    end

    -- product_get - simple select for benches
    function product_get(req)
        local product = box.space.products:get(uuid.fromstr(req.id))

        return {
            name = product.name,
            id = product.id:str()
        }
    end
end

box.once('access:v1', function()
    box.schema.user.grant('guest', 'read,write,execute', 'universe')
end)