Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 431 for clientv3 (0.07 sec)

  1. internal/config/etcd/etcd.go

    	Enabled     bool   `json:"enabled"`
    	PathPrefix  string `json:"pathPrefix"`
    	CoreDNSPath string `json:"coreDNSPath"`
    	clientv3.Config
    }
    
    // New - initialize new etcd client.
    func New(cfg Config) (*clientv3.Client, error) {
    	if !cfg.Enabled {
    		return nil, nil
    	}
    	cli, err := clientv3.New(cfg.Config)
    	if err != nil {
    		return nil, err
    	}
    	cli.KV = namespace.NewKV(cli.KV, cfg.PathPrefix)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 23:17:22 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  2. internal/config/dns/etcd_dns.go

    type CoreDNS struct {
    	domainNames []string
    	domainIPs   set.StringSet
    	domainPort  string
    	prefixPath  string
    	etcdClient  *clientv3.Client
    }
    
    // EtcdOption - functional options pattern style
    type EtcdOption func(*CoreDNS)
    
    // DomainNames set a list of domain names used by this CoreDNS
    // client setting, note this will fail if set to empty when
    // constructor initializes.
    func DomainNames(domainNames []string) EtcdOption {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 8K bytes
    - Viewed (0)
  3. docs/en/docs/advanced/generate-clients.md

    ```console
    $ npm run generate-client
    
    frontend-app@1.0.0 generate-client /home/user/code/frontend-app
    > openapi-ts --input http://localhost:8000/openapi.json --output ./src/client --client axios
    ```
    
    </div>
    
    That command will generate code in `./src/client` and will use `axios` (the frontend HTTP library) internally.
    
    ### Try Out the Client Code
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  4. docs/pt/docs/tutorial/handling-errors.md

    Há diversas situações em que você precisa notificar um erro a um cliente que está utilizando a sua API.
    
    Esse cliente pode ser um browser com um frontend, o código de outra pessoa, um dispositivo IoT, etc.
    
    Pode ser que você precise comunicar ao cliente que:
    
    * O cliente não tem direitos para realizar aquela operação.
    * O cliente não tem acesso aquele recurso.
    * O item que o cliente está tentando acessar não existe.
    * etc.
    
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10K bytes
    - Viewed (0)
  5. samples/guide/src/main/java/okhttp3/recipes/kt/PerCallSettings.kt

          client1.newCall(request).execute().use { response ->
            println("Response 1 succeeded: $response")
          }
        } catch (e: IOException) {
          println("Response 1 failed: $e")
        }
    
        // Copy to customize OkHttp for this request.
        val client2 =
          client.newBuilder()
            .readTimeout(3000, TimeUnit.MILLISECONDS)
            .build()
        try {
          client2.newCall(request).execute().use { response ->
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  6. samples/tlssurvey/src/main/kotlin/okhttp3/survey/Clients.kt

    import javax.net.ssl.SSLSocketFactory
    import okhttp3.ConnectionSpec
    import okhttp3.OkHttp
    import okhttp3.survey.types.Client
    import okhttp3.survey.types.SuiteId
    import okio.FileSystem
    import okio.Path.Companion.toPath
    import org.conscrypt.Conscrypt
    
    fun currentOkHttp(ianaSuites: IanaSuites): Client {
      return Client(
        userAgent = "OkHttp",
        version = OkHttp.VERSION,
        enabled =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Apr 02 01:44:15 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/OkHttpClientTest.kt

      }
    
      @Test fun durationDefaults() {
        val client = clientTestRule.newClient()
        assertThat(client.callTimeoutMillis).isEqualTo(0)
        assertThat(client.connectTimeoutMillis).isEqualTo(10000)
        assertThat(client.readTimeoutMillis).isEqualTo(10000)
        assertThat(client.writeTimeoutMillis).isEqualTo(10000)
        assertThat(client.pingIntervalMillis).isEqualTo(0)
        assertThat(client.webSocketCloseTimeout).isEqualTo(60_000)
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

              call: Call,
              e: IOException,
            ) {
              fail("")
            }
          },
        )
        val client2 =
          client.newBuilder()
            .eventListenerFactory(clientTestRule.wrap(request2Listener))
            .build()
        val call2 = client2.newCall(request)
        val response = call2.execute()
        assert200Http2Response(response, "san.com")
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  9. internal/rest/client.go

    func (n *NetworkError) Unwrap() error {
    	return n.Err
    }
    
    // Client - http based RPC client.
    type Client struct {
    	connected int32 // ref: https://golang.org/pkg/sync/atomic/#pkg-note-BUG
    	_         int32 // For 64 bits alignment
    	lastConn  int64
    
    	// HealthCheckFn is the function set to test for health.
    	// If not set the client will not keep track of health.
    	// Calling this returns true or false if the target
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  10. samples/tlssurvey/src/main/kotlin/okhttp3/survey/types/Client.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.survey.types
    
    data class Client(
      val userAgent: String,
      val version: String,
      val platform: String? = null,
      val enabled: List<SuiteId> = listOf(),
      val supported: List<SuiteId> = listOf(),
    ) {
      val nameAndVersion: String
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Apr 02 01:44:15 UTC 2024
    - 883 bytes
    - Viewed (0)
Back to top