reindexer

Documentation

Index

• Constants
• Variables
• type Config
  • func (c *Config) ValidAndRepair() error
• type Conn
  • func Open(conf Config, logger tracer.Log) (*Conn, error)
  • func (db *Conn) Close() error
  • func (db *Conn) Create(ns string, item interface{}) (err error)
  • func (db *Conn) Delete(ns string, item interface{}) error
  • func (db *Conn) Deletes(ctx context.Context, q Query) (err error)
  • func (db *Conn) ExecSQL(query string) *reindexer.Iterator
  • func (db *Conn) Exists(ctx context.Context, q Query) (exist bool, err error)
  • func (db *Conn) Get(ctx context.Context, q Query) (item interface{}, err error)
  • func (db *Conn) Migrate(namespaces map[string]interface{}, dropOnIndexesConflict bool) error
  • func (db *Conn) Query(ns string) Query
  • func (db *Conn) TryDeletes(ctx context.Context, q Query) (err error)
  • func (db *Conn) Update(ns string, item interface{}) (err error)
  • func (db *Conn) Updates(ctx context.Context, q Query) error
• type Query

Constants

const (
	EQ     = reindexer.EQ     // =
	GT     = reindexer.GT     // >
	LT     = reindexer.LT     // <
	GE     = reindexer.GE     // >= (GT|EQ)
	LE     = reindexer.LE     // <= (LT|EQ)
	SET    = reindexer.SET    // one of set in []
	ALLSET = reindexer.ALLSET // all of set in []
	RANGE  = reindexer.RANGE  // value in RANGE from,to
	ANY    = reindexer.ANY    // any value
	EMPTY  = reindexer.EMPTY  // empty value or len(value array) == 0
	LIKE   = reindexer.LIKE   // string like pattern
)

Variables

var (
	ErrPrimaryKey = errors.New("primary key error")
	ErrNoAffected = errors.New("no affected rows")
)

Types

type Config

type Config struct {
	Addr     string `desc:"database address (ip:port)"`
	Name     string `desc:"database name"`
	Username string
	Password string
	Builtin  bool `desc:"enable builtin mode"`
	// contains filtered or unexported fields
}

func (*Config) ValidAndRepair

func (c *Config) ValidAndRepair() error

type Conn

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

func Open

func Open(conf Config, logger tracer.Log) (*Conn, error)

Open reindexer database client

func (*Conn) Close

func (db *Conn) Close() error

func (*Conn) Create

func (db *Conn) Create(ns string, item interface{}) (err error)

Create new item

func (*Conn) Delete

func (db *Conn) Delete(ns string, item interface{}) error

Delete item

func (*Conn) Deletes

func (db *Conn) Deletes(ctx context.Context, q Query) (err error)

Deletes items by query

func (*Conn) ExecSQL

func (db *Conn) ExecSQL(query string) *reindexer.Iterator

func (*Conn) Exists

func (db *Conn) Exists(ctx context.Context, q Query) (exist bool, err error)

Exists items by query

func (*Conn) Get

func (db *Conn) Get(ctx context.Context, q Query) (item interface{}, err error)

Get item by query

func (*Conn) Migrate

func (db *Conn) Migrate(namespaces map[string]interface{}, dropOnIndexesConflict bool) error

func (*Conn) Query

func (db *Conn) Query(ns string) Query

func (*Conn) TryDeletes

func (db *Conn) TryDeletes(ctx context.Context, q Query) (err error)

TryDeletes items by query

func (*Conn) Update

func (db *Conn) Update(ns string, item interface{}) (err error)

Update item

func (*Conn) Updates

func (db *Conn) Updates(ctx context.Context, q Query) error

Updates items by query

type Query

type Query = *reindexer.Query