Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for ctx_ (0.03 sec)

  1. cmd/admin-handlers.go

    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    	}
    
    	err = verifyBinary(u, sha256Sum, releaseInfo, mode, bytes.NewReader(bin))
    	if err != nil {
    		adminLogIf(ctx, fmt.Errorf("server update failed with %w", err))
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  2. cmd/site-replication.go

    		if err != nil {
    			return err
    		}
    
    		c.healBucket(ctx, objAPI, bucket, info)
    
    		if bi.Deleted.IsZero() || (!bi.Created.IsZero() && bi.Deleted.Before(bi.Created)) {
    			c.healVersioningMetadata(ctx, objAPI, bucket, info)
    			c.healOLockConfigMetadata(ctx, objAPI, bucket, info)
    			c.healSSEMetadata(ctx, objAPI, bucket, info)
    			c.healBucketReplicationConfig(ctx, objAPI, bucket, info, &opts)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  3. cmd/object-handlers.go

    			rcfg, err := globalBucketObjectLockSys.Get(bucket)
    			if err != nil {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    				return
    			}
    			replcfg, err := getReplicationConfig(ctx, bucket)
    			if err != nil {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    				return
    			}
    			event := evalActionFromLifecycle(ctx, *lc, rcfg, replcfg, objInfo)
    			if event.Action.Delete() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    	if err != nil {
    		replLogOnceIf(ctx, err, bucket)
    		return nil, err
    	}
    	tgts, err := globalBucketTargetSys.ListBucketTargets(ctx, bucket)
    	if err != nil {
    		replLogIf(ctx, err)
    		return nil, err
    	}
    
    	objInfoCh := make(chan itemOrErr[ObjectInfo], 10)
    	if err := objAPI.Walk(ctx, bucket, opts.Prefix, objInfoCh, WalkOptions{}); err != nil {
    		replLogIf(ctx, err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  5. cmd/metrics-v2.go

    		metricsGroupOpts: opts,
    	}
    	mg.RegisterRead(func(ctx context.Context) (metrics []MetricV2) {
    		objLayer := newObjectLayerFn()
    		if objLayer == nil {
    			return
    		}
    
    		metrics = make([]MetricV2, 0, 50)
    		dataUsageInfo, err := loadDataUsageFromBackend(ctx, objLayer)
    		if err != nil {
    			metricsLogIf(ctx, err)
    			return
    		}
    
    		// data usage has not captured any data yet.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  6. cmd/object-handlers_test.go

    			uploadID:  uploadIDs[0],
    			parts:     inputParts[0].parts,
    			accessKey: credentials.AccessKey,
    			secretKey: credentials.SecretKey,
    
    			expectedContent: encodeResponse(getAPIErrorResponse(ctx,
    				toAPIError(ctx, InvalidPart{}),
    				getGetObjectURL("", bucketName, objectName), "", "")),
    			expectedRespStatus: http.StatusBadRequest,
    		},
    		// Test case - 2.
    		// No parts specified in CompletePart{}.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  7. cmd/server_test.go

    	// Shutdown.
    	s.testServer.cancel()
    	s.testServer.Server.Close()
    	s.testServer.Obj.Shutdown(context.Background())
    
    	// Restart.
    	ctx, cancel := context.WithCancel(context.Background())
    
    	s.testServer.cancel = cancel
    	s.testServer = initTestServerWithBackend(ctx, c, s.testServer, s.testServer.Obj, s.testServer.rawDiskPaths)
    	if s.secure {
    		s.testServer.Server.StartTLS()
    	} else {
    		s.testServer.Server.Start()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
  8. fastapi/routing.py

                                "loc": ("body", e.pos),
                                "msg": "JSON decode error",
                                "input": {},
                                "ctx": {"error": e.msg},
                            }
                        ],
                        body=e.doc,
                    )
                    raise validation_error from e
                except HTTPException:
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Oct 12 09:44:57 UTC 2024
    - 172.1K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.32.md

    ## Urgent Upgrade Notes
    
    ### (No, really, you MUST read this before you upgrade)
    
     - ACTION REQUIRED for custom scheduler plugin developers:
      `PodEligibleToPreemptOthers` in the `preemption` interface gets `ctx` in the parameters.
      Please change your plugins' implementation accordingly. ([#126465](https://github.com/kubernetes/kubernetes/pull/126465), [@googs1025](https://github.com/googs1025)) [SIG Scheduling]
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Oct 29 20:17:52 UTC 2024
    - 121.6K bytes
    - Viewed (0)
Back to top