- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 5,684 for collector (0.21 sec)
-
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirDataFlowInfoProvider.kt
jumpExpressions = jumpExpressions, hasJumps = collector.hasJumps, hasEscapingJumps = graphIndex.computeHasEscapingJumps(firDefaultStatement, collector), hasMultipleJumpKinds = collector.hasMultipleJumpKinds, hasMultipleJumpTargets = graphIndex.computeHasMultipleJumpTargets(collector), variableReassignments = collector.variableReassignments ) }
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed Jun 05 14:04:46 UTC 2024 - 22.9K bytes - Viewed (0) -
samples/open-telemetry/loki/REAME.md
``` ## Setup otel-collector service First, create an `otel-collector` backend with a simple configuration. ```bash kubectl apply -f otel.yaml -n istio-system ``` With the following configuration, otel-collector-contrib will create a grpc receiver on port `4317`, and output to stdout. You can find more details [here](https://github.com/open-telemetry/opentelemetry-collector-contrib). ```yaml receivers:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 06 20:18:25 UTC 2023 - 2.4K bytes - Viewed (0) -
pkg/controller/garbagecollector/config/types.go
type GarbageCollectorControllerConfiguration struct { // enables the generic garbage collector. MUST be synced with the // corresponding flag of the kube-apiserver. WARNING: the generic garbage // collector is an alpha feature. EnableGarbageCollector bool // concurrentGCSyncs is the number of garbage collector workers that are // allowed to sync concurrently. ConcurrentGCSyncs int32
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 04:54:33 UTC 2019 - 1.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/build/BuildOperationFiringBuildWorkPreparer.java
private PlannedNodeGraph computePlannedNodeGraph(QueryableExecutionPlan.ScheduledNodes scheduledWork) { PlannedNodeGraph.Collector collector = new PlannedNodeGraph.Collector(converterRegistry); scheduledWork.visitNodes((nodes, entryNodes) -> collector.collectNodes(nodes)); return collector.getGraph(); } private static class CalculateTaskGraphResult implements Result, CustomOperationTraceSerialization {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 13:46:07 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/metrics/metrics.go
v[pluginName] = count } func (collector *pvAndPVCCountCollector) DescribeWithStability(ch chan<- *metrics.Desc) { ch <- totalPVCountDesc ch <- boundPVCountDesc ch <- unboundPVCountDesc ch <- boundPVCCountDesc ch <- unboundPVCCountDesc } func (collector *pvAndPVCCountCollector) CollectWithStability(ch chan<- metrics.Metric) { collector.pvCollect(ch) collector.pvcCollect(ch) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 25 13:09:16 UTC 2022 - 10.5K bytes - Viewed (0) -
platforms/core-runtime/functional/src/main/java/org/gradle/internal/RenderingUtils.java
.collect(oxfordJoin(conjunction)); } public static Collector<? super String, ?, String> oxfordJoin(String conjunction) { return Collectors.collectingAndThen(Collectors.toList(), stringList -> { switch (stringList.size()) { case 0: return ""; case 1: return stringList.get(0); case 2:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Oct 09 14:11:31 UTC 2023 - 1.7K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/garbagecollectorcontroller.go
if o == nil { return } fs.Int32Var(&o.ConcurrentGCSyncs, "concurrent-gc-syncs", o.ConcurrentGCSyncs, "The number of garbage collector workers that are allowed to sync concurrently.") fs.BoolVar(&o.EnableGarbageCollector, "enable-garbage-collector", o.EnableGarbageCollector, "Enables the generic garbage collector. MUST be synced with the corresponding flag of the kube-apiserver.") } // ApplyTo fills up GarbageCollectorController config with options.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 04:54:33 UTC 2019 - 2K bytes - Viewed (0) -
src/time/tick.go
// [Ticker] would never be recovered by the garbage collector, and that // if efficiency was a concern, code should use NewTicker instead and // call [Ticker.Stop] when the ticker is no longer needed. // As of Go 1.23, the garbage collector can recover unreferenced // tickers, even if they haven't been stopped. // The Stop method is no longer necessary to help the garbage collector.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:21:30 UTC 2024 - 3.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/tasks/DefaultTaskRequiredServices.java
} private void collectConsumedServices() { GetServiceReferencesVisitor collector = new GetServiceReferencesVisitor(); TaskPropertyUtils.visitAnnotatedProperties(propertyWalker, task, TypeValidationContext.NOOP, collector); // this goes through task to benefit from services a task has available task.acceptServiceReferences(collector.getServiceReferences()); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Mar 16 23:29:30 UTC 2023 - 4.6K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/api/internal/provider/MapCollector.java
Value<Void> collectKeys(ValueConsumer consumer, ValueCollector<K> collector, ImmutableCollection.Builder<K> dest); void calculateExecutionTimeValue(Action<ExecutionTimeValue<? extends Map<? extends K, ? extends V>>> visitor); MapCollector<K, V> absentIgnoring(); /** * Returns a collector that may never return a missing value. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Feb 21 12:22:39 UTC 2024 - 1.7K bytes - Viewed (0)