unistack-org/micro-store-redis
4
0
Fork 2
Code Issues Pull Requests Actions Packages Projects Releases 33 Wiki Activity

store/redis: use operation options

Browse Source 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
Василий Толстов 2020-05-13 14:45:16 +03:00
parent 75f6ce0868
commit fe98f4a5f9
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
redis.go
View File

@ -26,9 +26,16 @@ func (r *rkv) Close() error {
} }
func (r *rkv) Read(key string, opts ...store.ReadOption) ([]*store.Record, error) { func (r *rkv) Read(key string, opts ...store.ReadOption) ([]*store.Record, error) {
options := store.ReadOptions{}
options.Table = r.options.Table
for _, o := range opts {
o(&options)
}
records := make([]*store.Record, 0, 1) records := make([]*store.Record, 0, 1)
rkey := fmt.Sprintf("%s%s", r.options.Table, key) rkey := fmt.Sprintf("%s%s", options.Table, key)
val, err := r.Client.Get(rkey).Bytes() val, err := r.Client.Get(rkey).Bytes()
if err != nil && err == redis.Nil { if err != nil && err == redis.Nil {
@ -75,7 +82,7 @@ func (r *rkv) Write(record *store.Record, opts ...store.WriteOption) error {
o(&options) o(&options)
} }
rkey := fmt.Sprintf("%s%s", r.options.Table, record.Key) rkey := fmt.Sprintf("%s%s", options.Table, record.Key)
return r.Client.Set(rkey, record.Value, record.Expiry).Err() return r.Client.Set(rkey, record.Value, record.Expiry).Err()
} }