- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 391 for ctx_ (0.08 sec)
-
cmd/xl-storage-disk-id-check.go
ctx, done, err := p.TrackDiskHealth(ctx, storageMetricStatVol, volume) if err != nil { return vol, err } defer done(0, &err) return xioutil.WithDeadline[VolInfo](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (result VolInfo, err error) { return p.storage.StatVol(ctx, volume) }) } func (p *xlStorageDiskIDCheck) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:56:26 UTC 2024 - 34.5K bytes - Viewed (0) -
cmd/bucket-versioning-handler.go
}, r.URL) return } configData, err := xml.Marshal(v) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketVersioningConfig, configData) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Call site replication hook. //
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5K bytes - Viewed (0) -
internal/logger/targets.go
func UpdateHTTPWebhooks(ctx context.Context, cfgs map[string]http.Config) (errs []error) { return updateHTTPTargets(ctx, cfgs, systemTargets) } // UpdateAuditWebhooks swaps audit webhook targets with newly loaded ones from the cfg func UpdateAuditWebhooks(ctx context.Context, cfgs map[string]http.Config) (errs []error) { return updateHTTPTargets(ctx, cfgs, auditTargets) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 03 15:44:50 UTC 2024 - 6K bytes - Viewed (0) -
cmd/iam-etcd-store.go
return deleteKeyEtcd(ctx, ies.client, path) } func (ies *IAMEtcdStore) loadPolicyDocWithRetry(ctx context.Context, policy string, m map[string]PolicyDoc, _ int) error { return ies.loadPolicyDoc(ctx, policy, m) } func (ies *IAMEtcdStore) loadPolicyDoc(ctx context.Context, policy string, m map[string]PolicyDoc) error { data, err := ies.loadIAMConfigBytes(ctx, getPolicyDocPath(policy)) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 01:29:20 UTC 2024 - 14K bytes - Viewed (0) -
cmd/config.go
}) return err } func readServerConfigHistory(ctx context.Context, objAPI ObjectLayer, uuidKV string) ([]byte, error) { historyFile := pathJoin(minioConfigHistoryPrefix, uuidKV+kvPrefix) data, err := readConfig(ctx, objAPI, historyFile) if err != nil { return nil, err } return decryptData(data, historyFile) } func saveServerConfigHistory(ctx context.Context, objAPI ObjectLayer, kv []byte) error {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 23 10:07:06 UTC 2023 - 6K bytes - Viewed (0) -
cmd/bucket-handlers.go
writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } getBucketInfo := objectAPI.GetBucketInfo if _, err := getBucketInfo(ctx, bucket, BucketOptions{}); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Generate response.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 12:24:04 UTC 2024 - 63.4K bytes - Viewed (0) -
cmd/admin-handlers-users_test.go
err = s.adm.RemoveUser(ctx, accessKey) if err != nil { c.Fatalf("user could not be deleted: %v", err) } err = s.adm.RemoveCannedPolicy(ctx, policy1) if err != nil { c.Fatalf("policy del err: %v", err) } err = s.adm.RemoveCannedPolicy(ctx, policy2) if err != nil { c.Fatalf("policy del err: %v", err) } } func (s *TestSuiteIAM) TestPolicyCreate(c *check) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 47.3K bytes - Viewed (0) -
cmd/object-lambda-handlers.go
if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } eventData, err := getLambdaEventData(bucket, object, cred, r) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } resp, err := target.Send(eventData) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } defer resp.Body.Close()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 22 07:04:48 UTC 2024 - 10.3K bytes - Viewed (0) -
cmd/config-current.go
} loggerCfg.HTTP[n] = l } if errs := logger.UpdateHTTPWebhooks(ctx, loggerCfg.HTTP); len(errs) > 0 { configLogIf(ctx, fmt.Errorf("Unable to update logger webhook config: %v", errs)) } case config.AuditWebhookSubSys: loggerCfg, err := logger.LookupConfigForSubSys(ctx, s, config.AuditWebhookSubSys) if err != nil { configLogIf(ctx, fmt.Errorf("Unable to load audit webhook config: %w", err)) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 30.1K bytes - Viewed (0) -
cmd/bucket-notification-handlers.go
writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } _, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{}) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } config, err := globalBucketMetadataSys.GetNotificationConfig(bucketName) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.1K bytes - Viewed (0)