Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 761 for fake (0.03 sec)

  1. docs/en/docs/how-to/custom-request-and-route.md

    * Decompressing gzip-compressed request bodies.
    * Automatically logging all request bodies.
    
    ## Handling custom request body encodings
    
    Let's see how to make use of a custom `Request` subclass to decompress gzip requests.
    
    And an `APIRoute` subclass to use that custom request class.
    
    ### Create a custom `GzipRequest` class
    
    /// tip
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 22:39:38 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  2. cmd/storage-datatypes_gen_test.go

    	v := BaseOptions{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBaseOptions(b *testing.B) {
    	v := BaseOptions{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		bts, _ = v.MarshalMsg(bts[0:0])
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 73.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/TopKSelector.java

            @SuppressWarnings("nullness") // safe because we pass sort() a range that contains real Ts
            T[] castBuffer = (T[]) buffer;
            // We've already taken O(k log k), let's make sure we don't take longer than O(k log k).
            sort(castBuffer, left, right + 1, comparator);
            break;
          }
        }
        bufferSize = k;
    
        threshold = uncheckedCastNullableTToT(buffer[minThresholdPosition]);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  4. CHANGELOG/CHANGELOG-1.19.md

      - [Changes by Kind](#changes-by-kind-1)
        - [Bug or Regression](#bug-or-regression-1)
        - [Other (Cleanup or Flake)](#other-cleanup-or-flake)
      - [Dependencies](#dependencies-1)
        - [Added](#added-1)
        - [Changed](#changed-1)
        - [Removed](#removed-1)
    - [v1.19.14](#v11914)
      - [Downloads for v1.19.14](#downloads-for-v11914)
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Jan 05 05:42:32 UTC 2022
    - 489.7K bytes
    - Viewed (0)
  5. internal/bucket/bandwidth/monitor.go

    	NodeCount             uint64
    }
    
    // NewMonitor returns a monitor with defaults.
    func NewMonitor(ctx context.Context, numNodes uint64) *Monitor {
    	m := &Monitor{
    		bucketsMeasurement:    make(map[BucketOptions]*bucketMeasurement),
    		bucketsThrottle:       make(map[BucketOptions]*bucketThrottle),
    		bucketMovingAvgTicker: time.NewTicker(2 * time.Second),
    		ctx:                   ctx,
    		NodeCount:             numNodes,
    	}
    	go m.trackEWMA()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  6. internal/s3select/simdj/reader.go

    func NewReader(readCloser io.ReadCloser, args *json.ReaderArgs) *Reader {
    	r := Reader{
    		args:       args,
    		readCloser: &safeCloser{r: io.Reader(readCloser)},
    		decoded:    make(chan simdjson.Object, 1000),
    		input:      make(chan simdjson.Stream, 2),
    		exitReader: make(chan struct{}),
    	}
    	r.onReaderExit = func() {
    		close(r.decoded)
    		readCloser.Close()
    		for range r.input {
    			// Read until EOF trickles through.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  7. istioctl/pkg/tag/util.go

    	namespaces, err := client.CoreV1().Namespaces().List(ctx, metav1.ListOptions{
    		LabelSelector: fmt.Sprintf("%s=%s", label.IoIstioRev.Name, tag),
    	})
    	if err != nil {
    		return nil, err
    	}
    
    	nsNames := make([]string, len(namespaces.Items))
    	for i, ns := range namespaces.Items {
    		nsNames[i] = ns.Name
    	}
    	return nsNames, nil
    }
    
    // GetWebhookTagName extracts tag name from webhook object.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  8. docs/bucket/replication/test_del_marker_proxying.sh

    	echo -n "Cleaning up instances of MinIO ..."
    	pkill -9 minio || sudo pkill -9 minio
    	rm -rf /tmp/sitea
    	rm -rf /tmp/siteb
    	echo "done"
    }
    
    cleanup
    
    export MINIO_CI_CD=1
    export MINIO_BROWSER=off
    
    make install-race
    
    # Start MinIO instances
    echo -n "Starting MinIO instances ..."
    minio server --address 127.0.0.1:9001 --console-address ":10000" "http://127.0.0.1:9001/tmp/sitea/data/disterasure/xl{1...4}" \
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  9. bin/init.sh

    # the needed environment variables.
    
    set -o errexit
    set -o nounset
    set -o pipefail
    
    if [[ "${TARGET_OUT_LINUX:-}" == "" ]]; then
      echo "Environment variables not set. Make sure you run through the makefile (\`make init\`) rather than directly."
      exit 1
    fi
    
    # Setup arch suffix for envoy binary. For backwards compatibility, amd64 has no suffix.
    if [[ "${TARGET_ARCH}" == "amd64" ]]; then
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jan 25 19:11:31 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  10. internal/s3select/jstream/scanner.go

    	fillReq   chan struct{}
    	fillReady chan int64
    	readerErr error // underlying reader error, if any
    }
    
    func newScanner(r io.Reader) *scanner {
    	sr := &scanner{
    		end:       maxInt,
    		fillReq:   make(chan struct{}),
    		fillReady: make(chan int64),
    	}
    
    	go func() {
    		var rpos int64 // total bytes read into buffer
    
    		defer func() {
    			atomic.StoreInt64(&sr.end, rpos)
    			close(sr.fillReady)
    		}()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.5K bytes
    - Viewed (0)
Back to top