mongodb

Documentation

Index

• Constants
• func BleveQueryToMongoFilters(queryString string, insensitive bool, fieldTransformer func(string) string) (filters []bson.E, err error)
• func NewDAO(ctx context.Context, driver string, dsn string, prefix string) (dao.DAO, error)
• func NewIndexer(ctx context.Context, dao dao.DAO) (dao.IndexDAO, error)
• type CollStats
• type Collation
• type Collection
• type DAO
• type Handler
  • func (h *Handler) Collection(name string) *mongo.Collection
  • func (h *Handler) DB() *mongo.Database
  • func (h *Handler) Init(ctx context.Context, cfg configx.Values) error
• type IndexDAO
• type Indexer
  • func (i *Indexer) Close(ctx context.Context) error
  • func (i *Indexer) DeleteMany(ctx context.Context, query interface{}) (int32, error)
  • func (i *Indexer) DeleteOne(ctx context.Context, data interface{}) error
  • func (i *Indexer) FindMany(ctx context.Context, query interface{}, offset, limit int32, sortFields string, ...) (chan interface{}, error)
  • func (i *Indexer) Flush(ctx context.Context) error
  • func (i *Indexer) Init(ctx context.Context, cfg configx.Values) error
  • func (i *Indexer) InsertOne(ctx context.Context, data interface{}) error
  • func (i *Indexer) Resync(ctx context.Context, logger func(string)) error
  • func (i *Indexer) SetCodex(c dao.IndexCodex)
  • func (i *Indexer) SetCollection(c string)
  • func (i *Indexer) Truncate(ctx context.Context, max int64, logger func(string)) error
• type Model
  • func (m Model) Init(ctx context.Context, dao DAO) error

Constants

const Driver = "mongodb"

Functions

func BleveQueryToMongoFilters

func BleveQueryToMongoFilters(queryString string, insensitive bool, fieldTransformer func(string) string) (filters []bson.E, err error)

BleveQueryToMongoFilters parses a Blevesearch query string to a slice of bson primitives

func NewDAO

func NewDAO(ctx context.Context, driver string, dsn string, prefix string) (dao.DAO, error)

NewDAO creates a new handler for the boltdb dao

func NewIndexer

func NewIndexer(ctx context.Context, dao dao.DAO) (dao.IndexDAO, error)

Types

type CollStats

type CollStats struct {
	Count       int64
	AvgObjSize  int64
	StorageSize int64
}

type Collation

type Collation struct {
	Locale   string
	Strength int
}

type Collection

type Collection struct {
	Name               string
	DefaultCollation   Collation
	Indexes            []map[string]int
	IDName             string
	TruncateSorterDesc string
}

type DAO

type DAO interface {
	dao.DAO
	Collection(name string) *mongo.Collection
	DB() *mongo.Database
}

DAO defines the functions specific to the boltdb dao

type Handler

type Handler struct {
	dao.DAO
	// contains filtered or unexported fields
}

Handler for the main functions of the DAO

func (*Handler) Collection

func (h *Handler) Collection(name string) *mongo.Collection

Collection returns a usable *mongo.Collection

func (*Handler) DB

func (h *Handler) DB() *mongo.Database

DB returns the bolt DB object

func (*Handler) Init

func (h *Handler) Init(ctx context.Context, cfg configx.Values) error

Init initialises the handler

type IndexDAO

type IndexDAO interface {
	DAO
	dao.IndexDAO
	SetCollection(string)
}

type Indexer

type Indexer struct {
	DAO
	// contains filtered or unexported fields
}

func (*Indexer) Close

func (i *Indexer) Close(ctx context.Context) error

func (*Indexer) DeleteMany

func (i *Indexer) DeleteMany(ctx context.Context, query interface{}) (int32, error)

func (*Indexer) DeleteOne

func (i *Indexer) DeleteOne(ctx context.Context, data interface{}) error

func (*Indexer) FindMany

func (i *Indexer) FindMany(ctx context.Context, query interface{}, offset, limit int32, sortFields string, sortDesc bool, customCodec dao.IndexCodex) (chan interface{}, error)

func (*Indexer) Flush

func (i *Indexer) Flush(ctx context.Context) error

func (*Indexer) Init

func (i *Indexer) Init(ctx context.Context, cfg configx.Values) error

func (*Indexer) InsertOne

func (i *Indexer) InsertOne(ctx context.Context, data interface{}) error

func (*Indexer) Resync

func (i *Indexer) Resync(ctx context.Context, logger func(string)) error

func (*Indexer) SetCodex

func (i *Indexer) SetCodex(c dao.IndexCodex)

func (*Indexer) SetCollection

func (i *Indexer) SetCollection(c string)

func (*Indexer) Truncate

func (i *Indexer) Truncate(ctx context.Context, max int64, logger func(string)) error

Truncate removes records from collection. If max is set, we find the starting index for deletion based on the collection average object size (using collStats command)

type Model

type Model struct {
	Collections []Collection
}

func (Model) Init

func (m Model) Init(ctx context.Context, dao DAO) error