Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 34 of 34 for newClient (0.07 seconds)

  1. internal/event/target/elasticsearch.go

    	}
    	// Set basic auth
    	if args.Username != "" && args.Password != "" {
    		elasticConfig.Username = args.Username
    		elasticConfig.Password = args.Password
    	}
    	// Create a client
    	client, err := elasticsearch7.NewClient(elasticConfig)
    	if err != nil {
    		return nil, err
    	}
    	clientV7 := &esClientV7{client}
    	return clientV7, nil
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt

    @Tag("Slow")
    class InterceptorTest {
      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
    
      @StartStop
      private val server = MockWebServer()
    
      private var client = clientTestRule.newClient()
      private val callback = RecordingCallback()
    
      @Test
      fun applicationInterceptorsCanShortCircuitResponses() {
        server.close() // Accept no connections.
        val request =
          Request
            .Builder()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 16:11:23 GMT 2025
    - 28.2K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

      @StartStop
      val server = MockWebServer()
    
      @StartStop
      val server2 = MockWebServer()
    
      private val handshakeCertificates = platform.localhostHandshakeCertificates()
      private var client = clientTestRule.newClient()
      private var cache: Cache? = null
    
      @BeforeEach
      fun setUp() {
        server.protocolNegotiationEnabled = false
      }
    
      @AfterEach
      fun tearDown() {
        java.net.Authenticator.setDefault(null)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Jun 21 20:36:35 GMT 2025
    - 133.2K bytes
    - Click Count (0)
  4. api/go1.txt

    pkg net/rpc, func DialHTTP(string, string) (*Client, error)
    pkg net/rpc, func DialHTTPPath(string, string, string) (*Client, error)
    pkg net/rpc, func HandleHTTP()
    pkg net/rpc, func NewClient(io.ReadWriteCloser) *Client
    pkg net/rpc, func NewClientWithCodec(ClientCodec) *Client
    pkg net/rpc, func NewServer() *Server
    pkg net/rpc, func Register(interface{}) error
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Aug 14 18:58:28 GMT 2013
    - 1.7M bytes
    - Click Count (0)
Back to Top