Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for Grovers (0.17 sec)

  1. internal/logger/config.go

    				break
    			}
    			brokers = append(brokers, *host)
    		}
    		if err != nil {
    			return cfg, err
    		}
    
    		clientAuthCfgVal := getCfgVal(EnvKafkaTLSClientAuth, k, kv.Get(KafkaTLSClientAuth))
    		clientAuth, err := strconv.Atoi(clientAuthCfgVal)
    		if err != nil {
    			return cfg, err
    		}
    
    		kafkaArgs := kafka.Config{
    			Enabled: enabled,
    			Brokers: brokers,
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  2. internal/config/notify/parse.go

    			return nil, err
    		}
    		if !enabled {
    			continue
    		}
    		var brokers []xnet.Host
    		brokersEnv := target.EnvKafkaBrokers
    		if k != config.Default {
    			brokersEnv = brokersEnv + config.Default + k
    		}
    		kafkaBrokers := env.Get(brokersEnv, kv.Get(target.KafkaBrokers))
    		if len(kafkaBrokers) == 0 {
    			return nil, config.Errorf("kafka 'brokers' cannot be empty")
    		}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 46.4K bytes
    - Viewed (0)
  3. cmd/metacache-entries.go

    		return other, other.isDir() == e.isDir()
    	}
    	eVers, eErr := e.xlmeta()
    	oVers, oErr := other.xlmeta()
    	if eErr != nil || oErr != nil {
    		return nil, false
    	}
    
    	// check both fileInfo's have same number of versions, if not skip
    	// the `other` entry.
    	if len(eVers.versions) != len(oVers.versions) {
    		eTime := eVers.latestModtime()
    		oTime := oVers.latestModtime()
    		if !eTime.Equal(oTime) {
    			if eTime.After(oTime) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  4. docs/fr/docs/async.md

    * de la donnée soit envoyée par le client à travers le réseau
    * de la donnée envoyée depuis votre programme soit reçue par le client à travers le réseau
    * le contenu d'un fichier sur le disque soit lu par le système et passé à votre programme
    * le contenu que votre programme a passé au système soit écrit sur le disque
    Plain Text
    - Registered: Sun Apr 21 07:19:11 GMT 2024
    - Last Modified: Sun Mar 31 23:52:53 GMT 2024
    - 24K bytes
    - Viewed (0)
  5. docs/en/docs/advanced/events.md

    Because this code is executed before the application **starts** taking requests, and right after it **finishes** handling requests, it covers the whole application **lifespan** (the word "lifespan" will be important in a second 😉).
    
    Plain Text
    - Registered: Sun Apr 21 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  6. cmd/postpolicyform.go

    			if !condPassed {
    				return fmt.Errorf("Invalid according to Policy: Policy Condition failed")
    			}
    		} else if strings.HasPrefix(policy.Key, "$x-amz-meta-") || strings.HasPrefix(policy.Key, "$x-amz-") {
    			// This covers all conditions X-Amz-Meta-* and X-Amz-*
    			// Check if policy condition is satisfied
    			condPassed = checkPolicyCond(op, formValues.Get(formCanonicalName), policy.Value)
    			if !condPassed {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 12.2K bytes
    - Viewed (0)
  7. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.stream.Stream;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Supplies an arbitrary "default" instance for a wide range of types, often useful in testing
     * utilities.
     *
     * <p>Covers arrays, enums and common types defined in {@code java.lang}, {@code java.lang.reflect},
     * {@code java.io}, {@code java.nio}, {@code java.math}, {@code java.util}, {@code
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 21K bytes
    - Viewed (1)
  8. android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.regex.Pattern;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Supplies an arbitrary "default" instance for a wide range of types, often useful in testing
     * utilities.
     *
     * <p>Covers arrays, enums and common types defined in {@code java.lang}, {@code java.lang.reflect},
     * {@code java.io}, {@code java.nio}, {@code java.math}, {@code java.util}, {@code
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 20.5K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/ImmutableSet.java

       * @throws NullPointerException if any of {@code elements} is null
       * @since 7.0 (source-compatible since 2.0)
       */
      // This the best we could do to get copyOfEnumSet to compile in the mainline.
      // The suppression also covers the cast to E[], discussed below.
      // In the backport, we don't have those cases and thus don't need this suppression.
      // We keep it to minimize diffs.
      @SuppressWarnings("unchecked")
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 22.4K bytes
    - Viewed (0)
  10. docs/en/docs/python-types.md

    By declaring types for your variables, editors and tools can give you better support.
    
    This is just a **quick tutorial / refresher** about Python type hints. It covers only the minimum necessary to use them with **FastAPI**... which is actually very little.
    
    **FastAPI** is all based on these type hints, they give it many advantages and benefits.
    
    Plain Text
    - Registered: Sun Apr 21 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 17K bytes
    - Viewed (0)
Back to top