- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 208 for newReader (0.1 sec)
-
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 Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 23.3K bytes - Viewed (0) -
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 Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 22.3K bytes - Viewed (0) -
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 Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 18 17:59:03 UTC 2024 - 21.9K bytes - Viewed (0) -
cmd/erasure-object.go
return &GetObjectReader{ ObjInfo: objInfo, }, err } // Zero byte objects don't even need to further initialize pipes etc. return NewGetObjectReaderFromReader(bytes.NewReader(nil), objInfo, opts) } if objInfo.IsRemote() { gr, err := getTransitionedObjectReader(ctx, bucket, object, rs, h, objInfo, opts) if err != nil { return nil, err } unlockOnDefer = false
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0) -
cmd/site-replication.go
// do some validation. newReplCfgBytes, err := xml.Marshal(replicationConfig) if err != nil { return err } newReplicationConfig, err := sreplication.ParseConfig(bytes.NewReader(newReplCfgBytes)) if err != nil { return err } sameTarget, apiErr := validateReplicationDestination(ctx, bucket, newReplicationConfig, &validateReplicationDestinationOptions{CheckRemoteBucket: true})
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 185.1K bytes - Viewed (0) -
cmd/sts-handlers.go
if len(form) == 0 { return nil } sessionPolicyStr := form.Get(stsPolicy) if len(sessionPolicyStr) == 0 { return nil } sessionPolicy, err := policy.ParseConfig(bytes.NewReader([]byte(sessionPolicyStr))) if err != nil { return err } // Version in policy must not be empty if sessionPolicy.Version == "" { return errors.New("Version cannot be empty expecting '2012-10-17'")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 01:29:20 UTC 2024 - 33.9K bytes - Viewed (0) -
cmd/iam-object-store.go
} func decryptData(data []byte, objPath string) ([]byte, error) { if utf8.Valid(data) { return data, nil } pdata, err := madmin.DecryptData(globalActiveCred.String(), bytes.NewReader(data)) if err == nil { return pdata, nil } if GlobalKMS != nil { pdata, err = config.DecryptBytes(GlobalKMS, data, kms.Context{ minioMetaBucket: path.Join(minioMetaBucket, objPath), })
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 23:40:37 UTC 2024 - 26.6K bytes - Viewed (0) -
guava/src/com/google/common/io/Files.java
* @param charset the charset used to decode the input stream; see {@link StandardCharsets} for * helpful predefined constants * @return the buffered reader */ public static BufferedReader newReader(File file, Charset charset) throws FileNotFoundException { checkNotNull(file); checkNotNull(charset); return new BufferedReader(new InputStreamReader(new FileInputStream(file), charset)); } /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jul 22 19:03:12 UTC 2024 - 33.1K bytes - Viewed (0) -
cmd/sts-handlers_test.go
iamFile := pathJoin(iamAssetsDir, f) fileContent, ok := exportContent[f] if !ok { t.Fatalf("missing content for %s", f) } if err := rawDataFn(bytes.NewReader(fileContent), iamFile, len(fileContent)); err != nil { t.Fatalf("failed to write %s: %v", iamFile, err) } } zipWriter.Close() importContent = b.Bytes() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 23:40:37 UTC 2024 - 97.1K bytes - Viewed (0) -
cmd/utils.go
formData := url.Values{} formData.Set("login", username) formData.Set("password", password) req, err = http.NewRequestWithContext(ctx, http.MethodPost, lastReq.URL.String(), strings.NewReader(formData.Encode())) if err != nil { return "", fmt.Errorf("new request err (/login): %v", err) } req.Header.Set("Content-Type", "application/x-www-form-urlencoded") _, err = dexClient.Do(req)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:22:04 UTC 2024 - 31.9K bytes - Viewed (0)