couchbase

Documentation

Index

• Variables
• type Collection
  • func (c *Collection) CallContext(ctx context.Context, query string, ...) error
  • func (c *Collection) CallTransaction(ctx context.Context, query string, ...) error
• type Config
  • func NewConfig(cfg *config.Config) Config
• type Couchbase
  • func NewCouchbase(l *zap.Logger, cfg Config) (*Couchbase, error)
  • func (c *Couchbase) GetCollection(bucketName, collectionName string) (connectors.DBConnector[*gocb.Collection, *txtype.CollectionTx], error)

Variables

var (
	ErrEmptyBuckets = errors.New("empty buckets")
)

var Module = types.Module{
	{CreateFunc: NewConfig},
	{CreateFunc: NewCouchbase},
}

Types

type Collection

type Collection struct {
	// contains filtered or unexported fields
}

func (*Collection) CallContext

func (c *Collection) CallContext(
	ctx context.Context,
	query string,
	f func(ctx context.Context, collection *gocb.Collection) error,
) error

func (*Collection) CallTransaction

func (c *Collection) CallTransaction(
	ctx context.Context,
	query string,
	f func(ctx context.Context, c *txtype.CollectionTx) error,
) error

type Config

type Config struct {
	DSN         string
	User        string
	Password    string
	Buckets     []string
	AppName     string
	EnableDebug bool
}

func NewConfig

func NewConfig(cfg *config.Config) Config

type Couchbase

type Couchbase struct {
	// contains filtered or unexported fields
}

func NewCouchbase

func NewCouchbase(l *zap.Logger, cfg Config) (*Couchbase, error)

func (*Couchbase) GetCollection

func (c *Couchbase) GetCollection(bucketName, collectionName string) (connectors.DBConnector[*gocb.Collection, *txtype.CollectionTx], error)