jjmalina

"""
           .dMMMb dMMMMMMP dMMMMb  dMP dMMMMb  .aMMMMP .dMMMb
          dMP" VP   dMP   dMP.dMP amr dMP dMP dMP"    dMP" VP
          VMMMb    dMP   dMMMMK" dMP dMP dMP dMP MMP" VMMMb
        dP .dMP   dMP   dMP"AMF dMP dMP dMP dMP.dMP dP .dMP
        VMMMP"   dMP   dMP dMP dMP dMP dMP  VMMMP"  VMMMP"

            .aMMMb  dMMMMb  dMMMMMP         dMMMMb  dMP dMP dMMMMMMP dMMMMMP .dMMMb
           dMP"dMP dMP.dMP dMP             dMP"dMP dMP.dMP    dMP   dMP     dMP" VP
          dMMMMMP dMMMMK" dMMMP           dMMMMK"  VMMMMP    dMP   dMMMP    VMMMb

jjmalina

$ brew update

$ brew install rbenv

$ brew install ruby-build

append eval "$(rbenv init -)" to your bash profile

$ rbenv install 1.9.3-p327

jjmalina

// Short module explanation             // Something to gather my thoughts
//                                      // I think this looks cool.
                                        //
module.exports = the_exported_function  // Modules are a function. Always.
                                        //
module.exports.extra = extra            // Additional API entry points if
module.exports.other = other            // desired.
                                        //
var util = require('util')              // Other packages from npm or core
var assert = require('assert')          // No comma-first due to lots of

jjmalina

# It's pretty annoying to get single CoffeeScript file compilation with grunt-contrib-coffee 
# and grunt-contrib-watch because it doesn't work out of the box.
#
# This is an open issue and it depends on how your project is structured and how your tasks are configured. 
# See: https://github.com/gruntjs/grunt-contrib-watch/issues/149
#
# Below is my simple solution which in a sort of hacky way alters the grunt config object at runtime.

module.exports = (grunt) ->

jjmalina

//
// insertion of logs into riak
// usage:
// cat logs | log-processing --host=127.0.0.1 --port=10017 mybucket

package main

import (
	"bufio"
	"encoding/json"

jjmalina

2013/11/22 13:33:59 ADDED 1VjPs9KAvFG52GuZJQsRvzgBN99 from line 2867651
2013/11/22 13:34:09 ADDED error from line 2867652
2013/11/22 13:34:09 ADDED error from line 2867653
2013/11/22 13:34:09 ADDED error from line 2867654
panic: interface conversion: interface is *riakpbc.RpbPutResp, not []uint8

goroutine 4 [running]:
github.com/mrb/riakpbc.(*Node).Ping(0xc200082190, 0xc20008b4b0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:141 +0xda
github.com/mrb/riakpbc.(*Pool).Ping(0xc20008b4d0)

jjmalina

//
// generates lines of json and sends them to stdout
// usage:
// make-logs -n 10000 | write-or-delete-logs mybucket

package main

import (
	"encoding/json"
	"flag"

jjmalina

//
// insertion or deletion of arbitrary json logs to riak
// usage:
// cat logs | write-or-delete-logs --hosts=127.0.0.1,127.0.0.2 --port=8087 mybucket 2>> write_log &
// OR you can delete EVERYTHING
// write-or-delete-logs --delete --hosts=127.0.0.1,127.0.0.2 --port=8087 mybucket

package main

import (

jjmalina

2013-12-03 23:40:00.823 [info] <0.489.0>@mi_scheduler:worker_loop:133 Pid <0.4398.0> compacted 20 segments for 6017383 bytes in 1.420779 seconds, 4.04 MB/sec
2013-12-03 23:40:07.463 [info] <0.489.0>@mi_scheduler:worker_loop:133 Pid <0.4987.0> compacted 12 segments for 28541685 bytes in 6.639782 seconds, 4.10 MB/sec
2013-12-03 23:40:25.105 [info] <0.489.0>@mi_scheduler:worker_loop:133 Pid <0.13536.16> compacted 9 segments for 57840707 bytes in 17.642435 seconds, 3.13 MB/sec
2013-12-03 23:40:33.330 [info] <0.489.0>@mi_scheduler:worker_loop:133 Pid <0.25160.10> compacted 13 segments for 47454983 bytes in 8.225041 seconds, 5.50 MB/sec 
2013-12-03 23:40:42.206 [info] <0.489.0>@mi_scheduler:worker_loop:133 Pid <0.6205.0> compacted 15 segments for 50722448 bytes in 8.875925 seconds, 5.45 MB/sec
2013-12-03 23:40:43.327 [info] <0.489.0>@mi_scheduler:worker_loop:133 Pid <0.4593.0> compacted 20 segments for 6306302 bytes in 1.121077 seconds, 5.36 MB/sec
2013-12-03 23:40:44.504 [info] <0.489.0>@mi_scheduler:worker_loop:1

jjmalina

2013/12/03 23:40:13 ADDED 2rKAq1snVFT978yI0mHt8XwAOod from line 2362324
2013/12/03 23:40:18 ADDED GMR5zWC2PKhG2Y6TVpdxhhLAO3X from line 2362325
2013/12/03 23:40:23 ERROR from line 2362326
2013/12/03 23:40:23 ERROR from line 2362327
panic: interface conversion: interface is *riakpbc.RpbPutResp, not []uint8

goroutine 11 [running]:
github.com/mrb/riakpbc.(*Node).Ping(0xc200083730, 0xc20008c4b0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:153 +0xde
github.com/mrb/riakpbc.(*Pool).Ping(0xc20008c510)