Jud White

consumer: FullJitterStrategy may increase backoff counter unexpectedly

8

https://github.com/nsqio/go-nsq/blob/3c0c5ed026c3a4b2ecc62c675fd4579c2ca65d16/consumer.go#L781-L786 If `FullJitterStrategy` calculates a value less than `config.MaxBackoffDuration` then `backoffCounter` will increment where `ExponentialStrategy` wouldn't, potentially causing `inBackoff()` and `RDY 1` to persist longer than intended. This probably matters...

See #87

Check: - `_transactionChan` - `_transactions` - `_conn.WriteCommand` - `_responseChan` - `_errorChan`, `_closeChan`, `_exitChan` for any possible race conditions. We need to guarantee that the `OK` received from nsqd for a...

See https://github.com/dotnet/corefx/blob/master/src/System.Reflection.Metadata/src/System/Reflection/Internal/Utilities/ObjectPool%601.cs

Logs are inconclusive in this case. Induced by leaving in break-all for a few minutes. ``` [2016-10-15 05:57:19.5504] [Error] P1 (127.0.0.1:4150) IO error on ReadUnpackedResponse - System.ArgumentException: length of response...

See: - https://github.com/nsqio/go-nsq/blob/d71fb89c9e0263aaed89645b0b168e11ccf597b1/conn.go#L360 - https://github.com/nsqio/go-nsq/blob/d71fb89c9e0263aaed89645b0b168e11ccf597b1/conn.go#L425 Go implementation: - https://github.com/mreiferson/go-snappystream - https://github.com/golang/snappy C++ reference implementation: - https://github.com/google/snappy .NET implementations: - http://snappy4net.codeplex.com/ - https://snappy.angeloflogic.com/ - https://github.com/jeffesp/Snappy.Sharp

Create Audit Example using RethinkDB

2

Currently there's an MS SQL Server example. Add one for RethinkDB. https://github.com/bchavez/RethinkDb.Driver https://www.rethinkdb.com/docs/install/windows/ Note: RethinkDB 2.4.0 will have support for running as a Windows service https://github.com/rethinkdb/docs/issues/1146

See: - https://github.com/nsqio/go-nsq/blob/d71fb89c9e0263aaed89645b0b168e11ccf597b1/conn.go#L352 - https://github.com/nsqio/go-nsq/blob/d71fb89c9e0263aaed89645b0b168e11ccf597b1/conn.go#L407 Notes: - Working with `DeflateStream` and TCP http://stackoverflow.com/questions/35460378/why-is-my-deflatestream-not-receiving-data-correctly-over-tcp - https://godoc.org/compress/flate - https://golang.org/src/compress/flate/