-
Notifications
You must be signed in to change notification settings - Fork 813
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* build Riak from source (two riaks to be precise, to be able to build a cluster) * add custom tags to Riak check + usual pep8 * add a new test for Riak And also: delete rotated log before caching
- Loading branch information
Showing
7 changed files
with
228 additions
and
33 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,88 @@ | ||
| require './ci/common' | ||
|
|
||
| def riak_version | ||
| ENV['COUCHDB_VERSION'] || '2.0.5' | ||
| end | ||
|
|
||
| def riak_rootdir | ||
| "#{ENV['INTEGRATIONS_DIR']}/riak_#{riak_version}" | ||
| end | ||
|
|
||
| namespace :ci do | ||
| namespace :riak do |flavor| | ||
| task :before_install => ['ci:common:before_install'] | ||
|
|
||
| task :install => ['ci:common:install'] do | ||
| unless Dir.exist? File.expand_path(riak_rootdir) | ||
| sh %(curl -o $VOLATILE_DIR/kerl https://raw.githubusercontent.com/spawngrid/kerl/master/kerl) | ||
| sh %(chmod a+x $VOLATILE_DIR/kerl) | ||
| sh %($VOLATILE_DIR/kerl build git git://github.com/basho/otp.git OTP_R16B02 R16B02) | ||
| sh %($VOLATILE_DIR/kerl install R16B02 $VOLATILE_DIR/erlang/R16B02) | ||
| sh %(curl -o $VOLATILE_DIR/riak.tar.gz http://s3.amazonaws.com/downloads.basho.com/riak/#{riak_version[0..2]}/#{riak_version}/riak-#{riak_version}.tar.gz) | ||
| sh %(mkdir -p $VOLATILE_DIR/riak) | ||
| sh %(tar zxvf $VOLATILE_DIR/riak.tar.gz -C $VOLATILE_DIR/riak --strip-components=1) | ||
| sh %(cd $VOLATILE_DIR/riak\ | ||
| && PATH=$PATH:$VOLATILE_DIR/erlang/R16B02/bin make all\ | ||
| && PATH=$PATH:$VOLATILE_DIR/erlang/R16B02/bin make devrel DEVNODES=2) | ||
| sh %(mv $VOLATILE_DIR/riak/dev #{riak_rootdir}) | ||
| end | ||
| end | ||
|
|
||
| task :before_script => ['ci:common:before_script'] do | ||
| %w(dev1 dev2).each do |dev| | ||
| sh %(#{riak_rootdir}/#{dev}/bin/riak start) | ||
| end | ||
| # When cached, dev2 is already a member of the cluster | ||
| sh %(#{riak_rootdir}/dev2/bin/riak-admin cluster join dev1@127.0.0.1 || true) | ||
| sh %(#{riak_rootdir}/dev2/bin/riak-admin cluster plan) | ||
| sh %(#{riak_rootdir}/dev2/bin/riak-admin cluster commit) | ||
| 10.times do | ||
| sh %(curl -s -XPUT http://localhost:10018/buckets/welcome/keys/german\ | ||
| -H 'Content-Type: text/plain'\ | ||
| -d 'herzlich willkommen') | ||
| sh %(curl -s http://localhost:10018/buckets/welcome/keys/german) | ||
| end | ||
| end | ||
|
|
||
| task :script => ['ci:common:script'] do | ||
| this_provides = [ | ||
| 'riak' | ||
| ] | ||
| Rake::Task['ci:common:run_tests'].invoke(this_provides) | ||
| end | ||
|
|
||
| task :before_cache => ['ci:common:before_cache'] | ||
|
|
||
| task :cache => ['ci:common:cache'] | ||
|
|
||
| task :cleanup => ['ci:common:cleanup'] do | ||
| %w(dev1 dev2).each do |dev| | ||
| sh %(#{riak_rootdir}/#{dev}/bin/riak stop) | ||
| end | ||
| end | ||
|
|
||
| task :execute do | ||
| exception = nil | ||
| begin | ||
| %w(before_install install before_script script).each do |t| | ||
| Rake::Task["#{flavor.scope.path}:#{t}"].invoke | ||
| end | ||
| rescue => e | ||
| exception = e | ||
| puts "Failed task: #{e.class} #{e.message}".red | ||
| end | ||
| if ENV['SKIP_CLEANUP'] | ||
| puts 'Skipping cleanup, disposable environments are great'.yellow | ||
| else | ||
| puts 'Cleaning up' | ||
| Rake::Task["#{flavor.scope.path}:cleanup"].invoke | ||
| end | ||
| if ENV['TRAVIS'] | ||
| %w(before_cache cache).each do |t| | ||
| Rake::Task["#{flavor.scope.path}:#{t}"].invoke | ||
| end | ||
| end | ||
| fail exception if exception | ||
| end | ||
| end | ||
| end |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -2,3 +2,6 @@ init_config: | |
|
|
||
| instances: | ||
| - url: http://127.0.0.1:8098/stats | ||
| # tags: | ||
| # - optional_tag1 | ||
| # - optional_tag2 | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,101 @@ | ||
| from nose.plugins.attrib import attr | ||
| import socket | ||
| from tests.common import AgentCheckTest | ||
|
|
||
|
|
||
| @attr(requires='riak') | ||
| class RiakTestCase(AgentCheckTest): | ||
|
|
||
| CHECK_NAME = 'riak' | ||
|
|
||
| CHECK_GAUGES = [ | ||
| 'riak.memory_atom', | ||
| 'riak.memory_atom_used', | ||
| 'riak.memory_binary', | ||
| 'riak.memory_code', | ||
| 'riak.memory_ets', | ||
| 'riak.memory_processes', | ||
| 'riak.memory_processes_used', | ||
| 'riak.memory_total', | ||
| 'riak.node_get_fsm_active_60s', | ||
| 'riak.node_get_fsm_in_rate', | ||
| 'riak.node_gets', | ||
| 'riak.node_put_fsm_active_60s', | ||
| 'riak.node_put_fsm_in_rate', | ||
| 'riak.node_put_fsm_out_rate', | ||
| 'riak.node_put_fsm_rejected_60s', | ||
| 'riak.node_puts', | ||
| 'riak.pbc_active', | ||
| 'riak.pbc_connects', | ||
| 'riak.read_repairs', | ||
| 'riak.vnode_gets', | ||
| 'riak.vnode_index_deletes', | ||
| 'riak.vnode_index_reads', | ||
| 'riak.vnode_index_writes', | ||
| 'riak.vnode_puts', | ||
| ] | ||
|
|
||
| CHECK_GAUGES_STATS = [ | ||
| 'riak.node_get_fsm_objsize_100', | ||
| 'riak.node_get_fsm_objsize_95', | ||
| 'riak.node_get_fsm_objsize_99', | ||
| 'riak.node_get_fsm_objsize_mean', | ||
| 'riak.node_get_fsm_objsize_median', | ||
| 'riak.node_get_fsm_siblings_100', | ||
| 'riak.node_get_fsm_siblings_95', | ||
| 'riak.node_get_fsm_siblings_99', | ||
| 'riak.node_get_fsm_siblings_mean', | ||
| 'riak.node_get_fsm_siblings_median', | ||
| 'riak.node_get_fsm_time_100', | ||
| 'riak.node_get_fsm_time_95', | ||
| 'riak.node_get_fsm_time_99', | ||
| 'riak.node_get_fsm_time_mean', | ||
| 'riak.node_get_fsm_time_median', | ||
| 'riak.node_put_fsm_time_100', | ||
| 'riak.node_put_fsm_time_95', | ||
| 'riak.node_put_fsm_time_99', | ||
| 'riak.node_put_fsm_time_mean', | ||
| 'riak.node_put_fsm_time_median', | ||
| ] | ||
|
|
||
| # Does not appear when null and we can't really fake it | ||
| # These metrics do not appear in the docs | ||
| # http://docs.basho.com/riak/latest/ops/running/stats-and-monitoring/ | ||
| CHECK_NOT_TESTED = [ | ||
| 'riak.node_get_fsm_out_rate', | ||
| 'riak.node_get_fsm_rejected_60s', | ||
| ] | ||
|
|
||
| def __init__(self, *args, **kwargs): | ||
| AgentCheckTest.__init__(self, *args, **kwargs) | ||
| self.config_dev1 = { | ||
| "instances": [{ | ||
| "url": "http://localhost:10018/stats", | ||
| "tags": ["my_tag"] | ||
| }] | ||
| } | ||
|
|
||
| def test_riak(self): | ||
| self.run_check(self.config_dev1) | ||
| tags = ['my_tag'] | ||
| sc_tags = tags + ['url:' + self.config_dev1['instances'][0]['url']] | ||
|
|
||
| for gauge in self.CHECK_GAUGES + self.CHECK_GAUGES_STATS: | ||
| self.assertMetric(gauge, count=1, tags=tags) | ||
|
|
||
| self.assertServiceCheckOK(self.check.SERVICE_CHECK_NAME, | ||
| tags=sc_tags, | ||
| count=1) | ||
| self.coverage_report() | ||
|
|
||
| def test_bad_config(self): | ||
| self.assertRaises( | ||
| socket.error, | ||
| lambda: self.run_check({"instances": [{"url": "http://localhost:5985"}]}) | ||
| ) | ||
| sc_tags = ['url:http://localhost:5985'] | ||
|
|
||
| self.assertServiceCheckCritical(self.check.SERVICE_CHECK_NAME, | ||
| tags=sc_tags, | ||
| count=1) | ||
| self.coverage_report() |