Merge pull request 'add MDelete' (#107) from mdelete into v3
Reviewed-on: #107
This commit is contained in:
commit
655be440e7
19
redis.go
19
redis.go
@ -166,6 +166,25 @@ func (r *rkv) MRead(ctx context.Context, keys []string, vals interface{}, opts .
|
||||
return nil
|
||||
}
|
||||
|
||||
func (r *rkv) MDelete(ctx context.Context, keys []string, opts ...store.DeleteOption) error {
|
||||
options := store.NewDeleteOptions(opts...)
|
||||
if len(options.Namespace) == 0 {
|
||||
options.Namespace = r.opts.Namespace
|
||||
}
|
||||
if options.Namespace == "" {
|
||||
return r.cli.Del(ctx, keys...).Err()
|
||||
}
|
||||
if r.opts.Timeout > 0 {
|
||||
var cancel context.CancelFunc
|
||||
ctx, cancel = context.WithTimeout(ctx, r.opts.Timeout)
|
||||
defer cancel()
|
||||
}
|
||||
for idx := range keys {
|
||||
keys[idx] = options.Namespace + keys[idx]
|
||||
}
|
||||
return r.cli.Del(ctx, keys...).Err()
|
||||
}
|
||||
|
||||
func (r *rkv) Delete(ctx context.Context, key string, opts ...store.DeleteOption) error {
|
||||
options := store.NewDeleteOptions(opts...)
|
||||
if len(options.Namespace) == 0 {
|
||||
|
Loading…
x
Reference in New Issue
Block a user