- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 110 for url (0.12 sec)
-
cni/pkg/plugin/plugin_test.go
return nil } // returns the test server URL and a dispose func for the test server func setupCNIEventClientWithMockServer(serverErr bool) (string, func() bool) { cniAddServerCalled := false // replace the global CNI client with mock newCNIClient = func(address, path string) CNIEventClient { c := http.DefaultClient eventC := CNIEventClient{ client: c, url: address + path, } return eventC }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
cmd/handler-utils.go
switch { case strings.HasPrefix(r.URL.Path, peerRESTPrefix): writeErrorResponseString(r.Context(), w, APIError{ Code: "XMinioPeerVersionMismatch", Description: desc, HTTPStatusCode: http.StatusUpgradeRequired, }, r.URL) case strings.HasPrefix(r.URL.Path, storageRESTPrefix): writeErrorResponseString(r.Context(), w, APIError{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.5K bytes - Viewed (3) -
cmd/listen-notification-handlers.go
writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL) return } vars := mux.Vars(r) bucketName := vars["bucket"] if bucketName == "" { if s3Error := checkRequestAuthType(ctx, r, policy.ListenNotificationAction, bucketName, ""); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/storage-rest-client.go
// and a healthcheck routine gets invoked that would reconnect. func (client *storageRESTClient) call(ctx context.Context, method string, values url.Values, body io.Reader, length int64) (io.ReadCloser, error) { if values == nil { values = make(url.Values) } values.Set(storageRESTDiskID, *client.diskID.Load()) respBody, err := client.restClient.Call(ctx, method, values, body, length) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/common-main.go
} // Look for if URL has invalid values and return error. if !((u.Scheme == "http" || u.Scheme == "https") && (u.Path == "/" || u.Path == "") && u.Opaque == "" && !u.ForceQuery && u.RawQuery == "" && u.Fragment == "") { err := fmt.Errorf("URL contains unexpected resources, expected URL to be of http(s)://minio.example.com format: %v", u)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
cmd/crossdomain-xml-handler.go
cxml := crossDomainXML if globalServerCtxt.CrossDomainXML != "" { cxml = globalServerCtxt.CrossDomainXML } // Look for 'crossdomain.xml' in the incoming request. if r.URL.Path == crossDomainXMLEntity { // Write the standard cross domain policy xml. w.Write([]byte(cxml)) // Request completed, no need to serve to other handlers. return } h.ServeHTTP(w, r) })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 18 06:42:40 GMT 2024 - 2.2K bytes - Viewed (0) -
internal/logger/config.go
enable, err := config.ParseBool(enableCfgVal) if err != nil || !enable { continue } var url *xnet.URL endpoint := getCfgVal(EnvLoggerWebhookEndpoint, k, kv.Get(Endpoint)) url, err = xnet.ParseHTTPURL(endpoint) if err != nil { return cfg, err } clientCert := getCfgVal(EnvLoggerWebhookClientCert, k, kv.Get(ClientCert))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.8K bytes - Viewed (0) -
cmd/api-response.go
} // getObjectLocation gets the fully qualified URL of an object. func getObjectLocation(r *http.Request, domains []string, bucket, object string) string { // unit tests do not have host set. if r.Host == "" { return path.Clean(r.URL.Path) } proto := handlers.GetSourceScheme(r) if proto == "" { proto = getURLScheme(globalIsTLS) } u := &url.URL{ Host: r.Host,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 33.3K bytes - Viewed (2) -
cmd/update.go
len(cpuMap), len(coreMap), cpu.VendorID, cpu.Family, cpu.Model, cpu.Stepping, cpu.ModelName)) } uaAppend(")", "") return strings.Join(userAgentParts, "") } func downloadReleaseURL(u *url.URL, timeout time.Duration, mode string) (content string, err error) { req, err := http.NewRequest(http.MethodGet, u.String(), nil) if err != nil { return content, AdminError{ Code: AdminUpdateUnexpectedFailure,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/license-update.go
// if required e.g. when it is expiring soon url := globalSubnetConfig.BaseURL + licRenewPath resp, err := globalSubnetConfig.Post(url, nil) if err != nil { subnetLogIf(ctx, fmt.Errorf("error from %s: %w", url, err)) return } r := gjson.Parse(resp).Get("license_v2") if r.Index == 0 { internalLogIf(ctx, fmt.Errorf("license not found in response from %s", url)) return } lic := r.String()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0)