- Sort Score
- Result 10 results
- Languages All
Results 61 - 66 of 66 for newClient (0.15 sec)
-
operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go
// and Start it when the Manager is Started. It also provides additional options to modify internal reconciler behavior. func Add(mgr manager.Manager, options *Options) error { restConfig = mgr.GetConfig() kubeClient, err := kube.NewClient(kube.NewClientConfigForRestConfig(restConfig), "") if err != nil { return fmt.Errorf("create Kubernetes client: %v", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 19.4K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt
@RegisterExtension public val clientTestRule = OkHttpClientTestRule().apply { logger = Logger.getLogger(OkHttpTest::class.java.name) } private var client: OkHttpClient = clientTestRule.newClient() private val moshi = Moshi.Builder() .add(KotlinJsonAdapterFactory()) .build() private val handshakeCertificates = localhost() private lateinit var server: MockWebServer
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 27K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/InterceptorTest.kt
@Tag("Slow") class InterceptorTest { @RegisterExtension val clientTestRule = OkHttpClientTestRule() private lateinit var server: MockWebServer private var client = clientTestRule.newClient() private val callback = RecordingCallback() @BeforeEach fun setUp(server: MockWebServer) { this.server = server } @Test fun applicationInterceptorsCanShortCircuitResponses() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 27.8K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
config.Burst = args.RegistryOptions.KubeOptions.KubernetesAPIBurst }) if err != nil { return fmt.Errorf("failed creating kube config: %v", err) } s.kubeClient, err = kubelib.NewClient(kubelib.NewClientConfigForRestConfig(kubeRestConfig), s.clusterID) if err != nil { return fmt.Errorf("failed creating kube client: %v", err) } s.kubeClient = kubelib.EnableCrdWatcher(s.kubeClient) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
private lateinit var server: MockWebServer private lateinit var server2: MockWebServer private val handshakeCertificates = platform.localhostHandshakeCertificates() private var client = clientTestRule.newClient() private var cache: Cache? = null @BeforeEach fun setUp( server: MockWebServer, @MockWebServerInstance("server2") server2: MockWebServer, ) { this.server = server
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 131.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go
{"DefaultRPCPath", Const, 0}, {"DefaultServer", Var, 0}, {"Dial", Func, 0}, {"DialHTTP", Func, 0}, {"DialHTTPPath", Func, 0}, {"ErrShutdown", Var, 0}, {"HandleHTTP", Func, 0}, {"NewClient", Func, 0}, {"NewClientWithCodec", Func, 0}, {"NewServer", Func, 0}, {"Register", Func, 0}, {"RegisterName", Func, 0}, {"Request", Type, 0}, {"Request.Seq", Field, 0},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 534.2K bytes - Viewed (0)