riak_client.go

package main

import (
  "fmt"
  "log"
  "strconv"
  "github.com/tpjg/goriakpbc"
)

func main() {

  err := riak.ConnectClientPool("127.0.0.1:8087", 32)
  if err != nil {
    fmt.Println("Cannot connect, is Riak running?")
    return
  }

  bucket, _ := riak.NewBucket("tstriak")
  obj := bucket.NewObject("tstobj")
  obj.ContentType = "application/json"
  obj.Data = []byte("{'field':'value'}")
  obj.Store()
  fmt.Printf("Stored an object in Riak, vclock = %v\n", obj.Vclock)

  for i := 0; i < 100; i++ {
    t := strconv.Itoa(i)
    fmt.Println(t)
    obj := bucket.NewObject(t)
    obj.ContentType = "application/json"
    obj.Data = []byte("{'field':'value'}")
    err = obj.Store()
    if err != nil {
      log.Fatal(err)
    }
  }

  riak.Close()
}