Jocko Versions Save

Changelog

c4bdec8 add goreleaser a4a403e Merge pull request #77 from travisjeffery/tests 37c8608 rm comment 89f2b7c broker: test add leader and isr new partition 61bbdbf broker: test shutdown be0ab37 fix sarama example to continue if topic already exists e9ca7e6 rm line leftover (fix #75) 98c4593 server: test join bad request 74e1fe2 add docs 7c5ba89 split out prometheus pkg dd1803f server: test join e498a89 broker: test fetch 6045c3a broker: test metadata f929635 broker: test offsets 790c1e9 broker: test deleting topic c66e9ed broker: test creating topic with invalid replication factor 6bdf05a broker: test produce unknown topic/partition 32b1cf1 broker: test produce 0ae4b66 fix readme 9925fa8 readme: add project layout (#71) 82db271 docs and codecov (#70) 6553b9a fixes for #68 29e8f02 broker tests (#68) 5463e2a broker/test: put request/response in args f2cd1fc broker: rm handle tests - should be tested via Run() tests 93bed6a broker: fix test log dir 98f0107 broker: test api versions 71d0b58 broker: test Join() b52d7dd broker: test New() b89b3d6 Merge pull request #65 from edkellena/master cf500bd fix the docker-compose file to spin up an example cluster. closes #64 8b4c40a cmd: fix parsing --debug flag 7f71492 rename create partition cmd b68cd2b rename pointer 6e78979 broker: test create replica 7a01fa4 broker: test cluster member 83a67cb broker: test create partition 993ed5f broker: test partition 916dbfb broker: test cluster members b3ee3c6 rename mock pkg 67d809b broker: test is controller da7782b add tests stubs, test topics() and topicPartitions() 0ef268d add mocks for raft and serf 84d27a9 fix msg a1f6c88 add jocko create topic cmd 36f488f privatize most the broker apis, follow up to the refactor 02a1063 cleanup e738825 broker: simplify run eab1e08 Merge pull request #62 from travisjeffery/fix-listeners c1603ab serf: fix pointer names 4e49c78 docker: update compose image 1bd95e9 add listener for http (fix #60) d116f9b refactor write ade5ff4 Update readme and Dockerfile with Prometheus address (#59) 83c6e61 Merge pull request #61 from travisjeffery/server-broker-refactor e0363fe Refactor server and broker 94c4f20 add err map 2cbf11c update readme 28c5a83 fix docker-compose 3fe5a80 Merge pull request #57 from travisjeffery/docker 86e3094 example: update args b89f90d docker/compose: give cluster 3 nodes, update args 6af135d docker: update for dep and use makefile 960d403 add Dockerfile, docker-compose.yml. updated examples/cluster documentation closes #49 565363f Fix travis-ci f964a59 govendor -> dep f1ceba1 always expose metrics 5aa4d9b Added Prometheus client and exposed number of requests handled (#55) 36414d5 cli: improve logs 7689523 Refactor cli (#54) 8562803 make broker use protocol.error consistently 5b076d5 use protocol.error 1ad1648 fix lock use 49dd62f add protocol.Error 42513a8 add some more docs 19e71e4 fix example baf2c05 create topic: support setting replication factor 636eecc cmd/createtopic: better logging 4d12fcd Fix metadata response (fix #47) 91740c3 add all error codes 8f45c6d broker: update test to compare contents rather than pointer 4276643 server: mv file 1fe8536 broker: better func name 027b58e rename proxy as client 2b34f68 server/test: close conn to create topic after creating topic 4828840 make: add separate test target w/o race f48e12f server: better req handling e7c94f6 server: better logs a2fd23a lowercase logs 6343bdf broker: add docs for opts e543f9a protocol: replace api iota with values 34c3fde Added APIVersions handler Solved bug in SetupIndex function that prevents the index to be set up 54ea894 fix style/api names 92020b0 Fix peer logging format in serf (#31) 06afc24 add more docs, clean up fn names 075f73b remove extraneous methods 8394c6b Move leadership from broker to raft (#36) 03a7547 rewrite serf tests without broker 7d43f27 stop accepting connections after server shutdown 0ceb188 expose replicator, rewrite replicator test w/ mocks 55bd7bb reduce commitlog interface f80578b commitlog: add benchmark test 6474f62 createtopic: default number of partitions to 1 537fe9e vendor: bump sarama for tests 4e81b6d add benchmark test cf9551c rename clients 25f1554 change partition conn when leader changes 824b34c added proxy for sending requests to server f4c1a63 rm docker-compose.yml 6f4a7f6 add docker-compose for benchmarking against kafka 8a703c9 add lock around creating commitlog/partition e585d27 make: add -race to test target (#27) 54f6616 raft: rename var 90cbc99 separate raft fsm from broker 4dd4d70 seprate serf, make raft interface using broker a61b698 add cmd/createtopic 03079b3 server: just use sarama for the tests rather than directly using the commit log/connections 8ac530a protocol: add doc, fix name of api versions key a6d6e4a broker: clean up serf tests 06a1a9c mv jocko to be top level pkg 9ffedd8 rename brokerconn to clustermember 27056b7 use serf const reap status 65595df hide serf and raft from broker 8145ad3 extract serf and raft pkgs from broker 2ce0047 add var for leader id fee05bf fix replica assignment 4c84f56 fix sarama example (close #26) fa68ab6 server: rm the server test's data dir only! (close #24) b2996a6 Merge branch 'cmdargs' 3a9bad8 update example e67a336 fix brokeraddr arg 0d9e74b make args consistent (fix #21) 25a0bb7 server: add sarama test 3b65289 server: put tests in own pkg 92c6260 Merge branch 'klavs-master' 49a12da keep protocol and commitlog separate 74e190e remove commitlog dependecy on protocol 5d5abbe rm binary (fix #18) 2d43357 use /... to prevent go get from complaining cdcf1cb Fix cmd/jocko/main.go 0bd2f7f Fix Cluster creation 67f2dce Fix setting Port 1847dc4 Standardize self-referrer in broker.go 25b3cdf Make Travis CI badge clickable 3bf02b3 clean up examples 5a63de5 check errs on serf bootstrap e4d0269 use kingpin's Strings flag (#10) cd63854 actually use the serf members list 4b82fae intial commit 55577b7 Config bind addresses from command line, and allow serf memberlist to be configured 3dbfe17 leader and isr: handle when partition doesn't exist yet b1fe2ec rename fn 42ca154 make replicator private and args consistent d638c4a clean up option apis 4916a05 readme: add reading 2f25f4f separate raft and serf some more 38da9d1 index: remove existing test since indexes are rebuilt 4ed2c4a add license 6523f47 Update README.md 9e9dd23 add makefile c9f8a40 update readme 70d6475 add rest of serf implementation e21072b travis: run tests serially 3002c82 add serf event handling to add/remove brokers 48fb383 add initial serf calls 180154f update readme f02f278 Add Gitter badge 1408532 add replication manager (#3) ac25989 add err checks 6ebb5ce protocol: fix isr leader request 6c88901 add replicator options 5c4a38b add broker options bd29860 refactor d0a4ecf protocol: fix replicas on leader and isr request 7cb979b remove naked returns (#7) 5bb50a1 protocol: add bool encoder/decoder (#7) b4176fe 1. add stop replica protocol 2. add const api key variable 6ff11be replication: truncate to hw when restarting to replicate 9dccfcf protocol: add leader and isr request/response c00ca30 add var for corrupt index err 36a5977 add sanity check for indexes (close #6) fc5b1ae rename index.offset -> position since its the byte position/offset to not confuse with a message offset b9ddd2c update contributing 6a5d11f rename var 50e7538 update contributing 8e45211 add CONTRIBUTING.md 44f3120 process errors for create data directory (#4) 01ccf60 be able to pass in replica id for fetch requests a98f5b2 add log cleaner 154ba08 commitlog: fix position of 1st entry 56a588b commitlog: add .TruncateTo(offset) (#3) 128fab4 clean up call f58630a add doc f742237 broker: check err 222cc90 replicator: fail fast when something goes wrong during replication 22b8a88 replicator: make client id descriptive 18c4e94 update readme bea38ac test: run server on another port so tests ran in parallel don't conflict 44c0edf update vendor 6c206d0 git: ignore vendor 8959492 tests: specify dir for logs 0e5ab15 fix test faa99c4 start on partition replicator 53ac606 hold references to brokers for host addrs, not just ids 1f03ae5 server: don't panic when serve fails 1ac1e3f example: separate client and jocko setup b21d0a6 add message, message set protocols cf5df62 add vendor 9a8906d add rest of group protocols 6266e97 add join group request/response 555414c check err f201be8 fix typo (close #2) 7fd8038 update readme 40df661 add godeps ee78e52 add ci 6923c1e change test addr 3255abb add err for topic created already aa2b36d add index rebuilding 0083695 add note about creating topic 70b7628 example: use broker api to create topic 031de7d remove some unused apis 25120ea add docs to example effb7b8 add example ca770ad fix some concurrency issues c0719ab add flag to enable debug logs 39bf869 update readme 837c9eb add topic deletes 555c0e4 implement baseoffset for produce response 7604435 remove logs 6c3d374 use better var names and add err checks 3871074 produce request: check all errors 6469b55 add highwatermark to fetch response 24abb98 make newest offset public and add oldest offset for offsets api 70f7d43 segment message set offset on write 309c097 clean up server logging 050dd3f add acks to produce request 46c56ea make segment writes threadsafe d7876bb brokers need both tcp and raft addrs 1c4fd92 support version 1 fetch request 55a533e add throttle time to produce response c630499 add offsets api 4d8cf0a produce: support acks 59ab629 update for api change 7b1daac use ints for ids 6c3066c fix server test 51c436d improve consensus test 54fbf5f add protocol to readme f6a86bf remove unused http stuff e3539fc add fetch request/response bbbed4a add produce request/response 651b725 add support for metadata request/response 21cceee update readme 3e1c83d implement protocol for create topics request/response b193f7e remove client cb07073 move protocol into its own pkg 08da003 start on decoding protocol d45bcd6 add client metadata api aedbf89 rename store to broker 39a5cb5 use bytes buffer/copy d7526c8 add max wait time support to fetch api a698dee update readme ea2e890 add fetch api 4d30e5c fix read to handle byte slices with various sizes 0423e40 update commitlog to read and write messagesets ee2f1ad add api to get each msg from msg set aa49997 add message, message set 84fe73b check that broker is leader on produce cf4038f add api to append messages b7d1367 add api to create topics 89196da use raft for partition consensus af87a57 add types for metadata 9f0cb7f add .gitignore 4b0aa1d add store f0c4e52 add server tests 7173665 remove main ca8623c add cluster 33dc011 add server 5109016 Update README.md 659c223 update readme 85692c8 update readme 3fd013b add partition 95c9c4d fix test to fail if write isn't ok 95b359f fix indexes to store relative offsets 7c3b7c7 move find entry to segment 93eca0a add clients to todos 433fad4 rename fba2b8a update readme e00d34b fix reading non-zero offsets of different segments 4885e5b add working index b106408 rename cfc462a able to read and write across segments 37146b3 add readme feeb19d add commit log 9f5b28e Just allow 1 log dir for now cf17240 Initial commit

Automated with GoReleaser Built with go version go1.9.2 darwin/amd64