kv

Documentation

Index

• type IThreadSafeStore
  • func NewThreadSafeMap[T any]() IThreadSafeStore[T]
• type SafeStoreKeyFilterFunc

Types

type IThreadSafeStore

type IThreadSafeStore[T any] interface {
	io.Closer
	AddOrUpdate(key string, obj T)
	Replace(items map[string]T)
	Delete(key string)
	Get(key string) (item T, exists bool)
	ListKeys(filters ...SafeStoreKeyFilterFunc) []string
	ListValues(keys ...string) (items []T)
}

func NewThreadSafeMap

func NewThreadSafeMap[T any]() IThreadSafeStore[T]

type SafeStoreKeyFilterFunc

type SafeStoreKeyFilterFunc func(key string) bool