Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1181 - 1190 of 1,334 for varr (0.05 sec)

  1. internal/logger/target/kafka/kafka.go

    	sconfig.Net.WriteTimeout = (10 * time.Second)
    	sconfig.Metadata.Retry.Max = 1
    	sconfig.Metadata.Retry.Backoff = (10 * time.Second)
    	sconfig.Metadata.RefreshFrequency = (15 * time.Minute)
    
    	h.config = sconfig
    
    	var brokers []string
    	for _, broker := range h.kconfig.Brokers {
    		brokers = append(brokers, broker.String())
    	}
    
    	client, err := sarama.NewClient(brokers, sconfig)
    	if err != nil {
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/CipherSuite.kt

         */
        internal val ORDER_BY_NAME =
          object : Comparator<String> {
            override fun compare(
              a: String,
              b: String,
            ): Int {
              var i = 4
              val limit = minOf(a.length, b.length)
              while (i < limit) {
                val charA = a[i]
                val charB = b[i]
                if (charA != charB) return if (charA < charB) -1 else 1
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 39.9K bytes
    - Viewed (0)
  3. docs/en/docs/advanced/settings.md

    <span style="color: green;">INFO</span>:     Uvicorn running on http://127.0.0.1:8000 (Press CTRL+C to quit)
    ```
    
    </div>
    
    /// tip
    
    To set multiple env vars for a single command just separate them with a space, and put them all before the command.
    
    ///
    
    And then the `admin_email` setting would be set to `"******@****.***"`.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  4. cmd/local-locker.go

    	if len(args.Resources) > 1 {
    		return false, fmt.Errorf("internal error: localLocker.RUnlock called with more than one resource")
    	}
    
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    	var lri []lockRequesterInfo
    
    	resource := args.Resources[0]
    	if lri, reply = l.lockMap[resource]; !reply {
    		// No lock is held on the given name
    		return true, nil
    	}
    	if isWriteLock(lri) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  5. cmd/object-handlers-common.go

    	"github.com/minio/minio/internal/bucket/lifecycle"
    	"github.com/minio/minio/internal/event"
    	"github.com/minio/minio/internal/hash"
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    var etagRegex = regexp.MustCompile("\"*?([^\"]*?)\"*?$")
    
    // Validates the preconditions for CopyObjectPart, returns true if CopyObjectPart
    // operation should not proceed. Preconditions supported are:
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 06:33:53 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  6. cmd/erasure-encode_test.go

    	return errFaultyDisk
    }
    
    func (badDisk) Hostname() string {
    	return ""
    }
    
    const oneMiByte = 1 * humanize.MiByte
    
    var erasureEncodeTests = []struct {
    	dataBlocks                   int
    	onDisks, offDisks            int
    	blocksize, data              int64
    	offset                       int
    	algorithm                    BitrotAlgorithm
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  7. docs/tr/docs/tutorial/first-steps.md

    ```Python hl_lines="7"
    {!../../docs_src/first_steps/tutorial003.py!}
    ```
    
    /// note | "Not"
    
    Eğer farkı bilmiyorsanız, [Async: *"Aceleniz mi var?"*](../async.md#in-a-hurry){.internal-link target=_blank} sayfasını kontrol edebilirsiniz.
    
    ///
    
    ### Adım 5: İçeriği Geri Döndürün
    
    ```Python hl_lines="8"
    {!../../docs_src/first_steps/tutorial001.py!}
    ```
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  8. internal/s3select/csv/reader.go

    					for {
    						record, err := cr.Read()
    						if err == io.EOF {
    							return nil
    						}
    						if err != nil {
    							return errCSVParsingError(err)
    						}
    						var recDst []string
    						if len(dst) > len(all) {
    							recDst = dst[len(all)]
    						}
    						if cap(recDst) < len(record) {
    							recDst = make([]string, len(record))
    						}
    						recDst = recDst[:len(record)]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  9. cmd/handler-api.go

    	}
    	t.clusterDeadline = clusterDeadline
    	corsAllowOrigin := cfg.CorsAllowOrigin
    	if len(corsAllowOrigin) == 0 {
    		corsAllowOrigin = []string{"*"}
    	}
    	t.corsAllowOrigins = corsAllowOrigin
    
    	var apiRequestsMaxPerNode int
    	if cfg.RequestsMax <= 0 {
    		maxSetDrives := slices.Max(setDriveCounts)
    
    		// Returns 75% of max memory allowed
    		maxMem := globalServerCtxt.MemLimit
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  10. istioctl/pkg/tag/generate_test.go

    	"k8s.io/apimachinery/pkg/runtime"
    	"k8s.io/apimachinery/pkg/runtime/serializer"
    
    	"istio.io/api/label"
    	"istio.io/istio/pkg/kube"
    	"istio.io/istio/pkg/test/env"
    	"istio.io/istio/pkg/test/util/assert"
    )
    
    var (
    	defaultRevisionCanonicalWebhook = admitv1.MutatingWebhookConfiguration{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:   "istio-sidecar-injector",
    			Labels: map[string]string{label.IoIstioRev.Name: "default"},
    		},
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 12.1K bytes
    - Viewed (0)
Back to top