Commit Graph

5951 Commits (e2f3ff26a5e14c151d99621e9090914da404b3a4)

Author SHA1 Message Date
Jason Wilder e2f3ff26a5 Fix data race when close hinted handoff service 2015-06-05 22:16:51 -06:00
Jason Wilder f4cea559d3 Purge hinted handoff queue if entries stick around past a cutoff 2015-06-05 22:16:51 -06:00
Jason Wilder 9d67f9bf62 Add hinted handoff max age and throughput rate limit config options 2015-06-05 22:16:51 -06:00
Jason Wilder 809b9b8a83 Add basic hinted handoff support
If a remote write fails, it will be queued to a per-node, local disk
queue and retried later.
2015-06-05 22:16:51 -06:00
Jason Wilder 1638ff8b6c Handle nil node returned from meta store in shard writer 2015-06-05 22:16:51 -06:00
Jason Wilder 89c01cd37d Add hinted handoff queue
This adds a disk backed queue that will be to persist hinted
handoff writes.
2015-06-05 22:16:51 -06:00
Jason Wilder 044e5b71f5 Remote temp dirs in store_test 2015-06-05 22:16:51 -06:00
Jason Wilder 75b72c60fe Add hinted handoff service
The hinted handoff service will queue a write to a remote node if
that write fails and periodically retry the write.
2015-06-05 22:16:51 -06:00
Jason Wilder 170c584b45 Add hinted handoff config and tests 2015-06-05 22:16:51 -06:00
Ben Johnson dd3c5261e2 Merge pull request #2796 from benbjohnson/mux-serve
Add mux.Serve()
2015-06-05 22:15:52 -06:00
Ben Johnson 413da5cdc4 add mux.Serve() 2015-06-05 22:13:49 -06:00
Todd Persen 4bf024109f Merge pull request #2779 from influxdb/hook-CQs-back-2733
fix #2733: hook CQs back in
2015-06-05 20:40:31 -07:00
Ben Johnson 9ec6e4ff7e Merge pull request #2794 from benbjohnson/mux
Influxd mux integration
2015-06-05 21:15:18 -06:00
David Norton fcf89c87dd cr #2733: uncomment defer in test 2015-06-05 22:30:57 -04:00
David Norton 5f49934a23 fix #2733: trying to fix CI race 2015-06-05 20:49:12 -04:00
David Norton a235b4998d fix #2733: trying to fix CI race 2015-06-05 20:23:44 -04:00
David Norton cc78fe4678 fix #2733: fix rebase issue...grrr 2015-06-05 20:05:31 -04:00
David Norton e107a681c5 cr #2733: make error message more detailed 2015-06-05 19:56:28 -04:00
David Norton d8f0445940 fix #2733: fix race in tests 2015-06-05 19:56:28 -04:00
David Norton fb514f2302 fix #2733: add endpoint to trigger CQ(s) 2015-06-05 19:56:28 -04:00
David Norton 8699aa8f0b fix #2733: more tests 2015-06-05 19:56:28 -04:00
David Norton e0838cb705 fix #2733: add tests for CQ service 2015-06-05 19:54:23 -04:00
David Norton 077159a126 fix #2733: check config before enabling CQ service 2015-06-05 19:54:23 -04:00
David Norton 092bc3fd2d fix #2733: hook CQs back in 2015-06-05 19:54:23 -04:00
Philip O'Toole 041b31d6b3 Merge pull request #2783 from renan-/udp-refresh
Make UDP service code simpler
2015-06-05 16:23:16 -07:00
Ben Johnson fb06549552 remove bind address from cluster config 2015-06-05 17:07:54 -06:00
Ben Johnson abbcf15bb2 integrate mux into influxd cluster service 2015-06-05 17:02:32 -06:00
Ben Johnson 5a5c077790 refactor cluster to use mux 2015-06-05 16:54:12 -06:00
Ben Johnson 6cf78206f0 refactor run.Server to use tcp.Mux 2015-06-05 16:31:58 -06:00
Ben Johnson db2d94a6a5 refactor store to use external listeners 2015-06-05 16:08:07 -06:00
Todd Persen dd9c04ad89 Rename `influxdb` => `client` 2015-06-05 14:46:42 -07:00
Todd Persen f2c92454b5 Merge branch 'vladlopes-include-client-timeout' 2015-06-05 14:23:23 -07:00
Todd Persen 202e420e91 Fixing merge conflict. 2015-06-05 14:23:13 -07:00
Ben Johnson b80496e819 Merge pull request #2769 from influxdb/cluster
Multi-node clustering
2015-06-05 14:45:08 -06:00
Ben Johnson b925e1c1af Multi-node clustering.
This commit adds the ability to cluster multiple nodes together to share
the same metadata through raft consensus.
2015-06-05 14:41:19 -06:00
Todd Persen 0ee71b9755 Merge pull request #2743 from influxdb/tsdb-benchmarks
add shard & index benchmarks
2015-06-05 13:15:38 -07:00
Philip O'Toole 27790e283c Merge pull request #2792 from influxdb/system_test_rpe
Deleted shard groups are not counted as "expired"
2015-06-05 13:10:28 -07:00
Philip O'Toole c59a234e7b Deleted shard groups are not counted as "expired" 2015-06-05 13:08:36 -07:00
Philip O'Toole 73f52121ec Merge pull request #2790 from influxdb/system_test_rpe
Unit test expired and deleted shard groups
2015-06-05 12:35:02 -07:00
Philip O'Toole d1864a4cdc Unit test expired and deleted shard groups 2015-06-05 12:31:10 -07:00
Philip O'Toole dd477fd73b Merge pull request #2789 from influxdb/re_by_default
Set retention enforcement default config
2015-06-05 11:30:36 -07:00
Philip O'Toole a4a05241ba Set retention enforcement default config 2015-06-05 11:27:30 -07:00
Philip O'Toole ca9f231fa1 Merge pull request #2776 from influxdb/enforce_retention_2_phase
Enforce retention policies
2015-06-05 11:15:21 -07:00
Philip O'Toole f3fa2b8192 Update CHANGELOG for PR 2776 2015-06-05 11:13:17 -07:00
Paul Dix 4ba7c5d1c1 Merge pull request #2787 from influxdb/pd-drop-database
Wire up DROP DATABASE query
2015-06-05 20:09:06 +02:00
Paul Dix 61ac4aad80 Fix spelling in test 2015-06-05 20:07:52 +02:00
Ben Johnson 2ef9a57cbc Merge pull request #2786 from influxdb/tcp-mux
Add tcp.Mux
2015-06-05 11:54:44 -06:00
Paul Dix 885e484746 Fix comment typo 2015-06-05 12:47:53 -04:00
Paul Dix 70e10b136e Wire up DROP DATABASE query. 2015-06-05 12:31:04 -04:00
Ben Johnson 9b08fadaa9 Add tcp.Mux.
This commit adds tcp.Mux which multiplexes connections over TCP using
the first byte as the header byte. Users can listen to the muxer
using mux.Listen(hdr) and obtain a net.Listener.
2015-06-05 10:30:35 -06:00