- Sort Score
- Num 10 results
- Language All
Results 331 - 340 of 859 for durable (0.05 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)