- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 559 for clientv3 (0.17 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)