55 lines
1.3 KiB
Go
55 lines
1.3 KiB
Go
// Package etcd...
|
|
//
|
|
// Description : 删除相关操作
|
|
//
|
|
// Author : go_developer@163.com<白茶清欢>
|
|
//
|
|
// Date : 2021-11-24 12:42 下午
|
|
package etcd
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"time"
|
|
|
|
clientv3 "go.etcd.io/etcd/client/v3"
|
|
)
|
|
|
|
// DeleteWithOption ...
|
|
//
|
|
// Author : go_developer@163.com<白茶清欢>
|
|
//
|
|
// Date : 2:02 下午 2021/11/24
|
|
func (wc *WrapperClient) DeleteWithOption(ctx context.Context, key string, timeout time.Duration, optionList ...clientv3.OpOption) (*clientv3.DeleteResponse, error) {
|
|
if nil == ctx {
|
|
ctx = context.Background()
|
|
}
|
|
|
|
if timeout <= 0 {
|
|
timeout = DefaultDeleteTimeout
|
|
}
|
|
|
|
var (
|
|
cancelFunc context.CancelFunc
|
|
deleteResponse *clientv3.DeleteResponse
|
|
err error
|
|
)
|
|
ctx, cancelFunc = context.WithTimeout(ctx, timeout)
|
|
defer cancelFunc()
|
|
|
|
if deleteResponse, err = wc.client.Delete(ctx, key, optionList...); nil != err {
|
|
return nil, errors.New("delete key fail : " + err.Error())
|
|
}
|
|
|
|
return deleteResponse, nil
|
|
}
|
|
|
|
// DeleteWithKeyPrefix 基于 key 前缀, 删除key
|
|
//
|
|
// Author : go_developer@163.com<白茶清欢>
|
|
//
|
|
// Date : 2:12 下午 2021/11/24
|
|
func (wc *WrapperClient) DeleteWithKeyPrefix(ctx context.Context, keyPrefix string, timeout time.Duration) (*clientv3.DeleteResponse, error) {
|
|
return wc.DeleteWithOption(ctx, keyPrefix, timeout, clientv3.WithPrefix())
|
|
}
|