Function NewAsyncCache

cache/async_cache.go:71–118

(cfg config.Cache, maxExecutionTime time.Duration)

}

func NewAsyncCache(cfg config.Cache, maxExecutionTime time.Duration) (*AsyncCache, error) {
	graceTime := time.Duration(cfg.GraceTime)
	if graceTime > 0 {
		log.Errorf("[DEPRECATED] detected grace time configuration %s. It will be removed in the new version",
			graceTime)
	}
	if graceTime == 0 {
		// Default grace time.
		graceTime = maxExecutionTime
	}
	if graceTime < 0 {
		// Disable protection from `dogpile effect`.
		graceTime = 0
	}

	var cache Cache
	var transaction TransactionRegistry
	var err error
	// transaction will be kept until we're sure there's no possible concurrent query running
	transactionDeadline := 2 * graceTime

	switch cfg.Mode {
	case "file_system":
		cache, err = newFilesSystemCache(cfg, graceTime)
		transaction = newInMemoryTransactionRegistry(transactionDeadline, transactionEndedTTL)
	case "redis":
		var redisClient redis.UniversalClient
		redisClient, err = clients.NewRedisClient(cfg.Redis)
		cache = newRedisCache(redisClient, cfg)
		transaction = newRedisTransactionRegistry(redisClient, transactionDeadline, transactionEndedTTL)
	default:
		return nil, fmt.Errorf("unknown config mode")
	}

	if err != nil {
		return nil, err
	}

	maxPayloadSize := cfg.MaxPayloadSize

	return &AsyncCache{
		Cache:               cache,
		TransactionRegistry: transaction,
		graceTime:           graceTime,
		MaxPayloadSize:      maxPayloadSize,
		SharedWithAllUsers:  cfg.SharedWithAllUsers,
	}, nil
}