bucket_test.go

package gocb

import (
	"flag"
	"fmt"
	"os"
	"testing"

	"gopkg.in/couchbaselabs/gojcbmock.v1"
)

var globalBucket *Bucket
var globalMock *gojcbmock.Mock
var globalCluster *Cluster

func TestMain(m *testing.M) {
	SetLogger(VerboseStdioLogger())
	flag.Parse()
	mpath, err := gojcbmock.GetMockPath()
	if err != nil {
		panic(err.Error())
	}

	globalMock, err = gojcbmock.NewMock(mpath, 4, 1, 64, []gojcbmock.BucketSpec{
		{Name: "default", Type: gojcbmock.BCouchbase},
		{Name: "memd", Type: gojcbmock.BMemcached},
	}...)

	if err != nil {
		panic(err.Error())
	}

	connStr := fmt.Sprintf("http://127.0.0.1:%d", globalMock.EntryPort)

	globalCluster, err = Connect(connStr)

	if err != nil {
		panic(err.Error())
	}

	globalBucket, err = globalCluster.OpenBucket("default", "")

	if err != nil {
		panic(err.Error())
	}

	os.Exit(m.Run())
}