Applications: custom role samples

Author: andreyaksenov

doc/code_snippets/snippets/config/instances.enabled/application_role/config.yaml

@@ -0,0 +1,7 @@
+groups:
+  group001:
+    replicasets:
+      replicaset001:
+        instances:
+          instance001:
+            roles: [ greeter ]

doc/code_snippets/snippets/config/instances.enabled/application_role/greeter.lua

@@ -0,0 +1,6 @@
+-- greeter.lua --
+return {
+    validate = function() end,
+    apply = function() require('log').info("Hi from the 'greeter' role!") end,
+    stop = function() end,
+}

doc/code_snippets/snippets/config/instances.enabled/application_role/instances.yml

@@ -0,0 +1 @@
+instance001:

doc/code_snippets/snippets/config/instances.enabled/application_role_cfg/byeer.lua

@@ -0,0 +1,9 @@
+-- byeer.lua --
+local log = require('log').new("byeer")
+
+return {
+    dependencies = { 'greeter' },
+    validate = function() end,
+    apply = function() log.info("Bye from the 'byeer' role!") end,
+    stop = function() end,
+}

doc/code_snippets/snippets/config/instances.enabled/application_role_cfg/config.yaml

@@ -0,0 +1,10 @@
+groups:
+  group001:
+    replicasets:
+      replicaset001:
+        instances:
+          instance001:
+            roles: [ greeter ]
+            roles_cfg:
+              greeter:
+                greeting: 'Hi'

doc/code_snippets/snippets/config/instances.enabled/application_role_cfg/greeter.lua

@@ -0,0 +1,23 @@
+-- greeter.lua --
+local log = require('log').new("greeter")
+
+local function validate_config(cfg)
+    if cfg.greeting then
+        assert(type(cfg.greeting) == "string", "'greeting' should be a string")
+        assert(cfg.greeting == "Hi" or cfg.greeting == "Hello", "'greeting' should be 'Hi' or 'Hello'")
+    end
+end
+
+local function apply_config(cfg)
+    log.info("%s from the 'greeter' role!", cfg.greeting)
+end
+
+local function stop_role()
+    log.info("The 'greeter' role is stopped")
+end
+
+return {
+    validate = validate_config,
+    apply = apply_config,
+    stop = stop_role,
+}

doc/code_snippets/snippets/config/instances.enabled/application_role_cfg/instances.yml

@@ -0,0 +1 @@
+instance001:

doc/code_snippets/snippets/config/instances.enabled/application_role_http_api/config.yaml

@@ -0,0 +1,11 @@
+groups:
+  group001:
+    replicasets:
+      replicaset001:
+        instances:
+          instance001:
+            roles: [ http-api ]
+            roles_cfg:
+              http-api:
+                host: '127.0.0.1'
+                port: 8080

doc/code_snippets/snippets/config/instances.enabled/application_role_http_api/data.lua

@@ -0,0 +1,32 @@
+local data = {}
+
+data.add_sample_data =  function()
+    box.watch('box.status', function()
+        if box.info.ro then
+            return
+        end
+
+        box.schema.space.create('bands', { if_not_exists = true })
+        box.space.bands:format({
+            { name = 'id', type = 'unsigned' },
+            { name = 'band_name', type = 'string' },
+            { name = 'year', type = 'unsigned' }
+        })
+        box.space.bands:create_index('primary', { parts = { 'id' } })
+        box.space.bands:create_index('band', { parts = { 'band_name' } })
+        box.space.bands:create_index('year_band', { parts = { { 'year' }, { 'band_name' } } })
+
+        box.space.bands:insert { 1, 'Roxette', 1986 }
+        box.space.bands:insert { 2, 'Scorpions', 1965 }
+        box.space.bands:insert { 3, 'Ace of Base', 1987 }
+        box.space.bands:insert { 4, 'The Beatles', 1960 }
+        box.space.bands:insert { 5, 'Pink Floyd', 1965 }
+        box.space.bands:insert { 6, 'The Rolling Stones', 1962 }
+        box.space.bands:insert { 7, 'The Doors', 1965 }
+        box.space.bands:insert { 8, 'Nirvana', 1987 }
+        box.space.bands:insert { 9, 'Led Zeppelin', 1968 }
+        box.space.bands:insert { 10, 'Queen', 1970 }
+    end)
+end
+
+return data

doc/code_snippets/snippets/config/instances.enabled/application_role_http_api/http-api.lua

@@ -0,0 +1,65 @@
+-- http-api.lua --
+local httpd
+local json = require('json')
+
+local function validate_config(cfg)
+    if cfg.host then
+        assert(type(cfg.host) == "string", "'host' should be a string containing a valid IP address")
+    end
+    if cfg.port then
+        assert(type(cfg.port) == "number", "'port' should be a number")
+        assert(cfg.port >= 1 and cfg.port <= 65536, "'port' should be between 1 and 65536")
+    end
+end
+
+local function apply_config(cfg)
+    if httpd then
+        httpd:stop()
+    end
+    httpd = require('http.server').new(cfg.host, cfg.port)
+    local response_headers = { ['content-type'] = 'application/json' }
+    httpd:route({ path = '/band/:id', method = 'GET' }, function(req)
+        local id = req:stash('id')
+        local band_tuple = box.space.bands:get(tonumber(id))
+        if not band_tuple then
+            return { status = 404, body = 'Band not found' }
+        else
+            local band = { id = band_tuple['id'],
+                           band_name = band_tuple['band_name'],
+                           year = band_tuple['year'] }
+            return { status = 200, headers = response_headers, body = json.encode(band) }
+        end
+    end)
+    httpd:route({ path = '/band', method = 'GET' }, function(req)
+        local limit = req:query_param('limit')
+        if not limit then
+            limit = 5
+        end
+        local band_tuples = box.space.bands:select({}, { limit = tonumber(limit) })
+        local bands = {}
+        for _, tuple in pairs(band_tuples) do
+            local band = { id = tuple['id'],
+                           band_name = tuple['band_name'],
+                           year = tuple['year'] }
+            table.insert(bands, band)
+        end
+        return { status = 200, headers = response_headers, body = json.encode(bands) }
+    end)
+    httpd:start()
+end
+
+local function stop_role()
+    httpd:stop()
+end
+
+local function init()
+    require('data'):add_sample_data()
+end
+
+init()
+
+return {
+    validate = validate_config,
+    apply = apply_config,
+    stop = stop_role,
+}

doc/code_snippets/snippets/config/instances.enabled/application_role_http_api/instances.yml

@@ -0,0 +1 @@
+instance001: