Home
last modified time | relevance | path

Searched refs:isHaltErr (Results 1 – 25 of 103) sorted by relevance

12345

/dports/devel/etcd31/etcd-3.1.20/clientv3/
H A Dclient_test.go126 if !isHaltErr(nil, fmt.Errorf("etcdserver: some etcdserver error")) {
129 if isHaltErr(nil, rpctypes.ErrGRPCStopped) {
132 if isHaltErr(nil, rpctypes.ErrGRPCNoLeader) {
136 if isHaltErr(ctx, nil) {
140 if !isHaltErr(ctx, nil) {
H A Dcluster.go59 if isHaltErr(ctx, err) {
71 if isHaltErr(ctx, err) {
85 if isHaltErr(ctx, err) {
98 if isHaltErr(ctx, err) {
H A Dlease.go180 if isHaltErr(cctx, err) {
198 if isHaltErr(ctx, err) {
222 if isHaltErr(cctx, err) {
277 if isHaltErr(ctx, err) {
364 if isHaltErr(l.stopCtx, err) {
H A Dtxn.go145 if isHaltErr(txn.ctx, err) {
H A Dmaintenance.go75 if isHaltErr(ctx, err) {
H A Dkv.go129 if isHaltErr(ctx, err) {
H A Dwatch.go485 if isHaltErr(w.ctx, err) || toErr(w.ctx, err) == v3rpc.ErrNoLeader {
766 if isHaltErr(w.ctx, err) {
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/clientv3/
H A Dclient_test.go136 if !isHaltErr(nil, fmt.Errorf("etcdserver: some etcdserver error")) {
139 if isHaltErr(nil, rpctypes.ErrGRPCStopped) {
142 if isHaltErr(nil, rpctypes.ErrGRPCNoLeader) {
146 if isHaltErr(ctx, nil) {
150 if !isHaltErr(ctx, nil) {
H A Dwatch.go500 if isHaltErr(w.ctx, err) || toErr(w.ctx, err) == v3rpc.ErrNoLeader {
788 if isHaltErr(w.ctx, err) {
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/clientv3/
H A Dclient_test.go139 if !isHaltErr(nil, fmt.Errorf("etcdserver: some etcdserver error")) {
142 if isHaltErr(nil, rpctypes.ErrGRPCStopped) {
145 if isHaltErr(nil, rpctypes.ErrGRPCNoLeader) {
149 if isHaltErr(ctx, nil) {
153 if !isHaltErr(ctx, nil) {
/dports/devel/etcd32/etcd-3.2.32/clientv3/
H A Dclient_test.go139 if !isHaltErr(nil, fmt.Errorf("etcdserver: some etcdserver error")) {
142 if isHaltErr(nil, rpctypes.ErrGRPCStopped) {
145 if isHaltErr(nil, rpctypes.ErrGRPCNoLeader) {
149 if isHaltErr(ctx, nil) {
153 if !isHaltErr(ctx, nil) {
H A Dwatch.go500 if isHaltErr(w.ctx, err) || toErr(w.ctx, err) == v3rpc.ErrNoLeader {
791 if isHaltErr(w.ctx, err) {
/dports/devel/etcd33/etcd-3.3.23/clientv3/
H A Dclient_test.go139 if !isHaltErr(nil, fmt.Errorf("etcdserver: some etcdserver error")) {
142 if isHaltErr(nil, rpctypes.ErrGRPCStopped) {
145 if isHaltErr(nil, rpctypes.ErrGRPCNoLeader) {
149 if isHaltErr(ctx, nil) {
153 if !isHaltErr(ctx, nil) {
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/clientv3/
H A Dclient_test.go139 if !isHaltErr(nil, fmt.Errorf("etcdserver: some etcdserver error")) {
142 if isHaltErr(nil, rpctypes.ErrGRPCStopped) {
145 if isHaltErr(nil, rpctypes.ErrGRPCNoLeader) {
149 if isHaltErr(ctx, nil) {
153 if !isHaltErr(ctx, nil) {
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/clientv3/
H A Dclient_test.go141 if !isHaltErr(nil, fmt.Errorf("etcdserver: some etcdserver error")) {
144 if isHaltErr(nil, rpctypes.ErrGRPCStopped) {
147 if isHaltErr(nil, rpctypes.ErrGRPCNoLeader) {
151 if isHaltErr(ctx, nil) {
155 if !isHaltErr(ctx, nil) {
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/clientv3/
H A Dclient_test.go141 if !isHaltErr(nil, fmt.Errorf("etcdserver: some etcdserver error")) {
144 if isHaltErr(nil, rpctypes.ErrGRPCStopped) {
147 if isHaltErr(nil, rpctypes.ErrGRPCNoLeader) {
151 if isHaltErr(ctx, nil) {
155 if !isHaltErr(ctx, nil) {
/dports/devel/etcd34/etcd-3.4.18/clientv3/
H A Dclient_test.go141 if !isHaltErr(nil, fmt.Errorf("etcdserver: some etcdserver error")) {
144 if isHaltErr(nil, rpctypes.ErrGRPCStopped) {
147 if isHaltErr(nil, rpctypes.ErrGRPCNoLeader) {
151 if isHaltErr(ctx, nil) {
155 if !isHaltErr(ctx, nil) {
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/clientv3/
H A Dclient_test.go141 if !isHaltErr(nil, fmt.Errorf("etcdserver: some etcdserver error")) {
144 if isHaltErr(nil, rpctypes.ErrGRPCStopped) {
147 if isHaltErr(nil, rpctypes.ErrGRPCNoLeader) {
151 if isHaltErr(ctx, nil) {
155 if !isHaltErr(ctx, nil) {
/dports/www/minio-client/etcd-3.5.0/client/v3/
H A Dclient_test.go150 if !isHaltErr(context.TODO(), fmt.Errorf("etcdserver: some etcdserver error")) {
153 if isHaltErr(context.TODO(), rpctypes.ErrGRPCStopped) {
156 if isHaltErr(context.TODO(), rpctypes.ErrGRPCNoLeader) {
160 if isHaltErr(ctx, nil) {
164 if !isHaltErr(ctx, nil) {
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/concourse/dex/vendor/github.com/coreos/etcd/clientv3/
H A Dcluster.go83 if isHaltErr(ctx, err) {
96 if isHaltErr(ctx, err) {
H A Dlease.go182 if isHaltErr(ctx, err) {
196 if isHaltErr(ctx, err) {
216 if isHaltErr(ctx, err) {
271 if isHaltErr(ctx, err) {
H A Dtxn.go143 if isHaltErr(txn.ctx, err) {
H A Dmaintenance.go95 if isHaltErr(ctx, err) {
H A Dkv.go124 if isHaltErr(ctx, err) {
H A Dwatch.go492 if isHaltErr(w.ctx, err) || toErr(w.ctx, err) == v3rpc.ErrNoLeader {
778 if isHaltErr(w.ctx, err) {

12345