Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 162 for newLoader (0.04 sec)

  1. cmd/sftp-server-driver.go

    		}
    
    		dirPath := buildMinioDir(prefix)
    
    		_, err = clnt.PutObject(context.Background(), bucket, dirPath, bytes.NewReader([]byte("")), 0,
    			minio.PutObjectOptions{DisableContentSha256: true},
    		)
    		return err
    	}
    
    	return NotImplemented{}
    }
    
    type listerAt []os.FileInfo
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Feb 10 16:35:49 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    	)
    
    	var objectSize int64
    	for _, partInfo := range objInfo.Parts {
    		if isSSEC {
    			hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.Size), partInfo.Size, "", "", partInfo.ActualSize)
    		} else {
    			hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.ActualSize), partInfo.ActualSize, "", "", partInfo.ActualSize)
    		}
    		if err != nil {
    			return err
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    					CurrentVersion: Version,
    					UpdatedVersion: lrTime.Format(MinioReleaseTagTimeLayout),
    				}
    			}
    		}
    	}
    
    	if err = verifyBinary(u, sha256Sum, releaseInfo, mode, bytes.NewReader(bin)); err != nil {
    		peerResults[local] = madmin.ServerPeerUpdateStatus{
    			Host:           local,
    			Err:            err.Error(),
    			CurrentVersion: Version,
    		}
    	} else {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  4. cmd/iam.go

    	if ptok && spok && pt == embeddedPolicyType {
    		policyBytes, err := base64.StdEncoding.DecodeString(sp)
    		if err != nil {
    			return UserIdentity{}, nil, err
    		}
    		embeddedPolicy, err = policy.ParseConfig(bytes.NewReader(policyBytes))
    		if err != nil {
    			return UserIdentity{}, nil, err
    		}
    	}
    
    	return sa, embeddedPolicy, nil
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 75.3K bytes
    - Viewed (0)
  5. cmd/bucket-replication-handlers.go

    			return
    		}
    		if sameTarget && bucket == clnt.Bucket {
    			writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrBucketRemoteIdenticalToSource), r.URL)
    			return
    		}
    
    		reader := bytes.NewReader(buf)
    		// fake a PutObject and RemoveObject call to validate permissions
    		c := &minio.Core{Client: clnt.Client}
    		putOpts := minio.PutObjectOptions{
    			Internal: minio.AdvancedPutOptions{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  6. cmd/s3-zip-handlers.go

    			return
    		}
    		defer gr.Close()
    		rc, err = file.Open(gr)
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	} else {
    		rc = io.NopCloser(bytes.NewReader([]byte{}))
    	}
    
    	defer rc.Close()
    
    	if err = setObjectHeaders(ctx, w, fileObjInfo, nil, opts); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  7. cmd/batch-expire.go

    	xioutil.SafeClose(saverQuitCh)
    
    	// Notify expire jobs final status to the configured endpoint
    	buf, _ := json.Marshal(ri)
    	if err := r.Notify(context.Background(), bytes.NewReader(buf)); err != nil {
    		batchLogIf(context.Background(), fmt.Errorf("unable to notify %v", err))
    	}
    
    	return nil
    }
    
    //msgp:ignore batchExpireJobError
    type batchExpireJobError struct {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Apr 22 11:16:32 UTC 2025
    - 23K bytes
    - Viewed (0)
  8. cmd/metacache-stream_test.go

    func loadMetacacheSample(t testing.TB) *metacacheReader {
    	b, err := os.ReadFile("testdata/metacache.s2")
    	if err != nil {
    		t.Fatal(err)
    	}
    	return newMetacacheReader(bytes.NewReader(b))
    }
    
    func loadMetacacheSampleEntries(t testing.TB) metaCacheEntriesSorted {
    	r := loadMetacacheSample(t)
    	defer r.Close()
    	entries, err := r.readN(-1, false, true, false, "")
    	if err != io.EOF {
    		t.Fatal(err)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 15K bytes
    - Viewed (0)
  9. cmd/object-api-utils.go

    			var dopts []s2.ReaderOption
    			if off > 0 || decOff > 0 {
    				// We are not starting at the beginning, so ignore stream identifiers.
    				dopts = append(dopts, s2.ReaderIgnoreStreamIdentifier())
    			}
    			s2Reader := s2.NewReader(inputReader, dopts...)
    			// Apply the skipLen and limit on the decompressed stream.
    			if decOff > 0 {
    				if err = s2Reader.Skip(decOff); err != nil {
    					// Call the cleanup funcs
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jun 25 15:08:54 UTC 2025
    - 37.3K bytes
    - Viewed (0)
  10. cmd/kms-handlers_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	testKMSPolicyName := "testKMSPolicy"
    	if p != "" {
    		p = `{"Version":"2012-10-17","Statement":[` + p + `]}`
    		policyData, err := policy.ParseConfig(strings.NewReader(p))
    		if err != nil {
    			t.Fatal(err)
    		}
    		_, err = globalIAMSys.SetPolicy(ctx, testKMSPolicyName, *policyData)
    		if err != nil {
    			t.Fatal(err)
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 22.3K bytes
    - Viewed (0)
Back to top