godm

Documentation

Index

• func SetConn(c Connection) func(query *Query)
• type A
• type Connection
• type Input
• type InputEndpoint
• type M
• type Options
  • func (o *Options) FindOneAndDeleteOptions() *options.FindOneAndDeleteOptions
  • func (o *Options) FindOneAndReplaceOptions() *options.FindOneAndReplaceOptions
  • func (o *Options) FindOneAndUpdateOptions() *options.FindOneAndUpdateOptions
  • func (o *Options) FindOneOptions() *options.FindOneOptions
  • func (o *Options) InsertOneOptions() *options.InsertOneOptions
• type PipelineFn
• type Query
  • func NewQuery(fn ...func(query *Query)) *Query
  • func NewQueryWitConn(c Connection) *Query
  • func (q *Query) All(value interface{}) *Query
  • func (q *Query) And(value interface{}) *Query
  • func (q *Query) AutoBindConditions(flag string, condition interface{}) *Query
  • func (q *Query) ElemMatch(value interface{}) *Query
  • func (q *Query) Eq(input interface{}) *Query
  • func (q *Query) Equals(input interface{}) *Query
  • func (q *Query) Exists(value bool) *Query
  • func (q *Query) FindOne(ctx context.Context, pipeline PipelineFn) error
  • func (q *Query) FindOneAndDelete(ctx context.Context, pipeline PipelineFn) error
  • func (q *Query) FindOneAndReplace(ctx context.Context, replacement interface{}, pipeline PipelineFn) error
  • func (q *Query) FindOneAndUpdateOne(ctx context.Context, update interface{}, pipeline PipelineFn) error
  • func (q *Query) GetConditions() M
  • func (q *Query) GetSelect() M
  • func (q *Query) Gt(value interface{}) *Query
  • func (q *Query) Gte(value interface{}) *Query
  • func (q *Query) In(value interface{}) *Query
  • func (q *Query) InsertOne(ctx context.Context, pipeline PipelineFn) error
  • func (q *Query) Lt(value interface{}) *Query
  • func (q *Query) Lte(value interface{}) *Query
  • func (q *Query) MaxDistance(value interface{}) *Query
  • func (q *Query) MinDistance(value interface{}) *Query
  • func (q *Query) Mod(value interface{}) *Query
  • func (q *Query) Ne(value interface{}) *Query
  • func (q *Query) Nin(value interface{}) *Query
  • func (q *Query) Nor(value interface{}) *Query
  • func (q *Query) Not(value interface{}) *Query
  • func (q *Query) Or(value interface{}) *Query
  • func (q *Query) Regex(value interface{}) *Query
  • func (q *Query) Select(value interface{}) *Query
  • func (q *Query) Set(field string) *Query
  • func (q *Query) Size(value interface{}) *Query
  • func (q *Query) Skip(value int32) *Query
  • func (q *Query) Sort(value interface{}) *Query
  • func (q *Query) Where(args ...interface{}) *Query

Functions

func SetConn

func SetConn(c Connection) func(query *Query)

Types

type A

type A []interface{}

type Connection

type Connection interface {
	InsertOne(ctx context.Context, doc interface{}, pipeline PipelineFn, opts *options.InsertOneOptions) error
	Find(ctx context.Context, filter interface{}, pipeline PipelineFn, opts *options.FindOptions) error
	FindOne(ctx context.Context, filter interface{}, pipeline PipelineFn, opts *options.FindOneOptions) error
	FindOneAndDelete(ctx context.Context, filter interface{}, pipeline PipelineFn, opts *options.FindOneAndDeleteOptions) error
	FindOneAndUpdate(ctx context.Context, filter, update interface{}, pipeline PipelineFn, opts *options.FindOneAndUpdateOptions) error
	FindOneAndReplace(ctx context.Context, filter, replacement interface{}, pipeline PipelineFn, opts *options.FindOneAndReplaceOptions) error
	Where(args ...interface{}) *Query
}

type Input

type Input interface{}

type InputEndpoint

type InputEndpoint func(Input) Input

