cache.go 756 B

1234567891011121314151617181920212223242526272829303132333435
  1. package cache
  2. import (
  3. "github.com/dgraph-io/ristretto/v2"
  4. "github.com/uozi-tech/cosy/logger"
  5. "time"
  6. )
  7. var cache *ristretto.Cache[string, any]
  8. func Init() {
  9. var err error
  10. cache, err = ristretto.NewCache[string, any](&ristretto.Config[string, any]{
  11. NumCounters: 1e7, // number of keys to track frequency of (10M).
  12. MaxCost: 1 << 30, // maximum cost of cache (1GB).
  13. BufferItems: 64, // number of keys per Get buffer.
  14. })
  15. if err != nil {
  16. logger.Fatal("initializing local cache err", err)
  17. }
  18. }
  19. func Set(key string, value interface{}, ttl time.Duration) {
  20. cache.SetWithTTL(key, value, 0, ttl)
  21. cache.Wait()
  22. }
  23. func Get(key string) (value interface{}, ok bool) {
  24. return cache.Get(key)
  25. }
  26. func Del(key string) {
  27. cache.Del(key)
  28. }