Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 559 for clientv3 (0.17 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/sts/client-grants.go

    }
    
    var (
    	stsEndpoint  string
    	idpEndpoint  string
    	clientID     string
    	clientSecret string
    )
    
    func init() {
    	flag.StringVar(&stsEndpoint, "sts-ep", "http://localhost:9000", "STS endpoint")
    	flag.StringVar(&idpEndpoint, "idp-ep", "http://localhost:8080/auth/realms/minio/protocol/openid-connect/token", "IDP token endpoint")
    	flag.StringVar(&clientID, "cid", "", "Client ID")
    	flag.StringVar(&clientSecret, "csec", "", "Client secret")
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 3.3K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. samples/guide/src/main/java/okhttp3/recipes/PerCallSettings.java

        try (Response response = client1.newCall(request).execute()) {
          System.out.println("Response 1 succeeded: " + response);
        } catch (IOException e) {
          System.out.println("Response 1 failed: " + e);
        }
    
        // Copy to customize OkHttp for this request.
        OkHttpClient client2 = client.newBuilder()
            .readTimeout(3000, TimeUnit.MILLISECONDS)
            .build();
        try (Response response = client2.newCall(request).execute()) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun May 22 01:29:42 UTC 2016
    - 1.9K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top