/dports/devel/etcd31/etcd-3.1.20/clientv3/ |
H A D | client_test.go | 126 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 D | cluster.go | 59 if isHaltErr(ctx, err) { 71 if isHaltErr(ctx, err) { 85 if isHaltErr(ctx, err) { 98 if isHaltErr(ctx, err) {
|
H A D | lease.go | 180 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 D | txn.go | 145 if isHaltErr(txn.ctx, err) {
|
H A D | maintenance.go | 75 if isHaltErr(ctx, err) {
|
H A D | kv.go | 129 if isHaltErr(ctx, err) {
|
H A D | watch.go | 485 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 D | client_test.go | 136 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 D | watch.go | 500 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 D | client_test.go | 139 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 D | client_test.go | 139 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 D | watch.go | 500 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 D | client_test.go | 139 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 D | client_test.go | 139 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 D | client_test.go | 141 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 D | client_test.go | 141 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 D | client_test.go | 141 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 D | client_test.go | 141 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 D | client_test.go | 150 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 D | cluster.go | 83 if isHaltErr(ctx, err) { 96 if isHaltErr(ctx, err) {
|
H A D | lease.go | 182 if isHaltErr(ctx, err) { 196 if isHaltErr(ctx, err) { 216 if isHaltErr(ctx, err) { 271 if isHaltErr(ctx, err) {
|
H A D | txn.go | 143 if isHaltErr(txn.ctx, err) {
|
H A D | maintenance.go | 95 if isHaltErr(ctx, err) {
|
H A D | kv.go | 124 if isHaltErr(ctx, err) {
|
H A D | watch.go | 492 if isHaltErr(w.ctx, err) || toErr(w.ctx, err) == v3rpc.ErrNoLeader { 778 if isHaltErr(w.ctx, err) {
|