- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 66 for newClient (0.12 sec)
-
pkg/test/framework/components/prometheus/kube.go
scopes.Framework.Debugf("initialized Prometheus port forwarder: %v", forwarder.Address()) address := fmt.Sprintf("http://%s", forwarder.Address()) var client prometheusApi.Client client, err = prometheusApi.NewClient(prometheusApi.Config{Address: address}) if err != nil { return nil, err } c.api[cls.Name()] = prometheusApiV1.NewAPI(client) } return c, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.3K bytes - Viewed (0) -
internal/rest/client.go
} return resp.Body, nil } // Close closes all idle connections of the underlying http client func (c *Client) Close() { atomic.StoreInt32(&c.connected, closed) } // NewClient - returns new REST client. func NewClient(uu *url.URL, tr http.RoundTripper, newAuthToken func(aud string) string) *Client { connected := int32(online) urlStr := uu.String() u, err := url.Parse(urlStr) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.4K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/query_param_verifier_v3_test.go
Group: "", Version: "v1", Kind: "List", }, queryParam: QueryParamFieldValidation, expectedSupports: false, }, } root := openapi3.NewRoot(cached.NewClient(openapitest.NewEmbeddedFileClient())) for tn, tc := range tests { t.Run(tn, func(t *testing.T) { verifier := &queryParamVerifierV3{ finder: NewCRDFinder(func() ([]schema.GroupKind, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 12 04:44:45 UTC 2023 - 5.9K bytes - Viewed (0) -
pilot/pkg/model/network.go
} type nameCacheEntry struct { value []string expiry time.Time timer *time.Timer } func newNetworkGatewayNameCache() (*networkGatewayNameCache, error) { c, err := newClient() if err != nil { return nil, err } return newNetworkGatewayNameCacheWithClient(c), nil } // newNetworkGatewayNameCacheWithClient exported for test
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 16.9K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
} credsJSON, err := conf.GetCredentialJSON() if err != nil { return nil, err } clnt := &http.Client{ Transport: globalRemoteTargetTransport, } client, err := storage.NewClient(context.Background(), option.WithCredentialsJSON(credsJSON), option.WithScopes(storage.ScopeReadWrite), option.WithHTTPClient(clnt), option.WithUserAgent(fmt.Sprintf("gcs-tier-%s", tier)+SlashSeparator+ReleaseTag),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Apr 21 11:43:18 UTC 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallKotlinTest.kt
@JvmField @RegisterExtension val clientTestRule = OkHttpClientTestRule().apply { recordFrames = true recordSslDebug = true } private var client = clientTestRule.newClient() private val handshakeCertificates = platform.localhostHandshakeCertificates() private lateinit var server: MockWebServer @BeforeEach fun setUp(server: MockWebServer) { this.server = server }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 8.4K bytes - Viewed (0) -
internal/event/target/mqtt.go
SetMaxReconnectInterval(args.MaxReconnectInterval). SetKeepAlive(args.KeepAlive). SetTLSConfig(&tls.Config{RootCAs: args.RootCAs}). AddBroker(args.Broker.String()) target.client = mqtt.NewClient(options) token := target.client.Connect() ok := token.WaitTimeout(reconnectInterval) if !ok { return store.ErrNotConnected } if token.Error() != nil { return token.Error() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
import org.junit.jupiter.api.extension.RegisterExtension @Timeout(30) @Tag("Slow") class WholeOperationTimeoutTest { @RegisterExtension val clientTestRule = OkHttpClientTestRule() private val client = clientTestRule.newClient() private lateinit var server: MockWebServer @BeforeEach fun setUp(server: MockWebServer) { this.server = server } @Test fun defaultConfigIsNoTimeout() { val request =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
config.QPS = 80 config.Burst = 160 }) if err != nil { return nil, fmt.Errorf("failed creating kube config: %v", err) } client, err := kube.NewClient(kube.NewClientConfigForRestConfig(kubeRestConfig), "") if err != nil { return nil, fmt.Errorf("failed creating kube client: %v", err) } return client, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CookiesTest.kt
@Timeout(30) class CookiesTest { @RegisterExtension val clientTestRule = OkHttpClientTestRule() private lateinit var server: MockWebServer private var client = clientTestRule.newClient() @BeforeEach fun setUp(server: MockWebServer) { this.server = server } @Test fun testNetscapeResponse() { val cookieManager = CookieManager(null, CookiePolicy.ACCEPT_ORIGINAL_SERVER)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 13K bytes - Viewed (0)