- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for reasonable (0.17 sec)
-
internal/s3select/csv/reader.go
dst = append(dst, in...) return dst, err } // csvSplitSize is the size of each block. // Blocks will read this much and find the first following newline. // 128KB appears to be a very reasonable default. const csvSplitSize = 128 << 10 // startReaders will read the header if needed and spin up a parser // and a number of workers based on GOMAXPROCS.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
// // First, we read the chunk size but fail if it is larger // than 16 MiB. We must not accept arbitrary large chunks. // One 16 MiB is a reasonable max limit. // // Then we read the signature and payload data. We compute the SHA256 checksum // of the payload and verify that it matches the expected signature value. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0) -
src/archive/zip/reader.go
} r.r = rdr r.baseOffset = baseOffset // Since the number of directory records is not validated, it is not // safe to preallocate r.File without first checking that the specified // number of files is reasonable, since a malformed archive may // indicate it contains up to 1 << 128 - 1 files. Since each file has a // header which will be _at least_ 30 bytes we can safely preallocate // if (data size / 30) >= end.directoryRecords.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 27.7K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
{"-t", iptablesconstants.NAT, "-F", ChainHostPostrouting}, {"-t", iptablesconstants.NAT, "-X", ChainHostPostrouting}, } // iptablei seems like a reasonable pluralization of iptables iptablesVariant := []dep.IptablesVersion{} iptablesVariant = append(iptablesVariant, cfg.iptV) if cfg.cfg.EnableIPv6 { iptablesVariant = append(iptablesVariant, cfg.ipt6V) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
internal/s3select/select.go
var parquetSupport bool func init() { parquetSupport = env.Get("MINIO_API_SELECT_PARQUET", config.EnableOff) == config.EnableOn } var bufPool = sync.Pool{ New: func() interface{} { // make a buffer with a reasonable capacity. return bytes.NewBuffer(make([]byte, 0, maxRecordSize)) }, } var bufioWriterPool = sync.Pool{ New: func() interface{} { // io.Discard is just used to create the writer. Actual destination
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
cmd/encryption-v1.go
// is more efficient than decrypting ETags sequentually. func DecryptETags(ctx context.Context, k kms.KMS, objects []ObjectInfo) error { const BatchSize = 250 // We process the objects in batches - 250 is a reasonable default. var ( metadata = make([]map[string]string, 0, BatchSize) buckets = make([]string, 0, BatchSize) names = make([]string, 0, BatchSize) ) for len(objects) > 0 { N := BatchSize
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate_test.go
// 3. inject label false // 4. inject label true and revision label // 5. inject label false and revision label // 6. no label // However, we filter out all the disable cases, leaving us with a reasonable number of cases testLabels := []LabelSet{} for _, namespaceLabel := range []klabels.Set{empty, revLabel, legacyLabel, legacyLabelDisabled, legacyAndRevLabel, legacyDisabledAndRevLabel} {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 43.5K bytes - Viewed (0) -
internal/s3select/progress.go
pbzip2.BZConcurrency((runtime.GOMAXPROCS(0)+1)/2), pbzip2.BZConcurrencyPool(bz2Limiter), )) pr.closer = &nopReadCloser{fn: cancel} case zstdType: // Set a max window of 64MB. More than reasonable. zr, err := zstd.NewReader(scannedReader, zstd.WithDecoderConcurrency(2), zstd.WithDecoderMaxWindow(64<<20)) if err != nil { return nil, errInvalidCompression(err, compType) } r = zr
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Oct 18 15:44:36 GMT 2021 - 4.2K bytes - Viewed (0) -
internal/s3select/json/preader.go
dst = append(dst, in...) return dst, err } // jsonSplitSize is the size of each block. // Blocks will read this much and find the first following newline. // 128KB appears to be a very reasonable default. const jsonSplitSize = 128 << 10 // startReaders will read the header if needed and spin up a parser // and a number of workers based on GOMAXPROCS.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0) -
src/cmd/api/main_test.go
log.Printf("%s: contains CRLFs", filename) exitCode = 1 } if filepath.Base(filename) == "go1.4.txt" { // No use for blank lines in api files, except go1.4.txt // used them in a reasonable way and we should let it be. } else if strings.HasPrefix(s, "\n") || strings.Contains(s, "\n\n") { log.Printf("%s: contains a blank line", filename) exitCode = 1 } if s == "" {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Apr 09 20:48:51 GMT 2024 - 31.4K bytes - Viewed (0)