Make public the syncronisation between redis and the source of truth …

…for a limit
datatrails · Oct 11, 2024 · e347cac · e347cac
1 parent a56a9d4
commit e347cac
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/redis/count_resource.go b/redis/count_resource.go
@@ -301,7 +301,7 @@ func (cr *CountResource) Available(ctx context.Context, tenantID string) (int64,
 	}
 
 	// count is now zero so check the actual number of resources and adjust if necessary.
-	newLimit, err := cr.refreshLimit(ctx, tenantID)
+	newLimit, err := cr.RefreshLimit(ctx, tenantID)
 	if err != nil {
 		log.Infof("reset count failure: %v", err)
 		newLimit = limit

diff --git a/redis/resource.go b/redis/resource.go
@@ -285,11 +285,11 @@ func (r *Resource) getLimit(ctx context.Context, tenantID string) (int64, error)
 		return limit, nil
 	}
 	// we haven't got the redis limit therefore attempt to retrieve from upstream
-	return r.refreshLimit(ctx, tenantID)
+	return r.RefreshLimit(ctx, tenantID)
 }
 
-// refreshLimit gets the limit for a given tenant from upstream.
-func (r *Resource) refreshLimit(ctx context.Context, tenantID string) (int64, error) {
+// RefreshLimit gets the limit for a given tenant from upstream.
+func (r *Resource) RefreshLimit(ctx context.Context, tenantID string) (int64, error) {
 	log := r.Log().FromContext(ctx)
 	defer log.Close()