mongo

Documentation

Index

• Constants
• func Create(addr string, opt graph.Options) (nosql.Database, error)
• func Open(addr string, opt graph.Options) (nosql.Database, error)
• type DB
  • func (db *DB) BatchInsert(col string) nosql.DocWriter
  • func (db *DB) Close() error
  • func (db *DB) Delete(col string) nosql.Delete
  • func (db *DB) EnsureIndex(ctx context.Context, col string, primary nosql.Index, secondary []nosql.Index) error
  • func (db *DB) FindByKey(ctx context.Context, col string, key nosql.Key) (nosql.Document, error)
  • func (db *DB) Insert(ctx context.Context, col string, key nosql.Key, d nosql.Document) (nosql.Key, error)
  • func (db *DB) Query(col string) nosql.Query
  • func (db *DB) Update(col string, key nosql.Key) nosql.Update
• type Delete
  • func (d *Delete) Do(ctx context.Context) error
  • func (d *Delete) Keys(keys ...nosql.Key) nosql.Delete
  • func (d *Delete) WithFields(filters ...nosql.FieldFilter) nosql.Delete
• type Iterator
  • func (it *Iterator) Close() error
  • func (it *Iterator) Doc() nosql.Document
  • func (it *Iterator) Err() error
  • func (it *Iterator) Key() nosql.Key
  • func (it *Iterator) Next(ctx context.Context) bool
• type Query
  • func (q *Query) Count(ctx context.Context) (int64, error)
  • func (q *Query) Iterate() nosql.DocIterator
  • func (q *Query) Limit(n int) nosql.Query
  • func (q *Query) One(ctx context.Context) (nosql.Document, error)
  • func (q *Query) WithFields(filters ...nosql.FieldFilter) nosql.Query
• type Update
  • func (u *Update) Do(ctx context.Context) error
  • func (u *Update) Inc(field string, dn int) nosql.Update
  • func (u *Update) Push(field string, v nosql.Value) nosql.Update
  • func (u *Update) Upsert(d nosql.Document) nosql.Update

Constants

const Type = "mongo"

Functions

func Create

func Create(addr string, opt graph.Options) (nosql.Database, error)

func Open

func Open(addr string, opt graph.Options) (nosql.Database, error)

Types

type DB

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

func (*DB) BatchInsert

func (db *DB) BatchInsert(col string) nosql.DocWriter

func (*DB) Close

func (db *DB) Close() error

func (*DB) Delete

func (db *DB) Delete(col string) nosql.Delete

func (*DB) EnsureIndex

func (db *DB) EnsureIndex(ctx context.Context, col string, primary nosql.Index, secondary []nosql.Index) error

func (*DB) FindByKey

func (db *DB) FindByKey(ctx context.Context, col string, key nosql.Key) (nosql.Document, error)

func (*DB) Insert

func (db *DB) Insert(ctx context.Context, col string, key nosql.Key, d nosql.Document) (nosql.Key, error)

func (*DB) Query

func (db *DB) Query(col string) nosql.Query

func (*DB) Update

func (db *DB) Update(col string, key nosql.Key) nosql.Update

type Delete

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

func (*Delete) Do

func (d *Delete) Do(ctx context.Context) error

func (*Delete) Keys

func (d *Delete) Keys(keys ...nosql.Key) nosql.Delete

func (*Delete) WithFields

func (d *Delete) WithFields(filters ...nosql.FieldFilter) nosql.Delete

type Iterator

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

func (*Iterator) Close

func (it *Iterator) Close() error

func (*Iterator) Doc

func (it *Iterator) Doc() nosql.Document

func (*Iterator) Err

func (it *Iterator) Err() error

func (*Iterator) Key

func (it *Iterator) Key() nosql.Key

func (*Iterator) Next

func (it *Iterator) Next(ctx context.Context) bool

type Query

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

func (*Query) Count

func (q *Query) Count(ctx context.Context) (int64, error)

func (*Query) Iterate

func (q *Query) Iterate() nosql.DocIterator

func (*Query) Limit

func (q *Query) Limit(n int) nosql.Query

func (*Query) One

func (q *Query) One(ctx context.Context) (nosql.Document, error)

func (*Query) WithFields

func (q *Query) WithFields(filters ...nosql.FieldFilter) nosql.Query

type Update

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

func (*Update) Do

func (u *Update) Do(ctx context.Context) error

func (*Update) Inc

func (u *Update) Inc(field string, dn int) nosql.Update

func (*Update) Push

func (u *Update) Push(field string, v nosql.Value) nosql.Update

func (*Update) Upsert

func (u *Update) Upsert(d nosql.Document) nosql.Update