- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 179 for watcher (0.56 sec)
-
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) -
tensorflow/compiler/mlir/quantization/stablehlo/python/integration_test/quantize_model_test.py
# Disable quantization for the quantizable unit (lifted function) whose # function name matches "composite_dot_general_fn_1". # "composite_dot_general_fn_2" will be quantized. specs=qc.QuantizationSpecs( specs=[ qc.QuantizationSpec( matcher=qc.MatcherSpec( function_name=qc.FunctionNameMatcherSpec(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue May 14 06:31:57 UTC 2024 - 51.4K bytes - Viewed (0) -
tests/integration/ambient/main_test.go
ServiceAddressedWaypoint = "service-addressed-waypoint" Captured = "captured" Uncaptured = "uncaptured" Sidecar = "sidecar" ) var inMesh = match.Matcher(func(instance echo.Instance) bool { return instance.Config().HasProxyCapabilities() }) func SetupApps(t resource.Context, i istio.Instance, apps *EchoDeployments) error { var err error
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 10.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/customresourcedefinition.go
Into(result) return } // Watch returns a watch.Interface that watches the requested customResourceDefinitions. func (c *customResourceDefinitions) Watch(ctx context.Context, opts v1.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().
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 12.1K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container_windows.go
// https://github.com/opencontainers/runtime-spec/blob/ad53dcdc39f1f7f7472b10aa0a45648fe4865496/config-windows.md#cpu // If both CpuWeight and CpuMaximum are set - ContainerD catches this invalid case and returns an error instead. resources.CpuMaximum = calculateCPUMaximum(cpuLimit, int64(winstats.ProcessorCount())) } // The processor resource controls are mutually exclusive on
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 8K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/service/scopes/VirtualFileSystemServices.java
import org.gradle.internal.watch.registry.FileWatcherRegistryFactory; import org.gradle.internal.watch.registry.impl.DarwinFileWatcherRegistryFactory; import org.gradle.internal.watch.registry.impl.LinuxFileWatcherRegistryFactory; import org.gradle.internal.watch.registry.impl.WindowsFileWatcherRegistryFactory; import org.gradle.internal.watch.vfs.BuildLifecycleAwareVirtualFileSystem;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 20.4K bytes - Viewed (0)