Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for ENDPOINT (0.1 sec)

  1. cmd/server_test.go

    		getURL          string
    		expectedStrings []string
    	}{
    		{getListObjectsV1URL(s.endPoint, bucketName, "", "1000", ""), []string{"<Key>foo bar 1</Key>", "<Key>foo bar 2</Key>"}},
    		{getListObjectsV1URL(s.endPoint, bucketName, "", "1000", "url"), []string{"<Key>foo+bar+1</Key>", "<Key>foo+bar+2</Key>"}},
    		{
    			getListObjectsV2URL(s.endPoint, bucketName, "", "1000", "", "", ""),
    			[]string{
    				"<Key>foo bar 1</Key>",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
  2. cmd/admin-handlers.go

    		newHost := fmt.Sprintf("pool%d.server%d", poolNum, srvrNum)
    		schemePfx := endpoint.Scheme + "://"
    
    		// Hostname
    		mapIfNotPresent(hostAnonymizer, endpoint.Hostname(), newHost)
    
    		newHostPort := newHost
    		if len(endpoint.Port()) > 0 {
    			// Host + port
    			newHostPort = newHost + ":" + endpoint.Port()
    			mapIfNotPresent(hostAnonymizer, endpoint.Host, newHostPort)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  3. cmd/site-replication.go

    			successMsg = fmt.Sprintf("%s\n- sync state %s for peer %s", successMsg, peer.SyncState, peer.Name)
    		}
    		if peer.Endpoint != "" { // `admin replicate update` requested an endpoint change
    			pi.Endpoint = peer.Endpoint
    			successMsg = fmt.Sprintf("%s\n- endpoint %s for peer %s", successMsg, peer.Endpoint, peer.Name)
    		}
    
    		if peer.DefaultBandwidth.IsSet {
    			if peer.DeploymentID == globalDeploymentID() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  4. fastapi/routing.py

            self,
            path: str,
            endpoint: Callable[..., Any],
            *,
            name: Optional[str] = None,
            dependencies: Optional[Sequence[params.Depends]] = None,
            dependency_overrides_provider: Optional[Any] = None,
        ) -> None:
            self.path = path
            self.endpoint = endpoint
            self.name = get_name(endpoint) if name is None else name
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Oct 12 09:44:57 UTC 2024
    - 172.1K bytes
    - Viewed (0)
  5. cmd/metrics-v2.go

    					VariableLabels: map[string]string{"endpoint": stat.Endpoint},
    				})
    				ml = append(ml, MetricV2{
    					Description:    getRepFailedOperationsLastMinuteMD(clusterMetricNamespace),
    					Value:          stat.Failed.LastMinute.Count,
    					VariableLabels: map[string]string{"endpoint": stat.Endpoint},
    				})
    				ml = append(ml, MetricV2{
    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/bucket-replication.go

    			}
    		}
    		// if checked bucket, then check the ready is unnecessary
    		if !opts.CheckRemoteBucket && opts.CheckReady {
    			endpoint := clnt.EndpointURL().String()
    			if errInt, ok := opts.checkReadyErr.Load(endpoint); !ok {
    				err = checkRemoteEndpoint(ctx, clnt.EndpointURL())
    				opts.checkReadyErr.Store(endpoint, err)
    			} else {
    				if errInt == nil {
    					err = nil
    				} else {
    					err = errInt.(error)
    				}
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  7. cmd/object-handlers_test.go

    		// Verify response of the V2 signed HTTP request.
    		// initialize HTTP NewRecorder, this records any mutations to response writer inside the handler.
    		recV2 := httptest.NewRecorder()
    		// construct HTTP request for Head Object endpoint.
    		reqV2, err := newTestSignedRequestV2(http.MethodHead, getHeadObjectURL("", testCase.bucketName, testCase.objectName),
    			0, nil, testCase.accessKey, testCase.secretKey, nil)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  8. cmd/storage-datatypes_gen.go

    		return
    	}
    	z.Scanning, err = dc.ReadBool()
    	if err != nil {
    		err = msgp.WrapError(err, "Scanning")
    		return
    	}
    	z.Endpoint, err = dc.ReadString()
    	if err != nil {
    		err = msgp.WrapError(err, "Endpoint")
    		return
    	}
    	z.MountPath, err = dc.ReadString()
    	if err != nil {
    		err = msgp.WrapError(err, "MountPath")
    		return
    	}
    	z.ID, err = dc.ReadString()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.32.md

      Similarly you can also access  kubelet's `/pods` endpoint to fetch a list of Pods bound to that node by granting the caller `nodes/pods` permission in RBAC.
      Similarly you can also access kubelet's `/configz` endpoint to fetch kubelet's configuration by granting the caller `nodes/configz` permission in RBAC.
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Oct 29 20:17:52 UTC 2024
    - 121.6K bytes
    - Viewed (0)
  10. fastapi/applications.py

            generate_unique_id_function: Callable[[routing.APIRoute], str] = Default(
                generate_unique_id
            ),
        ) -> None:
            self.router.add_api_route(
                path,
                endpoint=endpoint,
                response_model=response_model,
                status_code=status_code,
                tags=tags,
                dependencies=dependencies,
                summary=summary,
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Aug 17 04:52:31 UTC 2024
    - 172.2K bytes
    - Viewed (0)
Back to top