package etcd
import (
"errors"
"time"
"github.com/coreos/etcd/pkg/transport"
"github.com/sirupsen/logrus"
"github.com/coreos/etcd/clientv3"
v3 "github.com/coreos/etcd/clientv3"
spb "github.com/coreos/etcd/mvcc/mvccpb"
"golang.org/x/net/context"
)
var (
ErrKeyExists = errors.New("key already exists")
ErrWaitMismatch = errors.New("unexpected wait result")
ErrTooManyClients = errors.New("too many clients")
ErrNoWatcher = errors.New("no watcher channel")
ErrNoEndpoints = errors.New("no etcd endpoint")
)
func deleteRevKey(ctx context.Context, kv v3.KV, key string, rev int64) (bool, error) {
cmp := v3.Compare(v3.ModRevision(key), "=", rev)
req := v3.OpDelete(key)
txnresp, err := kv.Txn(ctx).If(cmp).Then(req).Commit()
if err != nil {
return false, err
} else if !txnresp.Succeeded {
return false, nil
}
return true, nil
}
func claimFirstKey(ctx context.Context, kv v3.KV, kvs []*spb.KeyValue) (*spb.KeyValue, error) {
for _, k := range kvs {
ok, err := deleteRevKey(ctx, kv, string(k.Key), k.ModRevision)
if err != nil {
return nil, err
} else if ok {
return k, nil
}
}
return nil, nil
}
type ClientArgs struct {
Endpoints []string
DialTimeout time.Duration
AutoSyncInterval time.Duration
CaFile string
CertFile string
KeyFile string
}
var (
defaultDialTimeout = 5 * time.Second
defaultAotuSyncInterval = 10 * time.Second
)
func NewClient(ctx context.Context, clientArgs *ClientArgs) (*v3.Client, error) {
if clientArgs.DialTimeout <= 5 {
clientArgs.DialTimeout = defaultDialTimeout
}
if clientArgs.AutoSyncInterval <= 30 {
clientArgs.AutoSyncInterval = defaultAotuSyncInterval
}
config := clientv3.Config{
Context: ctx,
Endpoints: clientArgs.Endpoints,
DialTimeout: clientArgs.DialTimeout,
DialKeepAliveTime: time.Second * 2,
DialKeepAliveTimeout: time.Second * 6,
AutoSyncInterval: clientArgs.AutoSyncInterval,
}
if clientArgs.CaFile != "" && clientArgs.CertFile != "" && clientArgs.KeyFile != "" {
tlsInfo := transport.TLSInfo{
CertFile: clientArgs.CertFile,
KeyFile: clientArgs.KeyFile,
TrustedCAFile: clientArgs.CaFile,
}
tlsConfig, err := tlsInfo.ClientConfig()
if err != nil {
return nil, err
}
config.TLS = tlsConfig
}
var etcdClient *v3.Client
var err error
for {
etcdClient, err = clientv3.New(config)
if err == nil {
logrus.Infof("etcd.v3 client is ready")
return etcdClient, nil
}
logrus.Errorf("create etcd.v3 client failed, try time is %d,%s", 10, err.Error())
time.Sleep(10 * time.Second)
}
}