Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mongodb

package

Go to main page

Versions in this module

v2

v2.0.2

Nov 7, 2022

Changes in this version

type DatabaseOperator

+ func (d *DatabaseOperator) ExecuteDelete(ctx context.Context, delete *clerk.Delete[*clerk.Database]) (int, error)

v2.0.1

Nov 7, 2022

Changes in this version

+ type CollectionOperator struct

+ func (d *CollectionOperator) ExecuteDelete(ctx context.Context, delete *clerk.Delete[*clerk.Collection]) (int, error)

+ func (q *CollectionOperator) ExecuteQuery(ctx context.Context, query *clerk.Query[*clerk.Collection]) (<-chan *clerk.Collection, error)

+ func (u *CollectionOperator) ExecuteUpdate(ctx context.Context, update *clerk.Update[*clerk.Collection]) error

+ type DatabaseOperator struct

+ func (q *DatabaseOperator) ExecuteQuery(ctx context.Context, query *clerk.Query[*clerk.Database]) (<-chan *clerk.Database, error)

+ func (t *DatabaseOperator) ExecuteTransaction(ctx context.Context, fn clerk.TransactionFn) error

+ type IndexOperator struct

+ func (c *IndexOperator) ExecuteCreate(ctx context.Context, create *clerk.Create[*clerk.Index]) error

+ func (d *IndexOperator) ExecuteDelete(ctx context.Context, delete *clerk.Delete[*clerk.Index]) (int, error)

+ func (q *IndexOperator) ExecuteQuery(ctx context.Context, query *clerk.Query[*clerk.Index]) (<-chan *clerk.Index, error)

+ type Operator struct

+ func (c *Operator) ExecuteCreate(ctx context.Context, create *clerk.Create[T]) error

+ func (d *Operator) ExecuteDelete(ctx context.Context, delete *clerk.Delete[T]) (int, error)

+ func (q *Operator) ExecuteQuery(ctx context.Context, query *clerk.Query[T]) (<-chan T, error)

+ func (u *Operator) ExecuteUpdate(ctx context.Context, update *clerk.Update[T]) error

+ func (w *Operator) ExecuteWatch(ctx context.Context, watch *clerk.Watch[T]) (<-chan *clerk.Event[T], error)

v2.0.0

Nov 3, 2022

Changes in this version

+ var ErrUnknownFilter = errors.New("unknown filter")

+ func NewCollectionOperator(connection *Connection, database *clerk.Database) *collectionOperator

+ func NewDatabaseOperator(connection *Connection) *databaseOperator

+ func NewIndexOperator(connection *Connection, collection *clerk.Collection) *indexOperator

+ func NewOperator(connection *Connection, collection *clerk.Collection) *operator[T]

+ type Connection struct

+ func NewConnection(ctx context.Context, uri string) (*Connection, error)

+ func (c *Connection) Close(handler func(err error))

Other modules containing this package

github.com/Becklyn/clerk

github.com/Becklyn/clerk/v3

github.com/Becklyn/clerk/v4