david birdsong

Update with external checkpoints

7

A draft to implement new functionality proposed in #197. Adding in values to the CRD to support conveying that savepoint during upgrade can be performed with a checkpoint instead. Checkpoints...

support for checkpoint-based updates

1

Our Flink job deploys rely heavily on checkpoints since our savepoints take around 30 -45 minutes to write and read back in on the new job. It appears that enabling...

We have kafka-websocket running behind haproxy with not health checks enabled. I'm watching kafka-websocket repeatedly and steadily march towards it's fd ulimit. lsof reports lots of stale looking fd's: ```...

Love the websocket gateway. It's allowing us to make use of kafka across the open internet protected in a TLS tunnel. I'm seeing pretty high CPU utilization for a topic...

missing lua module

1

just need to add a ``` local io = require "io" ``` https://github.com/sean-lin/protoc-gen-lua/blob/master/protobuf/protobuf.lua#L759

httploc.HttpLocation should ensure that the endpoint host is respected

2

I'm pretty sure I have this right, but LMK if I'm wrong. Using my own Middleware to provide `ProcessRequest` it's too easy to override which host the RoundTripper will Dial...

error building lua binding

1

``` [david@host1 lua{master}]$ C_INCLUDE_PATH=/usr/include/lua5.1 make gcc -O2 -Wall --shared -o protobuf.dll -I../.. -I/usr/local/include -L/usr/local/bin -L../../build pbc-lua.c -lpbc -llua52 pbc-lua.c: In function ‘_env_enum_id’: pbc-lua.c:80:38: warning: implicit declaration of function ‘_pbcM_sp_query’ [-Wimplicit-function-declaration]...

unexpected behavior when iterating over a pipe

2

``` python import vanilla import signal h = vanilla.Hub() p = h.process.execv(('/bin/sleep', '30000')) done = h.router() h.signal.subscribe(signal.SIGINT, signal.SIGTERM).pipe(done) p.done.pipe(done) svc_name = 'test_service' cclient = h.consul() for x in done.recver: if...