feat(minor): rename some cache functions

Signed-off-by: Matt Gleich <[email protected]>
gleich · Dec 29, 2024 · 423dfaa · 423dfaa
1 parent f913a52
commit 423dfaa
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 9 deletions.
diff --git a/internal/apis/applemusic/applemusic.go b/internal/apis/applemusic/applemusic.go
@@ -58,9 +58,9 @@ func Setup(router *chi.Mux) {
 		lumber.Fatal(err, "initial fetch of cache data failed")
 	}
 
-	applemusicCache := cache.NewCache("applemusic", data)
+	applemusicCache := cache.New("applemusic", data)
 	router.Get("/applemusic/cache", applemusicCache.ServeHTTP())
 	router.Handle("/applemusic/cache/ws", applemusicCache.ServeWS())
-	go applemusicCache.StartPeriodicUpdate(cacheUpdate, 30*time.Second)
+	go applemusicCache.PeriodicUpdate(cacheUpdate, 30*time.Second)
 	lumber.Done("setup apple music cache")
 }
diff --git a/internal/apis/github/github.go b/internal/apis/github/github.go
@@ -24,10 +24,10 @@ func Setup(router *chi.Mux) {
 		lumber.Fatal(err, "fetching initial pinned repos failed")
 	}
 
-	githubCache := cache.NewCache("github", pinnedRepos)
+	githubCache := cache.New("github", pinnedRepos)
 	router.Get("/github/cache", githubCache.ServeHTTP())
 	router.Handle("/github/cache/ws", githubCache.ServeWS())
-	go githubCache.StartPeriodicUpdate(
+	go githubCache.PeriodicUpdate(
 		func() ([]repository, error) { return fetchPinnedRepos(githubClient) },
 		2*time.Minute,
 	)

diff --git a/internal/apis/steam/steam.go b/internal/apis/steam/steam.go
@@ -14,9 +14,9 @@ func Setup(router *chi.Mux) {
 		lumber.Fatal(err, "initial fetch of games failed")
 	}
 
-	steamCache := cache.NewCache("steam", games)
+	steamCache := cache.New("steam", games)
 	router.Get("/steam/cache", steamCache.ServeHTTP())
 	router.Handle("/steam/cache/ws", steamCache.ServeWS())
-	go steamCache.StartPeriodicUpdate(fetchRecentlyPlayedGames, 5*time.Minute)
+	go steamCache.PeriodicUpdate(fetchRecentlyPlayedGames, 5*time.Minute)
 	lumber.Done("setup steam cache")
 }
diff --git a/internal/apis/strava/strava.go b/internal/apis/strava/strava.go
@@ -27,7 +27,7 @@ func Setup(router *chi.Mux) {
 	if err != nil {
 		lumber.ErrorMsg("failed to load initial data for strava cache; not updating")
 	}
-	stravaCache := cache.NewCache("strava", stravaActivities)
+	stravaCache := cache.New("strava", stravaActivities)
 	router.Get("/strava/cache", stravaCache.ServeHTTP())
 	router.Handle("/strava/cache/ws", stravaCache.ServeWS())
 	router.Post("/strava/event", eventRoute(stravaCache, *minioClient, stravaTokens))

diff --git a/internal/cache/cache.go b/internal/cache/cache.go
@@ -32,7 +32,7 @@ type Cache[T any] struct {
 	wsUpgrader      websocket.Upgrader
 }
 
-func NewCache[T any](name string, data T) *Cache[T] {
+func New[T any](name string, data T) *Cache[T] {
 	cache := Cache[T]{
 		name: name,
 		updateCounter: promauto.NewCounter(prometheus.CounterOpts{
@@ -115,7 +115,7 @@ func (c *Cache[T]) Update(data T) {
 	}
 }
 
-func (c *Cache[T]) StartPeriodicUpdate(updateFunc func() (T, error), interval time.Duration) {
+func (c *Cache[T]) PeriodicUpdate(updateFunc func() (T, error), interval time.Duration) {
 	ticker := time.NewTicker(interval)
 	defer ticker.Stop()
 	for range ticker.C {