tarantool/queue config example

jobserver.lua

queue = require('queue')

local function start(config)
    box.once('jobserver:v0.1.0', function()
        local tube = queue.create_tube('default', 'fifottl', {if_not_exists = true})
    end)
end

local function stop()
end

return {
    start = start,
    stop = stop
}

jobserver_config.lua

local os = require('os')

return {
    user = os.getenv('TARANTOOL_USER_NAME'),
    password = os.getenv('TARANTOOL_USER_PASSWORD')
}

jobserver_instance.lua

#!/usr/bin/env tarantool

box.cfg {
    listen = 3301,
    log_level = 5
}

if jobserver ~= nil then
    -- hot code reload using tarantoolctl or dofile()

    -- unload old application
    jobserver.stop()
    -- clear cache for loaded modules and dependencies
    package.loaded['jobserver'] = nil
end

local config = require('jobserver_config')

-- ensure a user exists
if not box.schema.user.exists(config.user) then
    box.schema.user.create(config.user, {password = config.password})
    box.schema.user.grant(config.user, 'read,write,execute', 'universe', nil)
end

-- load a new version of app and all dependencies
jobserver = require('jobserver')
jobserver.start(config)