- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 174 for watcher (4.03 sec)
-
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/conflicts/DefaultConflictHandler.java
return potentialConflict(conflicts.newElement(candidate.getId(), candidate.getVersions(), replacedBy)); } /** * Informs if there are any batched up conflicts. */ @Override public boolean hasConflicts() { return !conflicts.isEmpty(); } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 02:21:08 UTC 2024 - 5.2K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/test/groovy/org/gradle/internal/daemon/clientinput/StdInStreamTest.groovy
thread.block() stream.received(bytes) } then: 1 * dispatch.onOutput({ it instanceof ReadStdInEvent }) >> { instant.requested } } def "can read multiple batches of input from client"() { def dispatch = Mock(OutputEventListener) def stream = new StdInStream(dispatch) def text1 = "some text" def bytes1 = text1.bytes def text2 = "more"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 5.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/tests/reconfig_batch_op.mlir
// RUN: tf-tfrt-opt -split-input-file -tfrt-reconfig-batch-op="tfrt-min-num-batch-threads=2 tfrt-min-max-enqueued-batches=3" %s | FileCheck %s --dump-input=always // ----- // The num_batch_threads is lowered bound to 2 from the original attribute of 1 // CHECK-LABEL: func private @batched_function func.func private @batched_function(%arg0: tensor<1x3xf32>) -> tensor<1x3xf32> { %2 = "tf.Identity"(%arg0) : (tensor<1x3xf32>) -> tensor<1x3xf32>
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 31 17:38:34 UTC 2024 - 5.2K bytes - Viewed (0) -
tests/integration/telemetry/tracing/tracing.go
WorkloadPort: 9000, }, }, }) } echos, err := builder.Build() if err != nil { return err } servicePrefix := func(prefix string) match.Matcher { return func(i echo.Instance) bool { return strings.HasPrefix(i.Config().Service, prefix) } } client = servicePrefix("client").GetMatches(echos)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 19:05:09 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/kube/inject/inject.go
) // InjectionPolicy determines the policy for injecting the // sidecar proxy into the watched namespace(s). type InjectionPolicy string const ( // InjectionPolicyDisabled specifies that the sidecar injector // will not inject the sidecar into resources by default for the // namespace(s) being watched. Resources can enable injection // using the "sidecar.istio.io/inject" annotation with value of // true.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 20:35:11 UTC 2024 - 28.8K bytes - Viewed (1) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirCompilerFacility.kt
super.visitClassReference(expression) } @OptIn(UnsafeDuringIrConstructionAPI::class) private inline fun <reified T : IrSymbol> patchIfNeeded(irSymbol: T?, patcher: (T) -> Unit) { if (irSymbol != null) { val irDeclaration = irSymbol.owner as? IrMetadataSourceOwner ?: return val firDeclaration = (irDeclaration.metadata as? FirMetadataSource)?.fir ?: return
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed Jun 05 08:42:45 UTC 2024 - 29.4K bytes - Viewed (0) -
pkg/config/validation/virtualservice.go
// https://github.com/envoyproxy/envoy/blob/v1.29.2/api/envoy/config/route/v3/route_components.proto#L560 // whereas scheme/method/authority does not: // https://github.com/envoyproxy/envoy/blob/v1.29.2/api/envoy/type/matcher/string.proto#L38 errs = appendErrors(errs, validateStringMatchRegexp(match.GetUri(), "uri")) errs = appendErrors(errs, validateStringMatch(match.GetScheme(), "scheme"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:27 UTC 2024 - 9.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/example.go
WatchList(ctx). Into(result) return } // Watch returns a watch.Interface that watches the requested examples. func (c *examples) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error) { var timeout time.Duration if opts.TimeoutSeconds != nil { timeout = time.Duration(*opts.TimeoutSeconds) * time.Second } opts.Watch = true return c.client.Get(). Namespace(c.ns).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 8.6K bytes - Viewed (0) -
samples/addons/prometheus.yaml
- get - list - watch - apiGroups: - "extensions" - "networking.k8s.io" resources: - ingresses/status - ingresses verbs: - get - list - watch - apiGroups: - "discovery.k8s.io" resources: - endpointslices verbs: - get - list - watch - nonResourceURLs: - "/metrics"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:57:35 UTC 2024 - 16.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest_test.go
}, { name: "valid-negative-index-patch", patch: `[{"op": "test", "value": "foo", "path": "/metadata/finalizers/-1"}]`, }, } { p := &patcher{ patchType: types.JSONPatchType, patchBytes: []byte(test.patch), } jp := jsonPatcher{patcher: p} codec := codecs.LegacyCodec(examplev1.SchemeGroupVersion) pod := &examplev1.Pod{} pod.Name = "podA" pod.ObjectMeta.Finalizers = []string{"foo"}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 41.8K bytes - Viewed (0)