repo

Documentation

Index

• type IRepo
  • func NewRepo() IRepo
• type Repo
  • func (r *Repo) CreateCollection(scope, name string) error
  • func (r *Repo) CreateIndex(query string) error
  • func (r *Repo) CreateScope(name string) error
  • func (r *Repo) GetAllScopes() ([]gocb.ScopeSpec, error)
  • func (r *Repo) Init(uri string, opts *option.Options) error
  • func (r *Repo) UpsertData(scope, collection string, docs []gocb.BulkOp) error

Types

type IRepo

type IRepo interface {
	Init(uri string, opts *option.Options) error
	GetAllScopes() ([]gocb.ScopeSpec, error)
	CreateScope(name string) error
	CreateCollection(scope, name string) error
	UpsertData(scope, collection string, docs []gocb.BulkOp) error
	CreateIndex(query string) error
}

func NewRepo

func NewRepo() IRepo

type Repo

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

func (*Repo) CreateCollection

func (r *Repo) CreateCollection(scope, name string) error

func (*Repo) CreateIndex

func (r *Repo) CreateIndex(query string) error

func (*Repo) CreateScope

func (r *Repo) CreateScope(name string) error

func (*Repo) GetAllScopes

func (r *Repo) GetAllScopes() ([]gocb.ScopeSpec, error)

func (*Repo) Init

func (r *Repo) Init(uri string, opts *option.Options) error

func (*Repo) UpsertData

func (r *Repo) UpsertData(scope, collection string, docs []gocb.BulkOp) error