- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 70 for newClient (0.35 sec)
-
pkg/tracing/tracing.go
proto = os.Getenv("OTEL_EXPORTER_OTLP_PROTOCOL") } if proto == "" { proto = "grpc" } var c otlptrace.Client switch proto { case "grpc": c = otlptracegrpc.NewClient() case "http/protobuf": c = otlptracehttp.NewClient() // case "http/json": // unsupported by library default: return nil, fmt.Errorf("unsupported otlp protocol %v", proto) } return otlptrace.New(context.Background(), c) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jul 26 01:07:39 UTC 2023 - 3.9K bytes - Viewed (0) -
pkg/kubelet/winstats/winstats.go
// startTime is the time when the node was started startTime time.Time } type cpuUsageCoreNanoSecondsCache struct { latestValue uint64 previousValue uint64 } // newClient constructs a Client. func newClient(statsNodeClient winNodeStatsClient) (Client, error) { statsClient := new(StatsClient) statsClient.client = statsNodeClient err := statsClient.client.startMonitoring() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 5.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
import org.junit.jupiter.api.extension.ExtensionContext /** * Apply this rule to all tests. It adds additional checks for leaked resources and uncaught * exceptions. * * Use [newClient] as a factory for a OkHttpClient instances. These instances are specifically * configured for testing. */ class OkHttpClientTestRule : BeforeEachCallback, AfterEachCallback {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/BouncyCastleTest.kt
class BouncyCastleTest { @JvmField @RegisterExtension var platform = PlatformRule() @JvmField @RegisterExtension val clientTestRule = OkHttpClientTestRule() var client = clientTestRule.newClient() private lateinit var server: MockWebServer @BeforeEach fun setUp(server: MockWebServer) { this.server = server OkHttpDebugLogging.enable("org.bouncycastle.jsse") platform.assumeBouncyCastle()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CorrettoTest.kt
class CorrettoTest { @JvmField @RegisterExtension val platform = PlatformRule() @JvmField @RegisterExtension val clientTestRule = OkHttpClientTestRule() private val client = clientTestRule.newClient() @BeforeEach fun setUp() { platform.assumeCorretto() } @Test @Disabled fun testMozilla() { assumeNetwork()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.1K bytes - Viewed (0) -
cni/pkg/repair/repair.go
func clientSetup() (kube.Client, error) { config, err := kube.DefaultRestConfig("", "") if err != nil { return nil, err } return kube.NewClient(kube.NewClientConfigForRestConfig(config), "")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 1.5K bytes - Viewed (0) -
pkg/test/loadbalancersim/mesh/mesh.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 27 20:55:37 UTC 2022 - 2.3K bytes - Viewed (0) -
src/net/rpc/jsonrpc/all_test.go
} } } func TestClient(t *testing.T) { // Assume server is okay (TestServer is above). // Test client against server. cli, srv := net.Pipe() go ServeConn(srv) client := NewClient(cli) defer client.Close() // Synchronous calls args := &Args{7, 8} reply := new(Reply) err := client.Call("Arith.Add", args, reply) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 07 01:09:53 UTC 2022 - 7.8K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt
private lateinit var server: MockWebServer @RegisterExtension val clientTestRule = OkHttpClientTestRule() private val listener = EventSourceRecorder() private val client = clientTestRule.newClient() @BeforeEach fun before(server: MockWebServer) { this.server = server } @AfterEach fun after() { listener.assertExhausted() } @Test fun processResponse() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/RetryConnectionTest.kt
private val retryableException = SSLHandshakeException("Simulated handshake exception") @RegisterExtension val clientTestRule = OkHttpClientTestRule() private var client = clientTestRule.newClient() @AfterEach internal fun tearDown() { factory.close() } @Test fun nonRetryableIOException() { val exception = IOException("Non-handshake exception")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.3K bytes - Viewed (0)