/dports/devel/etcd/etcd-2.3.8/integration/ |
H A D | v3_lease_test.go | 369 func acquireLeaseAndKey(clus *ClusterV3, key string) (int64, error) { 390 func testLeaseRemoveLeasedKey(t *testing.T, act func(*ClusterV3, int64) error) { 414 func leaseExist(t *testing.T, clus *ClusterV3, leaseID int64) bool {
|
H A D | cluster.go | 707 type ClusterV3 struct { struct 708 *cluster 709 clients []*clientv3.Client 729 func (c *ClusterV3) Terminate(t *testing.T) { 738 func (c *ClusterV3) RandClient() *clientv3.Client { 742 func (c *ClusterV3) Client(i int) *clientv3.Client {
|
H A D | v3_double_barrier_test.go | 140 func dropSessionLease(clus *ClusterV3) {
|
/dports/www/gitea/gitea-1.16.5/vendor/go.etcd.io/etcd/tests/v3/integration/ |
H A D | cluster.go | 1250 type ClusterV3 struct { struct 1251 *cluster 1253 mu sync.Mutex 1254 clients []*clientv3.Client 1292 func (c *ClusterV3) TakeClient(idx int) { 1298 func (c *ClusterV3) Terminate(t testing.TB) { 1312 func (c *ClusterV3) RandClient() *clientv3.Client { 1316 func (c *ClusterV3) Client(i int) *clientv3.Client { 1398 func (c *ClusterV3) AddAndLaunchLearnerMember(t testing.TB) { 1428 func (c *ClusterV3) getMembers() []*pb.Member { [all …]
|
/dports/www/minio-client/etcd-3.5.0/tests/integration/ |
H A D | cluster.go | 1280 type ClusterV3 struct { struct 1281 *cluster 1283 mu sync.Mutex 1284 clients []*clientv3.Client 1314 func (c *ClusterV3) TakeClient(idx int) { 1320 func (c *ClusterV3) Terminate(t testutil.TB) { 1334 func (c *ClusterV3) RandClient() *clientv3.Client { 1338 func (c *ClusterV3) Client(i int) *clientv3.Client { 1420 func (c *ClusterV3) AddAndLaunchLearnerMember(t testutil.TB) { 1450 func (c *ClusterV3) getMembers() []*pb.Member { [all …]
|
H A D | v3_lease_test.go | 883 func acquireLeaseAndKey(clus *ClusterV3, key string) (int64, error) { 904 func testLeaseRemoveLeasedKey(t *testing.T, act func(*ClusterV3, int64) error) { 928 func leaseExist(t *testing.T, clus *ClusterV3, leaseID int64) bool {
|
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/integration/ |
H A D | cluster.go | 1232 type ClusterV3 struct { struct 1233 *cluster 1235 mu sync.Mutex 1236 clients []*clientv3.Client 1264 func (c *ClusterV3) TakeClient(idx int) { 1270 func (c *ClusterV3) Terminate(t testing.TB) { 1284 func (c *ClusterV3) RandClient() *clientv3.Client { 1288 func (c *ClusterV3) Client(i int) *clientv3.Client { 1329 func (c *ClusterV3) AddAndLaunchLearnerMember(t testing.TB) { 1359 func (c *ClusterV3) getMembers() []*pb.Member { [all …]
|
H A D | v3_lease_test.go | 872 func acquireLeaseAndKey(clus *ClusterV3, key string) (int64, error) { 893 func testLeaseRemoveLeasedKey(t *testing.T, act func(*ClusterV3, int64) error) { 917 func leaseExist(t *testing.T, clus *ClusterV3, leaseID int64) bool {
|
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/integration/ |
H A D | cluster.go | 1207 type ClusterV3 struct { struct 1208 *cluster 1210 mu sync.Mutex 1211 clients []*clientv3.Client 1239 func (c *ClusterV3) TakeClient(idx int) { 1245 func (c *ClusterV3) Terminate(t testing.TB) { 1259 func (c *ClusterV3) RandClient() *clientv3.Client { 1263 func (c *ClusterV3) Client(i int) *clientv3.Client { 1304 func (c *ClusterV3) AddAndLaunchLearnerMember(t testing.TB) { 1334 func (c *ClusterV3) getMembers() []*pb.Member { [all …]
|
H A D | v3_lease_test.go | 872 func acquireLeaseAndKey(clus *ClusterV3, key string) (int64, error) { 893 func testLeaseRemoveLeasedKey(t *testing.T, act func(*ClusterV3, int64) error) { 917 func leaseExist(t *testing.T, clus *ClusterV3, leaseID int64) bool {
|
/dports/devel/etcd34/etcd-3.4.18/integration/ |
H A D | cluster.go | 1213 type ClusterV3 struct { struct 1214 *cluster 1216 mu sync.Mutex 1217 clients []*clientv3.Client 1245 func (c *ClusterV3) TakeClient(idx int) { 1251 func (c *ClusterV3) Terminate(t testing.TB) { 1265 func (c *ClusterV3) RandClient() *clientv3.Client { 1269 func (c *ClusterV3) Client(i int) *clientv3.Client { 1310 func (c *ClusterV3) AddAndLaunchLearnerMember(t testing.TB) { 1340 func (c *ClusterV3) getMembers() []*pb.Member { [all …]
|
H A D | v3_lease_test.go | 872 func acquireLeaseAndKey(clus *ClusterV3, key string) (int64, error) { 893 func testLeaseRemoveLeasedKey(t *testing.T, act func(*ClusterV3, int64) error) { 917 func leaseExist(t *testing.T, clus *ClusterV3, leaseID int64) bool {
|
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/integration/ |
H A D | cluster.go | 1213 type ClusterV3 struct { struct 1214 *cluster 1216 mu sync.Mutex 1217 clients []*clientv3.Client 1245 func (c *ClusterV3) TakeClient(idx int) { 1251 func (c *ClusterV3) Terminate(t testing.TB) { 1265 func (c *ClusterV3) RandClient() *clientv3.Client { 1269 func (c *ClusterV3) Client(i int) *clientv3.Client { 1310 func (c *ClusterV3) AddAndLaunchLearnerMember(t testing.TB) { 1340 func (c *ClusterV3) getMembers() []*pb.Member { [all …]
|
H A D | v3_lease_test.go | 872 func acquireLeaseAndKey(clus *ClusterV3, key string) (int64, error) { 893 func testLeaseRemoveLeasedKey(t *testing.T, act func(*ClusterV3, int64) error) { 917 func leaseExist(t *testing.T, clus *ClusterV3, leaseID int64) bool {
|
/dports/devel/etcd31/etcd-3.1.20/integration/ |
H A D | v3_lease_test.go | 711 func acquireLeaseAndKey(clus *ClusterV3, key string) (int64, error) { 732 func testLeaseRemoveLeasedKey(t *testing.T, act func(*ClusterV3, int64) error) { 756 func leaseExist(t *testing.T, clus *ClusterV3, leaseID int64) bool {
|
H A D | cluster.go | 834 type ClusterV3 struct { struct 835 *cluster 837 mu sync.Mutex 838 clients []*clientv3.Client 860 func (c *ClusterV3) TakeClient(idx int) { 866 func (c *ClusterV3) Terminate(t *testing.T) { 880 func (c *ClusterV3) RandClient() *clientv3.Client { 884 func (c *ClusterV3) Client(i int) *clientv3.Client {
|
/dports/devel/etcd32/etcd-3.2.32/integration/ |
H A D | v3_lease_test.go | 766 func acquireLeaseAndKey(clus *ClusterV3, key string) (int64, error) { 787 func testLeaseRemoveLeasedKey(t *testing.T, act func(*ClusterV3, int64) error) { 811 func leaseExist(t *testing.T, clus *ClusterV3, leaseID int64) bool {
|
H A D | cluster.go | 968 type ClusterV3 struct { struct 969 *cluster 971 mu sync.Mutex 972 clients []*clientv3.Client 997 func (c *ClusterV3) TakeClient(idx int) { 1003 func (c *ClusterV3) Terminate(t *testing.T) { 1017 func (c *ClusterV3) RandClient() *clientv3.Client { 1021 func (c *ClusterV3) Client(i int) *clientv3.Client {
|
/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/integration/ |
H A D | v3_lease_test.go | 815 func acquireLeaseAndKey(clus *ClusterV3, key string) (int64, error) { 836 func testLeaseRemoveLeasedKey(t *testing.T, act func(*ClusterV3, int64) error) { 860 func leaseExist(t *testing.T, clus *ClusterV3, leaseID int64) bool {
|
H A D | cluster.go | 1028 type ClusterV3 struct { struct 1029 *cluster 1031 mu sync.Mutex 1032 clients []*clientv3.Client 1060 func (c *ClusterV3) TakeClient(idx int) { 1066 func (c *ClusterV3) Terminate(t *testing.T) { 1080 func (c *ClusterV3) RandClient() *clientv3.Client { 1084 func (c *ClusterV3) Client(i int) *clientv3.Client {
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/integration/ |
H A D | v3_lease_test.go | 817 func acquireLeaseAndKey(clus *ClusterV3, key string) (int64, error) { 838 func testLeaseRemoveLeasedKey(t *testing.T, act func(*ClusterV3, int64) error) { 862 func leaseExist(t *testing.T, clus *ClusterV3, leaseID int64) bool {
|
H A D | cluster.go | 1029 type ClusterV3 struct { struct 1030 *cluster 1032 mu sync.Mutex 1033 clients []*clientv3.Client 1061 func (c *ClusterV3) TakeClient(idx int) { 1067 func (c *ClusterV3) Terminate(t *testing.T) { 1081 func (c *ClusterV3) RandClient() *clientv3.Client { 1085 func (c *ClusterV3) Client(i int) *clientv3.Client {
|
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/integration/ |
H A D | v3_lease_test.go | 817 func acquireLeaseAndKey(clus *ClusterV3, key string) (int64, error) { 838 func testLeaseRemoveLeasedKey(t *testing.T, act func(*ClusterV3, int64) error) { 862 func leaseExist(t *testing.T, clus *ClusterV3, leaseID int64) bool {
|
/dports/devel/etcd33/etcd-3.3.23/integration/ |
H A D | v3_lease_test.go | 817 func acquireLeaseAndKey(clus *ClusterV3, key string) (int64, error) { 838 func testLeaseRemoveLeasedKey(t *testing.T, act func(*ClusterV3, int64) error) { 862 func leaseExist(t *testing.T, clus *ClusterV3, leaseID int64) bool {
|
H A D | cluster.go | 1029 type ClusterV3 struct { struct 1030 *cluster 1032 mu sync.Mutex 1033 clients []*clientv3.Client 1061 func (c *ClusterV3) TakeClient(idx int) { 1067 func (c *ClusterV3) Terminate(t *testing.T) { 1081 func (c *ClusterV3) RandClient() *clientv3.Client { 1085 func (c *ClusterV3) Client(i int) *clientv3.Client {
|