interfaces.go

package tcb

import (
	"github.com/couchbase/gocb"
)

// CouchBaseAdapter CouchBase connect Adapter
type CouchBaseAdapter interface {
	Configurer
	Logger
}

// Configurer governs for configure and open connect
type Configurer interface {
	Open() error
	Close(bucket string) error
	CloseAll() error
	Cluster() *gocb.Cluster
	AddBucket(bucket, password string) (*gocb.Bucket, error)
	Bucket(name string) *gocb.Bucket
	Operator(bucketName string) (Operator, error)
}

// Operator abstracted for operating on couchbase
type Operator interface {
	Get(key string, data interface{}) (gocb.Cas, error)
	Insert(key string, data interface{}, expire uint32) (gocb.Cas, error)
	Upsert(key string, data interface{}, expire uint32) (gocb.Cas, error)
	Remove(key string) (gocb.Cas, error)
	N1qlQuery(q string, params interface{}) (gocb.QueryResults, error)
	N1qlQueryWithMode(mode gocb.ConsistencyMode, q string, params interface{}) (gocb.QueryResults, error)
}

// Logger logging interface
type Logger interface {
	Log(...interface{})
	Logf(format string, v ...interface{})
}