Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 53 for Producer (0.04 seconds)

  1. internal/bucket/replication/filter.go

    	cachedTags map[string]string
    }
    
    // IsEmpty returns true if filter is not set
    func (f Filter) IsEmpty() bool {
    	return f.And.isEmpty() && f.Tag.IsEmpty() && f.Prefix == ""
    }
    
    // MarshalXML - produces the xml representation of the Filter struct
    // only one of Prefix, And and Tag should be present in the output.
    func (f Filter) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    	if err := e.EncodeToken(start); err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Sep 28 18:25:46 GMT 2022
    - 3.5K bytes
    - Click Count (0)
  2. internal/kms/secret-key.go

    		Ciphertext: ciphertext,
    	}, nil
    }
    
    // Decrypt decrypts req.Ciphertext. The key name req.Name must match the key
    // name of the secretKey.
    //
    // Decrypt supports decryption of binary-encoded ciphertexts, as produced by KES
    // and MinKMS, and legacy JSON formatted ciphertexts.
    func (s secretKey) Decrypt(_ context.Context, req *DecryptRequest) ([]byte, error) {
    	if req.Name != s.keyID {
    		return nil, ErrKeyNotFound
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Apr 21 16:23:51 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  3. .teamcity/src/main/kotlin/configurations/FunctionalTest.kt

                preSteps = preBuildSteps,
            )
    
            failureConditions {
                // JavaExecDebugIntegrationTest.debug session fails without debugger might cause JVM crash
                // Some soak tests produce OOM exceptions
                // There are also random worker crashes for some tests.
                // We have test-retry to handle the crash in tests
                javaCrash = false
            }
        })
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu Oct 09 05:26:45 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  4. build-logic/cleanup/src/main/kotlin/gradlebuild/cleanup/Cleanup.kt

                        delete { delete(stateDir) }
                    }
                }
            }
        }
    }
    
    
    /**
     * Clean up daemon log files produced in integration tests.
     */
    fun FileSystemOperations.removeDaemonLogFiles(dir: Directory) {
        if (dir.asFile.isDirectory) {
            val daemonLogFiles = dir.asFileTree.matching {
                include("**/*.log")
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Fri Jun 28 08:29:28 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  5. build-logic/documentation/src/main/groovy/gradlebuild/docs/UserGuideTransformTask.groovy

     *
     * Takes the following as input:
     * <ul>
     * <li>A source docbook XML file.</li>
     * <li>Meta-info about the canonical documentation for each class referenced in the document, as produced by {@link gradlebuild.docs.dsl.docbook.AssembleDslDocTask}.</li>
     * </ul>
     *
     */
    @CacheableTask
    abstract class UserGuideTransformTask extends DefaultTask {
    
        @PathSensitive(PathSensitivity.NONE)
        @InputFile
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Fri May 16 07:58:02 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  6. architecture/standards/0002-avoid-using-java-serialization.md

    This is due to Java's use of reflection and the need to maintain a lot of metadata.
    
    - **Size of Serialized Data:**
    Java serialization tends to produce larger serialized objects because it includes class metadata and other overhead.
    
    - **Flexibility and Control:**
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu Feb 29 22:32:18 GMT 2024
    - 2.3K bytes
    - Click Count (0)
  7. cmd/object-api-utils.go

    		gotIdx = <-indexCh
    		return gotIdx
    	}
    }
    
    // compressSelfTest performs a self-test to ensure that compression
    // algorithms completes a roundtrip. If any algorithm
    // produces an incorrect checksum it fails with a hard error.
    //
    // compressSelfTest tries to catch any issue in the compression implementation
    // early instead of silently corrupting data.
    func compressSelfTest() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 37.3K bytes
    - Click Count (0)
  8. WORKSPACE

            "https://github.com/bazelbuild/rules_shell/releases/download/v0.4.1/rules_shell-v0.4.1.tar.gz",
        ),
    )
    
    # Initialize toolchains for ML projects.
    #
    # A hermetic build system is designed to produce completely reproducible builds for C++.
    # Details: https://github.com/google-ml-infra/rules_ml_toolchain
    tf_http_archive(
        name = "rules_ml_toolchain",
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Fri Dec 26 23:20:26 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  9. build-logic/jvm/src/main/kotlin/gradlebuild/startscript/tasks/GradleStartScriptGenerator.kt

                    }
    
                    else -> line
                }
            }.toByteArray(StandardCharsets.UTF_8))
            require(replacementsCount == 1) { "The script file produced by the default start script doesn't match expected layout" }
        }
    
        private
        fun getAgentOptions(appHomeVar: String) = agentJarNames.map { "-javaagent:$appHomeVar/lib/agents/$it" }
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Apr 08 01:46:59 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  10. internal/crypto/error.go

    	errInvalidInternalSealAlgorithm = Errorf("The internal seal algorithm is invalid and not supported")
    )
    
    // errOutOfEntropy indicates that the a source of randomness (PRNG) wasn't able
    // to produce enough random data. This is fatal error and should cause a panic.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.4K bytes
    - Click Count (0)
Back to Top