Method load

pkg/cache/memory.go:48–87

(ctx context.Context, key string, r *http.Request)

}

func (c *MemoryCache) load(ctx context.Context, key string, r *http.Request) {
	log := logger.FromContext(ctx)

	payload, statusCode, contentType, overrideDuration, err := c.loader.Load(ctx, key, r)

	if statusCode == nil {
		log.Warnw("Missing status code, setting to 200 default")
		statusCode = &defaultStatusCode
	}
	if contentType == nil {
		log.Warnw("Missing content type, setting to application/json default")
		contentType = &defaultContentType
	}

	dur := c.cacheDuration
	if overrideDuration != 0 {
		dur = overrideDuration
	}

	response := Response{
		Payload:     payload,
		StatusCode:  *statusCode,
		ContentType: *contentType,
	}

	// Cache it
	if err == nil {
		cacheKey := c.keyProvider.CacheKey(ctx, key)
		kvCache.Set(cacheKey, response, dur)
	} else {
		fmt.Println("Error when some load function was called:", err)
	}

	c.requestsMutex.Lock()
	for _, ch := range c.requests[key] {
		ch <- response
	}
	delete(c.requests, key)
	c.requestsMutex.Unlock()
}

func (c *MemoryCache) Get(ctx context.Context, key string, r *http.Request) (*Response, error) {
	log := logger.FromContext(ctx)