Skip to content

Commit

Permalink
Rename struct
Browse files Browse the repository at this point in the history
  • Loading branch information
miguelreiswildlife committed Sep 25, 2023
1 parent 2b68449 commit ab7f2ca
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 12 deletions.
2 changes: 1 addition & 1 deletion api/app.go
Original file line number Diff line number Diff line change
Expand Up @@ -232,7 +232,7 @@ func (app *App) configureEnrichment() {
Password: app.ParsedConfig.Enrichment.Cache.Password,
})

enrichCache := enrichercache.NewEnricherCache(redisClient)
enrichCache := enrichercache.NewEnricherRedisCache(redisClient)
enricher := enriching.NewEnricher(
enriching.WithLogger(app.Logger),
enriching.WithWebhookUrls(app.ParsedConfig.Enrichment.WebhookUrls),
Expand Down
12 changes: 6 additions & 6 deletions leaderboard/enriching/cache/cache.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,21 +13,21 @@ import (
// cacheKeyFormat is {tenantID}:{leaderboardID}:{memberID}
const cacheKeyFormat = "leaderboards-enrich-caching:%s:%s:%s"

type enricherCache struct {
type enricherRedisCache struct {
redis *redis.Client
}

var _ enriching.EnricherCache = &enricherCache{}
var _ enriching.EnricherCache = &enricherRedisCache{}

func NewEnricherCache(
func NewEnricherRedisCache(
redis *redis.Client,
) enriching.EnricherCache {
return &enricherCache{
return &enricherRedisCache{
redis: redis,
}
}

func (e *enricherCache) Get(
func (e *enricherRedisCache) Get(
ctx context.Context,
tenantID,
leaderboardID string,
Expand Down Expand Up @@ -58,7 +58,7 @@ func (e *enricherCache) Get(
return dataMap, true, nil
}

func (e *enricherCache) Set(
func (e *enricherRedisCache) Set(
ctx context.Context,
tenantID,
leaderboardID string,
Expand Down
10 changes: 5 additions & 5 deletions leaderboard/enriching/cache/cache_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ var _ = Describe("Enricher cacheConfig Get tests", func() {
getKeysFromMemberArray(tenantID, leaderboardID, members)...,
).SetErr(errors.New("some error"))

cache := NewEnricherCache(redis)
cache := NewEnricherRedisCache(redis)
res, hit, err := cache.Get(context.Background(), tenantID, leaderboardID, members)

Expect(res).To(BeNil())
Expand All @@ -75,7 +75,7 @@ var _ = Describe("Enricher cacheConfig Get tests", func() {
getKeysFromMemberArray(tenantID, leaderboardID, members)...,
).SetVal([]interface{}{nil, nil})

cache := NewEnricherCache(redis)
cache := NewEnricherRedisCache(redis)
res, hit, err := cache.Get(context.Background(), tenantID, leaderboardID, members)

Expect(res).To(BeNil())
Expand Down Expand Up @@ -104,7 +104,7 @@ var _ = Describe("Enricher cacheConfig Get tests", func() {
getKeysFromMemberArray(tenantID, leaderboardID, members)...,
).SetVal(mgetExpectedResult)

cache := NewEnricherCache(redis)
cache := NewEnricherRedisCache(redis)
res, hit, err := cache.Get(context.Background(), tenantID, leaderboardID, members)

Expect(res).To(BeNil())
Expand Down Expand Up @@ -133,7 +133,7 @@ var _ = Describe("Enricher cacheConfig Get tests", func() {
getKeysFromMemberArray(tenantID, leaderboardID, members)...,
).SetVal(mgetExpectedResult)

cache := NewEnricherCache(redis)
cache := NewEnricherRedisCache(redis)
res, hit, err := cache.Get(context.Background(), tenantID, leaderboardID, members)

expectedResult := map[string]map[string]string{
Expand All @@ -158,7 +158,7 @@ var _ = Describe("Ericher cacheConfig Set tests", func() {
It("should set the data in redis", func() {
redis := redis.NewClient(&redis.Options{Addr: "localhost:6379"})

cache := NewEnricherCache(redis)
cache := NewEnricherRedisCache(redis)
members := []*model.Member{
{
PublicID: "member1",
Expand Down

0 comments on commit ab7f2ca

Please sign in to comment.