Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for Flow (0.29 sec)

  1. cmd/server_test.go

    	response, err := s.client.Do(request)
    	c.Assert(err, nil)
    	c.Assert(response.StatusCode, http.StatusOK)
    	response.Body.Close()
    }
    
    // TestCopyObject - Validates copy object.
    // The following is the test flow.
    // 1. Create bucket.
    // 2. Insert Object.
    // 3. Use "X-Amz-Copy-Source" header to copy the previously created object.
    // 4. Validate the content of copied object.
    func (s *TestSuiteCommon) TestCopyObject(c *check) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    	// WorkerMinLimit min number of workers per node for "slow" mode
    	WorkerMinLimit = 50
    
    	// WorkerAutoDefault is default number of workers for "auto" mode
    	WorkerAutoDefault = 100
    
    	// MRFWorkerMaxLimit max number of mrf workers per node for "fast" mode
    	MRFWorkerMaxLimit = 8
    
    	// MRFWorkerMinLimit min number of mrf workers per node for "slow" mode
    	MRFWorkerMinLimit = 2
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  3. cmd/admin-handlers.go

    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL)
    		return
    	}
    	setEventStreamHeaders(w)
    
    	// Trace Publisher and peer-trace-client uses nonblocking send and hence does not wait for slow receivers.
    	// Keep 100k buffered channel.
    	// If receiver cannot keep up with that we drop events.
    	traceCh := make(chan []byte, 100000)
    	peers, _ := newPeerRestClients(globalEndpoints)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
Back to top