- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for TestRequest (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/filterlatency/filterlatency_test.go
filterCompletedAtGot = completedAt }) testRequest, err := http.NewRequest(http.MethodGet, "/api/v1/namespaces", nil) if err != nil { t.Fatalf("failed to create new http request - %v", err) } testRequest = testRequest.WithContext(withRequestFilterRecord(testRequest.Context(), &requestFilterRecord{})) w := httptest.NewRecorder() wrapped.ServeHTTP(w, testRequest) if handlerCallCount != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 7.1K bytes - Viewed (0) -
container-tests/src/test/java/okhttp3/containers/BasicProxyTest.kt
@Test fun testUrlConnectionDirect() { testRequest { val url = URI(mockServer.endpoint + "/person?name=peter").toURL() val connection = url.openConnection() as HttpURLConnection assertThat(connection.inputStream.source().buffer().readUtf8()).contains("Peter the person") } } @Test fun testUrlConnectionPlaintextProxied() { testRequest { val proxy = Proxy(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 5.9K bytes - Viewed (0) -
internal/grid/grid_types_test.go
package grid //go:generate msgp -unexported -file=$GOFILE -tests=false -o=grid_types_msgp_test.go type testRequest struct { Num int String string } type testResponse struct { OrgNum int OrgString string Embedded testRequest } func newTestRequest() *testRequest { return &testRequest{} } func newTestResponse() *testResponse { return &testResponse{}
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 1.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/request_received_time_test.go
wrapped := withRequestReceivedTimestampWithClock(handler, testingclock.NewFakeClock(receivedTimestampExpected)) testRequest, err := http.NewRequest(http.MethodGet, "/api/v1/namespaces", nil) if err != nil { t.Fatalf("failed to create new http request - %v", err) } w := httptest.NewRecorder() wrapped.ServeHTTP(w, testRequest) if callCount != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 2K bytes - Viewed (0) -
internal/grid/grid_types_msgp_test.go
package grid // Code generated by github.com/tinylib/msgp DO NOT EDIT. import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *testRequest) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 8.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/audit_init_test.go
} testRequest, err := http.NewRequest(http.MethodGet, "/api/v1/namespaces", nil) if err != nil { t.Fatalf("failed to create new http request - %v", err) } if len(test.auditIDSpecified) > 0 { testRequest.Header.Set(auditKey, test.auditIDSpecified) } w := httptest.NewRecorder() wrapped.ServeHTTP(w, testRequest) if innerHandlerCallCount != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 14 23:04:35 UTC 2022 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/cachecontrol_test.go
//do nothing }) wrapped := WithCacheControl(handler) testRequest, err := http.NewRequest(http.MethodGet, test.path, nil) if err != nil { t.Fatal(err) } w := httptest.NewRecorder() if len(test.startingHeader) > 0 { w.Header().Set("Cache-Control", test.startingHeader) } wrapped.ServeHTTP(w, testRequest) actual := w.Header().Get("Cache-Control")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 26 17:00:31 UTC 2019 - 1.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/LoomTest.kt
} private fun newVirtualThreadPerTaskExecutor(): ExecutorService { return Executors::class.java.getMethod("newVirtualThreadPerTaskExecutor").invoke(null) as ExecutorService } @Test fun testRequest() { server.enqueue(MockResponse()) val request = Request(server.url("/")) client.newCall(request).execute().use { assertThat(it.code).isEqualTo(200) } } @Test
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
container-tests/src/test/java/okhttp3/containers/BasicMockServerTest.kt
@Container val mockServer: MockServerContainer = MockServerContainer(MOCKSERVER_IMAGE) val client = OkHttpClient.Builder() .trustMockServer() .build() @Test fun testRequest() { MockServerClient(mockServer.host, mockServer.serverPort).use { mockServerClient -> mockServerClient .`when`( request().withPath("/person")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 3.3K bytes - Viewed (0) -
okhttp-android/src/androidTest/kotlin/okhttp3/android/AndroidAsyncDnsTest.kt
.build() serverRule.server.useHttps(localhost.sslSocketFactory()) } @Test @Ignore("java.net.UnknownHostException: No results for localhost, in CI.") fun testRequest() { serverRule.server.enqueue(MockResponse()) val call = client.newCall(Request(serverRule.server.url("/"))) call.execute().use { response -> assertThat(response.code).isEqualTo(200) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.7K bytes - Viewed (0)