mongodb

Dec 16, 2022

Changes in this version

type Collection

+ func (c *Collection) DeleteOne(ctx context.Context, selector interface{}) (*CollectionDeleteResult, error)

+ func (c *Collection) InsertOne(ctx context.Context, document interface{}) (*CollectionInsertResult, error)

+ func (c *Collection) UpdateOne(ctx context.Context, selector interface{}, update interface{}) (*CollectionUpdateResult, error)

+ func (c *Collection) UpsertOne(ctx context.Context, selector interface{}, update interface{}) (*CollectionUpdateResult, error)

type Must

+ func (m *Must) DeleteOne(ctx context.Context, selector interface{}) (*CollectionDeleteResult, error)

+ func (m *Must) UpdateMany(ctx context.Context, selector interface{}, update interface{}) (*CollectionUpdateResult, error)

+ func (m *Must) UpdateOne(ctx context.Context, selector interface{}, update interface{}) (*CollectionUpdateResult, error)

Nov 25, 2022

Changes in this version

type MongoConnection

+ func (ms *MongoConnection) RunTransaction(ctx context.Context, withRetries bool, fn TransactionFunc) (interface{}, error)

+ type TransactionFunc func(transactionCtx context.Context) (interface{}, error)

Sep 20, 2022

Changes in this version

type Collection

+ func (c *Collection) FindCursor(ctx context.Context, filter interface{}, opts ...FindOption) (Cursor, error)

+ type Cursor interface

+ Close func(ctx context.Context) error

+ Decode func(val interface{}) error

+ Err func() error

+ Next func(ctx context.Context) bool

Apr 21, 2022

Changes in this version

+ const LastUpdatedKey

+ const UniqueTimestampKey

+ var ErrDisconnect = mongo.ErrClientDisconnected

+ var ErrNoDocumentFound = mongo.ErrNoDocuments

+ var IgnoreZeroLimit = func() FindOption

+ var InvalidCACertChain = errors.New("cannot parse CA certificate chain - invalid or corrupt")

+ var Limit = func(l int) FindOption

+ var NoCACertChain = errors.New("no CA certificate chain supplied, or chain cannot be read")

+ var Offset = func(o int) FindOption

+ var Projection = func(p interface{}) FindOption

+ var Sort = func(s interface{}) FindOption

+ func IsServerErr(err error) bool

+ func IsTimeout(err error) bool

+ func WithLastUpdatedUpdate(updateDoc bson.M) (bson.M, error)

+ func WithNamespacedLastUpdatedUpdate(updateDoc bson.M, prefixes []string) (newUpdateDoc bson.M, err error)

+ func WithNamespacedUniqueTimestampQuery(queryDoc bson.M, timestamps []primitive.Timestamp, prefixes []string) bson.M

+ func WithNamespacedUniqueTimestampUpdate(updateDoc bson.M, prefixes []string) (newUpdateDoc bson.M, err error)

+ func WithNamespacedUpdates(updateDoc bson.M, prefixes []string) (bson.M, error)

+ func WithUniqueTimestampQuery(queryDoc bson.M, timestamp primitive.Timestamp) bson.M

+ func WithUniqueTimestampUpdate(updateDoc bson.M) (bson.M, error)

+ func WithUpdates(updateDoc bson.M) (bson.M, error)

+ type Collection struct

+ func NewCollection(collection *mongo.Collection) *Collection

+ func (c *Collection) Aggregate(ctx context.Context, pipeline, results interface{}) error

+ func (c *Collection) Count(ctx context.Context, filter interface{}, opts ...FindOption) (int, error)

+ func (c *Collection) Delete(ctx context.Context, selector interface{}) (*CollectionDeleteResult, error)

+ func (c *Collection) DeleteById(ctx context.Context, id interface{}) (*CollectionDeleteResult, error)

+ func (c *Collection) DeleteMany(ctx context.Context, selector interface{}) (*CollectionDeleteResult, error)

+ func (c *Collection) Distinct(ctx context.Context, fieldName string, filter interface{}) ([]interface{}, error)

+ func (c *Collection) Find(ctx context.Context, filter, results interface{}, opts ...FindOption) (int, error)

