ecache

package

v1.3.2 Latest Latest Go to latest Published: Feb 24, 2026 License: GPL-3.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Cache[T any] struct {
	RedisTimeout time.Duration
	// contains filtered or unexported fields
}

func NewCache[T any](client *redis.Client, topic string) *Cache[T]

func (e *Cache[T]) Get(ctx context.Context, key string) (T, bool)

func (e *Cache[T]) GetRecheckKeys(ctx context.Context) []string

func (e *Cache[T]) LocalKeys() []string

func (e *Cache[T]) SetTTL(ctx context.Context, key string, value T, ttl1 time.Duration, ttl2 time.Duration) error

type Item[T any] struct {
	Value     T
	ExpiresAt time.Time
	RecheckAt time.Time
}