cache

Documentation

Index

• func NewCachedEnricher(cache enriching.EnricherCache, enricher enriching.Enricher, ...) enriching.Enricher
• func NewEnricherRedisCache(redis *redis.Client) enriching.EnricherCache
• func NewInstrumentedCache(impl enriching.EnricherCache, metricsReporter extensions.MetricsReporter) enriching.EnricherCache
• type CachedEnricherOptions
  • func WithLogger(logger *zap.Logger) CachedEnricherOptions
  • func WithTTL(ttl time.Duration) CachedEnricherOptions

Functions

func NewCachedEnricher

func NewCachedEnricher(
	cache enriching.EnricherCache,
	enricher enriching.Enricher,
	options ...CachedEnricherOptions,
) enriching.Enricher

func NewEnricherRedisCache

func NewEnricherRedisCache(
	redis *redis.Client,
) enriching.EnricherCache

func NewInstrumentedCache

func NewInstrumentedCache(
	impl enriching.EnricherCache,
	metricsReporter extensions.MetricsReporter,
) enriching.EnricherCache

NewInstrumentedCache returns an EnrichCache implementation wrapped with metrics reporting and tracing

Types

type CachedEnricherOptions

type CachedEnricherOptions func(enriching.Enricher)

func WithLogger

func WithLogger(logger *zap.Logger) CachedEnricherOptions

WithLogger sets the logger for the cached enricher.

func WithTTL

func WithTTL(ttl time.Duration) CachedEnricherOptions