Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 1,228 for incoming (0.05 seconds)

  1. cmd/signature-v4-utils.go

    	// We found 'X-Amz-Content-Sha256' return the captured value.
    	if ok {
    		return v[0]
    	}
    
    	// We couldn't find 'X-Amz-Content-Sha256'.
    	return defaultSha256Cksum
    }
    
    // isValidRegion - verify if incoming region value is valid with configured Region.
    func isValidRegion(reqRegion string, confRegion string) bool {
    	if confRegion == "" {
    		return true
    	}
    	if confRegion == "US" {
    		confRegion = globalMinioDefaultRegion
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Nov 25 17:10:22 GMT 2024
    - 9.1K bytes
    - Click Count (0)
  2. cmd/metrics-v3-api.go

    	apiRequestsWaitingTotalMD = NewGaugeMD(apiRequestsWaitingTotal,
    		"Total number of requests in the waiting queue", "type")
    	apiRequestsIncomingTotalMD = NewGaugeMD(apiRequestsIncomingTotal,
    		"Total number of incoming requests", "type")
    
    	apiRequestsInFlightTotalMD = NewGaugeMD(apiRequestsInFlightTotal,
    		"Total number of requests currently in flight", "name", "type")
    	apiRequestsTotalMD = NewCounterMD(apiRequestsTotal,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Sep 24 17:13:00 GMT 2024
    - 9.4K bytes
    - Click Count (0)
  3. cmd/bucket-replication.go

    		p.mu.RUnlock()
    		switch prio {
    		case "fast":
    			replLogOnceIf(GlobalContext, fmt.Errorf("Unable to keep up with incoming traffic"), string(replicationSubsystem), logger.WarningKind)
    		case "slow":
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  4. cmd/admin-handlers.go

    package cmd
    
    import (
    	"bytes"
    	"context"
    	crand "crypto/rand"
    	"crypto/rsa"
    	"crypto/subtle"
    	"crypto/x509"
    	"encoding/base64"
    	"encoding/json"
    	"encoding/pem"
    	"errors"
    	"fmt"
    	"hash/crc32"
    	"io"
    	"math"
    	"net/http"
    	"net/url"
    	"os"
    	"path"
    	"path/filepath"
    	"regexp"
    	"runtime"
    	"sort"
    	"strconv"
    	"strings"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  5. docs/en/docs/tutorial/body-nested-models.md

    <img src="/img/tutorial/body-nested-models/image01.png">
    
    You couldn't get this kind of editor support if you were working directly with `dict` instead of Pydantic models.
    
    But you don't have to worry about them either, incoming dicts are converted automatically and your output is converted automatically to JSON too.
    
    ## Bodies of arbitrary `dict`s { #bodies-of-arbitrary-dicts }
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  6. guava/src/com/google/common/graph/AbstractBaseGraph.java

            checkNotNull(node);
            checkArgument(nodes().contains(node));
            IncidentEdgeSet<N> incident =
                new IncidentEdgeSet<N>(this, node, IncidentEdgeSet.EdgeType.INCOMING) {
                  @Override
                  public UnmodifiableIterator<EndpointPair<N>> iterator() {
                    return Iterators.unmodifiableIterator(
                        Iterators.transform(
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 07 15:57:03 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  7. docs/contribute/concurrency.md

    So we have a dedicated thread for every socket that just reads frames and dispatches them.
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 06 16:35:36 GMT 2022
    - 7K bytes
    - Click Count (0)
  8. cmd/globals.go

    	// can reach that size according to https://aws.amazon.com/articles/1434
    	maxFormFieldSize = int64(1 * humanize.MiByte)
    
    	// The maximum allowed time difference between the incoming request
    	// date and server date during signature verification.
    	globalMaxSkewTime = 15 * time.Minute // 15 minutes skew allowed.
    
    	// GlobalStaleUploadsExpiry - Expiry duration after which the uploads in multipart,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Sep 03 18:23:41 GMT 2024
    - 16.2K bytes
    - Click Count (1)
  9. internal/event/targetlist.go

    		return
    	default:
    		list.eventsSkipped.Add(1)
    		err := fmt.Errorf("concurrent target notifications exceeded %d, configured notification target is too slow to accept events for the incoming request rate", maxConcurrentAsyncSend)
    		for id := range targetIDset {
    			reqInfo := &logger.ReqInfo{}
    			reqInfo.AppendTags("targetID", id.String())
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  10. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

      /**
       * True if ALPN is used on incoming HTTPS connections to negotiate a protocol like HTTP/1.1 or
       * HTTP/2. This is true by default; set to false to disable negotiation and restrict connections
       * to HTTP/1.1.
       */
      public var protocolNegotiationEnabled: Boolean = true
    
      /**
       * The protocols supported by ALPN on incoming HTTPS connections in order of preference. The list
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Aug 02 20:36:00 GMT 2025
    - 40.3K bytes
    - Click Count (0)
Back to Top