- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 141 for waiters (0.44 sec)
-
pkg/scheduler/framework/plugins/dynamicresources/structuredparameters_test.go
slices resourceSliceLister claims assumeCacheLister inFlight map[types.UID]resourceapi.ResourceClaimStatus wantResources resources wantErr bool }{ "empty": {}, "slice-list-error": { slices: sliceError("slice list error"), wantErr: true, }, "unknown-model": { slices: sliceList{ &resourceapi.ResourceSlice{ NodeName: "node", DriverName: "driver",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 09:27:01 UTC 2024 - 34.8K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/SystemHelperTest.java
final List<Map<String, String>> enItems = systemHelper.getLanguageItems(Locale.ENGLISH); assertEquals(55, enItems.size()); final List<Map<String, String>> jaItems = systemHelper.getLanguageItems(Locale.JAPANESE); assertEquals(55, jaItems.size()); } public void test_getHostnamet() { assertNotNull(systemHelper.getHostname()); try { envMap.put("COMPUTERNAME", "xxx");
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controlplane/reconcilers/instancecount_test.go
expectUpdate: makeEndpointsArray("foo", []string{"1.2.3.4"}, []corev1.EndpointPort{{Name: "foo", Port: 8080, Protocol: "TCP"}}), }, { testName: "existing endpoints satisfy but too many + extra masters", serviceName: "foo", ip: "1.2.3.4", endpointPorts: []corev1.EndpointPort{{Name: "foo", Port: 8080, Protocol: "TCP"}}, additionalMasters: 3,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 27 12:46:24 UTC 2022 - 14K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/storage/storage_factory.go
// of exposing one set of concepts. autoscaling.HPA and extensions.HPA as a for instance // The order of the slice matters! It is the priority order of lookup for finding a storage location cohabitatingResources []schema.GroupResource // encoderDecoratorFn is optional and may wrap the provided encoder prior to being serialized.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 13:35:58 UTC 2023 - 14.1K bytes - Viewed (0) -
pkg/controlplane/instance.go
ServiceNodePortRange utilnet.PortRange // If non-zero, the "kubernetes" services uses this port as NodePort. KubernetesServiceNodePort int // Number of masters running; all masters must be started with the // same value for this field. (Numbers > 1 currently untested.) MasterCount int // MasterEndpointReconcileTTL sets the time to live in seconds of an
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.2K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
} return err } // Reset the read pointer and writer pointer to zero. func (r *RingBuffer) Reset() { r.mu.Lock() defer r.mu.Unlock() // Set error so any readers/writers will return immediately. r.setErr(errors.New("reset called"), true) if r.block { r.readCond.Broadcast() r.writeCond.Broadcast() } // Unlock the mutex so readers/writers can finish. r.mu.Unlock() r.wg.Wait()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease.go
storagefactory "k8s.io/apiserver/pkg/storage/storagebackend/factory" endpointsv1 "k8s.io/kubernetes/pkg/api/v1/endpoints" ) // Leases is an interface which assists in managing the set of active masters type Leases interface { // ListLeases retrieves a list of the current master IPs ListLeases() ([]string, error) // UpdateLease adds or refreshes a master's lease UpdateLease(ip string) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 11.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/CharStreamsTest.java
StringWriter writer = new StringWriter(); long copied = CharStreams.copy(new StringReader(ASCII), writer); assertEquals(ASCII, writer.toString()); assertEquals(ASCII.length(), copied); StringWriter writer2 = new StringWriter(); copied = CharStreams.copy(new StringReader(I18N), writer2); assertEquals(I18N, writer2.toString()); assertEquals(I18N.length(), copied); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 11.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CharStreamsTest.java
StringWriter writer = new StringWriter(); long copied = CharStreams.copy(new StringReader(ASCII), writer); assertEquals(ASCII, writer.toString()); assertEquals(ASCII.length(), copied); StringWriter writer2 = new StringWriter(); copied = CharStreams.copy(new StringReader(I18N), writer2); assertEquals(I18N, writer2.toString()); assertEquals(I18N.length(), copied); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 11.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
private val messageFrameBuffer = Buffer() /** Lazily initialized on first use. */ private var messageInflater: MessageInflater? = null // Masks are only a concern for server writers. private val maskKey: ByteArray? = if (isClient) null else ByteArray(4) private val maskCursor: Buffer.UnsafeCursor? = if (isClient) null else Buffer.UnsafeCursor() interface FrameCallback {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.8K bytes - Viewed (0)