cache

type AutoRefresh interface {
	// Starts background refresh of items. To shutdown the cache, cancel the context.
	Start(ctx context.Context) error

	// Get item by id.
	Get(id ItemID) (Item, error)

	// Get object if exists else create it.
	GetOrCreate(id ItemID, item Item) (Item, error)

	// DeleteDelayed queues an item for deletion. It Will get deleted as part of the next Sync cycle. Until the next sync
	// cycle runs, Get and GetOrCreate will continue to return the Item in its previous state.
	DeleteDelayed(id ItemID) error
}

type Batch = []ItemWrapper

type Config struct {
	// Type of cache to use
	Type Type `json:"type" pflag:",type, Type of cache to use"`

	// Config for in-memory cache
	InMemoryFixedSize InMemoryFixedSizeConfig `json:"inMemoryFixedSize" pflag:"-,Config for in-memory cache"`

	// Config for Redis cache
	Redis RedisConfig `json:"redis" pflag:"-,Config for Redis cache"`
}

type CreateBatchesFunc func(ctx context.Context, snapshot []ItemWrapper) (batches []Batch, err error)

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

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

type InMemoryFixedSizeConfig struct {
	Size              *resource.Quantity `` /* 150-byte string literal not displayed */
	DefaultExpiration config.Duration    `json:"defaultExpiration" pflag:",Default expiration time for items"`
}

type Item interface {
	IsTerminal() bool
}

type ItemID = string

type ItemSyncResponse struct {
	ID     ItemID
	Item   Item
	Action SyncAction
}

type ItemWrapper interface {
	GetID() ItemID
	GetItem() Item
}

type Marshaler struct {
	cache.CacheInterface[any]
	// contains filtered or unexported fields
}

type NamespacedCache[T any] struct {
	cache.CacheInterface[T]
	// contains filtered or unexported fields
}

type Option func(*Options)

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

type RedisConfig struct {
	Options           RedisOptions    `json:"options" pflag:"-,Redis options."`
	DefaultExpiration config.Duration `json:"defaultExpiration" pflag:",Default expiration time for items."`
}

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

type RedisOptions struct {
	// The network type, either tcp or unix.
	// Default is tcp.
	Network string
	// host:port address.
	Addr string

	// ClientName will execute the `CLIENT SETNAME ClientName` command for each conn.
	ClientName string

	// Protocol 2 or 3. Use the version to negotiate RESP version with redis-server.
	// Default is 3.
	Protocol int
	// Use the specified Username to authenticate the current connection
	// with one of the connections defined in the ACL list when connecting
	// to a Redis 6.0 instance, or greater, that is using the Redis ACL system.
	Username string
	// Optional password. Must match the password specified in the
	// requirepass server configuration option (if connecting to a Redis 5.0 instance, or lower),
	// or the User Password when connecting to a Redis 6.0 instance, or greater,
	// that is using the Redis ACL system.
	Password string

	// PasswordSecretName is the name of the secret that contains the password.
	PasswordSecretName string

	// Database to be selected after connecting to the server.
	DB int

	// Maximum number of retries before giving up.
	// Default is 3 retries; -1 (not 0) disables retries.
	MaxRetries int
	// Minimum backoff between each retry.
	// Default is 8 milliseconds; -1 disables backoff.
	MinRetryBackoff config.Duration
	// Maximum backoff between each retry.
	// Default is 512 milliseconds; -1 disables backoff.
	MaxRetryBackoff config.Duration

	// Dial timeout for establishing new connections.
	// Default is 5 seconds.
	DialTimeout config.Duration
	// Timeout for socket reads. If reached, commands will fail
	// with a timeout instead of blocking. Supported values:
	//   - `0` - default timeout (3 seconds).
	//   - `-1` - no timeout (block indefinitely).
	//   - `-2` - disables SetReadDeadline calls completely.
	ReadTimeout config.Duration
	// Timeout for socket writes. If reached, commands will fail
	// with a timeout instead of blocking.  Supported values:
	//   - `0` - default timeout (3 seconds).
	//   - `-1` - no timeout (block indefinitely).
	//   - `-2` - disables SetWriteDeadline calls completely.
	WriteTimeout config.Duration
	// ContextTimeoutEnabled controls whether the client respects context timeouts and deadlines.
	// See https://redis.uptrace.dev/guide/go-redis-debugging.html#timeouts
	ContextTimeoutEnabled bool

	// Type of connection pool.
	// true for FIFO pool, false for LIFO pool.
	// Note that FIFO has slightly higher overhead compared to LIFO,
	// but it helps closing idle connections faster reducing the pool size.
	PoolFIFO bool
	// Base number of socket connections.
	// Default is 10 connections per every available CPU as reported by runtime.GOMAXPROCS.
	// If there is not enough connections in the pool, new connections will be allocated in excess of PoolSize,
	// you can limit it through MaxActiveConns
	PoolSize int
	// Amount of time client waits for connection if all connections
	// are busy before returning an error.
	// Default is ReadTimeout + 1 second.
	PoolTimeout config.Duration
	// Minimum number of idle connections which is useful when establishing
	// new connection is slow.
	// Default is 0. the idle connections are not closed by default.
	MinIdleConns int
	// Maximum number of idle connections.
	// Default is 0. the idle connections are not closed by default.
	MaxIdleConns int
	// Maximum number of connections allocated by the pool at a given time.
	// When zero, there is no limit on the number of connections in the pool.
	MaxActiveConns int
	// ConnMaxIdleTime is the maximum amount of time a connection may be idle.
	// Should be less than server's timeout.
	//
	// Expired connections may be closed lazily before reuse.
	// If d <= 0, connections are not closed due to a connection's idle time.
	//
	// Default is 30 minutes. -1 disables idle timeout check.
	ConnMaxIdleTime config.Duration
	// ConnMaxLifetime is the maximum amount of time a connection may be reused.
	//
	// Expired connections may be closed lazily before reuse.
	// If <= 0, connections are not closed due to a connection's age.
	//
	// Default is to not close idle connections.
	ConnMaxLifetime config.Duration

	// TLS Config to use. When set, TLS will be negotiated.
	TLSConfig *tls.Config

	// // Disable set-lib on connect. Default is false.
	DisableIndentity bool
}

type SecretManager interface {
	Get(ctx context.Context, key string) (string, error)
}

type StringCache = cache.CacheInterface[string]

type SyncAction int

type SyncFunc func(ctx context.Context, batch Batch) (
	updatedBatch []ItemSyncResponse, err error)

type Type uint8

type TypedMarshaler[T any] struct {
	*Marshaler
	// contains filtered or unexported fields
}

type UInt64Cache = cache.CacheInterface[uint64]