type M

type M map[string]interface{}

type Options

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

func (*Options) FindOneAndDeleteOptions

func (o *Options) FindOneAndDeleteOptions() *options.FindOneAndDeleteOptions

func (*Options) FindOneAndReplaceOptions

func (o *Options) FindOneAndReplaceOptions() *options.FindOneAndReplaceOptions

func (*Options) FindOneAndUpdateOptions

func (o *Options) FindOneAndUpdateOptions() *options.FindOneAndUpdateOptions

func (*Options) FindOneOptions

func (o *Options) FindOneOptions() *options.FindOneOptions

func (*Options) InsertOneOptions

func (o *Options) InsertOneOptions() *options.InsertOneOptions

type PipelineFn

type PipelineFn func(interface{}) error

type Query

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

func NewQuery

func NewQuery(fn ...func(query *Query)) *Query

func NewQueryWitConn

func NewQueryWitConn(c Connection) *Query

func (*Query) All

func (q *Query) All(value interface{}) *Query

func (*Query) And

func (q *Query) And(value interface{}) *Query

func (*Query) AutoBindConditions

func (q *Query) AutoBindConditions(flag string, condition interface{}) *Query

func (*Query) ElemMatch

func (q *Query) ElemMatch(value interface{}) *Query

func (*Query) Eq

func (q *Query) Eq(input interface{}) *Query

func (*Query) Equals

func (q *Query) Equals(input interface{}) *Query

func (*Query) Exists

func (q *Query) Exists(value bool) *Query

func (*Query) FindOne

func (q *Query) FindOne(ctx context.Context, pipeline PipelineFn) error

func (*Query) FindOneAndDelete

func (q *Query) FindOneAndDelete(ctx context.Context, pipeline PipelineFn) error

func (*Query) FindOneAndReplace

func (q *Query) FindOneAndReplace(ctx context.Context, replacement interface{}, pipeline PipelineFn) error

func (*Query) FindOneAndUpdateOne

func (q *Query) FindOneAndUpdateOne(ctx context.Context, update interface{}, pipeline PipelineFn) error

func (*Query) GetConditions

func (q *Query) GetConditions() M

func (*Query) GetSelect

func (q *Query) GetSelect() M

func (*Query) Gt

func (q *Query) Gt(value interface{}) *Query

func (*Query) Gte

func (q *Query) Gte(value interface{}) *Query

func (*Query) In

func (q *Query) In(value interface{}) *Query

func (*Query) InsertOne

func (q *Query) InsertOne(ctx context.Context, pipeline PipelineFn) error

func (*Query) Lt

func (q *Query) Lt(value interface{}) *Query

func (*Query) Lte

func (q *Query) Lte(value interface{}) *Query

func (*Query) MaxDistance

func (q *Query) MaxDistance(value interface{}) *Query

func (*Query) MinDistance

func (q *Query) MinDistance(value interface{}) *Query

func (*Query) Mod

func (q *Query) Mod(value interface{}) *Query

func (*Query) Ne

func (q *Query) Ne(value interface{}) *Query

func (*Query) Nin

func (q *Query) Nin(value interface{}) *Query

func (*Query) Nor

func (q *Query) Nor(value interface{}) *Query

e.g. query.Nor([]M{{"name": "weny"}, {"age": "20"}})

func (*Query) Not

func (q *Query) Not(value interface{}) *Query

func (*Query) Or

func (q *Query) Or(value interface{}) *Query

e.g. query.Or([]M{{"name": "weny"}, {"age": "20"}})

func (*Query) Regex

func (q *Query) Regex(value interface{}) *Query

func (*Query) Select

func (q *Query) Select(value interface{}) *Query

func (*Query) Set

func (q *Query) Set(field string) *Query

func (*Query) Size

func (q *Query) Size(value interface{}) *Query

func (*Query) Skip

func (q *Query) Skip(value int32) *Query

func (*Query) Sort

func (q *Query) Sort(value interface{}) *Query

func (*Query) Where

func (q *Query) Where(args ...interface{}) *Query