Sandglass is a distributed, horizontally scalable, persistent, time sorted message queue.
4c77621 Merge branch 'release/0.1.8' e4ec737 fix not setting the state of ACK/NACK in service c9ae48d renamed CreateTopicParams to TopicConfig 7113819 vendor: update grpc 8a9da27 vendor: update 024ff2b Merge branch 'feature/refactor-grpc' into dev f5012e5 prefix the key with a version 4f5f0ab fix compilation errors 9af3dbb remove consumerName in arguments to Mark* fd164d6 fix tests a9e93d4 fix sandctl f98535f adapt code to the refactoring in sandglass-grpc 00e3c86 vendor: update 66c2506 fix redelivery duration and added test 7ee8e08 clarify naming of variables 369d6f2 use the correct offset for clustering key, mark consumed instead of nack and adjust delay for redelivery 4b88ba4 Fix stopping redelivery after N trials 81fa75d Merge pull request #11 from wkhere/patch-1 dfd8191 fix typo 1abe07c small cleanup d47b3b3 Update README.md db465c8 Merge pull request #10 from sercand/dev 54bb563 fix isURL function by checking url scheme 3360b14 list technologies used 7f3fbe9 Merge pull request #7 from TrueFurby/patch-1 7f96eef Merge pull request #6 from ergl/fix-readme-example 9dc2f15 Fix client variable in README 4ed96d0 Fix future message example dfb05d7 normalize examples around emails instead of mixing payments and emails 7455a6f readme: added example for producing message to be consumed in the future c08a092 Update README.md 9ca32b2 Updated TOC d23c39e Update readme de79ae8 Updated TOC c713610 Merge tag 'v0.1.7' into dev
Automated with GoReleaser Built with go version go1.9.1 linux/amd64
b5866c1 Merge branch 'release/v0.1.7' 42190a0 updated README.md a6a7eae fix tests 1ab6b9c fix critical bug in consumption when increasing delivery count 353f897 handle nack f0faf9a added NotAcknowledge e9123f4 vendor: update a4d236b commit every 10k messages consumed e851758 enable gzip 972322b vendor: update 39c900c fix commit when all messages are acknowledged a427d12 choose random partition if none is set 3ff3e1e use sandglass directly and avoid using go client 24f91e1 use localhost for demos 2fa11b2 vendor: update c5df82a simplify FetchRange, partition is now required 66cb025 Merge branch 'feature/refactor-grpc' into dev 9b5d17a Merge branch 'dev' into feature/refactor-grpc 218b654 rename broker_publish to broker_produce 3761937 read messages directly in the WAL now that the messages are available there 3ca69ca use a uniform nomenclature 6c6ac4e vendor: update 1733efc update readme 66e8beb fix sandctl 9823336 vendor: update ea58ebb use latest version of sandglass-grpc 2ac72cf vendor: update 316fefc vendor: update 6066d82 move client to its own repo ed1103b vendor: update 7951ede fix multiple acks aed93e6 sandctl: ack each messages instead of commit e29deb8 Update README.md 380a6f4 changed import path for sgproto 19338e2 vendor: update 99e724f get rid of protobuf building f8f7088 update Readme to make it work only single node for demo purpose f7ddaa0 use only BatchPutMessages instead of PutMessage + remove unused functions 164ec4e slice commit 1f60f76 Merge tag 'v0.1.6' into dev
Automated with GoReleaser Built with go version go1.9.1 linux/amd64
1fed233 Merge branch 'release/v0.1.6' b2404d5 fix tests 721feee Merge tag 'v0.1.6' into dev 63519d4 Merge branch 'release/v0.1.6' 24b4e43 added template for ldflags with main.version, etc... 3cc154e Ability to configure consumer offset topic's replication factor 0d5cd07 Merge tag 'v0.1.5' into dev
Automated with GoReleaser Built with go version go1.9.1 linux/amd64
fb15e4d Merge branch 'release/v0.1.5' 80bb14b renamed CompactedTopic to KVTopic 5e319ca added versions to cli 660c9db renamed MsgPrefix to ViewPrefix representing a view of the data under the prefix (either time sorted or kv) 14944ca use storage.Separator, abstract separator to avoid constants lying all over the place 7480e9c Merge branch 'feature/redeliver-nack' into dev 42c64d1 skip first item since it is committed 656f1ab advance commit offset 8143982 added test for redelivery and fix it 1ff2e92 added deliveryCount 8375e72 vendor: update 9bfeab3 switch to jump hashing which uses less memory than consistent hashing 24ad3cb fix out of memory by using RocksDB for ConsumerOffsetsTopic, badger consumes a lot of memory 894d549 vendor: update 4ada49b fix consumption and test without commit e1da32b Merge branch 'dev' into feature/redeliver-nack 6065b2c close broker properly 34c18c3 Redeliver inflight messages (after a fixed delay) and nacked messages a09f1ee mark last consumed message instead of checking if each message is acknowleged 41ad94c remove debug dialing e53b05d Force cluster size b8397b1 vendor: update 10b88cd resolve addresses, this make it possible to test a cluster using docker(-compose) 3972734 vendor: update 0218abc resolve addr to be ok with membership contract 2dfff4e update node* config in docker compose 250d6b6 bump rocksdb version 51a0f60 update call to .Set in badger 56fb196 vendor: update 8b05ce5 provide the max id in FetchRange arguments 6270432 print wait for it 6a63be4 Revert "travis: added language:go" 2aac2fa travis: added language:go 44a886e remove all traces of time.Sleep in tests 615fb88 query all nodes if a majority has received the new topic 56b115c use a single event name d16f921 remove sleep time after creating brokers 4fa6c0e fix WaitForIt b9459f4 Merge branch 'dev' into feature/clustering-key 1396518 ensure that the benchmark count is correct 2dad870 Fix FetchRange to work when we are not leader of the partition 3361539 fix partition_test 1b7f06a Handle consumption in consumer_offset partition leader responsible for the current consumer group. Previously, this was handled by the consumed topic's leader resulting on a lot of unary requests which in turn triggers many random reads over the network. This does not solve the issue of random reads but reduce network IO by doing the check locally. a2decc1 added clustering key e25ee17 added benchmark for consumption c375fb0 write only len messages is > 0 ae10e44 fix display after topic creation 9c91b2f update readme e1007b9 update readme 92d2979 make examples using emails topic instead of payments fe57cad reduce the number of partitions, 300 is a bit too much for a demo...
Automated with GoReleaser Built with go version go1.9.1 linux/amd64
f36b774 vendor: update e83cc70 added verbose flag ea36e39 respect log level and prettify startup c02d713 watchy added on 4123045 goreleaser: cleanup dockerfile
Automated with GoReleaser Built with go version go1.9.1 linux/amd64
3dd7875 untar the correct file... 266f74b goreleaser: use goreleaser for x86_64 and not arm... ba294b5 goreleaser: macOS format 8ee5ad8 dockerfile releaser remove AS build
Automated with GoReleaser Built with go version go1.9.1 linux/amd64
98d78bf update readme 7410288 sandctl: added consume and produce commands eac080c use blockquote 021da38 update readme
Automated with GoReleaser Built with go version go1.9.1 linux/amd64