Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for Final (0.12 sec)

  1. internal/http/server.go

    	return srv
    }
    
    // UseReadHeaderTimeout configure read header timeout
    func (srv *Server) UseReadHeaderTimeout(d time.Duration) *Server {
    	srv.ReadHeaderTimeout = d
    	return srv
    }
    
    // UseHandler configure final handler for this HTTP *Server
    func (srv *Server) UseHandler(h http.Handler) *Server {
    	srv.Handler = h
    	return srv
    }
    
    // UseTLSConfig pass configured TLSConfig for this HTTP *Server
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  2. cmd/erasure-object_test.go

    			ObjectOptions{Versioned: testCase.versioned})
    		if err != nil {
    			t.Fatalf("Test %d: Failed to upload the final object: %v", i+1, err)
    		}
    
    		// Step 4: Try to read the object back and check its md5sum
    		sets.erasureDisksMu.Lock()
    		xl.getDisks = func() []StorageAPI { return origErasureDisks }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    			partsMetadata[index].SetInlineData()
    		}
    		if opts.DataMovement {
    			partsMetadata[index].SetDataMov()
    		}
    	}
    
    	// Rename the successfully written temporary object to final location.
    	onlineDisks, versions, oldDataDir, err := renameData(ctx, onlineDisks, minioMetaTmpBucket, tempObj, partsMetadata, bucket, object, writeQuorum)
    	if err != nil {
    		if errors.Is(err, errFileNotFound) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  4. cmd/storage-rest-common_gen.go

    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "Final")
    					return
    				}
    				z.Final = nil
    			} else {
    				if z.Final == nil {
    					z.Final = new(dataUsageCache)
    				}
    				err = z.Final.DecodeMsg(dc)
    				if err != nil {
    					err = msgp.WrapError(err, "Final")
    					return
    				}
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  5. cmd/storage-rest-client.go

    		Cache:    &cache,
    	})
    	if err != nil {
    		return cache, toStorageErr(err)
    	}
    	var final *dataUsageCache
    	err = st.Results(func(resp *nsScannerResp) error {
    		if resp.Update != nil {
    			select {
    			case <-ctx.Done():
    			case updates <- *resp.Update:
    			}
    		}
    		if resp.Final != nil {
    			final = resp.Final
    		}
    		// We can't reuse the response since it is sent upstream.
    		return nil
    	})
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  6. cmd/endpoint-ellipses.go

    		return setCounts[i] < setCounts[j]
    	})
    
    	return setCounts
    }
    
    // getSetIndexes returns list of indexes which provides the set size
    // on each index, this function also determines the final set size
    // The final set size has the affinity towards choosing smaller
    // indexes (total sets)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  7. cmd/streaming-signature-v4.go

    // newSignV4ChunkedReader returns a new s3ChunkedReader that translates the data read from r
    // out of HTTP "chunked" format before returning it.
    // The s3ChunkedReader returns io.EOF when the final 0-length chunk is read.
    //
    // NewChunkedReader is not needed by normal applications. The http package
    // automatically decodes chunking when reading response bodies.
    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)
  8. cmd/post-policy_test.go

    	}
    
    	// get random bucket name.
    	bucketName := getRandomBucketName()
    
    	// Key specified in Form data
    	keyName := "test/object"
    
    	var opts ObjectOptions
    
    	// The final name of the upload object
    	targetObj := keyName + "/upload.txt"
    
    	// The url of success_action_redirect field
    	redirectURL, err := url.Parse("http://www.google.com?query=value")
    	if err != nil {
    		t.Fatal(err)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 29.6K bytes
    - Viewed (0)
  9. cmd/peer-s3-client.go

    //   - Return an error when a pool cannot return N/2+1 valid bucket information
    //   - For each pool, check if the bucket exists in N/2+1 nodes before including it in the final result
    func (sys *S3PeerSys) ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error) {
    	g := errgroup.WithNErrs(len(sys.peerClients))
    
    	nodeBuckets := make([][]BucketInfo, len(sys.peerClients))
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  10. cmd/storage-datatypes.go

    	DiskID   string `msg:"id"`
    	Volume   string `msg:"v"`
    	FilePath string `msg:"fp"`
    	Buf      []byte `msg:"b"`
    }
    
    // RenameDataResp - RenameData()'s response.
    // Provides information about the final state of Rename()
    //   - on xl.meta (array of versions) on disk to check for version disparity
    //   - on rewrite dataDir on disk that must be additionally purged
    //     only after as a 2-phase call, allowing the older dataDir to
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
Back to top