Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 339 for client (0.16 sec)

  1. internal/rest/client.go

    		HealthCheckTimeout:       time.Second,
    	}
    	if err != nil {
    		clnt.lastErr = err
    		clnt.lastErrTime = time.Now()
    	}
    
    	if clnt.HealthCheckFn != nil {
    		// make connection pre-emptively.
    		go clnt.HealthCheckFn()
    	}
    	return clnt
    }
    
    // IsOnline returns whether the client is likely to be online.
    func (c *Client) IsOnline() bool {
    	return atomic.LoadInt32(&c.connected) == online
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 14.4K bytes
    - Viewed (0)
  2. cmd/peer-rest-client.go

    func (client *peerRESTClient) String() string {
    	return client.host.String()
    }
    
    // IsOnline returns true if the peer client is online.
    func (client *peerRESTClient) IsOnline() bool {
    	return client.restClient.IsOnline()
    }
    
    // Close - marks the client as closed.
    func (client *peerRESTClient) Close() error {
    	client.restClient.Close()
    	return nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  3. cmd/peer-s3-client.go

    	return toStorageErr(err)
    }
    
    func (client remotePeerS3Client) GetHost() string {
    	return client.node.Host
    }
    
    func (client remotePeerS3Client) GetPools() []int {
    	return client.pools
    }
    
    func (client *remotePeerS3Client) SetPools(p []int) {
    	client.pools = make([]int, len(p))
    	copy(client.pools, p)
    }
    
    // newPeerS3Clients creates new peer clients.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    }
    
    func (client *storageRESTClient) IsLocal() bool {
    	return false
    }
    
    func (client *storageRESTClient) Hostname() string {
    	return client.endpoint.Host
    }
    
    func (client *storageRESTClient) Endpoint() Endpoint {
    	return client.endpoint
    }
    
    func (client *storageRESTClient) Healing() *healingTracker {
    	// This call is not implemented for remote client on purpose.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  5. docs/en/docs/advanced/generate-clients.md

    ```console
    $ npm run generate-client
    
    frontend-app@1.0.0 generate-client /home/user/code/frontend-app
    > openapi-ts --input http://localhost:8000/openapi.json --output ./src/client --client axios
    ```
    
    </div>
    
    That command will generate code in `./src/client` and will use `axios` (the frontend HTTP library) internally.
    
    ### Try Out the Client Code
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  6. docs/de/docs/advanced/generate-clients.md

    ```console
    $ npm run generate-client
    
    frontend-app@1.0.0 generate-client /home/user/code/frontend-app
    > openapi-ts --input http://localhost:8000/openapi.json --output ./src/client --client axios
    ```
    
    </div>
    
    Dieser Befehl generiert Code in `./src/client` und verwendet intern `axios` (die Frontend-HTTP-Bibliothek).
    
    ### Den Client-Code ausprobieren
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Wed Apr 03 03:42:11 GMT 2024
    - 12K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/OkHttpClientTest.kt

      }
    
      @Test fun durationDefaults() {
        val client = clientTestRule.newClient()
        assertThat(client.callTimeoutMillis).isEqualTo(0)
        assertThat(client.connectTimeoutMillis).isEqualTo(10000)
        assertThat(client.readTimeoutMillis).isEqualTo(10000)
        assertThat(client.writeTimeoutMillis).isEqualTo(10000)
        assertThat(client.pingIntervalMillis).isEqualTo(0)
        assertThat(client.webSocketCloseTimeout).isEqualTo(60_000)
      }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Mar 31 17:16:15 GMT 2024
    - 13.2K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

        assertThat(client.connectionPool.connectionCount()).isEqualTo(1)
      }
    
      /** Test a previously coalesced connection that's no longer healthy.  */
      @Test
      fun staleCoalescedConnection() {
        server.enqueue(MockResponse())
        server.enqueue(MockResponse())
        val connection = AtomicReference<Connection?>()
        client =
          client.newBuilder()
            .addNetworkInterceptor(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  9. cmd/admin-handlers-users_test.go

    func (c *check) mustListObjects(ctx context.Context, client *minio.Client, bucket string) {
    	c.Helper()
    	res := client.ListObjects(ctx, bucket, minio.ListObjectsOptions{})
    	v, ok := <-res
    	if ok && v.Err != nil {
    		c.Fatalf("user was unable to list: %v", v.Err)
    	}
    }
    
    func (c *check) mustListBuckets(ctx context.Context, client *minio.Client) {
    	c.Helper()
    	_, err := client.ListBuckets(ctx)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 16:36:16 GMT 2024
    - 45.7K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/informers_test.go

    	client.RunAndWait(ctx.Done())
    	go handlers.Start()
    
    	waitForMockCalls()
    	// wait until pod add was called
    	mt.Assert(EventTotals.Name(), map[string]string{"type": "add"}, monitortest.AtLeast(1))
    
    	assertPodAnnotated(t, client, pod)
    
    	// check expectations on mocked calls
    	fs.AssertExpectations(t)
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 15.8K bytes
    - Viewed (0)
Back to top