modules/ketcd: added polling

diff --git a/modules/ketcd/ketcd.lua b/modules/ketcd/ketcd.lua
index fed767632d6ace0ae5569c986da1b14c0a552576..5a43af086b49d077ea7186f45c80abd55a8786ae 100644 (file)
--- a/modules/ketcd/ketcd.lua
+++ b/modules/ketcd/ketcd.lua
@@ -39,11 +39,17 @@ function ketcd.config(conf)
        if type(conf) == 'table' then
                for k,v in pairs(conf) do options[k] = v end
        end
+       -- create connection
        local cli, err = ketcd.Etcd.new(options)
        if err then
                error(err) 
        end
        ketcd.cli = cli
+       -- schedule recurrent polling
+       -- @todo: the etcd has watch() API, but this requires
+       --        coroutines on socket operations
+       if ketcd.ev then event.cancel(ketcd.ev) end
+       ketcd.ev = event.recurrent(5 * sec, ketcd.reload)
 end
 
 return ketcd