redisstore

type Options struct {
	// Addr is the "host:port" of a single Redis endpoint. Required unless
	// Client is set. ElastiCache Serverless exposes one endpoint that
	// transparently scales, so this package targets a single address rather
	// than a cluster topology.
	Addr string
	// Namespace scopes tag-version keys and the tag-bump channel to one
	// deploy; see the package doc. Entry keys are not namespaced here - the
	// caller already did that (cache.RouteKey / cache.DataKey).
	Namespace string
	// Username and Password authenticate to Redis via AUTH. Both are
	// optional; ElastiCache Serverless with an auth token uses Password
	// only ("default" user).
	Username, Password string
	// TLS overrides the TLS config used to dial Redis. When nil and
	// DisableTLS is false, New builds one itself with ServerName set to
	// Addr's host, matching ElastiCache Serverless's requirement that
	// clients speak TLS with a verifiable certificate.
	TLS *tls.Config
	// DisableTLS connects in plaintext, for local development against a
	// Redis started without TLS. It must never be set in a deployment that
	// talks to ElastiCache Serverless, which requires TLS.
	DisableTLS bool
	// Client injects a pre-built redis.UniversalClient (e.g. a cluster
	// client, or a client shared with other packages) and takes ownership
	// away from Store: Close will not close it. When set, Addr, Username,
	// Password, TLS, and DisableTLS are ignored - the client is already
	// fully configured.
	Client redis.UniversalClient
	// WriteWorkers and WriteQueue bound the write-behind pool: WriteWorkers
	// goroutines drain a channel buffered to WriteQueue. DefaultWriteWorkers
	// / DefaultWriteQueue apply when either is <= 0.
	WriteWorkers int
	WriteQueue   int
	// WriteTimeout bounds one queued write's Redis round trip, applied to a
	// context detached from the caller's (see the package doc's write-behind
	// section). DefaultWriteTimeout applies when <= 0.
	WriteTimeout time.Duration
	// DialTimeout and ReadTimeout configure the owned client's network
	// timeouts; ignored when Client is set. Defaults above apply when <= 0.
	DialTimeout time.Duration
	ReadTimeout time.Duration
	// Logger receives write-behind failures and other best-effort-operation
	// warnings. slog.Default() applies when nil.
	Logger *slog.Logger
	// Clock overrides time.Now, for tests.
	Clock func() time.Time
}

type Stats struct {
	// Enqueued counts writes accepted onto the queue.
	Enqueued int64
	// Dropped counts writes discarded because the queue was full.
	Dropped int64
	// Persisted counts writes whose CAS matched and were stored.
	Persisted int64
	// Rejected counts writes whose CAS did not match: some tag was bumped
	// between the version read and the write running.
	Rejected int64
	// Failed counts writes that errored talking to Redis.
	Failed int64
}

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