redis

type CacheStrategy string

type ClusterConfig struct {
	Enabled   bool     `json:"enabled" yaml:"enabled"`
	Addresses []string `json:"addresses" yaml:"addresses"`
	Username  string   `json:"username" yaml:"username"`
	Password  string   `json:"password" yaml:"password"`
}

type Config struct {
	// Cache Strategy
	Enabled      bool          `json:"enabled" yaml:"enabled"`
	Strategy     CacheStrategy `json:"strategy" yaml:"strategy"` // read_through, write_through, write_behind
	DefaultTTL   time.Duration `json:"default_ttl" yaml:"default_ttl"`
	NullCacheTTL time.Duration `json:"null_cache_ttl" yaml:"null_cache_ttl"` // Cache null results

	// Redis Connection
	Host     string `json:"host" yaml:"host"`
	Port     int    `json:"port" yaml:"port"`
	Password string `json:"password" yaml:"password"`
	Database int    `json:"database" yaml:"database"`

	// Connection Pool
	PoolSize           int           `json:"pool_size" yaml:"pool_size"`
	MinIdleConns       int           `json:"min_idle_conns" yaml:"min_idle_conns"`
	MaxConnAge         time.Duration `json:"max_conn_age" yaml:"max_conn_age"`
	PoolTimeout        time.Duration `json:"pool_timeout" yaml:"pool_timeout"`
	IdleTimeout        time.Duration `json:"idle_timeout" yaml:"idle_timeout"`
	IdleCheckFrequency time.Duration `json:"idle_check_frequency" yaml:"idle_check_frequency"`

	// Performance
	ReadTimeout  time.Duration `json:"read_timeout" yaml:"read_timeout"`
	WriteTimeout time.Duration `json:"write_timeout" yaml:"write_timeout"`
	DialTimeout  time.Duration `json:"dial_timeout" yaml:"dial_timeout"`

	// Clustering (for Redis Cluster)
	Cluster ClusterConfig `json:"cluster" yaml:"cluster"`

	// Cache Invalidation
	Invalidation InvalidationConfig `json:"invalidation" yaml:"invalidation"`

	// Cache Warming
	WarmUp WarmUpConfig `json:"warm_up" yaml:"warm_up"`

	// Cache Metrics
	EnableMetrics bool `json:"enable_metrics" yaml:"enable_metrics"`

	// Serialization Format
	// msgpack: 5-10x faster than JSON, smaller payload (recommended for production)
	// json: Human-readable, easier debugging (good for development)
	SerializationFormat SerializationFormat `json:"serialization_format" yaml:"serialization_format"`

	// Cache Logging
	Logging LoggingConfig `json:"logging" yaml:"logging"`

	// Large Value Handling
	LargeValue LargeValueConfig `json:"large_value" yaml:"large_value"`
}

type InvalidationConfig struct {
	// Relationship Detection
	AutoDetectRelationships bool     `json:"auto_detect_relationships" yaml:"auto_detect_relationships"`
	MaxRelationshipDepth    int      `json:"max_relationship_depth" yaml:"max_relationship_depth"`
	IgnoreRelationships     []string `json:"ignore_relationships" yaml:"ignore_relationships"`

	// Invalidation Strategy
	Strategy           InvalidationStrategy `json:"strategy" yaml:"strategy"` // immediate, batch, async
	BatchSize          int                  `json:"batch_size" yaml:"batch_size"`
	BatchFlushInterval time.Duration        `json:"batch_flush_interval" yaml:"batch_flush_interval"`

	// Pattern-based Invalidation
	KeyPatterns map[string][]string `json:"key_patterns" yaml:"key_patterns"` // entity -> patterns to invalidate
}

type InvalidationStrategy string

type LargeValueConfig struct {
	MaxValueSize      int  `json:"max_value_size" yaml:"max_value_size"`         // Maximum size per key (bytes)
	ChunkSize         int  `json:"chunk_size" yaml:"chunk_size"`                 // Size per chunk (bytes)
	CompressThreshold int  `json:"compress_threshold" yaml:"compress_threshold"` // Auto-compress above this size
	EnableCompression bool `json:"enable_compression" yaml:"enable_compression"` // Enable/disable compression
	EnableChunking    bool `json:"enable_chunking" yaml:"enable_chunking"`       // Enable/disable chunking
}

type LoggingConfig struct {
	LogCacheHits     bool `json:"log_cache_hits" yaml:"log_cache_hits"`
	LogCacheMisses   bool `json:"log_cache_misses" yaml:"log_cache_misses"`
	LogInvalidations bool `json:"log_invalidations" yaml:"log_invalidations"`
}

type Manager struct {
	// contains filtered or unexported fields
}

type Metrics struct {
	// contains filtered or unexported fields
}

type MetricsSnapshot struct {
	// Cache metrics
	CacheHits    uint64
	CacheMisses  uint64
	CacheErrors  uint64
	CacheHitRate float64 // Percentage

	// Operation counts
	GetOperations    uint64
	SetOperations    uint64
	DeleteOperations uint64

	// Latency metrics
	AvgGetLatency    time.Duration
	AvgSetLatency    time.Duration
	AvgDeleteLatency time.Duration

	// Large value metrics
	CompressionBytesSaved uint64
	ChunkedOperations     uint64

	// Invalidation metrics
	InvalidationCount uint64
	DependencyCount   uint64
}

type SerializationFormat string

type WarmUpConfig struct {
	Enabled    bool     `json:"enabled" yaml:"enabled"`
	Strategies []string `json:"strategies" yaml:"strategies"` // startup, schedule, on_demand

	// Scheduled warming
	CronExpression string        `json:"cron_expression" yaml:"cron_expression"`
	WarmUpTimeout  time.Duration `json:"warm_up_timeout" yaml:"warm_up_timeout"`

	// Entities to warm
	Entities []string `json:"entities" yaml:"entities"`
}