- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 20 for newClient (0.17 sec)
-
okhttp/src/test/java/okhttp3/ConscryptTest.kt
class ConscryptTest { @JvmField @RegisterExtension val platform = PlatformRule() @JvmField @RegisterExtension val clientTestRule = OkHttpClientTestRule() private val client = clientTestRule.newClient() @BeforeEach fun setUp() { platform.assumeConscrypt() } @Test fun testTrustManager() { assertThat(Conscrypt.isConscrypt(Platform.get().platformTrustManager())).isTrue() } @Test
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/JSSETest.kt
@JvmField @RegisterExtension val clientTestRule = OkHttpClientTestRule() private val handshakeCertificates = platform.localhostHandshakeCertificates() var client = clientTestRule.newClient() private lateinit var server: MockWebServer @BeforeEach fun setUp(server: MockWebServer) { this.server = server // Default after JDK 14, but we are avoiding tests that assume special setup.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 5.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SessionReuseTest.kt
@JvmField @RegisterExtension val clientTestRule = OkHttpClientTestRule() private val handshakeCertificates = platform.localhostHandshakeCertificates() var client = clientTestRule.newClient() private lateinit var server: MockWebServer @BeforeEach fun setUp(server: MockWebServer) { this.server = server // Default after JDK 14, but we are avoiding tests that assume special setup.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 6K bytes - Viewed (0) -
pkg/test/framework/components/prometheus/kube.go
scopes.Framework.Debugf("initialized Prometheus port forwarder: %v", forwarder.Address()) address := fmt.Sprintf("http://%s", forwarder.Address()) var client prometheusApi.Client client, err = prometheusApi.NewClient(prometheusApi.Config{Address: address}) if err != nil { return nil, err } c.api[cls.Name()] = prometheusApiV1.NewAPI(client) } return c, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
} credsJSON, err := conf.GetCredentialJSON() if err != nil { return nil, err } clnt := &http.Client{ Transport: globalRemoteTargetTransport, } client, err := storage.NewClient(context.Background(), option.WithCredentialsJSON(credsJSON), option.WithScopes(storage.ScopeReadWrite), option.WithHTTPClient(clnt), option.WithUserAgent(fmt.Sprintf("gcs-tier-%s", tier)+SlashSeparator+ReleaseTag),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Apr 21 11:43:18 UTC 2024 - 5.9K bytes - Viewed (0) -
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) -
internal/event/target/mqtt.go
SetMaxReconnectInterval(args.MaxReconnectInterval). SetKeepAlive(args.KeepAlive). SetTLSConfig(&tls.Config{RootCAs: args.RootCAs}). AddBroker(args.Broker.String()) target.client = mqtt.NewClient(options) token := target.client.Connect() ok := token.WaitTimeout(reconnectInterval) if !ok { return store.ErrNotConnected } if token.Error() != nil { return token.Error() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.2K 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) -
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/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)