- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 72 for newClient (0.18 sec)
-
okhttp/src/test/java/okhttp3/CallKotlinTest.kt
@JvmField @RegisterExtension val clientTestRule = OkHttpClientTestRule().apply { recordFrames = true recordSslDebug = true } private var client = clientTestRule.newClient() private val handshakeCertificates = platform.localhostHandshakeCertificates() private lateinit var server: MockWebServer @BeforeEach fun setUp(server: MockWebServer) { this.server = server }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 8.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
import org.junit.jupiter.api.extension.RegisterExtension @Timeout(30) @Tag("Slow") class WholeOperationTimeoutTest { @RegisterExtension val clientTestRule = OkHttpClientTestRule() private val client = clientTestRule.newClient() private lateinit var server: MockWebServer @BeforeEach fun setUp(server: MockWebServer) { this.server = server } @Test fun defaultConfigIsNoTimeout() { val request =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
config.QPS = 80 config.Burst = 160 }) if err != nil { return nil, fmt.Errorf("failed creating kube config: %v", err) } client, err := kube.NewClient(kube.NewClientConfigForRestConfig(kubeRestConfig), "") if err != nil { return nil, fmt.Errorf("failed creating kube client: %v", err) } return client, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CookiesTest.kt
@Timeout(30) class CookiesTest { @RegisterExtension val clientTestRule = OkHttpClientTestRule() private lateinit var server: MockWebServer private var client = clientTestRule.newClient() @BeforeEach fun setUp(server: MockWebServer) { this.server = server } @Test fun testNetscapeResponse() { val cookieManager = CookieManager(null, CookiePolicy.ACCEPT_ORIGINAL_SERVER)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 13K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics.go
} printMetrics(c.OutOrStdout(), sm) } return nil } func prometheusAPI(address string) (promv1.API, error) { promClient, err := api.NewClient(api.Config{Address: address}) if err != nil { return nil, fmt.Errorf("could not build prometheus client: %v", err) } return promv1.NewAPI(promClient), nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 8.4K bytes - Viewed (0) -
pkg/test/loadbalancersim/lb_test.go
topology: topologyCase.name, } sm = append(sm, tm) // Create the clients. for i := 0; i < numClients; i++ { _ = m.NewClient(mesh.ClientSettings{ RPS: clientRPS, Locality: sameZone, }) } // Allocate the nodes in the configured topology.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 19 23:29:30 UTC 2022 - 11K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/fallback_query_param_verifier_test.go
Group: "", Version: "v1", Kind: "List", }, queryParam: QueryParamFieldValidation, expectedSupports: false, }, } root := openapi3.NewRoot(cached.NewClient(openapitest.NewEmbeddedFileClient())) for tn, tc := range tests { t.Run(tn, func(t *testing.T) { primary := createFakeV3Verifier(tc.crds, root, tc.queryParam) // secondary verifier should not be called.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 10 18:30:16 UTC 2023 - 10.3K bytes - Viewed (0) -
pkg/kubelet/winstats/perfcounter_nodestats.go
const allProcessorGroups = 0xFFFF // NewPerfCounterClient creates a client using perf counters func NewPerfCounterClient() (Client, error) { // Initialize the cache initCache := cpuUsageCoreNanoSecondsCache{0, 0} return newClient(&perfCounterNodeStatsClient{ cpuUsageCoreNanoSecondsCache: initCache, }) } // perfCounterNodeStatsClient is a client that provides Windows Stats via PerfCounters type perfCounterNodeStatsClient struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 26 18:37:21 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/bootstrap/platform/gcp.go
success <- false return } url := fmt.Sprintf("https://compute.googleapis.com/compute/v1/projects/%s/zones/%s/instances/%s", md[GCPProject], md[GCPLocation], md[GCEInstance]) resp, err := oauth2.NewClient(ctx, creds.TokenSource).Get(url) if err != nil { log.Warnf("unable to retrieve instance labels: %v", err) success <- false return } defer resp.Body.Close() instance := &GcpInstance{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 15 00:37:33 UTC 2023 - 11.1K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
h.config = sconfig var brokers []string for _, broker := range h.kconfig.Brokers { brokers = append(brokers, broker.String()) } client, err := sarama.NewClient(brokers, sconfig) if err != nil { return err } producer, err := sarama.NewSyncProducerFromClient(client) if err != nil { return err } h.client = client h.producer = producer
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K bytes - Viewed (0)