- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for numWrites (0.09 sec)
-
pkg/controller/namespace/deletion/namespaced_resources_deleter_test.go
} } } }) } } func TestRetryOnConflictError(t *testing.T) { mockClient := &fake.Clientset{} numTries := 0 retryOnce := func(ctx context.Context, namespace *v1.Namespace) (*v1.Namespace, error) { numTries++ if numTries <= 1 { return namespace, errors.NewConflict(api.Resource("namespaces"), namespace.Name, fmt.Errorf("ERROR")) } return namespace, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 07:34:23 UTC 2023 - 15.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler_test.go
numReaders := 100 numRequestsPerReader := 1000 numWriters := 10 numWritesPerWriter := 1000 waitGroup := sync.WaitGroup{} // Spawn a bunch of writers that randomly add groups, remove groups, and // reset the list of groups for i := 0; i < numWriters; i++ { source := rand.NewSource(int64(i)) waitGroup.Add(1) go func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 00:29:39 UTC 2024 - 28.6K bytes - Viewed (0)