WIP implementation of the NSQ message queue in Rust.
Integration tests are all written in Python and are using ansq library. Have a looksy at their example. That's on purpose, although at this point the server is fairly compatible with any client implementation out there. To run the test suite:
$ DOCKER_BUILDKIT=1 ./tests/runtests.sh ./testsThis repo is WIP, at this point in time:
- Implement the core features from the protocol
- Implement the in-memory queue
- Implement the durable (disk backed queue)
- Implement observability - statsd integration and HTTP API
Blazingly fast I am working on it, as for right now it performs 10-15% better than the Go version, at least in terms of the round trip latency. I am pretty sure tangle can do much better than that, stay tuned.