Mohamed Sohail
2793d92343
* breaking: use event router, adsd telegram notifier, update indexer schema * fix: early ack on handler not found * fix: jetstream switch to new API, discard buffer on close * remove telegram dependency, rely on log alters instead, which indirectly connect to telegram via uptrace * feat (breaking): switch to self contained auto bootstrapper
27 lines
406 B
Go
27 lines
406 B
Go
package cache
|
|
|
|
import "github.com/puzpuzpuz/xsync/v3"
|
|
|
|
type Cache struct {
|
|
provider *xsync.MapOf[string, bool]
|
|
}
|
|
|
|
func New() *Cache {
|
|
return &Cache{
|
|
provider: xsync.NewMapOf[string, bool](),
|
|
}
|
|
}
|
|
|
|
func (c *Cache) Set(key string) {
|
|
c.provider.Store(key, true)
|
|
}
|
|
|
|
func (c *Cache) Get(key string) bool {
|
|
v, _ := c.provider.Load(key)
|
|
return v
|
|
}
|
|
|
|
func (c *Cache) Size() int {
|
|
return c.provider.Size()
|
|
}
|