- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,840 for caClient (0.05 sec)
-
cmd/lock-rest-client.go
"context" "errors" "github.com/minio/minio/internal/dsync" "github.com/minio/minio/internal/grid" ) // lockRESTClient is authenticable lock REST client type lockRESTClient struct { connection *grid.Connection } // IsOnline - returns whether REST client failed to connect or not. func (c *lockRESTClient) IsOnline() bool { return c.connection.State() == grid.StateConnected } // Not a local locker
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 3.3K bytes - Viewed (0) -
cmd/peer-rest-client.go
} // Stringer provides a canonicalized representation of node. func (client *peerRESTClient) String() string { return client.host.String() } // IsOnline returns true if the peer client is online. func (client *peerRESTClient) IsOnline() bool { conn := client.gridConn() if conn == nil { return false } return client.restClient.IsOnline() || conn.State() == grid.StateConnected }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 26.1K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
Xiaopeng Han <******@****.***> 1703025762 +0800
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 3.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
assertThat(client.processNextFrame()).isFalse() client.listener.assertClosing(1000, "Goodbye!") client.webSocket!!.finishReader() server.listener.assertClosed(1000, "Hello!") client.listener.assertClosed(1000, "Goodbye!") } @Test fun clientCloseThenMethodsReturnFalse() { client.webSocket!!.close(1000, "Hello!") assertThat(client.webSocket!!.close(1000, "Hello!")).isFalse()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 01:59:58 UTC 2024 - 18.5K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/CrawlerClientFactoryTest.java
url = "smb1:/home/hoge"; client = clientFactory.getClient(url); assertNotNull(client); assertTrue(client instanceof org.codelibs.fess.crawler.client.smb1.SmbClient); url = "ftp:/home/hoge"; client = clientFactory.getClient(url); assertNotNull(client); assertTrue(client instanceof FtpClient); url = "storage:/home/hoge"; client = clientFactory.getClient(url);
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 5.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
client.newWebSocket(newRequest("http://a/2"), webSocketListener) client.newWebSocket(newRequest("http://a/3"), webSocketListener) executor.assertJobs("http://a/1", "http://a/2", "http://a/3") } @Test fun increasingMaxRequestsPromotesJobsImmediately() { dispatcher.maxRequests = 2 client.newCall(newRequest("http://a/1")).enqueue(callback) client.newCall(newRequest("http://b/1")).enqueue(callback)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 12.7K bytes - Viewed (0) -
tests/test_default_response_class.py
with client: response = client.get("/a/override") assert response.content == b"Hello A" assert response.headers["content-type"] == text_type def test_router_a_a(): with client: response = client.get("/a/a") assert response.json() == {"msg": "Hello A A"} assert response.headers["content-type"] == orjson_type def test_router_a_a_override(): with client:
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Mar 01 20:49:20 UTC 2020 - 5.2K bytes - Viewed (0) -
tests/test_tutorial/test_bigger_applications/test_main.py
import pytest from dirty_equals import IsDict from fastapi.testclient import TestClient @pytest.fixture(name="client") def get_client(): from docs_src.bigger_applications.app.main import app client = TestClient(app) return client def test_users_token_jessica(client: TestClient): response = client.get("/users?token=jessica") assert response.status_code == 200
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Apr 18 19:40:57 UTC 2024 - 24.6K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/AbstractCrawlerClientTest.java
}; ResponseData responseData = new ResponseData(); responseData.setUrl("http://test.com/"); client.setMaxContentLength(1000000L); client.checkMaxContentLength(responseData); responseData.setContentLength(-1); client.checkMaxContentLength(responseData); responseData.setContentLength(1000L); client.checkMaxContentLength(responseData);
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 3K bytes - Viewed (0) -
cmd/etcd.go
} func saveKeyEtcd(ctx context.Context, client *etcd.Client, key string, data []byte, opts ...options) error { timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() if len(opts) > 0 { return saveKeyEtcdWithTTL(ctx, client, key, data, opts[0].ttl) } _, err := client.Put(timeoutCtx, key, string(data)) etcdLogIf(ctx, err) return etcdErrToErr(err, client.Endpoints()) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 2.9K bytes - Viewed (0)