riakshell.go

// tim$ go install
// tim$ cat logs | riakshell

package main

import (
	"bufio"
	"github.com/mrb/riakpbc"
	"io"
	"log"
	"os"
)

func main() {
	riak := riakpbc.NewClient([]string{"127.0.0.1:8087"})
	if err := riak.Dial(); err != nil {
		log.Print(err.Error())
	}

	bio := bufio.NewReader(os.Stdin)
	for {
		line, err := bio.ReadString('\n')
		log.Print(line)
		if _, riak_err := riak.StoreObject("bucket", "other", line); riak_err != nil {
			log.Println(riak_err.Error())
		}

		if err != nil {
			if err == io.EOF {
				break
			}

			log.Println(err)
		}

	}

	log.Println("Done!")
}