- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 184 for HUB (0.03 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubTest.groovy
hub.getOutgoing("channel", String) when: hub.requestStop() hub.getOutgoing("channel", String) then: IllegalStateException e = thrown() e.message == 'Cannot create outgoing dispatch, as <hub> has been stopped.' } def "cannot add handler after stop started"() { when: hub.requestStop() hub.addHandler("channel", new Object())
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 21.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/OutgoingQueue.java
*/ package org.gradle.internal.remote.internal.hub; import org.gradle.internal.remote.internal.hub.protocol.ChannelMessage; import org.gradle.internal.remote.internal.hub.protocol.EndOfStream; import org.gradle.internal.remote.internal.hub.queue.MultiEndPointQueue; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; import org.gradle.internal.remote.internal.hub.protocol.RejectedMessage; import java.util.ArrayList;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.8K bytes - Viewed (0) -
operator/pkg/translate/translate_value_test.go
autoscaleMin: 1 cpu: targetAverageUtilization: 80 traceSampling: 1.0 image: pilot env: GODEBUG: gctrace=1 global: hub: docker.io/istio istioNamespace: istio-system tag: 1.2.3 proxy: readinessInitialDelaySeconds: 2 `, want: ` hub: docker.io/istio tag: 1.2.3 components: pilot: enabled: true k8s: replicaCount: 1 env: - name: GODEBUG
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 06 02:56:54 UTC 2023 - 20.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/MultiChannelQueue.java
* limitations under the License. */ package org.gradle.internal.remote.internal.hub.queue; import org.gradle.internal.remote.internal.hub.protocol.ChannelIdentifier; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; import org.gradle.internal.remote.internal.hub.protocol.Routable; import java.util.HashMap; import java.util.Map; import java.util.concurrent.locks.Lock;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.4K bytes - Viewed (0) -
manifests/charts/ztunnel/values.yaml
defaults: # Hub to pull from. Image will be `Hub/Image:Tag-Variant` hub: gcr.io/istio-testing # Tag to pull from. Image will be `Hub/Image:Tag-Variant` tag: latest # Variant to pull. Options are "debug" or "distroless". Unset will use the default for the given version. variant: "" # Image name to pull from. Image will be `Hub/Image:Tag-Variant` # If Image contains a "/", it will replace the entire `image` in the pod. image: ztunnel
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 20:32:30 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/ConnectionSet.java
* limitations under the License. */ package org.gradle.internal.remote.internal.hub; import org.gradle.internal.remote.internal.RemoteConnection; import org.gradle.internal.remote.internal.hub.protocol.EndOfStream; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; import org.gradle.internal.remote.internal.hub.queue.EndPointQueue; import java.util.HashSet; import java.util.Set;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnection.java
hub.addConnection(connection); hub.noFurtherConnections(); completion = null; } @Override public void requestStop() { hub.requestStop(); } @Override public void stop() { // TODO:ADAM - need to cleanup completion too, if not used CompositeStoppable.stoppable(hub, connection).stop(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 7.5K bytes - Viewed (0) -
samples/bookinfo/README.md
## General Setup ```bash # This defines the docker hub to use when running integration tests and building docker images # eg: HUB="docker.io/istio", HUB="gcr.io/istio-testing" export HUB="docker.io/$USER" # This defines the docker tag to use when running integration tests and
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 23:56:37 UTC 2024 - 16.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/ConnectionState.java
* limitations under the License. */ package org.gradle.internal.remote.internal.hub; import org.gradle.internal.remote.internal.RemoteConnection; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; import org.gradle.internal.remote.internal.hub.queue.EndPointQueue; class ConnectionState { private boolean receiveFinished; private boolean dispatchFinished;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.9K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/InterHubMessageSerializer.java
import org.gradle.internal.serialize.StatefulSerializer; import org.gradle.internal.remote.internal.hub.protocol.ChannelIdentifier; import org.gradle.internal.remote.internal.hub.protocol.EndOfStream; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; import java.io.IOException; import java.util.HashMap; import java.util.Map; public class InterHubMessageSerializer implements StatefulSerializer<InterHubMessage> {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 5K bytes - Viewed (0)