Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 40 for finally (0.15 sec)

  1. docs/hotfixes.md

    # Introduction
    
    This document outlines how to make hotfix binaries and containers for MinIO?. The main focus in this article is about how to backport patches to a specific branch and finally building binaries/containers.
    
    ## Pre-pre requisite
    
    - A working knowledge of MinIO codebase and its various components.
    - A working knowledge of AWS S3 API behaviors and corner cases.
    
    ## Pre-requisite for backporting any fixes
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 14 21:36:02 GMT 2024
    - 5K bytes
    - Viewed (0)
  2. internal/s3select/message.go

    		writer.payloadBufferIndex = 0
    	}
    	return result
    }
    
    // Finish is the last call to the message writer - it sends any
    // remaining record payload, then sends statistics and finally the end
    // message.
    func (writer *messageWriter) Finish(bytesScanned, bytesProcessed int64) error {
    	select {
    	case <-writer.doneCh:
    		return fmt.Errorf("messageWriter is done")
    	default:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 30 15:26:43 GMT 2022
    - 15.2K bytes
    - Viewed (0)
  3. cmd/iam.go

    		// Check policy for parent user of service account.
    		svcPolicies, err = sys.PolicyDBGet(parentUser, args.Groups...)
    		if err != nil {
    			iamLogIf(GlobalContext, err)
    			return false
    		}
    
    		// Finally, if there is no parent policy, check if a policy claim is
    		// present.
    		if len(svcPolicies) == 0 {
    			policySet, _ := policy.GetPoliciesFromClaims(args.Claims, iamPolicyClaimNameOpenID())
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  4. 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)
  5. 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)
  6. 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)
  7. cmd/test-utils_test.go

    	// Fill in Expires for presigned query.
    	query.Set("Expires", strconv.FormatInt(epochExpires, 10))
    
    	// Encode query and save.
    	req.URL.RawQuery = query.Encode()
    
    	// Save signature finally.
    	req.URL.RawQuery += "&Signature=" + url.QueryEscape(signature)
    	return nil
    }
    
    // Sign given request using Signature V2.
    func signRequestV2(req *http.Request, accessKey, secretKey string) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  8. cmd/site-replication.go

    		// server configuration, and convert it to minio-go's
    		// replication configuration type (by converting to xml and
    		// parsing it back), use minio-go's add rule function, and
    		// finally convert it back to the server type (again via xml).
    		// This is needed as there is no add-rule function in the server
    		// yet.
    
    		// Though we do not check if the rule already exists, this is
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  9. cmd/bucket-replication.go

    		if err != nil {
    			continue
    		}
    
    		mrfRec, err = loadMRF(rc)
    		if err != nil {
    			continue
    		}
    
    		// finally delete the file after processing mrf entries
    		localDrive.Delete(p.ctx, minioMetaBucket, pathJoin(replicationMRFDir, globalLocalNodeNameHex+".bin"), DeleteOptions{})
    		break
    	}
    
    	return mrfRec, nil
    }
    
    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)
  10. 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)
Back to top