Golang Samber Hot
Samuel BertheCommunityCreated by samberDistributed by Samuel Berthe
- Skill
- Tool integration
- Software development
- MIT
- No issues found
AutoGineer summary
Written by AutoGineer from the skill’s own files, not by the author
The samber/hot library provides a generic, type-safe in-memory caching solution for Go 1.22+. It supports nine different eviction algorithms including W-TinyLFU, LRU, and S3FIFO, allowing developers to select a strategy based on specific access patterns. The library includes features such as TTL management, background janitors for cleanup, loader chains with singleflight deduplication, sharding to reduce lock contention, and Prometheus metrics integration.
What it does
- Implements nine eviction algorithms including W-TinyLFU, LRU, LFU, and S3FIFO.
- Supports TTL-based expiration with optional background janitor cleanup.
- Provides loader chains with singleflight deduplication to handle cache misses.
- Enables sharding to reduce lock contention in concurrent environments.
- Offers stale-while-revalidate patterns and missing key caching.
- Integrates with Prometheus for monitoring cache hit rates and performance metrics.
When to use it
- When you need to reduce latency or backend pressure by caching frequently accessed resources.
- When you need to implement in-memory caching in a Go project.
- When you need to choose specific eviction algorithms based on known access patterns.
- When you require automatic cache population via loader functions.
Advantages
- Type-safe generic implementation for Go 1.22+.
- Flexible configuration for eviction strategies and cache sizing.
- Built-in support for observability via Prometheus metrics.
- Prevents thundering herd issues using singleflight deduplication and TTL jitter.
Usage examples
- “How do I initialize a basic cache with a 5-minute TTL?”
- Use hot.NewHotCache[string, *User](hot.WTinyLFU, 10_000).WithTTL(5 * time.Minute).WithJanitor().Build() to create and start the cache.
- “How can I automatically load missing keys from a database?”
- Use the .WithLoaders() builder method to provide a function that fetches missing keys, which will be triggered automatically on a cache miss.
Install
Download the skill as a ZIP:
https://autogineer.com/agent-skills/samber/golang-samber-hot/downloadUnzip it into the cross-client skills folder of your project:
mkdir -p .agents/skills && unzip golang-samber-hot.zip -d .agents/skills
Documentation by samber
Persona: You are a Go engineer who treats caching as a system design decision. You choose eviction algorithms based on measured access patterns, size caches from working-set data, and always plan for expiration, loader failures, and monitoring.
Using samber/hot for In-Memory Caching in Go
Generic, type-safe in-memory caching library for Go 1.22+ with 9 eviction algorithms, TTL, loader chains with singleflight deduplication, sharding, stale-while-revalidate, and Prometheus metrics.
Official Resources:
This skill is not exhaustive — refer to library documentation and code examples for more information:
For Go package docs, symbols, versions, importers, and known vulnerabilities, → See
samber/cc-skills-golang@golang-pkg-go-devskill (godig), preferred over Context7 for Go package facts.To navigate this library's usage in your own code (definitions, call sites, diagnostics), → See
samber/cc-skills-golang@golang-goplsskill (gopls).Context7 remains a fallback for docs not indexed on pkg.go.dev.
go get -u github.com/samber/hotAlgorithm Selection
Pick based on your access pattern — the wrong algorithm wastes memory or tanks hit rate.
| Algorithm | Constant | Best for | Avoid when |
|---|---|---|---|
| W-TinyLFU | hot.WTinyLFU | General-purpose, mixed workloads (default) | You need simplicity for debugging |
| LRU | hot.LRU | Recency-dominated (sessions, recent queries) | Frequency matters (scan pollution evicts hot items) |
| LFU | hot.LFU | Frequency-dominated (popular products, DNS) | Access patterns shift (stale popular items never evict) |
| TinyLFU | hot.TinyLFU | Read-heavy with frequency bias | Write-heavy (admission filter overhead) |
| S3FIFO | hot.S3FIFO | High throughput, scan-resistant | Small caches (<1000 items) |
| ARC | hot.ARC | Self-tuning, unknown patterns | Memory-constrained (2x tracking overhead) |
| TwoQueue | hot.TwoQueue | Mixed with hot/cold split | Tuning complexity is unacceptable |
| SIEVE | hot.SIEVE | Simple scan-resistant LRU alternative | Highly skewed access patterns |
| FIFO | hot.FIFO | Simple, predictable eviction order | Hit rate matters (no frequency/recency awareness) |
Decision shortcut: Start with hot.WTinyLFU. Switch only when profiling shows the miss rate is too high for your SLO.
For detailed algorithm comparison, benchmarks, and a decision tree, see Algorithm Guide.
Core Usage
Basic Cache with TTL
import "github.com/samber/hot"
cache := hot.NewHotCache[string, *User](hot.WTinyLFU, 10_000).
WithTTL(5 * time.Minute).
WithJanitor().
Build()
defer cache.StopJanitor()
cache.Set("user:123", user)
cache.SetWithTTL("session:abc", session, 30*time.Minute)
value, found, err := cache.Get("user:123")Loader Pattern (Read-Through)
Loaders fetch missing keys automatically with singleflight deduplication — concurrent Get() calls for the same missing key share one loader invocation:
cache := hot.NewHotCache[int, *User](hot.WTinyLFU, 10_000).
WithTTL(5 * time.Minute).
WithLoaders(func(ids []int) (map[int]*User, error) {
return db.GetUsersByIDs(ctx, ids) // batch query
}).
WithJanitor().
Build()
defer cache.StopJanitor()
user, found, err := cache.Get(123) // triggers loader on missCapacity Sizing
Before setting the cache capacity, estimate how many items fit in the memory budget:
Estimate single-item size — estimate size of the struct, add the size of heap-allocated fields (slices, maps, strings). Include the key size. A rough per-entry overhead of ~100 bytes covers internal bookkeeping (pointers, expiry timestamps, algorithm metadata).
Ask the developer how much memory is dedicated to this cache in production (e.g., 256 MB, 1 GB). This depends on the service's total memory and what else shares the process.
Compute capacity —
capacity = memoryBudget / estimatedItemSize. Round down to leave headroom.
Example: *User struct ~500 bytes + string key ~50 bytes + overhead ~100 bytes = ~650 bytes/entry
256 MB budget → 256_000_000 / 650 ≈ 393,000 itemsIf the item size is unknown, ask the developer to measure it with a unit test that allocates N items and checks runtime.ReadMemStats. Guessing capacity without measuring leads to OOM or wasted memory.
Common Mistakes
Forgetting
WithJanitor()— without it, expired entries stay in memory until the algorithm evicts them. Always chain.WithJanitor()in the builder anddefer cache.StopJanitor().Calling
SetMissing()without missing cache config — panics at runtime. EnableWithMissingCache(algorithm, capacity)orWithMissingSharedCache()in the builder first.WithoutLocking()+WithJanitor()— mutually exclusive, panics.WithoutLocking()is only safe for single-goroutine access without background cleanup.Oversized cache — a cache holding everything is a map with overhead. Size to your working set (typically 10-20% of total data). Monitor hit rate to validate.
Ignoring loader errors —
Get()returns(zero, false, err)on loader failure. Always checkerr, not justfound.
Best Practices
Always set TTL — unbounded caches serve stale data indefinitely because there is no signal to refresh
Use
WithJitter(lambda, upperBound)to spread expirations — without jitter, items created together expire together, causing thundering herd on the loaderMonitor with
WithPrometheusMetrics(cacheName)— hit rate below 80% usually means the cache is undersized or the algorithm is wrong for the workloadUse
WithCopyOnRead(fn)/WithCopyOnWrite(fn)for mutable values — without copies, callers mutate cached objects and corrupt shared state
For advanced patterns (revalidation, sharding, missing cache, monitoring setup), see Production Patterns.
For the complete API surface, see API Reference.
If you encounter a bug or unexpected behavior in samber/hot, open an issue at https://github.com/samber/hot/issues.
Cross-References
→ See
samber/cc-skills-golang@golang-performanceskill for general caching strategy and when to use in-memory cache vs Redis vs CDN→ See
samber/cc-skills-golang@golang-observabilityskill for Prometheus metrics integration and monitoring→ See
samber/cc-skills-golang@golang-databaseskill for database query patterns that pair with cache loaders→ See
samber/cc-skills@promql-cliskill for querying Prometheus cache metrics via CLI
Files
- ATTRIBUTION.mdAdded by AutoGineer908 B
- LICENSELicence file added by AutoGineer1.0 KiB
- SKILL.md7.8 KiB
- evals/evals.json16.3 KiB
- references/algorithm-guide.md9.2 KiB
- references/api-reference.md6.6 KiB
- references/production-patterns.md7.4 KiB
references/production-patterns.md
Production Patterns
Table of Contents
Stale-While-Revalidate
Sharding
Missing Key Caching (Negative Caching)
Dedicated missing cache (recommended)
Shared missing cache
Manual missing key marking
Loader Chains
Copy-on-Read / Copy-on-Write
Prometheus Monitoring
Setup
Key PromQL Queries
Warm-Up on Startup
Graceful Shutdown
Stale-While-Revalidate
Return stale data immediately while refreshing in the background. Two time thresholds:
TTL — after this, entries become "stale" and trigger async background refresh via loaders
Stale duration — after TTL + stale, entries are hard-expired and removed
refreshLoader := func(keys []string) (map[string]*Config, error) {
return fetchConfigsFromDB(keys)
}
cache := hot.NewHotCache[string, *Config](hot.WTinyLFU, 1_000).
WithTTL(5 * time.Minute). // stale after 5min
WithRevalidation(1 * time.Minute, refreshLoader). // hard-expire after 6min total
WithRevalidationErrorPolicy(hot.KeepOnError). // keep stale value if refresh fails
WithJitter(0.1, 30*time.Second). // spread expirations
WithJanitor().
Build()
defer cache.StopJanitor()Timeline for an entry set at T=0 with this config:
T=0 to T=5min: fresh — returned directly
T=5min to T=6min: stale — returned immediately, background refresh triggered
T>6min: expired — removed, next
Get()blocks on loader
Error policies:
hot.KeepOnError— if background refresh fails, keep the stale value until hard expiryhot.DropOnError— if refresh fails, drop the entry immediately
Use KeepOnError when stale data is better than no data (config caches, product catalogs). Use DropOnError when correctness matters more than availability.
Sharding
Split the cache into N independent segments to reduce lock contention under high concurrency:
cache := hot.NewHotCache[string, *User](hot.WTinyLFU, 100_000).
WithTTL(5 * time.Minute).
WithSharding(16, func(key string) uint64 {
h := fnv.New64a()
h.Write([]byte(key))
return h.Sum64()
}).
WithJanitor().
Build()
defer cache.StopJanitor()Sizing guidance:
Use powers of 2 (4, 8, 16, 32) for optimal hash distribution
Rule of thumb: shard count ~= number of CPU cores for high-contention workloads
Each shard gets
capacity / shardsitemsOver-sharding (>64 shards) adds overhead without benefit
Missing Key Caching (Negative Caching)
Prevents repeated loader calls for keys that don't exist in the source:
Dedicated missing cache (recommended)
Independent eviction algorithm and capacity — gives fine-grained control:
cache := hot.NewHotCache[string, *User](hot.WTinyLFU, 100_000).
WithTTL(1 * time.Hour).
WithMissingCache(hot.LFU, 10_000). // separate LFU cache for missing keys
WithLoaders(userLoader).
WithJanitor().
Build()
defer cache.StopJanitor()Shared missing cache
Missing entries stored in the main cache — simpler but uses main cache capacity:
cache := hot.NewHotCache[string, *User](hot.WTinyLFU, 100_000).
WithTTL(1 * time.Hour).
WithMissingSharedCache().
WithLoaders(userLoader).
WithJanitor().
Build()
defer cache.StopJanitor()Manual missing key marking
// Mark individual key as missing
cache.SetMissing("nonexistent-user")
cache.SetMissingWithTTL("temp-missing", 5*time.Minute)
// Batch mark missing
cache.SetMissingMany([]string{"user:404", "user:405"})Important: Keys(), Values(), All() exclude missing entries — they only return real values.
Loader Chains
Multiple loaders execute sequentially for L1/L2 cache patterns:
redisLoader := func(keys []string) (map[string]*User, error) {
return redis.MGet(ctx, keys...)
}
dbLoader := func(keys []string) (map[string]*User, error) {
return db.GetUsersByIDs(ctx, keys)
}
cache := hot.NewHotCache[string, *User](hot.WTinyLFU, 10_000).
WithTTL(5 * time.Minute).
WithLoaders(redisLoader, dbLoader). // Redis first, then DB for remaining
WithJanitor().
Build()
defer cache.StopJanitor()Chain behavior:
redisLoadercalled first with all missing keysdbLoadercalled only with keys NOT found byredisLoaderIf both return the same key,
dbLoader's value wins (later overwrites earlier)Any error stops the chain — partial results from earlier loaders are discarded
Copy-on-Read / Copy-on-Write
Required when cached values are mutable (pointers, slices, maps):
cache := hot.NewHotCache[string, *User](hot.WTinyLFU, 10_000).
WithTTL(5 * time.Minute).
WithCopyOnRead(func(u *User) *User {
copy := *u
return ©
}).
WithCopyOnWrite(func(u *User) *User {
copy := *u
return ©
}).
WithJanitor().
Build()
defer cache.StopJanitor()CopyOnRead — clones at retrieval: callers get independent copies, mutations don't affect cache
CopyOnWrite — clones at storage: cache holds a snapshot, external mutations to the original don't corrupt cached value
Use both when callers read and write concurrently. Use only one when the mutation direction is known.
Prometheus Monitoring
Setup
cache := hot.NewHotCache[string, *User](hot.WTinyLFU, 10_000).
WithTTL(5 * time.Minute).
WithPrometheusMetrics("user_cache").
WithJanitor().
Build()
defer cache.StopJanitor()
prometheus.MustRegister(cache)Key PromQL Queries
# Hit ratio (target: >80%)
rate(hot_cache_hit_count{cache="user_cache"}[5m]) /
rate(hot_cache_get_count{cache="user_cache"}[5m])
# Eviction rate (high = cache too small or TTL too short)
rate(hot_cache_eviction_count{cache="user_cache"}[5m])
# Cache size vs capacity
hot_cache_len{cache="user_cache"} / hot_cache_capacity{cache="user_cache"}Alerts to consider:
Hit rate drops below 70% for >5 minutes — cache may be undersized
Eviction rate spikes — working set exceeds capacity
Cache size near capacity — consider increasing capacity or reviewing TTLs
Warm-Up on Startup
Pre-populate the cache before serving traffic:
cache := hot.NewHotCache[string, *User](hot.WTinyLFU, 10_000).
WithTTL(1 * time.Hour).
WithWarmUp(func() (map[string]*User, []string, error) {
users, err := db.GetFrequentUsers(ctx)
if err != nil {
return nil, nil, err
}
missingKeys := []string{"deleted-user-1", "deleted-user-2"}
return users, missingKeys, nil // values + known missing keys + error
}).
WithJanitor().
Build()
defer cache.StopJanitor()Use WithWarmUpWithTimeout(30*time.Second, fn) to bound startup time.
Graceful Shutdown
Always stop the janitor goroutine before exit:
cache := hot.NewHotCache[string, *User](hot.WTinyLFU, 10_000).
WithTTL(5 * time.Minute).
WithJanitor().
Build()
defer cache.StopJanitor() // clean up background goroutineIn applications with graceful shutdown orchestration, call cache.StopJanitor() during the shutdown phase alongside other resource cleanup.
Requirements and compatibility
Written for: Claude Code, OpenAI Codex
Works with: Claude Code, Claude apps, OpenAI Codex, GitHub Copilot, Cursor, Gemini CLI, Kiro, OpenCode, Goose, Amp, Roo Code, JetBrains Junie, Factory Droid, Devin (ex-Windsurf), Mistral Vibe, OpenHands, Letta
“Works with” means the tool reads the open Agent Skills format; a skill written for one tool may use features others lack.
Needs: Declares allowed tools, Claude Code frontmatter
The author says: Designed for Claude Code, Codex or similar harness, and for projects using Golang.
Security
No issues found by our static scan· No issues found
A static scan is not a guarantee. Skills are third-party content: review a skill before you let an agent use it.
Attribution and licence
- Created by
- samber
- Publisher
- Samuel Berthe (Community)
- Distributed by
- Samuel Berthe
- Source
- samber/cc-skills-golang · skills/golang-samber-hot · commit bb1d43d
- Licence
- MIT License (redistribution allowed)
- LICENSE (added by AutoGineer from LICENSE)
- ATTRIBUTION.md (written by AutoGineer)
- Synced
AutoGineer is not affiliated with or endorsed by samber or Samuel Berthe.
Download ZIP
The ZIP holds the skill’s files, its licence files and an ATTRIBUTION.md. Download golang-samber-hot.zip