how to watch etcd change with openresty

citywanders · 2017-06-14T15:58:20+00:00

Thanks a lot for the quick response and helpful information. I decided to go with 1. On Tuesday, June 13, 2017 at 12:04:01 AM UTC-7, bjoe2k4 wrote:rewri...

how to watch etcd change with openresty

citywanders

I want to watch etcd value change, so I wrote some codes to test coroutine

http {

include mime.types;

lua_shared_dict routeIndicator 1m;

default_type application/octet-stream;

init_by_lua '

local routeIndicator = ngx.shared.routeIndicator;

co=coroutine.create(function ()

local index=0

while(true)

local routeIndicator = ngx.shared.routeIndicator;

index=index+1

routeIndicator:set("index", index)

ngx.sleep(5)

end

end)

coroutine.resume(co)

I found nothing happened? any idea

qleex001

ngx.sleep can not use in int_by_lua*

在 2017年6月14日星期三 UTC+8下午3:58:20，forrest gan写道：

I want to watch etcd value change, so I wrote some codes to test coroutine
http {
include mime.types;
lua_shared_dict routeIndicator 1m;
default_type application/octet-stream;
init_by_lua '
local routeIndicator = ngx.shared.routeIndicator;
co=coroutine.create(function ()
local index=0
while(true)
do
local routeIndicator = ngx.shared.routeIndicator;
index=index+1
routeIndicator:set("index", index)
ngx.sleep(5)
end
end)
coroutine.resume(co)
';

I found nothing happened? any idea

detailyang

Hello.

Any HTTP client can talk to etcdv2 by HTTP.  And you can talk to etcd
v2 with HTTP upon cosocket on OpenResty. A trick is you can create a
timer and send a HTTP request then wait something happened like read
timeout、closed、etcd response. when you got the events, you can decide
to how to deal with. if it's read timeout, you can restart the timer
or it's closed you can rewatch another etcdv2 instance, it's etcd
response you can restart the timer with the new index.

PS: you should carefully set the read timeout and the watch index.

2017-06-14 19:05 GMT+08:00 FQ Liu <qle...@gmail.com>:
> ngx.sleep can not use in int_by_lua*
>
> 在 2017年6月14日星期三 UTC+8下午3:58:20，forrest gan写道：
>>
>> I want to watch etcd value change, so I wrote some codes to test coroutine
>> http {
>>     include       mime.types;
>> lua_shared_dict routeIndicator 1m;
>>       default_type  application/octet-stream;
>> init_by_lua '
>> local routeIndicator = ngx.shared.routeIndicator;
>> co=coroutine.create(function ()
>>   local index=0
>>   while(true)
>>   do
>>     local routeIndicator = ngx.shared.routeIndicator;
>> index=index+1
>> routeIndicator:set("index", index)
>>                         ngx.sleep(5)
>>   end
>>          end)
>> coroutine.resume(co)
>> ';
>>
>> I found nothing happened? any idea.

citywanders

So tricky, so many tcp time out. Thanks.

On Wednesday, June 14, 2017 at 3:58:20 PM UTC+8, forrest gan wrote:

I want to watch etcd value change, so I wrote some codes to test coroutine
http {
include mime.types;
lua_shared_dict routeIndicator 1m;
default_type application/octet-stream;
init_by_lua '
local routeIndicator = ngx.shared.routeIndicator;
co=coroutine.create(function ()
local index=0
while(true)
do
local routeIndicator = ngx.shared.routeIndicator;
index=index+1
routeIndicator:set("index", index)
ngx.sleep(5)
end
end)
coroutine.resume(co)
';

I found nothing happened? any idea