- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for httpclient (0.18 sec)
-
internal/event/targetid_test.go
testCases := []struct { tid TargetID expectedResult string }{ {TargetID{}, ":"}, {TargetID{"1", "webhook"}, "1:webhook"}, {TargetID{"httpclient+2e33cdee-fbec-4bdd-917e-7d8e3c5a2531", "localhost:55638"}, "httpclient+2e33cdee-fbec-4bdd-917e-7d8e3c5a2531:localhost:55638"}, } for i, testCase := range testCases { result := testCase.tid.String() if result != testCase.expectedResult {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 3.5K bytes - Viewed (0) -
internal/config/dns/operator_dns.go
if err != nil { return newError(bucket, err) } if err = c.addAuthHeader(req); err != nil { return newError(bucket, err) } resp, err := c.httpClient.Do(req) if err != nil { if derr := c.Delete(bucket); derr != nil { return newError(bucket, derr) } return err } defer xhttp.DrainBody(resp.Body) if resp.StatusCode != http.StatusOK {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 6.6K bytes - Viewed (0) -
internal/event/target/webhook.go
} return nil } // WebhookTarget - Webhook target. type WebhookTarget struct { initOnce once.Init id event.TargetID args WebhookArgs transport *http.Transport httpClient *http.Client store store.Store[event.Event] loggerOnce logger.LogOnce cancel context.CancelFunc cancelCh <-chan struct{} addr string // full address ip/dns with a port number, e.g. x.x.x.x:8080
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig_test.go
} }) } } func Test_chooseClientFlag(t *testing.T) { url, _ := url.Parse("http://localhost/scopej/resource") ctrzClient := &ControlzClient{ baseURL: url, httpClient: &http.Client{}, } type args struct { ctrzClient *ControlzClient reset bool outputLogLevel string stackTraceLevel string outputFormat string } tests := []struct {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 6.2K bytes - Viewed (0) -
internal/rest/client.go
MaxErrResponseSize int64 // Avoid metrics update if set to true NoMetrics bool // TraceOutput will print debug information on non-200 calls if set. TraceOutput io.Writer // Debug trace output httpClient *http.Client url *url.URL newAuthToken func(audience string) string sync.RWMutex // mutex for lastErr lastErr error lastErrTime time.Time } type restError string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
internal/config/lambda/event/targetid_test.go
testCases := []struct { tid TargetID expectedResult string }{ {TargetID{}, ":"}, {TargetID{"1", "webhook"}, "1:webhook"}, {TargetID{"httpclient+2e33cdee-fbec-4bdd-917e-7d8e3c5a2531", "localhost:55638"}, "httpclient+2e33cdee-fbec-4bdd-917e-7d8e3c5a2531:localhost:55638"}, } for i, testCase := range testCases { result := testCase.tid.String() if result != testCase.expectedResult {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 3.5K bytes - Viewed (0) -
internal/config/lambda/target/webhook.go
type WebhookTarget struct { activeRequests int64 totalRequests int64 failedRequests int64 lazyInit lazyInit id event.TargetID args WebhookArgs transport *http.Transport httpClient *http.Client loggerOnce logger.LogOnce cancel context.CancelFunc cancelCh <-chan struct{} } // ID - returns target ID. func (target *WebhookTarget) ID() event.TargetID { return target.id }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 17 20:02:26 GMT 2023 - 6.7K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
} scopeInfos = append(scopeInfos, si) } return scopeInfos, nil } type ControlzClient struct { baseURL *url.URL httpClient *http.Client } func (c *ControlzClient) GetScopes() ([]*ScopeInfo, error) { var scopeInfos []*ScopeInfo resp, err := c.httpClient.Get(c.baseURL.String()) if err != nil { return nil, err } defer resp.Body.Close() if resp.StatusCode != http.StatusOK {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
internal/kms/kes.go
kmsContext := Context{"MinIO admin API": "ServerInfoHandler"} // Context for a test key operation for _, endpoint := range c.client.Endpoints { client := kes.Client{ Endpoints: []string{endpoint}, HTTPClient: c.client.HTTPClient, } // 1. Get stats for the KES instance state, err := client.Status(ctx) if err != nil { results = append(results, VerifyResult{Status: "offline", Endpoint: endpoint}) continue
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
cmd/prepare-storage.go
serverURL := &url.URL{ Scheme: endpoint.Scheme, Host: endpoint.Host, Path: pathJoin(healthCheckPathPrefix, healthCheckLivenessPath), } httpClient := &http.Client{ Transport: globalInternodeTransport, } ctx, cancel := context.WithTimeout(GlobalContext, timeout) defer cancel()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0)