package storage

import (
    "gitee.com/mysoft-free/cron-task/lib/context"
    "sync"
)

//定义存储的接口
type IStorage interface {
    Set(key string ,value interface{},force bool)error
    Get(key string)(interface{},error)
    Del(key string)error
    Release(keys ...string)error
}

//获取新的存储引擎
func NewStorage(context *context.Context) IStorage {

    stype := context.Config.HttpServer.Storage

    switch stype {
    case "local":
        return &LocalStorage{sMap:sync.Map{}}
    case "redis":
        s := &RedisStorage{}
        redis :=context.Config.Redis //关联原配置redis
        s.Init(redis.Addr,redis.Password,redis.DB)
        return s
    default:
        return nil
    }


}