Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 331 - 340 of 859 for durable (0.07 seconds)

  1. internal/store/store.go

    	defer retryTicker.Stop()
    
    	send := func(key Key) bool {
    		for {
    			err := target.SendFromStore(key)
    			if err == nil {
    				break
    			}
    
    			logger(
    				context.Background(),
    				fmt.Errorf("unable to send log entry to '%s' err '%w'", target.Name(), err),
    				target.Name(),
    			)
    
    			select {
    			// Retrying after 3secs back-off
    			case <-retryTicker.C:
    			case <-doneCh:
    				return false
    			}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  2. build-logic-commons/publishing/src/main/kotlin/gradlebuild.publish-public-libraries.gradle.kts

        }
        tasks.named("publishGradleDistributionPublicationToLocalRepository") {
            enabled = false // this should not be used so we disable it to avoid confusion when using 'publish' lifecycle task
        }
        val localPublish = project.tasks.named("publishLocalPublicationToLocalRepository") {
            doFirst {
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Oct 30 16:56:31 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  3. docs/zh/docs/how-to/custom-docs-ui-assets.md

    ## 为 JavaScript 和 CSS 自定义 CDN { #custom-cdn-for-javascript-and-css }
    
    假设你想使用不同的 <abbr title="Content Delivery Network - 内容分发网络">CDN</abbr>,例如使用 `https://unpkg.com/`。
    
    如果你所在的国家/地区屏蔽了某些 URL,这会很有用。
    
    ### 关闭自动文档 { #disable-the-automatic-docs }
    
    第一步是关闭自动文档,因为默认它们会使用默认的 CDN。
    
    要关闭它们,在创建 `FastAPI` 应用时将其 URL 设为 `None`:
    
    {* ../../docs_src/custom_docs_ui/tutorial001_py310.py hl[8] *}
    
    ### 包含自定义文档 { #include-the-custom-docs }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 17:06:37 GMT 2026
    - 7.1K bytes
    - Click Count (0)
  4. api/maven-api-core/src/test/java/org/apache/maven/api/feature/FeaturesTest.java

            assertFalse(Features.deployBuildPom(properties)); // "0".parseBoolean() = false
        }
    
        @Test
        void testDeployBuildPomWithMutableMap() {
            // Test with a mutable map to ensure the method doesn't modify the input
            Map<String, Object> properties = new HashMap<>();
            properties.put(Constants.MAVEN_DEPLOY_BUILD_POM, "false");
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jul 04 19:42:23 GMT 2025
    - 7.2K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

            .add("services", Collections2.filter(services, not(instanceOf(NoOpService.class))))
            .toString();
      }
    
      /**
       * An encapsulation of all the mutable state of the {@link ServiceManager} that needs to be
       * accessed by instances of {@link ServiceListener}.
       */
      private static final class ServiceManagerState {
        final Monitor monitor = new Monitor();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 33.2K bytes
    - Click Count (1)
  6. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/transform/ReleaseArtifactTransformation.java

                try {
                    String version = resolveVersion(artifact, request);
    
                    if (Artifact.RELEASE_VERSION.equals(version)) {
                        throw new ArtifactNotFoundException("Unable to determine the release version", artifact);
                    }
    
                    artifact.setBaseVersion(version);
                    artifact.updateVersion(version, request.getLocalRepository());
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 3.6K bytes
    - Click Count (0)
  7. internal/logger/target/http/http.go

    	queueStore := store.NewQueueStore[any](
    		filepath.Join(h.config.QueueDir, h.Name()),
    		uint64(h.config.QueueSize),
    		httpLoggerExtension,
    	)
    
    	if err := queueStore.Open(); err != nil {
    		return fmt.Errorf("unable to initialize the queue store of %s webhook: %w", h.Name(), err)
    	}
    
    	h.store = queueStore
    	store.StreamItems(h.store, h, ctx.Done(), h.config.LogOnceIf)
    
    	return nil
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  8. docs/sts/assume-role.go

    	stsOpts.AccessKey = minioUsername
    	stsOpts.SecretKey = minioPassword
    
    	if sessionPolicyFile != "" {
    		var policy string
    		if f, err := os.Open(sessionPolicyFile); err != nil {
    			log.Fatalf("Unable to open session policy file: %v", err)
    		} else {
    			defer f.Close()
    			bs, err := io.ReadAll(f)
    			if err != nil {
    				log.Fatalf("Error reading session policy file: %v", err)
    			}
    			policy = string(bs)
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Aug 17 01:24:54 GMT 2024
    - 4.4K bytes
    - Click Count (1)
  9. CONTRIBUTING.md

      patches should only highlight the actual difference, not being disturbed by any formatting issues:
      + Only use spaces for indentation.
      + Create minimal diffs - disable on save actions like reformat source code or organize imports.
        If you feel the source code should be reformatted, create a separate PR for this change.
      + Check for unnecessary whitespace with `git diff --check` before committing.
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sat Jun 07 09:55:33 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  10. internal/config/etcd/etcd.go

    	if err != nil {
    		return cfg, err
    	}
    
    	cfg.Enabled = true
    	cfg.DialTimeout = defaultDialTimeout
    	cfg.DialKeepAliveTime = defaultDialKeepAlive
    	// Disable etcd client SDK logging, etcd client
    	// incorrectly starts logging in unexpected data
    	// format.
    	cfg.LogConfig = &zap.Config{
    		Level:    zap.NewAtomicLevelAt(zap.FatalLevel),
    		Encoding: "console",
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 5.2K bytes
    - Click Count (0)
Back to Top