riakpbc panic test case

riakpbc-close-test.go

package main

import (
	"fmt"
	"log"

	"github.com/mrb/riakpbc"
)

func main() {
	var err error

	riak := riakpbc.NewClient([]string{"127.0.0.1:8087"})

	if err = riak.Dial(); err != nil {
		log.Fatalf(err.Error())
	}

	log.Printf("Stop riak and press enter... I'll wait here.")

	fmt.Scanf("\n")

	log.Printf("Do we panic?")

	_, err = riak.FetchObject("not_a_bucket", "not_a_key")

	switch err {
	case riakpbc.ErrObjectNotFound:
		log.Fatalf("Riak wasn't stopped, try agian.")
	case nil:
		log.Fatalf("Really? not_a_bucket/not_a_key exists? ;-(")
	default:
		log.Fatalf("Some other error occured: %s", err)
	}
}