Struct MemoryCache

serv/cache_memory.go:28–50

MemoryCache provides in-memory LRU response caching with row-level invalidation

// MemoryCache provides in-memory LRU response caching with row-level invalidation
type MemoryCache struct {
	cache        *lru.Cache[string, *memoryCacheEntry]
	conf         CachingConfig
	metrics      *CacheMetrics
	excludeTable map[string]bool
	workerPool   *SWRWorkerPool

	// Dependency index: dependency key -> set of fragment keys
	rowIndex   map[string]map[string]struct{}
	tableIndex map[string]map[string]struct{}
	modTimes   map[string]int64 // dependency key -> modification timestamp (ms)
	cacheMu    sync.Mutex
	mu         sync.RWMutex

	// OpenTelemetry metric instruments
	otelHitCounter          metric.Int64Counter
	otelMissCounter         metric.Int64Counter
	otelInvalidationCounter metric.Int64Counter
	otelErrorCounter        metric.Int64Counter
	otelSWRRefreshCounter   metric.Int64Counter
	otelBytesCachedGauge    metric.Int64UpDownCounter
	otelBytesSavedGauge     metric.Int64UpDownCounter
}

// NewMemoryCache creates a new in-memory LRU cache
func NewMemoryCache(conf CachingConfig, maxEntries int) (*MemoryCache, error) {