Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 391 for ctx_ (0.03 sec)

  1. cmd/admin-handler-utils.go

    	if entity == "" {
    		return toAPIError(ctx, fmt.Errorf("error exporting %s with: %w", fname, err))
    	}
    	return toAPIError(ctx, fmt.Errorf("error exporting %s from %s with: %w", entity, fname, err))
    }
    
    // wraps import error for more context
    func importError(ctx context.Context, err error, fname, entity string) APIError {
    	if entity == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 07:17:20 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top