dynacache

package

v0.153.0 Latest Latest Go to latest Published: Oct 12, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

codeberg.org/PersonalTechHelp/golda

Links

Open Source Insights

Documentation ¶

Index ¶

func CleanKey(s string) string
type Cache
- func New(opts Options) *Cache
type ClearWhen
type KeyIdentity
type Options
type OptionsPartition
- func (o OptionsPartition) CalculateMaxSize(maxSizePerPartition int) int
- func (o OptionsPartition) WeightFraction() float64
type Partition
- func GetOrCreatePartition[K comparable, V any](c *Cache, name string, opts OptionsPartition) *Partition[K, V]
type PartitionManager

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CleanKey ¶

func CleanKey(s string) string

CleanKey turns s into a format suitable for a cache key for this package. The key will be a Unix-styled path with a leading slash but no trailing slash.

Types ¶

type Cache ¶

type Cache struct {
	// contains filtered or unexported fields
}

A dynamic partitioned cache.

func New ¶

func New(opts Options) *Cache

New creates a new cache.

func (*Cache) ClearMatching ¶

func (c *Cache) ClearMatching(predicatePartition func(k string, p PartitionManager) bool, predicateValue func(k, v any) bool)

ClearMatching clears all partition for which the predicate returns true.

func (*Cache) ClearOnRebuild ¶

func (c *Cache) ClearOnRebuild(predicate func(k, v any) bool, changeset ...identity.Identity)

ClearOnRebuild prepares the cache for a new rebuild taking the given changeset into account. predicate is optional and will clear any entry for which it returns true.

func (*Cache) DrainEvictedIdentities ¶

func (c *Cache) DrainEvictedIdentities() []KeyIdentity

DrainEvictedIdentities drains the evicted identities from the cache.

func (*Cache) DrainEvictedIdentitiesMatching ¶

func (c *Cache) DrainEvictedIdentitiesMatching(predicate func(KeyIdentity) bool) []KeyIdentity

DrainEvictedIdentitiesMatching drains the evicted identities from the cache that match the given predicate.

func (*Cache) Keys ¶

func (c *Cache) Keys(predicate func(s string) bool) []string

Keys returns a list of keys in all partitions.

func (*Cache) Stop ¶

func (c *Cache) Stop()

Stop stops the cache.

type ClearWhen ¶

type ClearWhen int

const (
	ClearOnRebuild ClearWhen = iota + 1
	ClearOnChange
	ClearNever
)

type KeyIdentity ¶

type KeyIdentity struct {
	Key      any
	Identity identity.Identity
}

type Options ¶

type Options struct {
	Log           loggers.Logger
	CheckInterval time.Duration
	MaxSize       int
	MinMaxSize    int
	Watching      bool
}

Options for the cache.

type OptionsPartition ¶

type OptionsPartition struct {
	// When to clear the this partition.
	ClearWhen ClearWhen

	// Weight is a number between 1 and 100 that indicates how, in general, how big this partition may get.
	Weight int
}

Options for a partition.

func (OptionsPartition) CalculateMaxSize ¶

func (o OptionsPartition) CalculateMaxSize(maxSizePerPartition int) int

func (OptionsPartition) WeightFraction ¶

func (o OptionsPartition) WeightFraction() float64

type Partition ¶

type Partition[K comparable, V any] struct {
	// contains filtered or unexported fields
}

Partition is a partition in the cache.

func GetOrCreatePartition ¶

func GetOrCreatePartition[K comparable, V any](c *Cache, name string, opts OptionsPartition) *Partition[K, V]

GetOrCreatePartition gets or creates a partition with the given name.

func (*Partition[K, V]) Clear ¶

func (p *Partition[K, V]) Clear()

func (*Partition[K, V]) Get ¶

func (p *Partition[K, V]) Get(ctx context.Context, key K) (V, bool)

func (*Partition[K, V]) GetOrCreate ¶

func (p *Partition[K, V]) GetOrCreate(key K, create func(key K) (V, error)) (V, error)

GetOrCreate gets or creates a value for the given key.

func (*Partition[K, V]) GetOrCreateWitTimeout ¶

func (p *Partition[K, V]) GetOrCreateWitTimeout(key K, duration time.Duration, create func(key K) (V, error)) (V, error)

func (*Partition[K, V]) Keys ¶

func (p *Partition[K, V]) Keys() []K

type PartitionManager ¶

type PartitionManager interface {
	// contains filtered or unexported methods
}

Source Files ¶

View all Source files

dynacache.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL