mongo

Jul 9, 2021

Changes in this version

+ const LastUpdatedKey

+ const UniqueTimestampKey

+ func Close(ctx context.Context, session *mgo.Session) error

+ 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 []bson.MongoTimestamp, 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 bson.MongoTimestamp) bson.M

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

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

+ type Graceful interface

+ type Timestamps struct

+ LastUpdated time.Time

+ UniqueTimestamp *bson.MongoTimestamp