Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for NewClient (0.05 sec)

  1. internal/dsync/dsync-client_test.go

    type ReconnectRESTClient struct {
    	u    *url.URL
    	rest *rest.Client
    }
    
    // newClient constructs a ReconnectRESTClient object with addr and endpoint initialized.
    // It _doesn't_ connect to the remote endpoint. See Call method to see when the
    // connect happens.
    func newClient(endpoint string) NetLocker {
    	u, err := url.Parse(endpoint)
    	if err != nil {
    		panic(err)
    	}
    
    	tr := &http.Transport{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  2. cmd/warm-backend-azure.go

    		return errors.New("no authentication mechanism was provided")
    	}
    
    	if conf.Bucket == "" {
    		return errors.New("no bucket name was provided")
    	}
    
    	return nil
    }
    
    func (conf azureConf) NewClient() (clnt *azblob.Client, clntErr error) {
    	if err := conf.Validate(); err != nil {
    		return nil, err
    	}
    
    	ep := conf.Endpoint
    	if ep == "" {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 7K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/BouncyCastleTest.kt

    class BouncyCastleTest {
      @JvmField @RegisterExtension
      var platform = PlatformRule()
    
      @JvmField @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
      var client = clientTestRule.newClient()
    
      @StartStop
      private val server = MockWebServer()
    
      @BeforeEach
      fun setUp() {
        OkHttpDebugLogging.enable("org.bouncycastle.jsse")
        platform.assumeBouncyCastle()
      }
    
      @Test
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/OpenJSSETest.kt

    class OpenJSSETest {
      @JvmField @RegisterExtension
      var platform = PlatformRule()
    
      @JvmField @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
    
      var client = clientTestRule.newClient()
    
      @StartStop
      private val server = MockWebServer()
    
      @BeforeEach
      fun setUp() {
        platform.assumeOpenJSSE()
      }
    
      @Test
      fun testTlsv13Works() {
        enableTls()
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/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: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/java/okhttp3/CallJavaTest.java

    import static org.junit.jupiter.api.Assertions.assertEquals;
    
    public class CallJavaTest {
      @RegisterExtension
      OkHttpClientTestRule clientTestRule = new OkHttpClientTestRule();
    
      private OkHttpClient client = clientTestRule.newClient();
    
      @Test
      public void tagsSeededFromRequest() {
        Request request = new Request.Builder()
          .url(HttpUrl.get("https://square.com/"))
          .tag(Integer.class, 5)
          .tag(String.class, "hello")
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Oct 26 14:54:46 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/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: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  8. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt

      @StartStop
      private val server = MockWebServer()
    
      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
    
      private val listener = EventSourceRecorder()
      private val client = clientTestRule.newClient()
    
      @AfterEach
      fun after() {
        listener.assertExhausted()
      }
    
      @Test
      fun processResponse() {
        server.enqueue(
          MockResponse
            .Builder()
            .body(
              """
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Oct 03 07:51:20 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/CallTagsTest.kt

    import org.junit.jupiter.api.extension.RegisterExtension
    
    class CallTagsTest {
      @JvmField @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
    
      private var client = clientTestRule.newClient()
    
      @Test
      fun tagsSeededFromRequest() {
        val request =
          Request
            .Builder()
            .url("https://square.com/".toHttpUrl())
            .tag(Integer::class, 5 as Integer)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Oct 26 14:54:46 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/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: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 4.3K bytes
    - Viewed (0)
Back to top