mirror of
https://github.com/go-gitea/gitea.git
synced 2024-10-29 08:17:31 -04:00
511f6138d4
* Move last commit cache back into modules/git Signed-off-by: Andrew Thornton <art27@cantab.net> * Remove go-git from the interface for last commit cache Signed-off-by: Andrew Thornton <art27@cantab.net> * move cacheref to last_commit_cache Signed-off-by: Andrew Thornton <art27@cantab.net> * Remove go-git from routers/private/hook Signed-off-by: Andrew Thornton <art27@cantab.net> * Move FindLFSFiles to pipeline Signed-off-by: Andrew Thornton <art27@cantab.net> * Make no-go-git variants Signed-off-by: Andrew Thornton <art27@cantab.net> * Submodule RefID Signed-off-by: Andrew Thornton <art27@cantab.net> * fix issue with GetCommitsInfo Signed-off-by: Andrew Thornton <art27@cantab.net> * fix GetLastCommitForPaths Signed-off-by: Andrew Thornton <art27@cantab.net> * Improve efficiency Signed-off-by: Andrew Thornton <art27@cantab.net> * More efficiency Signed-off-by: Andrew Thornton <art27@cantab.net> * even faster Signed-off-by: Andrew Thornton <art27@cantab.net> * Reduce duplication * As per @lunny Signed-off-by: Andrew Thornton <art27@cantab.net> * attempt to fix drone Signed-off-by: Andrew Thornton <art27@cantab.net> * fix test-tags Signed-off-by: Andrew Thornton <art27@cantab.net> * default to use no-go-git variants and add gogit build tag Signed-off-by: Andrew Thornton <art27@cantab.net> * placate lint Signed-off-by: Andrew Thornton <art27@cantab.net> * as per @6543 Signed-off-by: Andrew Thornton <art27@cantab.net> Co-authored-by: 6543 <6543@obermui.de> Co-authored-by: techknowlogick <techknowlogick@gitea.io>
165 lines
3.7 KiB
Go
165 lines
3.7 KiB
Go
// Copyright 2017 The Gitea Authors. All rights reserved.
|
|
// Use of this source code is governed by a MIT-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package cache
|
|
|
|
import (
|
|
"fmt"
|
|
"strconv"
|
|
|
|
"code.gitea.io/gitea/modules/setting"
|
|
|
|
mc "gitea.com/macaron/cache"
|
|
|
|
_ "gitea.com/macaron/cache/memcache" // memcache plugin for cache
|
|
)
|
|
|
|
var (
|
|
conn mc.Cache
|
|
)
|
|
|
|
func newCache(cacheConfig setting.Cache) (mc.Cache, error) {
|
|
return mc.NewCacher(cacheConfig.Adapter, mc.Options{
|
|
Adapter: cacheConfig.Adapter,
|
|
AdapterConfig: cacheConfig.Conn,
|
|
Interval: cacheConfig.Interval,
|
|
})
|
|
}
|
|
|
|
// Cache is the interface that operates the cache data.
|
|
type Cache interface {
|
|
// Put puts value into cache with key and expire time.
|
|
Put(key string, val interface{}, timeout int64) error
|
|
// Get gets cached value by given key.
|
|
Get(key string) interface{}
|
|
// Delete deletes cached value by given key.
|
|
Delete(key string) error
|
|
// Incr increases cached int-type value by given key as a counter.
|
|
Incr(key string) error
|
|
// Decr decreases cached int-type value by given key as a counter.
|
|
Decr(key string) error
|
|
// IsExist returns true if cached value exists.
|
|
IsExist(key string) bool
|
|
// Flush deletes all cached data.
|
|
Flush() error
|
|
}
|
|
|
|
// NewContext start cache service
|
|
func NewContext() error {
|
|
var err error
|
|
|
|
if conn == nil && setting.CacheService.Enabled {
|
|
if conn, err = newCache(setting.CacheService.Cache); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
return err
|
|
}
|
|
|
|
// GetCache returns the currently configured cache
|
|
func GetCache() Cache {
|
|
return conn
|
|
}
|
|
|
|
// GetString returns the key value from cache with callback when no key exists in cache
|
|
func GetString(key string, getFunc func() (string, error)) (string, error) {
|
|
if conn == nil || setting.CacheService.TTL == 0 {
|
|
return getFunc()
|
|
}
|
|
if !conn.IsExist(key) {
|
|
var (
|
|
value string
|
|
err error
|
|
)
|
|
if value, err = getFunc(); err != nil {
|
|
return value, err
|
|
}
|
|
err = conn.Put(key, value, int64(setting.CacheService.TTL.Seconds()))
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
}
|
|
value := conn.Get(key)
|
|
if v, ok := value.(string); ok {
|
|
return v, nil
|
|
}
|
|
if v, ok := value.(fmt.Stringer); ok {
|
|
return v.String(), nil
|
|
}
|
|
return fmt.Sprintf("%s", conn.Get(key)), nil
|
|
}
|
|
|
|
// GetInt returns key value from cache with callback when no key exists in cache
|
|
func GetInt(key string, getFunc func() (int, error)) (int, error) {
|
|
if conn == nil || setting.CacheService.TTL == 0 {
|
|
return getFunc()
|
|
}
|
|
if !conn.IsExist(key) {
|
|
var (
|
|
value int
|
|
err error
|
|
)
|
|
if value, err = getFunc(); err != nil {
|
|
return value, err
|
|
}
|
|
err = conn.Put(key, value, int64(setting.CacheService.TTL.Seconds()))
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
}
|
|
switch value := conn.Get(key).(type) {
|
|
case int:
|
|
return value, nil
|
|
case string:
|
|
v, err := strconv.Atoi(value)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return v, nil
|
|
default:
|
|
return 0, fmt.Errorf("Unsupported cached value type: %v", value)
|
|
}
|
|
}
|
|
|
|
// GetInt64 returns key value from cache with callback when no key exists in cache
|
|
func GetInt64(key string, getFunc func() (int64, error)) (int64, error) {
|
|
if conn == nil || setting.CacheService.TTL == 0 {
|
|
return getFunc()
|
|
}
|
|
if !conn.IsExist(key) {
|
|
var (
|
|
value int64
|
|
err error
|
|
)
|
|
if value, err = getFunc(); err != nil {
|
|
return value, err
|
|
}
|
|
err = conn.Put(key, value, int64(setting.CacheService.TTL.Seconds()))
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
}
|
|
switch value := conn.Get(key).(type) {
|
|
case int64:
|
|
return value, nil
|
|
case string:
|
|
v, err := strconv.ParseInt(value, 10, 64)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return v, nil
|
|
default:
|
|
return 0, fmt.Errorf("Unsupported cached value type: %v", value)
|
|
}
|
|
}
|
|
|
|
// Remove key from cache
|
|
func Remove(key string) {
|
|
if conn == nil {
|
|
return
|
|
}
|
|
_ = conn.Delete(key)
|
|
}
|