- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for simulate (1.03 sec)
-
operator/cmd/mesh/testdata/manifest-generate/input-extra-resources/default_installation_failed.yaml
# Simulate the case where the default installation failed, and the user has to reinstall the components. apiVersion: admissionregistration.k8s.io/v1 kind: MutatingWebhookConfiguration metadata: labels: app: sidecar-injector name: w-istio-sidecar-injector-istio-system webhooks: - admissionReviewVersions: - v1beta1 - v1 clientConfig: service: name: istiod namespace: istio-system path: /inject
Others - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Thu Feb 22 08:32:23 GMT 2024 - 1.9K bytes - Viewed (0) -
cmd/xl-storage-free-version_test.go
"00000000-0000-0000-0000-0000000000f1", "00000000-0000-0000-0000-0000000000f2", } // Simulate overwrite of null version newtierfi := tierfi newtierfi.SetTierFreeVersionID(fvIDs[0]) fatalErr(xl.AddFreeVersion(newtierfi)) report() fatalErr(xl.AddVersion(newtierfi)) report() // Simulate removal of null version newtierfi.TransitionTier = "" newtierfi.TransitionedObjName = ""
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 7.8K bytes - Viewed (0) -
cmd/admin-handlers_test.go
// single node setup, this degenerates to a simple function // call under the hood. globalMinioAddr = "127.0.0.1:9000" var wg sync.WaitGroup // Setting up a go routine to simulate ServerRouter's // handleServiceSignals for stop and restart commands. if cmd == restartCmd { wg.Add(1) go func() { defer wg.Done() testServiceSignalReceiver(cmd, t) }() }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
cmd/metrics-v2_test.go
}, { val: 0.79, label: labels[2], }, } ticker := time.NewTicker(1 * time.Millisecond) defer ticker.Stop() for _, obs := range observations { // Send observations once every 1ms, to simulate delay between // observations. This is to test the channel based // synchronization used internally. select { case <-ticker.C: ttfbHist.With(prometheus.Labels{"api": obs.label}).Observe(obs.val) } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 2.3K bytes - Viewed (0) -
cmd/naughty-disk_test.go
import ( "context" "io" "sync" "time" "github.com/minio/madmin-go/v3" ) // naughtyDisk wraps a POSIX disk and returns programmed errors // specified by the developer. The purpose is to simulate errors // that are hard to simulate in practice like DiskNotFound. // Programmed errors are stored in errors field. type naughtyDisk struct { // The real disk disk StorageAPI // Programmed errors: API call number => error to return
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheTesting.java
* * @author mike nonemacher */ @SuppressWarnings("GuardedBy") // TODO(b/35466881): Fix or suppress. class CacheTesting { /** * Poke into the Cache internals to simulate garbage collection of the value associated with the * given key. This assumes that the associated entry is a WeakValueReference or a * SoftValueReference (and not a LoadingValueReference), and throws an IllegalStateException if
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 16.7K bytes - Viewed (0) -
cmd/erasure-healing_test.go
fileInfoPreHeal, err := disk.ReadVersion(context.Background(), "", bucket, object, "", ReadOptions{ReadData: false, Healing: true}) if err != nil { t.Fatal(err) } // Remove the object - to simulate the case where the disk was down when the object // was created. err = removeAll(pathJoin(disk.String(), bucket, object)) if err != nil { t.Fatal(err) } // Checking abandoned parts should do nothing
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 47.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheTesting.java
* * @author mike nonemacher */ @SuppressWarnings("GuardedBy") // TODO(b/35466881): Fix or suppress. class CacheTesting { /** * Poke into the Cache internals to simulate garbage collection of the value associated with the * given key. This assumes that the associated entry is a WeakValueReference or a * SoftValueReference (and not a LoadingValueReference), and throws an IllegalStateException if
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 16.7K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
ctx, cancel := context.WithCancel(context.Background()) defer cancel() pods := &fakePodCache{} pod, f := podAndNetns() f.Close() pods.pods = map[string]WorkloadInfo{ string(pod.UID): {}, // simulate unknown netns } fixture := connectWithPods(ctx, pods) ztunClient := fixture.ztunClient // read initial pod add keep, fds := readRequest(t, ztunClient) assert.Equal(t, len(fds), 0)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
val sleepUntil = nanoTime + durationNanos yieldUntil { nanoTime >= sleepUntil } } } /** * Artificially stall until manually resumed by the test thread with [runTasks]. Use this to * simulate races in tasks that doesn't have a deterministic sequence. */ fun yield() { taskRunner.assertThreadDoesntHoldLock() taskRunner.lock.withLock { yieldUntil() } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0)