- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 141 for consumed (0.2 sec)
-
common-protos/k8s.io/api/discovery/v1/generated.proto
} // EndpointHints provides hints describing how an endpoint should be consumed. message EndpointHints { // forZones indicates the zone(s) this endpoint should be consumed by to // enable topology aware routing. // +listType=atomic repeated ForZone forZones = 1; } // EndpointPort represents a Port used by an EndpointSlice // +structType=atomic message EndpointPort {
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 8K bytes - Viewed (0) -
common-protos/k8s.io/api/discovery/v1beta1/generated.proto
} // EndpointHints provides hints describing how an endpoint should be consumed. message EndpointHints { // forZones indicates the zone(s) this endpoint should be consumed by to // enable topology aware routing. May contain a maximum of 8 entries. // +listType=atomic repeated ForZone forZones = 1; } // EndpointPort represents a Port used by an EndpointSlice message EndpointPort {
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 8K bytes - Viewed (0) -
cmd/admin-heal-ops.go
healFinishedStatus = "finished" ) const ( // a heal sequence with this many un-consumed heal result // items blocks until heal-status consumption resumes or is // aborted due to timeout. maxUnconsumedHealResultItems = 1000 // if no heal-results are consumed (via the heal-status API) // for this timeout duration, the heal sequence is aborted. healUnconsumedTimeout = 24 * time.Hour
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/flowcontrol/WindowCounter.kt
* limitations under the License. */ package okhttp3.internal.http2.flowcontrol class WindowCounter( val streamId: Int, ) { /** The total number of bytes consumed. */ var total: Long = 0L private set /** The total number of bytes acknowledged by outgoing `WINDOW_UPDATE` frames. */ var acknowledged: Long = 0L private set val unacknowledged: Long
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 1.4K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/artifact/MavenArtifactProperties.java
* consumer project. * <p> * Note: This property is about "build path", whatever it means in the scope of the consumer project. It is NOT * about Java classpath or anything alike. How artifact is being consumed depends heavily on the consumer project. * Resolver is and will remain agnostic of consumer project use cases. */
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 2.5K bytes - Viewed (0) -
architecture/ambient/ztunnel.md
A secondary goal was to enable a smoother on-ramp from "Zero" to "Getting some value". Historically, Istio had to really be consumed all-or-nothing for things to work as expected. In particular, an easy answer to "I just want to have mTLS everywhere, then I can think about adopting the rest of service mesh" was desired. ## Goals Ztunnel should:
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 22:35:16 GMT 2024 - 16.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
val condition: Condition = lock.newCondition() // Internal state is guarded by [lock]. No long-running or potentially blocking operations are // performed while the lock is held. /** The bytes consumed and acknowledged by the stream. */ val readBytes: WindowCounter = WindowCounter(id) /** The total number of bytes produced by the application. */ var writeBytesTotal = 0L internal set
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
common-protos/k8s.io/api/storage/v1alpha1/generated.proto
// - such an object exists, but the capacity is unset // - such an object exists, but the capacity is zero // // The producer of these objects can decide which approach is more suitable. // // They are consumed by the kube-scheduler when a CSI driver opts into // capacity-aware scheduling with CSIDriverSpec.StorageCapacity. The scheduler // compares the MaximumVolumeSize against the requested size of pending volumes
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 9.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
service.shutdown(); } assertThat(holder.count).isEqualTo(ITERATION_COUNT); for (int length : completeLengthChecks) { // Verify that at max depth, less than one stack frame per submitted task was consumed assertThat(length - baseStackDepth).isLessThan(DIRECT_EXECUTIONS_PER_THREAD / 2); } } @SuppressWarnings("ObjectToString") // Intended behavior public void testToString() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
service.shutdown(); } assertThat(holder.count).isEqualTo(ITERATION_COUNT); for (int length : completeLengthChecks) { // Verify that at max depth, less than one stack frame per submitted task was consumed assertThat(length - baseStackDepth).isLessThan(DIRECT_EXECUTIONS_PER_THREAD / 2); } } @SuppressWarnings("ObjectToString") // Intended behavior public void testToString() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0)