cache

Documentation

Overview

Package cache provides ready-to-use in-memory cache mechanisms

Index

• func DefaultBigCacheConfig() bigcache.Config
• type EventWithContext
• type EventsBatcher
  • func NewEventsBatcher(ctx context.Context, debounce time.Duration, idle time.Duration, max int, ...) *EventsBatcher
  • func (b *EventsBatcher) Start()
  • func (b *EventsBatcher) Stop()
• type InstrumentedCache
  • func NewInstrumentedCache(serviceName string, cacheConfig ...bigcache.Config) *InstrumentedCache
  • func (i *InstrumentedCache) Close()
  • func (i *InstrumentedCache) Set(key string, entry []byte) error

Functions

func DefaultBigCacheConfig

func DefaultBigCacheConfig() bigcache.Config

DefaultBigCacheConfig returns a bigcache default config with an eviction time of 30minutes and a HadMaxCachesize of 20MB

Types

type EventWithContext

type EventWithContext struct {
	tree.NodeChangeEvent
	Ctx context.Context
}

EventWithContext composes a NodeChangeEvent and a context

type EventsBatcher

type EventsBatcher struct {
	Events chan *EventWithContext
	Done   chan bool
	// contains filtered or unexported fields
}

EventsBatcher debounces events on a given timeframe and calls process on them afterward

func NewEventsBatcher

func NewEventsBatcher(ctx context.Context, debounce time.Duration, idle time.Duration, max int, process func(context.Context, *tree.NodeChangeEvent)) *EventsBatcher

NewEventsBatcher inits a new EventsBatcher

func (*EventsBatcher) Start

func (b *EventsBatcher) Start()

Start starts listening to incoming events

func (*EventsBatcher) Stop

func (b *EventsBatcher) Stop()

Stop stops listening to incoming events

type InstrumentedCache

type InstrumentedCache struct {
	bigcache.BigCache
	// contains filtered or unexported fields
}

InstrumentCache wraps BigCache with metrics

func NewInstrumentedCache

func NewInstrumentedCache(serviceName string, cacheConfig ...bigcache.Config) *InstrumentedCache

NewInstrumentedCache creates a BigCache instance with a regular report of statistics

func (*InstrumentedCache) Close

func (i *InstrumentedCache) Close()

Close stops internal timer for reporting statistics

func (*InstrumentedCache) Set

func (i *InstrumentedCache) Set(key string, entry []byte) error

Set adds a key/value to the cache.