- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 176 for CLIENT (0.12 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
) server.enqueue( MockResponse(body = "Successful auth!"), ) val credential = basic("username", "password") client = client.newBuilder() .authenticator(RecordingOkAuthenticator(credential, "Basic")) .build() val call = client.newCall(Request(server.url("/"))) val response = call.execute() assertThat(response.body.string()).isEqualTo("Successful auth!")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
staging/publishing/rules.yaml
dirs: - staging/src/k8s.io/api library: true - destination: client-go branches: - name: master dependencies: - repository: apimachinery branch: master - repository: api branch: master source: branch: master dirs: - staging/src/k8s.io/client-go smoke-test: | # assumes GO111MODULE=on go build -mod=mod ./...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 09:33:40 UTC 2024 - 57.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
.build(), ) server.enqueue(MockResponse()) val dns = FakeDns() dns["fakeurl"] = client.dns.lookup(server.hostName) dns["www.fakeurl"] = client.dns.lookup(server.hostName) client = client.newBuilder() .dns(dns) .build() val call = client.newCall( Request.Builder() .url("http://fakeurl:" + server.port) .build(), )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 56.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
public EngineInfo getEngineInfo() { if (client instanceof final HttpClient httpClient) { return httpClient.getEngineInfo(); } throw new SearchEngineClientException("client is not HttpClient."); } // // Fesen Client // @Override public ThreadPool threadPool() { return client.threadPool(); } @Override
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 84.1K bytes - Viewed (0) -
cmd/sts-handlers_test.go
Secure: s.secure, Transport: s.TestSuiteCommon.client.Transport, }) if err != nil { c.Fatalf("Error initializing client: %v", err) } // Validate that the client from sts creds can access the bucket. c.mustListObjects(ctx, minioClient, bucket) // Create an madmin client with user creds userAdmClient, err := madmin.NewWithOptions(s.endpoint, &madmin.Options{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 18:45:50 UTC 2024 - 90K bytes - Viewed (0) -
src/crypto/tls/handshake_client_test.go
}() go func() { defer close(doneChan) config := test.config if config == nil { config = testConfig } client := Client(clientConn, config) defer client.Close() if _, err := client.Write([]byte("hello\n")); err != nil { t.Errorf("Client.Write failed: %s", err) return } for i := 1; i <= test.numRenegotiations; i++ { // The initial handshake will generate a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 88.7K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/options_test.go
"--cluster-signing-kubelet-client-cert-file=/cluster-signing-kubelet-client/cert-file", "--cluster-signing-kubelet-client-key-file=/cluster-signing-kubelet-client/key-file", "--cluster-signing-kube-apiserver-client-cert-file=/cluster-signing-kube-apiserver-client/cert-file", "--cluster-signing-kube-apiserver-client-key-file=/cluster-signing-kube-apiserver-client/key-file",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 02:59:09 UTC 2024 - 55.1K bytes - Viewed (0) -
src/net/http/client_test.go
defer afterTest(t) tr := &recordingTransport{} client := &Client{Transport: tr} client.Jar = &TestJar{perURL: make(map[string][]*Cookie)} us := "http://dummy.faketld/" u, _ := url.Parse(us) client.Jar.SetCookies(u, expectedCookies) client.Get(us) // Note: doesn't hit network matchReturnedCookies(t, expectedCookies, tr.req.Cookies()) client.Head(us) // Note: doesn't hit network
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
"k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/intstr" "k8s.io/apimachinery/pkg/util/rand" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" k8stesting "k8s.io/client-go/testing" "k8s.io/client-go/tools/cache" "k8s.io/endpointslice/topologycache" endpointsliceutil "k8s.io/endpointslice/util" "k8s.io/klog/v2/ktesting" "k8s.io/kubernetes/pkg/controller"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
src/crypto/tls/handshake_server_test.go
serverConn = &recordingConn{Conn: serverConn} go func() { config := testConfig.Clone() config.MaxVersion = version config.CurvePreferences = []CurveID{curve} client := Client(clientConn, config) client.Handshake() }() server := Server(serverConn, config) if err := server.Handshake(); err != nil { b.Fatalf("handshake failed: %v", err) } serverConn.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 64.7K bytes - Viewed (0)