cache

package

v0.1.1 Latest Latest Go to latest Published: May 13, 2025 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrEdgesNotFound = errors.New("edges not found in cache")
)

View Source

var (
	ErrEntityNotFound = fmt.Errorf("entity not found in cache")
)

View Source

var (
	ErrFieldsNotFound = errors.New("fields not found in cache")
)

func NewEdgeCache(ttl time.Duration)

func NewEntityCache(ttl time.Duration)

func NewFieldCache(ttl time.Duration)

type Cache[K comparable, V any] struct {
	Values map[K]Item[V]
	// contains filtered or unexported fields
}

var Edge Cache[string, []entity.Edge]

var Field Cache[string, []entity.Field]

func NewCache[K comparable, V any](ttl time.Duration) Cache[K, V]

func (c *Cache[K, V]) Delete(key K)

func (c *Cache[K, V]) Get(key K) (V, bool)

func (c *Cache[K, V]) GetAll() []V

func (c *Cache[K, V]) Set(key K, val V)

type EntityCache struct {
	Cache[string, entity.Entity]
}

var Entity EntityCache

func (c *EntityCache) GetByUniqueInput(where entity.EntityWhereUniqueInput) (entity.Entity, bool)

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