blob: 6814fb702420abba0868c0d9a4d45af5b42f4512 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
package redis
import (
"fmt"
"log"
"github.com/gomodule/redigo/redis"
"git.ofmax.li/iserv/internal/image"
)
const V1FilePathFmt = "filepath:up/%s"
// ImageRepo deps. for storage
type ImageRepo struct {
db *redis.Pool
}
// NewRedisImageRepo
func NewRedisImageRepo(conn *redis.Pool) *ImageRepo {
return &ImageRepo{
conn,
}
}
func (r *ImageRepo) AddNewFile(filename string, meta *image.PostMeta, timeout int) error {
conn := r.db.Get()
defer conn.Close()
key := fmt.Sprintf(V1FilePathFmt, filename)
_, err := conn.Do("HMSET", redis.Args{}.Add(key).AddFlat(meta)...)
if err != nil {
log.Fatal(err)
}
return err
}
|
