- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 99 for Input (0.12 sec)
-
cmd/xl-storage-format-v2_test.go
// Run multiple times, shuffling the input order. for i := int64(0); i < 50; i++ { t.Run(fmt.Sprint(i), func(t *testing.T) { rng := rand.New(rand.NewSource(i)) rng.Shuffle(len(test.input), func(i, j int) { test.input[i], test.input[j] = test.input[j], test.input[i] }) got := mergeXLV2Versions(test.quorum, true, 0, test.input...) if !reflect.DeepEqual(test.want, got) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 36.4K bytes - Viewed (0) -
internal/config/config.go
tgt = subSystemValue[1] } return subSys, inputs, tgt, e } // kvFields - converts an input string of form "k1=v1 k2=v2" into // fields of ["k1=v1", "k2=v2"], the tokenization of each `k=v` // happens with the right number of input keys, if keys // input is empty returned value is empty slice as well. func kvFields(input string, keys []string) []string { valueIndexes := make([]int, 0, len(keys)) for _, key := range keys {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
cmd/http-stats.go
} // Return S3 total input bytes func (s *connStats) getS3InputBytes() uint64 { return atomic.LoadUint64(&s.s3InputBytes) } // Return S3 total output bytes func (s *connStats) getS3OutputBytes() uint64 { return atomic.LoadUint64(&s.s3OutputBytes) } // Return connection stats (total input/output bytes and total s3 input/output bytes) func (s *connStats) toServerConnStats() serverConnStats {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 11.4K bytes - Viewed (0) -
internal/config/errors.go
) ErrInvalidBatchKeyRotationWorkersWait = newErrFn( "Invalid value for batch key rotation workers wait", "Please input a non-negative duration", "keyrotation_workers_wait should be > 0ms", ) ErrInvalidBatchReplicationWorkersWait = newErrFn( "Invalid value for batch replication workers wait", "Please input a non-negative duration", "replication_workers_wait should be > 0ms", )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 18 22:25:32 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
idx, err = strconv.Atoi(pool) if err != nil { // We didn't find any matching pools, invalid input writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errInvalidArgument), r.URL) return } } else { idx = globalEndpoints.GetPoolIdx(pool) if idx == -1 { // We didn't find any matching pools, invalid input writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errInvalidArgument), r.URL) return } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 10.9K bytes - Viewed (0) -
cmd/object-handlers_test.go
} // iterate through the above set of inputs and upload the object. for i, input := range putObjectInputs { // uploading the object. _, err := obj.PutObject(context.Background(), input.bucketName, input.objectName, mustGetPutObjReader(t, bytes.NewReader(input.textData), input.contentLength, input.metaData[""], ""), ObjectOptions{UserDefined: input.metaData}) // if object upload fails stop the test. if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
func splitZipExtensionPath(input string) (zipPath, object string, err error) { idx := strings.Index(input, archivePattern) if idx < 0 { // Should never happen return "", "", errors.New("unable to parse zip path") } return input[:idx+len(archivePattern)-1], input[idx+len(archivePattern):], nil } // getObjectInArchiveFileHandler - GET Object in the archive file
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 09 10:41:25 GMT 2024 - 15.8K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
diskCount := 0 for _, disk := range disks { if disk == nil { continue } diskCount++ } return diskCount } // hashOrder - hashes input key to return consistent // hashed integer slice. Returned integer order is salted // with an input key. This results in consistent order. // NOTE: collisions are fine, we are not looking for uniqueness // in the slices returned.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 11.3K bytes - Viewed (0) -
cmd/bucket-listobjects-handlers.go
// Initiate a list objects operation inside a zip file based in the input params listObjectsV2Info, err = listObjectsV2InArchive(ctx, objectAPI, bucket, prefix, token, delimiter, maxKeys, fetchOwner, startAfter) } else { // Initiate a list objects operation based on the input params. // On success would return back ListObjectsInfo object to be // marshaled into S3 compatible XML header.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 11.4K bytes - Viewed (0) -
cmd/postpolicyform.go
metaMap[formCanonicalName] = policy.Value } } // Check if any extra metadata field is passed as input for key := range formValues { if strings.HasPrefix(key, "X-Amz-Meta-") { if _, ok := metaMap[key]; !ok { return fmt.Errorf("Invalid according to Policy: Extra input fields: %s", key) } } } // Flag to indicate if all policies conditions are satisfied var condPassed bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.2K bytes - Viewed (0)