mongoclient

Dec 6, 2024

Changes in this version

type Collection

+ func (c *Collection) Find(filter Document) (Documents, error)

May 16, 2024

Changes in this version

type Document

+ func (d *Document) ToBson() (bson.D, error)

+ func (d *Document) ToEJson() (string, error)

May 8, 2024

Changes in this version

+ const PlaceholderCollectionName

+ type Collection struct

+ func (c *Collection) Client() *MongoClient

+ func (c *Collection) Database() *Database

+ func (c *Collection) DeleteByID(id string) error

+ func (c *Collection) Drop() error

+ func (c *Collection) EnsureExistance() error

+ func (c *Collection) Exists() (bool, error)

+ func (c *Collection) FindById(id string, opts *FindByIdOptions) (Document, error)

+ func (c *Collection) Index(name string) *Index

+ func (c *Collection) IndexFromField(field string, direction int, unique bool) *Index

+ func (c *Collection) InsertOne(document Document) (string, error)

+ func (c *Collection) IsEmpty() (bool, error)

+ func (c *Collection) Name() string

+ func (c *Collection) UpdateByID(id string, update Document) error

+ func (c *Collection) WithContext(ctx context.Context) *Collection

+ func (c *Collection) WithLogger(logger *zap.Logger) *Collection

+ type Config struct

+ URI string

+ type Database struct

+ func (d *Database) Client() *MongoClient

+ func (d *Database) Collection(name string) *Collection

+ func (d *Database) Drop() error

+ func (d *Database) EnsureExistance() error

+ func (d *Database) Exists() (bool, error)

+ func (d *Database) IsEmpty() (bool, error)

+ func (d *Database) Name() string

+ func (d *Database) WithContext(ctx context.Context) *Database

+ func (d *Database) WithLogger(logger *zap.Logger) *Database

+ type Document map[string]interface

+ type Documents []Document

+ type FindByIdOptions struct

+ IncludeId bool

+ type Index struct

+ func (i *Index) Client() *MongoClient

+ func (i *Index) Collection() *Collection

+ func (i *Index) Database() *Database

+ func (i *Index) Direction() int

+ func (i *Index) Drop() error

+ func (i *Index) EnsureExistance() error

+ func (i *Index) Exists() (bool, error)

+ func (i *Index) Field() string

+ func (i *Index) GetSpec() (*SanitizedIndexSpec, error)

+ func (i *Index) Hydrate(spec *SanitizedIndexSpec) *Index

+ func (i *Index) Name() string

+ func (i *Index) Unique() bool

+ func (i *Index) WithContext(ctx context.Context) *Index

+ type MongoClient struct

+ func FromURI(uri string) *MongoClient

+ func New(ctx context.Context, config *Config) *MongoClient

+ func (c *MongoClient) Client() *mongo.Client

+ func (c *MongoClient) Connect() error

+ func (c *MongoClient) Database(name string) *Database

+ func (c *MongoClient) Disconnect()

+ func (c *MongoClient) IsConnected() bool

+ func (c *MongoClient) Run(callback func(client *MongoClient, err error))

+ func (c *MongoClient) WithContext(ctx context.Context) *MongoClient

+ func (c *MongoClient) WithLogger(logger *zap.Logger) *MongoClient

+ type SanitizedIndexSpec struct

+ Direction int

+ Field string

+ Name string

+ Unique bool