cache

package

v0.0.0-...-98ba599 Latest Latest Go to latest Published: Jul 2, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

func NewLRUCache(size int) *LRUCache

func (c *LRUCache) GetAggregate(a fes.Aggregate) (fes.Entity, error)

func (c *LRUCache) Invalidate(a fes.Aggregate)

func (c *LRUCache) List() []fes.Aggregate

func (c *LRUCache) Put(entity fes.Entity) error

func (c *LRUCache) Refresh(key fes.Aggregate)

type LoadingCache struct {
	fes.CacheReaderWriter
	// contains filtered or unexported fields
}

LoadingCache looks into a backing data store in case there is a cache miss

func NewLoadingCache(cache fes.CacheReaderWriter, client fes.Backend, projector fes.Projector) *LoadingCache

func (c *LoadingCache) GetAggregate(key fes.Aggregate) (fes.Entity, error)

func (c *LoadingCache) List() []fes.Aggregate

List for a LoadingCache returns the keys of all entities in the cache.

TODO provide option to force fallback or only do quick cache lookup. TODO sync cache with store while you are at it.

func (c *LoadingCache) Load(key fes.Aggregate) error

func (c *LoadingCache) Refresh(key fes.Aggregate)

type SubscribedCache struct {
	pubsub.Publisher
	fes.CacheReaderWriter
	// contains filtered or unexported fields
}

A SubscribedCache is subscribed to an event emitter

func NewSubscribedCache(cache fes.CacheReaderWriter, projector fes.Projector,
	sub *pubsub.Subscription) *SubscribedCache

func (uc *SubscribedCache) Close() error