Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 5,684 for collector (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top