sdpcache

Sep 27, 2023

Changes in this version

type Cache

+ func (c *Cache) Lookup(ctx context.Context, srcName string, method sdp.QueryMethod, scope string, ...) (bool, CacheKey, []*sdp.Item, *sdp.QueryError)

+ type CacheKey struct

+ Method *sdp.QueryMethod

+ Query *string

+ SST SST

+ UniqueAttributeValue *string

+ func CacheKeyFromParts(srcName string, method sdp.QueryMethod, scope string, typ string, query string) CacheKey

+ func CacheKeyFromQuery(q *sdp.Query, srcName string) CacheKey

+ func (ck CacheKey) Matches(i IndexValues) bool

+ func (ck CacheKey) String() string

+ func (ck CacheKey) ToIndexValues() IndexValues

Jul 3, 2023

Changes in this version

+ var ErrCacheNotFound = errors.New("not found in cache")

type Cache

+ func NewCache() *Cache

+ type CacheQuery struct

+ Method *sdp.QueryMethod

+ Query *string

+ SST SST

+ UniqueAttributeValue *string

+ func (cq CacheQuery) Matches(i IndexValues) bool

+ func (cq CacheQuery) String() string

+ func (cq CacheQuery) ToIndexValues() IndexValues

type CachedResult

+ Expiry time.Time

+ IndexValues IndexValues

+ type IndexValues struct

+ Method sdp.QueryMethod

+ Query string

+ SSTHash SSTHash

+ UniqueAttributeValue string

type PurgeStats

+ NextExpiry *time.Time

+ type SST struct

+ Scope string

+ SourceName string

+ Type string

+ func (s SST) Hash() SSTHash

+ type SSTHash string

Jan 20, 2022

Changes in this version

type Cache

+ func (c *Cache) StopPurger()

Jan 17, 2022

Changes in this version

type Cache

+ func (c *Cache) Clear()

Nov 2, 2021

Changes in this version

+ const MinWaitDefault

+ type Cache struct

+ MinWaitTime time.Duration

+ Name string

+ Storage []CachedResult

+ func (c *Cache) BulkStoreItem(items []*sdp.Item, duration time.Duration, tags Tags)

+ func (c *Cache) Delete(searchTags Tags) error

+ func (c *Cache) GetMinWaitTime() time.Duration

+ func (c *Cache) Purge() PurgeStats

+ func (c *Cache) Search(searchTags Tags) ([]*sdp.Item, error)

+ func (c *Cache) StartPurger()

+ func (c *Cache) StoreError(err error, duration time.Duration, tags Tags)

+ func (c *Cache) StoreItem(item *sdp.Item, duration time.Duration, tags Tags)

+ type CacheNotFoundError Tags

+ func (c CacheNotFoundError) Error() string

+ type CachedResult struct

+ CacheDuration time.Duration

+ Error error

+ InsertTime time.Time

+ Item *sdp.Item

+ Tags Tags

+ func (cr *CachedResult) Expired() bool

+ func (cr *CachedResult) HasTag(key string, value string) bool

+ func (cr *CachedResult) HasTags(tags Tags) bool

+ type PurgeStats struct

+ NumPurged int

+ ShortestCacheRemaining time.Duration

+ TimeTaken time.Duration

+ type Tags map[string]string

+ func DefaultErrorTags(e error) Tags

+ func DefaultItemTags(item *sdp.Item) Tags