Documentation ¶
Index ¶
- Constants
- Variables
- type BucketConfig
- type BucketOperator
- func (b *BucketOperator) Get(key string, data interface{}) (cas gocb.Cas, err error)
- func (b *BucketOperator) Insert(k string, d interface{}, e uint32) (cas gocb.Cas, err error)
- func (b *BucketOperator) N1qlQuery(q string, params interface{}) (r gocb.QueryResults, err error)
- func (b *BucketOperator) N1qlQueryWithMode(m gocb.ConsistencyMode, q string, params interface{}) (r gocb.QueryResults, err error)
- func (b *BucketOperator) Remove(key string) (cas gocb.Cas, err error)
- func (b *BucketOperator) Upsert(k string, d interface{}, e uint32) (cas gocb.Cas, err error)
- type Cluster
- func (a *Cluster) AddBucket(bucket, password string) (*gocb.Bucket, error)
- func (a *Cluster) Bucket(bucket string) *gocb.Bucket
- func (a *Cluster) Close(bucket string) error
- func (a *Cluster) CloseAll() error
- func (a *Cluster) Cluster() *gocb.Cluster
- func (a *Cluster) Open() error
- func (a *Cluster) Operator(bucket string) (Operator, error)
- type Configure
- type Configurer
- type CouchBaseAdapter
- type DefaultLogger
- type Logger
- type Operator
- type SilentLogger
Constants ¶
const (
ConsistencyModeNone = gocb.ConsistencyMode(-1)
)
Variables ¶
var ( // ErrBucketMissing Constant error for Missing bucket ErrBucketMissing error = errors.New("bucket is missing") )
var ErrOperationUnenforceable = errors.New("operator is nil or not enabled")
ErrOperationUnenforceable returns this error if operator is nil
Functions ¶
This section is empty.
Types ¶
type BucketConfig ¶
BucketConfig tuple for bucket connection
type BucketOperator ¶
BucketOperator Operator instance
func NewBucketOperator ¶
func NewBucketOperator(b *gocb.Bucket, l Logger) *BucketOperator
NewBucketOperator return new Operator instance
func (*BucketOperator) Get ¶
func (b *BucketOperator) Get(key string, data interface{}) (cas gocb.Cas, err error)
Get invoke gocb.Bucket.Get
func (*BucketOperator) N1qlQuery ¶
func (b *BucketOperator) N1qlQuery(q string, params interface{}) (r gocb.QueryResults, err error)
N1qlQuery prepare query and execute
func (*BucketOperator) N1qlQueryWithMode ¶
func (b *BucketOperator) N1qlQueryWithMode(m gocb.ConsistencyMode, q string, params interface{}) (r gocb.QueryResults, err error)
N1qlQuery prepare query and execute
type Cluster ¶
Cluster to connect couchbase
type Configure ¶
type Configure struct { ConnectString string User string Password string BucketConfigs []BucketConfig }
Configure struct for config
type Configurer ¶
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) }
Configurer governs for configure and open connect
type CouchBaseAdapter ¶
type CouchBaseAdapter interface { Configurer Logger }
CouchBaseAdapter CouchBase connect Adapter
type DefaultLogger ¶
DefaultLogger type-default logger
func NewDefaultActiveLogger ¶
func NewDefaultActiveLogger() *DefaultLogger
NewDefaultActiveLogger Generate New Silent Logger
func NewDefaultDisabledLogger ¶
func NewDefaultDisabledLogger() *DefaultLogger
NewDefaultDisabledLogger Generate New Silent Logger
func (*DefaultLogger) Log ¶
func (d *DefaultLogger) Log(v ...interface{})
Log logging with log-package
func (*DefaultLogger) LogEnabled ¶
func (d *DefaultLogger) LogEnabled() bool
LogEnabled return Log-enabled or not
func (*DefaultLogger) Logf ¶
func (d *DefaultLogger) Logf(f string, v ...interface{})
Logf logging with format using log-package
type Logger ¶
type Logger interface { Log(...interface{}) Logf(format string, v ...interface{}) }
Logger logging interface
type Operator ¶
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) }
Operator abstracted for operating on couchbase
type SilentLogger ¶
type SilentLogger struct{}
SilentLogger logger say noting
func (*SilentLogger) Logf ¶
func (s *SilentLogger) Logf(f string, v ...interface{})
Logf but say nothing with format either