persistence

Oct 7, 2022

Changes in this version

+ type IMongoDbPersistenceOverrides interface

+ ConvertFromPublic func(item T) (map[string]any, error)

+ ConvertFromPublicPartial func(item T) (map[string]any, error)

+ ConvertToPublic func(item any) (T, error)

+ DefineSchema func()

+ type IdentifiableMongoDbPersistence struct

+ func InheritIdentifiableMongoDbPersistence(overrides IMongoDbPersistenceOverrides[T], collection string) *IdentifiableMongoDbPersistence[T, K]

+ func (c *IdentifiableMongoDbPersistence[T, K]) Configure(ctx context.Context, config *cconf.ConfigParams)

+ func (c *IdentifiableMongoDbPersistence[T, K]) Create(ctx context.Context, correlationId string, item T) (result T, err error)

+ func (c *IdentifiableMongoDbPersistence[T, K]) DeleteById(ctx context.Context, correlationId string, id K) (item T, err error)

+ func (c *IdentifiableMongoDbPersistence[T, K]) DeleteByIds(ctx context.Context, correlationId string, ids []K) error

+ func (c *IdentifiableMongoDbPersistence[T, K]) GetListByIds(ctx context.Context, correlationId string, ids []K) (items []T, err error)

+ func (c *IdentifiableMongoDbPersistence[T, K]) GetOneById(ctx context.Context, correlationId string, id K) (item T, err error)

+ func (c *IdentifiableMongoDbPersistence[T, K]) Set(ctx context.Context, correlationId string, item T) (result T, err error)

+ func (c *IdentifiableMongoDbPersistence[T, K]) Update(ctx context.Context, correlationId string, item T) (result T, err error)

+ func (c *IdentifiableMongoDbPersistence[T, K]) UpdatePartially(ctx context.Context, correlationId string, id K, data cdata.AnyValueMap) (item T, err error)

+ type MongoDbPersistence struct

+ Client *mongodrv.Client

+ Collection *mongodrv.Collection

+ CollectionName string

+ Connection *conn.MongoDbConnection

+ DatabaseName string

+ Db *mongodrv.Database

+ DependencyResolver *crefer.DependencyResolver

+ JsonConvertor cconv.IJSONEngine[T]

+ JsonMapConvertor cconv.IJSONEngine[map[string]any]

+ Logger clog.CompositeLogger

+ Overrides IMongoDbPersistenceOverrides[T]

+ func InheritMongoDbPersistence(overrides IMongoDbPersistenceOverrides[T], collection string) *MongoDbPersistence[T]

+ func (c *MongoDbPersistence[T]) Clear(ctx context.Context, correlationId string) error

+ func (c *MongoDbPersistence[T]) Close(ctx context.Context, correlationId string) error

+ func (c *MongoDbPersistence[T]) Configure(ctx context.Context, config *cconf.ConfigParams)

+ func (c *MongoDbPersistence[T]) ConvertFromPublic(value T) (map[string]any, error)

+ func (c *MongoDbPersistence[T]) ConvertFromPublicPartial(item T) (map[string]any, error)

+ func (c *MongoDbPersistence[T]) ConvertToPublic(value any) (T, error)

+ func (c *MongoDbPersistence[T]) Create(ctx context.Context, correlationId string, item T) (result T, err error)

+ func (c *MongoDbPersistence[T]) DefineSchema()

+ func (c *MongoDbPersistence[T]) DeleteByFilter(ctx context.Context, correlationId string, filter any) error

+ func (c *MongoDbPersistence[T]) EnsureIndex(keys any, options *mongoopt.IndexOptions)

+ func (c *MongoDbPersistence[T]) GetCountByFilter(ctx context.Context, correlationId string, filter any) (count int64, err error)

+ func (c *MongoDbPersistence[T]) GetListByFilter(ctx context.Context, correlationId string, filter any, sort any, sel any) (items []T, err error)

+ func (c *MongoDbPersistence[T]) GetOneRandom(ctx context.Context, correlationId string, filter any) (item T, err error)

+ func (c *MongoDbPersistence[T]) GetPageByFilter(ctx context.Context, correlationId string, filter any, ...) (page cdata.DataPage[T], err error)

+ func (c *MongoDbPersistence[T]) IsOpen() bool

+ func (c *MongoDbPersistence[T]) IsTerminated() bool

+ func (c *MongoDbPersistence[T]) Open(ctx context.Context, correlationId string) error

+ func (c *MongoDbPersistence[T]) SetReferences(ctx context.Context, references crefer.IReferences)

+ func (c *MongoDbPersistence[T]) UnsetReferences()