- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 106 for rResources (0.15 sec)
-
cmd/metrics-v3-handler.go
func (h *metricsV3Server) handle(path string, isListingRequest bool, buckets []string) http.Handler { var notFoundHandler http.Handler = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { http.Error(w, "Metrics Resource Not found", http.StatusNotFound) }) // Require that metrics path has at least component. if path == "/" { return notFoundHandler } if isListingRequest { handler := h.listMetrics(path)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/test-utils_test.go
t.Fatal(failTestStr(unknownSignTestStr, "error response failed to parse error XML")) } if path.Clean(actualError.Resource) != pathJoin(SlashSeparator, bucketName, SlashSeparator, objectName) { t.Fatal(failTestStr(unknownSignTestStr, "error response resource differs from expected value")) } } // expected error response when the unsigned HTTP request is not permitted.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/object-api-datatypes.go
for _, upload := range lm.Uploads { if upload.UploadID == uploadID { return true } } return false } // ListMultipartsInfo - represents bucket resources for incomplete multipart uploads. type ListMultipartsInfo struct { // Together with upload-id-marker, this parameter specifies the multipart upload // after which listing should begin. KeyMarker string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
cmd/api-router.go
apiRouter.MethodNotAllowedHandler = collectAPIStats("methodnotallowed", httpTraceAll(methodNotAllowedHandler("S3"))) } // corsHandler handler for CORS (Cross Origin Resource Sharing) func corsHandler(handler http.Handler) http.Handler { commonS3Headers := []string{ xhttp.Date, xhttp.ETag, xhttp.ServerInfo, xhttp.Connection, xhttp.AcceptRanges, xhttp.ContentRange,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0) -
cmd/object-api-utils.go
compressOpts = append(compressOpts, s2.WriterBetterCompression()) } } // newS2CompressReader will read data from r, compress it and return the compressed data as a Reader. // Use Close to ensure resources are released on incomplete streams. // // input 'on' is always recommended such that this function works // properly, because we do not wish to create an object even if // client closed the stream prematurely.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
internal/dsync/lock-args.go
// Unique ID of lock/unlock request. UID string // Resources contains single or multiple entries to be locked/unlocked. Resources []string // Source contains the line number, function and file name of the code // on the client node that requested the lock. Source string // Owner represents unique ID for this instance, an owner who originally requested // the locked resource, useful primarily in figuring out stale locks. Owner string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 04:34:26 GMT 2024 - 1.7K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
w := new(tabwriter.Writer).Init(s.Writer, 0, 8, 5, ' ', 0) _, _ = fmt.Fprintln(w, "NAME\tCLUSTER\tCDS\tLDS\tEDS\tRDS\tECDS\tISTIOD\tVERSION") for _, dr := range drs { for _, resource := range dr.Resources { clientConfig := xdsstatus.ClientConfig{} err := resource.UnmarshalTo(&clientConfig) if err != nil { return nil, nil, fmt.Errorf("could not unmarshal ClientConfig: %w", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
var locksHeld int64 if locksHeld, reply = l.lockMap[args.Resources[0]]; !reply { // No lock is held on the given name return false, fmt.Errorf("Unlock attempted on an unlocked entity: %s", args.Resources[0]) } if reply = locksHeld == WriteLock; !reply { // Unless it is a write lock return false, fmt.Errorf("Unlock attempted on a read locked entity: %s (%d read locks active)", args.Resources[0], locksHeld) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 23 16:46:37 GMT 2023 - 8.3K bytes - Viewed (0) -
istioctl/pkg/cli/kubectl_factory.go
import ( "k8s.io/apimachinery/pkg/api/meta" "k8s.io/cli-runtime/pkg/resource" openapiclient "k8s.io/client-go/openapi" "k8s.io/kubectl/pkg/cmd/util" "k8s.io/kubectl/pkg/util/openapi" "k8s.io/kubectl/pkg/validation" "istio.io/istio/pkg/kube" ) type Factory struct { kube.PartialFactory full util.Factory } func (f Factory) NewBuilder() *resource.Builder { return f.full.NewBuilder() }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 18:17:49 GMT 2023 - 2K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
} return nil } func ObjectToInstance(c controllers.Object) *resource.Instance { return &resource.Instance{ Origin: &legacykube.Origin{ Type: kubetypes.GvkFromObject(c), FullName: resource.FullName{ Namespace: resource.Namespace(c.GetNamespace()), Name: resource.LocalName(c.GetName()), }, ResourceVersion: resource.Version(c.GetResourceVersion()), Ref: nil,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0)