concurrent_lru

Documentation

Index

• type ConcurrentLRU
  • func NewConecurrentLRU[K comparable, V any](maxSize int, onEvict func(key K, v V)) *ConcurrentLRU[K, V]
  • func (c *ConcurrentLRU[K, V]) Add(key K, v V)
  • func (c *ConcurrentLRU[K, V]) Clean(f func(key K, v V) (remove bool)) (removed int)
  • func (c *ConcurrentLRU[K, V]) Del(key K)
  • func (c *ConcurrentLRU[K, V]) Get(key K) (v V, ok bool)
  • func (c *ConcurrentLRU[K, V]) Len() int
• type ShardedLRU
  • func NewShardedLRU[V any](shardNum, maxSizePerShard int, onEvict func(key string, v V)) *ShardedLRU[V]
  • func (c *ShardedLRU[V]) Add(key string, v V)
  • func (c *ShardedLRU[V]) Clean(f func(key string, v V) (remove bool)) (removed int)
  • func (c *ShardedLRU[V]) Del(key string)
  • func (c *ShardedLRU[V]) Get(key string) (v V, ok bool)
  • func (c *ShardedLRU[V]) Len() int

Types

type ConcurrentLRU

type ConcurrentLRU[K comparable, V any] struct {
	sync.Mutex
	// contains filtered or unexported fields
}

ConcurrentLRU is a lru.LRU with a lock. It is concurrent safe.

func NewConecurrentLRU

func NewConecurrentLRU[K comparable, V any](maxSize int, onEvict func(key K, v V)) *ConcurrentLRU[K, V]

func (*ConcurrentLRU[K, V]) Add

func (c *ConcurrentLRU[K, V]) Add(key K, v V)

func (*ConcurrentLRU[K, V]) Clean

func (c *ConcurrentLRU[K, V]) Clean(f func(key K, v V) (remove bool)) (removed int)

func (*ConcurrentLRU[K, V]) Del

func (c *ConcurrentLRU[K, V]) Del(key K)

func (*ConcurrentLRU[K, V]) Get

func (c *ConcurrentLRU[K, V]) Get(key K) (v V, ok bool)

func (*ConcurrentLRU[K, V]) Len

func (c *ConcurrentLRU[K, V]) Len() int

type ShardedLRU

type ShardedLRU[V any] struct {
	// contains filtered or unexported fields
}

func NewShardedLRU

func NewShardedLRU[V any](
	shardNum, maxSizePerShard int,
	onEvict func(key string, v V),
) *ShardedLRU[V]

func (*ShardedLRU[V]) Add

func (c *ShardedLRU[V]) Add(key string, v V)

func (*ShardedLRU[V]) Clean

func (c *ShardedLRU[V]) Clean(f func(key string, v V) (remove bool)) (removed int)

func (*ShardedLRU[V]) Del

func (c *ShardedLRU[V]) Del(key string)

func (*ShardedLRU[V]) Get

func (c *ShardedLRU[V]) Get(key string) (v V, ok bool)

func (*ShardedLRU[V]) Len

func (c *ShardedLRU[V]) Len() int