####Nodes
# Cluster1, Node1
10.224.13.24
# Cluster1, Node2
10.249.9.198
# Cluster2, Node1
10.224.8.208
Drew Kerrigan drewkerrigan
This file contains hidden or 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
| def add_index(index, value) | |
| @robject.indexes[index] << value | |
| end |
drewkerrigan
/ load_data.rb
Created
September 5, 2013 00:33
This file contains hidden or 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
| require 'bundler/setup' | |
| require('riak') | |
| require('riak_crdts') | |
| require('./riak_hosts') | |
| require('./models/zombie') | |
| def load_data(filename) | |
| logname = "load_progress.txt" | |
| client = RiakHosts.new.get_riak_connection | |
| zip3 = RiakCrdts::InvertedIndex.new(client, 'zip3_inv') |
drewkerrigan
/ test.js
Created
August 15, 2013 13:54
run:
npm install 'git://github.com/nathanaschbacher/nodiak.git#master'
first
This file contains hidden or 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
| var cluster = require('cluster'); | |
| var riak = require('nodiak').getClient('http', 'localhost', 9098); | |
| var numObjects = 1000; | |
| if (cluster.isMaster) { | |
| var worker = cluster.fork(); | |
| } else { | |
| for(var i = 0; i <= numObjects; i++) { | |
| var robj = riak.bucket("test_bucket").object.new(null, {message: "hello, this is a test"}); | |
| robj.addToIndex("someindex", "something_" + i); |
drewkerrigan
/ aws_mdc_guide.md
Last active
December 17, 2015 16:49
This is a guide for setting up MDC Replication between 2 2-node clusters in AWS.
drewkerrigan
/ gradle clean run_local
Created
April 11, 2013 14:51
This file contains hidden or 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
| basho-ninja:damp dkerrigan$ gradle clean run_local | |
| No overrides found | |
| :server:clean | |
| :server:bootstrap:clean | |
| :server:core:clean | |
| :server:endpoint:clean | |
| :server:persist:clean | |
| :server:router:clean | |
| :server:service:clean | |
| :server:endpoint:rest:clean |
drewkerrigan
/ run_local log
Created
April 11, 2013 14:46
This file contains hidden or 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
| basho-ninja:damp dkerrigan$ gradle clean run_local | |
| No overrides found | |
| :server:clean | |
| :server:bootstrap:clean | |
| :server:core:clean | |
| :server:endpoint:clean | |
| :server:persist:clean | |
| :server:router:clean | |
| :server:service:clean | |
| :server:endpoint:rest:clean |
drewkerrigan
/ build log
Created
April 11, 2013 14:40
This file contains hidden or 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
| /Applications/gradle-1.5/bin/gradle clean assemble | |
| No overrides found | |
| :server:clean | |
| :server:bootstrap:clean | |
| :server:core:clean | |
| :server:endpoint:clean | |
| :server:persist:clean | |
| :server:router:clean | |
| :server:service:clean | |
| :server:endpoint:rest:clean |
drewkerrigan
/ output.json
Created
April 3, 2013 22:24
This file contains hidden or 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
| {"riak_kv_stat_ts":1365005608,"vnode_gets":0,"vnode_gets_total":6,"vnode_puts":0,"vnode_puts_total":7,"vnode_index_reads":0,"vnode_index_reads_total":0,"vnode_index_writes":0,"vnode_index_writes_total":0,"vnode_index_writes_postings":0,"vnode_index_writes_postings_total":0,"vnode_index_deletes":0,"vnode_index_deletes_total":0,"vnode_index_deletes_postings":0,"vnode_index_deletes_postings_total":0,"node_gets":0,"node_gets_total":2,"node_get_fsm_siblings_mean":0,"node_get_fsm_siblings_median":0,"node_get_fsm_siblings_95":0,"node_get_fsm_siblings_99":0,"node_get_fsm_siblings_100":0,"node_get_fsm_objsize_mean":0,"node_get_fsm_objsize_median":0,"node_get_fsm_objsize_95":0,"node_get_fsm_objsize_99":0,"node_get_fsm_objsize_100":0,"node_get_fsm_time_mean":0,"node_get_fsm_time_median":0,"node_get_fsm_time_95":0,"node_get_fsm_time_99":0,"node_get_fsm_time_100":0,"node_puts":0,"node_puts_total":1,"node_put_fsm_time_mean":0,"node_put_fsm_time_median":0,"node_put_fsm_time_95":0,"node_put_fsm_time_99":0,"node_put_fsm_time_ |
This file contains hidden or 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
| riak_kv_stat_ts : 1365005608 | |
| vnode_gets : 0 | |
| vnode_gets_total : 6 | |
| vnode_puts : 0 | |
| vnode_puts_total : 7 | |
| vnode_index_reads : 0 | |
| vnode_index_reads_total : 0 | |
| vnode_index_writes : 0 | |
| vnode_index_writes_total : 0 | |
| vnode_index_writes_postings : 0 |
This file contains hidden or 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
| import re | |
| def is_number(s): | |
| try: | |
| float(s) | |
| return True | |
| except ValueError: | |
| return False | |
| def status_to_json(raw_stats): |