output.txt

$ test
> Connected!
> Stored test object!
> Fetched stored object: this is a test

test.go

package main

import (
  "fmt"
	"github.com/mrb/riakpbc"
)

func main() {
	riak := riakpbc.NewClient([]string{"127.0.0.1:8087"})
	if err := riak.Dial(); err != nil {
		fmt.Println("! Couldn't connect")
	} else {
		fmt.Println("> Connected!")
	}

	if _, err := riak.StoreObject("test", "key", "this is a test"); err != nil {
		fmt.Println("! Couldn't store an object")
	} else {
		fmt.Println("> Stored test object!")
	}

	obj, err := riak.FetchObject("test", "key")
	if err != nil {
		fmt.Println("! Couldn't fetch stored object: %s", err)
	} else {
		fmt.Printf("> Fetched stored object: %s\n", obj.GetContent()[0].Value)
	}
	riak.Close()
}