cachedrepository

Feb 2, 2024

Changes in this version

+ type CacheActionCause int64

+ const CacheActionCauseReconciliation

+ const CacheActionCauseRepositoryAction

+ type CachedRepository struct

+ func NewCachedRepository[BaseEntity any, ProcessedEntity any, ChangeContext any](key string, repository Repository[BaseEntity, ChangeContext], ...) *CachedRepository[BaseEntity, ProcessedEntity, ChangeContext]

+ func (c *CachedRepository[BaseEntity, ProcessedEntity, ChangeContext]) Create(ctx context.Context, name string, entity BaseEntity, ...) error

+ func (c *CachedRepository[BaseEntity, ProcessedEntity, ChangeContext]) Delete(ctx context.Context, name string, changeContext *ChangeContext) error

+ func (c *CachedRepository[BaseEntity, ProcessedEntity, ChangeContext]) Read(ctx context.Context, name string) (ProcessedEntity, string, error)

+ func (c *CachedRepository[BaseEntity, ProcessedEntity, ChangeContext]) ReadAll(ctx context.Context) (map[string]ProcessedEntity, error)

+ func (c *CachedRepository[BaseEntity, ProcessedEntity, ChangeContext]) Reconcile(ctx context.Context, name string) error

+ func (c *CachedRepository[BaseEntity, ProcessedEntity, ChangeContext]) ReconcileAll(ctx context.Context) error

+ func (c *CachedRepository[BaseEntity, ProcessedEntity, ChangeContext]) Update(ctx context.Context, name string, entity BaseEntity, modifyIfMatchHash string, ...) error

+ type CustomCompare interface

+ IsEqual func(other any) (bool, error)

+ type CustomHash interface

+ Hash func() (string, error)

+ type ErrHashMismatch struct

+ func NewErrHashMismatch(providedHash string, actualHash string) ErrHashMismatch

+ func (e ErrHashMismatch) Error() string

+ type ErrRepositoryEntityNotFound struct

+ func NewErrRepositoryEntityNotFound(name string) ErrRepositoryEntityNotFound

+ func (e ErrRepositoryEntityNotFound) Error() string

+ type Hooks interface

+ OnCacheEntityAdded func(ctx context.Context, name string, entity Entity, cause CacheActionCause) error

+ OnCacheEntityRemoved func(ctx context.Context, name string, cause CacheActionCause) error

+ OnCacheEntityUpdated func(ctx context.Context, name string, entity Entity, cause CacheActionCause) error

+ OnRepositoryEntityCreated func(ctx context.Context, name string, entity Entity) error

+ OnRepositoryEntityDeleted func(ctx context.Context, name string) error

+ OnRepositoryEntityUpdated func(ctx context.Context, name string, entity Entity) error

+ type Processor interface

+ InverseProcessEntity func(ctx context.Context, entity ProcessedEntity) (BaseEntity, error)

+ ProcessEntity func(ctx context.Context, entity BaseEntity) (ProcessedEntity, error)

+ func NewNoProcessor[BaseEntity any]() Processor[BaseEntity, BaseEntity]

+ type Repository interface

+ Create func(ctx context.Context, name string, entity Entity, changeContext *ChangeContext) error

+ Delete func(ctx context.Context, name string, changeContext *ChangeContext) error

+ Read func(ctx context.Context, name string) (Entity, error)

+ ReadAll func(ctx context.Context) (map[string]Entity, error)

+ Update func(ctx context.Context, name string, entity Entity, changeContext *ChangeContext) error