- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 212 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) -
operator/cmd/mesh/operator-common.go
"istio.io/istio/operator/pkg/helm" "istio.io/istio/operator/pkg/name" "istio.io/istio/operator/pkg/util" ) type operatorCommonArgs struct { // hub is the hub for the operator image. hub string // tag is the tag for the operator image. tag string // imagePullSecrets is an array of imagePullSecret to pull operator image from the private registry imagePullSecrets []string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Dec 17 02:25:04 UTC 2022 - 3.8K bytes - Viewed (0) -
operator/cmd/mesh/operator-dump.go
// common is shared operator args common operatorCommonArgs } func addOperatorDumpFlags(cmd *cobra.Command, args *operatorDumpArgs) { hub, tag := buildversion.DockerInfo.Hub, buildversion.DockerInfo.Tag cmd.PersistentFlags().StringVar(&args.common.hub, "hub", hub, HubFlagHelpStr) cmd.PersistentFlags().StringVar(&args.common.tag, "tag", tag, TagFlagHelpStr)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.6K 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)