- Sort Score
- Result 10 results
- Languages All
Results 251 - 260 of 761 for fake (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)