Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 291 - 300 of 347 for ctx (0.01 seconds)

  1. docs/distributed/DESIGN.md

    MinIO places new objects in server pools based on proportionate free space, per pool. Following pseudo code demonstrates this behavior.
    
    ```go
    func getAvailablePoolIdx(ctx context.Context) int {
            serverPools := z.getServerPoolsAvailableSpace(ctx)
            total := serverPools.TotalAvailable()
            // choose when we reach this many
            choose := rand.Uint64() % total
            atTotal := uint64(0)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Feb 26 09:25:50 GMT 2025
    - 8K bytes
    - Click Count (2)
  2. tests/test_filter_pydantic_sub_model_pv2.py

        assert err.value.errors() == [
            {
                "type": "value_error",
                "loc": ("response", "name"),
                "msg": "Value error, name must end in A",
                "input": "modelX",
                "ctx": {"error": HasRepr("ValueError('name must end in A')")},
            }
        ]
    
    
    def test_openapi_schema(client: TestClient):
        response = client.get("/openapi.json")
        assert response.status_code == 200, response.text
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 18:19:10 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  3. cmd/endpoint.go

    						reqInfo.AppendTags("elapsedTime",
    							humanize.RelTime(startTime,
    								startTime.Add(timeElapsed),
    								"elapsed",
    								"",
    							))
    						ctx := logger.SetReqInfo(GlobalContext,
    							reqInfo)
    						bootLogOnceIf(ctx, fmt.Errorf("%s resolves to localhost in a containerized deployment, waiting for it to resolve to a valid IP",
    							endpoints[i].Hostname()), endpoints[i].Hostname(), logger.ErrorKind)
    					}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  4. cmd/metacache-entries.go

    // otherwise the function will return nil.
    func mergeEntryChannels(ctx context.Context, in []chan metaCacheEntry, out chan<- metaCacheEntry, readQuorum int) error {
    	defer xioutil.SafeClose(out)
    	top := make([]*metaCacheEntry, len(in))
    	nDone := 0
    	ctxDone := ctx.Done()
    
    	// Use simpler forwarder.
    	if len(in) == 1 {
    		for {
    			select {
    			case <-ctxDone:
    				return ctx.Err()
    			case v, ok := <-in[0]:
    				if !ok {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 24.1K bytes
    - Click Count (0)
  5. cmd/metrics-realtime.go

    			}
    		}
    
    		metrics[d.Endpoint] = dm
    	}
    	return metrics
    }
    
    func collectRemoteMetrics(ctx context.Context, types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) {
    	if !globalIsDistErasure {
    		return m
    	}
    	all := globalNotificationSys.GetMetrics(ctx, types, opts)
    	for _, remote := range all {
    		m.Merge(&remote)
    	}
    	return m
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  6. tests/test_tutorial/test_query_params_str_validations/test_tutorial005.py

                {
                    "type": "string_too_short",
                    "loc": ["query", "q"],
                    "msg": "String should have at least 3 characters",
                    "input": "fa",
                    "ctx": {"min_length": 3},
                }
            ]
        }
    
    
    def test_openapi_schema(client: TestClient):
        response = client.get("/openapi.json")
        assert response.status_code == 200, response.text
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Fri Dec 26 10:43:02 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  7. cmd/metrics-v3-cluster-erasure-set.go

    )
    
    func b2f(v bool) float64 {
    	if v {
    		return 1
    	}
    	return 0
    }
    
    // loadClusterErasureSetMetrics - `MetricsLoaderFn` for cluster storage erasure
    // set metrics.
    func loadClusterErasureSetMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	result, _ := c.esetHealthResult.Get()
    
    	m.Set(erasureSetOverallWriteQuorum, float64(result.WriteQuorum))
    	m.Set(erasureSetOverallHealth, b2f(result.Healthy))
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 14 07:25:56 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  8. tensorflow/c/c_api_experimental.h

    TF_CAPI_EXPORT extern void TFE_AbortCollectiveOps(TFE_Context* ctx,
                                                      TF_Status* status);
    
    // Checks the health of collective ops peers. Explicit health check is needed in
    // multi worker collective ops to detect failures in the cluster.  If a peer is
    // down, collective ops may hang.
    TF_CAPI_EXPORT extern void TFE_CollectiveOpsCheckPeerHealth(
        TFE_Context* ctx, const char* task, int64_t timeout_in_ms,
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Thu Apr 27 21:07:00 GMT 2023
    - 15.1K bytes
    - Click Count (0)
  9. 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{}.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 163.1K bytes
    - Click Count (0)
  10. tests/test_tutorial/test_query_params_str_validations/test_tutorial007.py

                {
                    "type": "string_too_short",
                    "loc": ["query", "q"],
                    "msg": "String should have at least 3 characters",
                    "input": "fa",
                    "ctx": {"min_length": 3},
                }
            ]
        }
    
    
    def test_openapi_schema(client: TestClient):
        response = client.get("/openapi.json")
        assert response.status_code == 200, response.text
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Fri Dec 26 10:43:02 GMT 2025
    - 4.6K bytes
    - Click Count (0)
Back to Top