Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 369 for Endpoints (0.16 sec)

  1. cmd/bootstrap-peer-server.go

    	var clnts []*bootstrapRESTClient
    	for _, ep := range endpointServerPools {
    		for _, endpoint := range ep.Endpoints {
    			if endpoint.IsLocal {
    				continue
    			}
    			if seenClient.Contains(endpoint.Host) {
    				continue
    			}
    			seenClient.Add(endpoint.Host)
    			clnts = append(clnts, &bootstrapRESTClient{gm.Connection(endpoint.GridHost())})
    		}
    	}
    	return clnts
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. cmd/bucket-handlers_test.go

    func TestRemoveBucketHandler(t *testing.T) {
    	ExecObjectLayerAPITest(ExecObjectLayerAPITestArgs{t: t, objAPITest: testRemoveBucketHandler, endpoints: []string{"RemoveBucket"}})
    }
    
    func testRemoveBucketHandler(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler,
    	credentials auth.Credentials, t *testing.T,
    ) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 39.8K bytes
    - Viewed (0)
  3. cmd/batch-replicate_test.go

               value: "image/*" # match objects with 'content-type', with all values starting with 'image/'
    
    #    notify:
    #      endpoint: "https://notify.endpoint" # notification endpoint to receive job status events
    #      token: "Bearer xxxxx" # optional authentication token for the notification endpoint
    #
    #    retry:
    #      attempts: 10 # number of retries for the job before giving up
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  4. cmd/peer-s3-client.go

    	peerClients []peerS3Client // Excludes self
    	poolsCount  int
    }
    
    // NewS3PeerSys - creates new S3 peer calls.
    func NewS3PeerSys(endpoints EndpointServerPools) *S3PeerSys {
    	return &S3PeerSys{
    		peerClients: newPeerS3Clients(endpoints),
    		poolsCount:  len(endpoints),
    	}
    }
    
    // HealBucket - heals buckets at node level
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  5. docs/es/docs/advanced/websockets.md

    Y todos usarán la misma conexión WebSocket.
    
    ## Usando `Depends` y otros
    
    En endpoints de WebSocket puedes importar desde `fastapi` y usar:
    
    * `Depends`
    * `Security`
    * `Cookie`
    * `Header`
    * `Path`
    * `Query`
    
    Funcionan de la misma manera que para otros endpoints de FastAPI/*path operations*:
    
    {* ../../docs_src/websockets/tutorial002_an_py310.py hl[68:69,82] *}
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 18:26:57 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  6. docs/orchestration/kubernetes/README.md

    ## Monitoring MinIO in Kubernetes
    
    MinIO server exposes un-authenticated liveness endpoints so Kubernetes can natively identify unhealthy MinIO containers. MinIO also exposes Prometheus compatible data on a different endpoint to enable Prometheus users to natively monitor their MinIO deployments.
    
    ## Explore Further
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  7. docs/logging/README.md

    ```
    
    MinIO also honors environment variable for Kafka target Audit logging as shown below, this setting will override the endpoint settings in the MinIO server config.
    
    ```
    mc admin config set myminio/ audit_kafka --env
    KEY:
    audit_kafka[:name]  send audit logs to kafka endpoints
    
    ARGS:
    MINIO_AUDIT_KAFKA_ENABLE*          (on|off)    enable audit_kafka target, default is 'off'
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/graph/AbstractStandardDirectedGraphTest.java

      }
    
      @Test
      public void putEdge_orderMismatch() {
        assume().that(graphIsMutable()).isTrue();
    
        EndpointPair<Integer> endpoints = EndpointPair.unordered(N1, N2);
        IllegalArgumentException e =
            assertThrows(IllegalArgumentException.class, () -> graphAsMutableGraph.putEdge(endpoints));
        assertThat(e).hasMessageThat().contains(ENDPOINTS_MISMATCH);
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  9. cmd/veeam-sos-api.go

    //   - Handover of IAM & STS Endpoints instead of manual definition in Veeam Backup & Replication. This allows Veeam
    //     Agents to directly backup to object storage.
    //
    // An object storage system can implement one, multiple, or all functions.
    //
    //   - Optional (mandatory if <IAMSTS> is true): Set Endpoints for IAM and STS processing.
    //
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  10. samples/guide/src/main/java/okhttp3/recipes/kt/PostMultipart.kt

    import okhttp3.RequestBody.Companion.asRequestBody
    
    class PostMultipart {
      private val client = OkHttpClient()
    
      fun run() {
        // Use the imgur image upload API as documented at https://api.imgur.com/endpoints/image
        val requestBody =
          MultipartBody
            .Builder()
            .setType(MultipartBody.FORM)
            .addFormDataPart("title", "Square Logo")
            .addFormDataPart(
              "image",
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2.1K bytes
    - Viewed (0)
Back to top