Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 174 for watcher (0.33 sec)

  1. pkg/kubelet/configmap/configmap_manager.go

    // necessary for registered pods.
    // It implements the following logic:
    //   - whenever a pod is created or updated, we start individual watches for all
    //     referenced objects that aren't referenced from other registered pods
    //   - every GetObject() returns a value from local cache propagated via watches
    func NewWatchingConfigMapManager(kubeClient clientset.Interface, resyncInterval time.Duration) Manager {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. pkg/kubelet/secret/secret_manager.go

    // necessary for registered pods.
    // It implements the following logic:
    //   - whenever a pod is created or updated, we start individual watches for all
    //     referenced objects that aren't referenced from other registered pods
    //   - every GetObject() returns a value from local cache propagated via watches
    func NewWatchingSecretManager(kubeClient clientset.Interface, resyncInterval time.Duration) Manager {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  3. pkg/kubelet/util/manager/watch_based_manager.go

    // necessary for registered pods.
    // It implements the following logic:
    //   - whenever a pod is created or updated, we start individual watches for all
    //     referenced objects that aren't referenced from other registered pods
    //   - every GetObject() returns a value from local cache propagated via watches
    func NewWatchBasedManager(
    	listObject listObjectFunc,
    	watchObject watchObjectFunc,
    	newObject newObjectFunc,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  4. subprojects/core/src/main/java/org/gradle/execution/selection/DefaultBuildTaskSelector.java

                });
            }
            Pattern emptySegment = Pattern.compile("(:\\s*:)|(^\\s+:)|(:\\s*$)");
            if (emptySegment.matcher(name).find()) {
                Pattern emptyFirstSegment = Pattern.compile("^\\s*:");
                boolean isAbsolute = emptyFirstSegment.matcher(name).find();
                StringBuilder normalized = new StringBuilder();
                for (int i = 0; i < path.segmentCount(); i++) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 09:03:53 UTC 2024
    - 14K bytes
    - Viewed (0)
  5. tensorflow/compiler/mlir/quantization/stablehlo/cc/config.cc

          break;
        default:
          break;
      }
    }
    
    // Returns a default `QuantizationSpec` for performing static-range PTQ on all
    // ops.
    //
    // In textproto, the spec corresponds to:
    //
    // {
    //   {matcher {function_name {regex: ".*"}}
    //   {method {static_range_ptq {}}}
    // }
    QuantizationSpec GetDefaultStaticRangePtqSpec(StaticRangePtqPreset preset) {
      QuantizationSpec spec{};
      // Default for all ops.
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Fri May 17 03:36:50 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  6. pilot/pkg/xds/deltatest.go

    		// Both SotW and Delta did not respond, nothing to compare
    		return
    	}
    	newByName := slices.GroupUnique(sotwRes, (*discovery.Resource).GetName)
    	curByName := slices.GroupUnique(current, (*discovery.Resource).GetName)
    
    	watched := sets.New(w.ResourceNames...)
    
    	details := fmt.Sprintf("last:%v sotw:%v delta:%v-%v", len(current), len(sotwRes), len(deltaRes), len(deleted))
    	wantDeleted := sets.New[string]()
    	wantChanged := sets.New[string]()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  7. maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultModelValidator.java

                if (hasProjectExpression(s)) {
                    String path = pathSupplier.get();
                    Matcher matcher = EXPRESSION_PROJECT_NAME_PATTERN.matcher(s);
                    while (matcher.find()) {
                        String propertyName = matcher.group(0);
    
                        if (path.startsWith("activation.file.") && "${project.basedir}".equals(propertyName)) {
                            continue;
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Mon Jun 10 11:04:53 UTC 2024
    - 73.9K bytes
    - Viewed (0)
  8. platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/runtimeshaded/RuntimeShadedJarCreatorTest.groovy

            bytecode.contains('GETSTATIC org/gradle/internal/impldep/org/apache/ivy/plugins/matcher/ExactPatternMatcher.INSTANCE : Lorg/gradle/internal/impldep/org/apache/ivy/plugins/matcher/ExactPatternMatcher;')
            bytecode.contains('LDC Lorg/gradle/internal/impldep/org/apache/ivy/core/settings/IvySettings;.class')
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 22 13:39:49 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  9. platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/AbstractConfigurationCacheIntegrationTest.groovy

                .replaceAll(/Received \d+ file system events .*\n/, '')
                .replaceAll(/Spent \d+ ms processing file system events since last build\n/, '')
                .replaceAll(/Spent \d+ ms registering watches for file system events\n/, '')
                .replaceAll(/Virtual file system .*\n/, '')
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:25 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  10. platforms/core-runtime/logging/src/main/java/org/gradle/util/TextUtil.java

            StringBuilder builder = new StringBuilder();
            String[] lines = text.split("\n");
    
            for (int i = 0; i < lines.length; i++) {
                String line = lines[i];
                if (!WHITESPACE.matcher(line).matches()) {
                    builder.append(indent);
                }
                builder.append(line);
                if (i < lines.length - 1) {
                    builder.append('\n');
                }
            }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 13:09:37 UTC 2024
    - 8.9K bytes
    - Viewed (0)
Back to top