- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 1,203 for client (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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 }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.7K bytes - Click Count (0) -
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.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.6K bytes - Click Count (0) -
cmd/storage-rest-client.go
func (client *storageRESTClient) String() string { return client.endpoint.String() } // IsOnline - returns whether client failed to connect or not. func (client *storageRESTClient) IsOnline() bool { return client.restClient.IsOnline() || client.IsOnlineWS() } // IsOnlineWS - returns whether websocket client failed to connect or not. func (client *storageRESTClient) IsOnlineWS() bool {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 08 02:38:41 GMT 2025 - 30.4K bytes - Click Count (0) -
docs/en/docs/advanced/generate-clients.md
### Generate a TypeScript Client with Tags { #generate-a-typescript-client-with-tags } If you generate a client for a FastAPI app using tags, it will normally also separate the client code based on the tags. This way, you will be able to have things ordered and grouped correctly for the client code: <img src="/img/tutorial/generate-clients/image06.png"> In this case, you have:Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 9.7K bytes - Click Count (1) -
okhttp/src/jvmTest/kotlin/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) }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 22:17:59 GMT 2026 - 13.4K bytes - Click Count (1) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientFactory.java
} if (client == null) { throw new CrawlerSystemException("CrawlerClient instance is null. Cannot register null client."); } clientMap.put(Pattern.compile(regex), client); } /** * Adds a client with a regular expression pattern at a specific position.Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 7.3K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/SwitchableHttpClient.java
*/ package org.codelibs.fess.crawler.client.http; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.crawler.client.CrawlerClient; import org.codelibs.fess.crawler.client.FaultTolerantClient; /** * SwitchableHttpClient is a switchable HTTP client that can use either Apache HttpComponents 4.x or 5.x.
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Thu Jan 08 04:17:06 GMT 2026 - 4.9K bytes - Click Count (0) -
tests/benchmarks/test_general_performance.py
@pytest.fixture(scope="module") def client() -> Iterator[TestClient]: with TestClient(app) as client: yield client def _bench_get(benchmark, client: TestClient, path: str) -> tuple[int, bytes]: warmup = client.get(path) assert warmup.status_code == 200 def do_request() -> tuple[int, bytes]: response = client.get(path) return response.status_code, response.content
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Dec 26 20:40:26 GMT 2025 - 11.1K bytes - Click Count (0) -
cmd/notification.go
states := make([]madmin.BgHealState, len(sys.peerClients)) for idx, client := range sys.peerClients { client := client ng.Go(ctx, func() error { if client == nil { return errPeerNotReachable } st, err := client.BackgroundHealStatus(ctx) if err != nil { return err } states[idx] = st return nil }, idx, *client.host) } return states, ng.Wait() }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 46K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java
suggester = Suggester.builder().build(runner.client(), "SuggesterTest"); suggester.createIndexIfNothing(); } @Test public void test_Read() throws Exception { String indexName = "test-index"; Client client = runner.client(); SuggestSettings settings = suggester.settings(); int num = 10000; addDocument(indexName, client, num);
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Nov 23 13:04:17 GMT 2025 - 8.7K bytes - Click Count (0)