+ func (c *Collection) FindOne(ctx context.Context, filter interface{}, result interface{}, ...) error

+ func (c *Collection) Insert(ctx context.Context, document interface{}) (*CollectionInsertResult, error)

+ func (c *Collection) InsertMany(ctx context.Context, documents []interface{}) (*CollectionInsertManyResult, error)

+ func (c *Collection) Must() *Must

+ func (c *Collection) NewLockClient() *lock.Client

+ func (c *Collection) Update(ctx context.Context, selector interface{}, update interface{}) (*CollectionUpdateResult, error)

+ func (c *Collection) UpdateById(ctx context.Context, id interface{}, update interface{}) (*CollectionUpdateResult, error)

+ func (c *Collection) UpdateMany(ctx context.Context, selector interface{}, update interface{}) (*CollectionUpdateResult, error)

+ func (c *Collection) Upsert(ctx context.Context, selector interface{}, update interface{}) (*CollectionUpdateResult, error)

+ func (c *Collection) UpsertById(ctx context.Context, id interface{}, update interface{}) (*CollectionUpdateResult, error)

+ type CollectionDeleteResult struct

+ DeletedCount int

+ type CollectionInsertManyResult struct

+ InsertedIds []interface{}

+ type CollectionInsertResult struct

+ InsertedId interface{}

+ type CollectionUpdateResult struct

+ MatchedCount int

+ ModifiedCount int

+ UpsertedCount int

+ UpsertedID interface{}

+ type Error struct

+ func (e Error) Error() string

+ func (e Error) Unwrap() error

+ type FindOption func(*findOptions)

+ type Graceful interface

+ type MongoConnection struct

+ func NewMongoConnection(client *mongo.Client, database string) *MongoConnection

+ func Open(m *MongoDriverConfig) (*MongoConnection, error)

+ func (ms *MongoConnection) Close(ctx context.Context) error

+ func (ms *MongoConnection) Collection(collection string) *Collection

+ func (ms *MongoConnection) DropDatabase(ctx context.Context) error

+ func (ms *MongoConnection) ListCollectionsFor(ctx context.Context, database string) ([]string, error)

+ func (ms *MongoConnection) Ping(ctx context.Context, timeoutInSeconds time.Duration) error

+ func (ms *MongoConnection) RunCommand(ctx context.Context, runCommand interface{}) error

+ type MongoConnector interface

+ Close func(ctx context.Context) error

+ Collection func(collection string) *Collection

+ DropDatabase func(ctx context.Context) error

+ ListCollectionsFor func(ctx context.Context, database string) ([]string, error)

+ Ping func(ctx context.Context, timeoutInSeconds time.Duration) error

+ RunCommand func(ctx context.Context, runCommand interface{}) error

+ type MongoDriverConfig struct

+ ClusterEndpoint string

+ Collections map[string]string

+ ConnectTimeout time.Duration

+ Database string

+ IsStrongReadConcernEnabled bool

+ IsWriteConcernMajorityEnabled bool

+ Password string

+ QueryTimeout time.Duration

+ ReplicaSet string

+ Username string

+ func (m *MongoDriverConfig) ActualCollectionName(wellKnownName string) string

+ func (m *MongoDriverConfig) GetConnectionURI() (string, error)

+ type Must struct

+ func (m *Must) Delete(ctx context.Context, selector interface{}) (*CollectionDeleteResult, error)

+ func (m *Must) DeleteById(ctx context.Context, id interface{}) (*CollectionDeleteResult, error)

+ func (m *Must) DeleteMany(ctx context.Context, selector interface{}) (*CollectionDeleteResult, error)

+ func (m *Must) Update(ctx context.Context, selector interface{}, update interface{}) (*CollectionUpdateResult, error)

+ func (m *Must) UpdateById(ctx context.Context, id interface{}, update interface{}) (*CollectionUpdateResult, error)

+ type TLSConnectionConfig struct

+ CACertChain string

+ IsSSL bool

+ RealHostnameForSSH string

+ VerifyCert bool

+ func (m TLSConnectionConfig) GetTLSConfig() (*tls.Config, error)

+ type Timestamps struct

+ LastUpdated time.Time

+ UniqueTimestamp *primitive.Timestamp