redis

type Config struct {
	HostName string
	Username string
	Password string
	Port     int
	DB       int
	Options  *redis.Options
	TLS      *tls.Config

	// PubSub configuration
	PubSubMode          string // "pubsub" or "streams"
	PubSubStreamsConfig *StreamsConfig
	PubSubBufferSize    int           // Message buffer size for channels (default: 100)
	PubSubQueryTimeout  time.Duration // Default query timeout (default: 5s)
	PubSubQueryLimit    int           // Default query message limit (default: 10)
}

type Metrics interface {
	RecordHistogram(ctx context.Context, name string, value float64, labels ...string)
	IncrementCounter(ctx context.Context, name string, labels ...string)
}

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

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

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

type QueryLog struct {
	Query    string `json:"query"`
	Duration int64  `json:"duration"`
	Args     any    `json:"args,omitempty"`
}

type Redis struct {
	*redis.Client
	// contains filtered or unexported fields
}

type StreamsConfig struct {
	// ConsumerGroup is the name of the consumer group (required for Streams)
	ConsumerGroup string

	// ConsumerName is the name of the consumer (optional, auto-generated if empty)
	ConsumerName string

	// MaxLen is the maximum length of the stream (optional)
	// If > 0, the stream will be trimmed to this length on publish
	MaxLen int64

	// Block is the blocking duration for XREADGROUP (optional)
	// If > 0, calls will block for this duration waiting for new messages
	Block time.Duration

	// PELRatio is the ratio of PEL (pending) messages to read (0.0-1.0)
	// Default: 0.7 (70% PEL, 30% new messages)
	// 0.0 = only new messages, 1.0 = only PEL messages
	PELRatio float64
}