Home
last modified time | relevance | path

Searched defs:ClusterV3 (Results 1 – 25 of 49) sorted by relevance

12

/dports/devel/etcd/etcd-2.3.8/integration/
H A Dv3_lease_test.go369 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 Dcluster.go707 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 Dv3_double_barrier_test.go140 func dropSessionLease(clus *ClusterV3) {
/dports/www/gitea/gitea-1.16.5/vendor/go.etcd.io/etcd/tests/v3/integration/
H A Dcluster.go1250 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 Dcluster.go1280 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 Dv3_lease_test.go883 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 Dcluster.go1232 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 Dv3_lease_test.go872 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 Dcluster.go1207 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 Dv3_lease_test.go872 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 Dcluster.go1213 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 Dv3_lease_test.go872 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 Dcluster.go1213 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 Dv3_lease_test.go872 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 Dv3_lease_test.go711 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 Dcluster.go834 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 Dv3_lease_test.go766 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 Dcluster.go968 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 Dv3_lease_test.go815 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 Dcluster.go1028 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 Dv3_lease_test.go817 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 Dcluster.go1029 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 Dv3_lease_test.go817 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 Dv3_lease_test.go817 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 Dcluster.go1029 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 {

12