Skip to content

Commit

Permalink
chore(ARCO-283): remove clear cache
Browse files Browse the repository at this point in the history
  • Loading branch information
pawellewandowski98 committed Nov 19, 2024
1 parent d490e9f commit 8093791
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 14 deletions.
5 changes: 0 additions & 5 deletions internal/metamorph/processor.go
Original file line number Diff line number Diff line change
Expand Up @@ -487,11 +487,6 @@ func (p *Processor) checkAndUpdate(ctx context.Context) error {
p.logger.Error("failed to bulk update statuses", slog.String("err", err.Error()))
}

err = p.clearCache(statusUpdatesMap)
if err != nil {
p.logger.Error("failed to clear status update cache", slog.String("err", err.Error()))
}

return nil
}

Expand Down
9 changes: 0 additions & 9 deletions internal/metamorph/processor_helpers.go
Original file line number Diff line number Diff line change
Expand Up @@ -96,15 +96,6 @@ func (p *Processor) getAndDeleteAllTransactionStatuses() (StatusUpdateMap, error
return statuses, nil
}

func (p *Processor) clearCache(updateStatusMap StatusUpdateMap) error {
keys := make([]string, len(updateStatusMap))
for k := range updateStatusMap {
keys = append(keys, k.String())
}

return p.cacheStore.Del(&CacheStatusUpdateHash, keys...)
}

func (p *Processor) getStatusUpdateCount() (int, error) {
count, err := p.cacheStore.CountElementsForHash(CacheStatusUpdateHash)
if err != nil {
Expand Down

0 comments on commit 8093791

Please sign in to comment.