Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 280 for Produced (0.06 seconds)

  1. internal/event/target/kafka.go

    	config.Producer.Retry.Max = 2
    	config.Producer.Retry.Backoff = (1 * time.Second)
    	config.Producer.Return.Successes = true
    	config.Producer.Return.Errors = true
    	config.Producer.RequiredAcks = 1
    	config.Producer.Timeout = (5 * time.Second)
    	// Set Producer Compression
    	cc, ok := codecs[strings.ToLower(args.Producer.Compression)]
    	if ok {
    		config.Producer.Compression = cc
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  2. internal/event/target/nsq.go

    	}
    	return target.isActive()
    }
    
    func (target *NSQTarget) isActive() (bool, error) {
    	if target.producer == nil {
    		producer, err := nsq.NewProducer(target.args.NSQDAddress.String(), target.config)
    		if err != nil {
    			return false, err
    		}
    		target.producer = producer
    	}
    
    	if err := target.producer.Ping(); err != nil {
    		// To treat "connection refused" errors as errNotConnected.
    		if xnet.IsConnRefusedErr(err) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/collect/QueuesTest.java

          assertEquals(0, Queues.drain(q, ImmutableList.of(), 1, 10, MILLISECONDS));
    
          Producer producer = new Producer(q, 1);
          // producing one, will ask for two
          Future<?> producerThread = threadPool.submit(producer);
          producer.beganProducing.await();
    
          // make sure we time out
          Stopwatch timer = Stopwatch.createStarted();
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Nov 04 17:24:58 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  4. src/test/java/jcifs/internal/smb2/Smb3KeyDerivationTest.java

            byte[] signingKey2 = Smb3KeyDerivation.deriveSigningKey(dialect, sessionKey, preauthIntegrity);
    
            // Then - should produce identical results
            assertArrayEquals(signingKey1, signingKey2, "Same input should produce same output");
        }
    
        @Test
        @DisplayName("Should handle empty session key")
        void testDeriveKeys_EmptySessionKey() {
            // Given
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 17.5K bytes
    - Click Count (0)
  5. .github/ISSUE_TEMPLATE/tflite-converter-issue.md

    ```
    
    ### 3. Failure after conversion
    If the conversion is successful, but the generated model is wrong, then state what is wrong:
    
    - Model produces wrong results and/or has lesser accuracy.
    - Model produces correct results, but it is slower than expected.
    
    ### 4. (optional) RNN conversion support
    If converting TF RNN to TFLite fused RNN ops, please prefix [RNN] in the title.
    
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Wed Jun 15 03:35:58 GMT 2022
    - 2.1K bytes
    - Click Count (0)
  6. src/test/java/jcifs/smb/NtlmUtilTest.java

            // Assert
            assertArrayEquals(expected, actual, "NT hash must match known test vector");
        }
    
        @Test
        @DisplayName("getNTHash: verify different passwords produce different hashes")
        void testGetNTHash_differentPasswords() {
            // Arrange
            String password1 = "password";
            String password2 = "Password";
    
            // Act
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 12K bytes
    - Click Count (1)
  7. src/test/java/jcifs/spnego/NegTokenInitTest.java

            NegTokenInit parsed = new NegTokenInit(token);
            assertEquals(flags, parsed.getContextFlags(), "Context flags should parse from DER BIT STRING");
        }
    
        @Test
        @DisplayName("Sanity: toByteArray produces APPLICATION class wrapper and valid structure")
        void testToByteArrayStructureSanity() throws Exception {
            NegTokenInit init =
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 21K bytes
    - Click Count (0)
  8. internal/config/storageclass/storage-class.go

    )
    
    // Standard constants for all storage class
    const (
    	// Reduced redundancy storage class
    	RRS = "REDUCED_REDUNDANCY"
    	// Standard storage class
    	STANDARD = "STANDARD"
    )
    
    // Standard constants for config info storage class
    const (
    	ClassStandard = "standard"
    	ClassRRS      = "rrs"
    	Optimize      = "optimize"
    	InlineBlock   = "inline_block"
    
    	// Reduced redundancy storage class environment variable
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  9. build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/filters/KotlinInvokeDefaultBridgeFilter.groovy

     * limitations under the License.
     */
    
    package gradlebuild.binarycompatibility.filters
    
    import japicmp.filter.BehaviorFilter
    import javassist.CtBehavior
    
    /**
     * Kotlin 2.2 produces bridge methods for invoke operator functions compiled as JVM default methods.
     */
    class KotlinInvokeDefaultBridgeFilter implements BehaviorFilter {
        @Override
        boolean matches(CtBehavior ctBehavior) {
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Jul 08 07:03:16 GMT 2025
    - 1K bytes
    - Click Count (0)
  10. build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AbstractBinaryCompatibilityTest.kt

         * Runs the binary compatibility check against two source trees.
         *
         * The fixture build supports both Java and Kotlin sources.
         *
         * @param v1 sources producer for V1, receiver is the `src/main` directory
         * @param v2 sources producer for V2, receiver is the `src/main` directory
         * @param block convenience block invoked on the result
         * @return the check result
         */
        private
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Dec 30 10:14:25 GMT 2025
    - 18K bytes
    - Click Count (0)
Back to Top