- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 37 for Rendle (0.14 sec)
-
cmd/metrics-router.go
auth = NoAuthMiddleware } metricsRouter.Handle(prometheusMetricsPathLegacy, auth(metricsHandler())) metricsRouter.Handle(prometheusMetricsV2ClusterPath, auth(metricsServerHandler())) metricsRouter.Handle(prometheusMetricsV2BucketPath, auth(metricsBucketHandler())) metricsRouter.Handle(prometheusMetricsV2NodePath, auth(metricsNodeHandler())) metricsRouter.Handle(prometheusMetricsV2ResourcePath, auth(metricsResourceHandler()))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/xl-storage-format-utils.go
return FileInfoVersions{}, err } versions, err = xlMeta.ListVersions(volume, path, allParts) } if err == nil && len(versions) == 0 { // This special case is needed to handle len(xlMeta.versions) == 0 versions = []FileInfo{ { Volume: volume, Name: path, Deleted: true, IsLatest: true, ModTime: timeSentinel1970, }, } } if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 17:45:28 GMT 2024 - 4.7K bytes - Viewed (0) -
istioctl/pkg/util/clusters/wrapper.go
type Wrapper struct { *admin.Clusters } // MarshalJSON is a custom marshaller to handle protobuf pain func (w *Wrapper) MarshalJSON() ([]byte, error) { return protomarshal.Marshal(w) } // UnmarshalJSON is a custom unmarshaller to handle protobuf pain func (w *Wrapper) UnmarshalJSON(b []byte) error { cd := &admin.Clusters{} err := protomarshal.UnmarshalAllowUnknown(b, cd)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 1.2K bytes - Viewed (0) -
internal/config/policy/plugin/config.go
opaRespBytes, err := io.ReadAll(resp.Body) if err != nil { return false, err } // Handle large OPA responses when OPA URL is of // form http://localhost:8181/v1/data/httpapi/authz type opaResultAllow struct { Result struct { Allow bool `json:"allow"` } `json:"result"` } // Handle simpler OPA responses when OPA URL is of // form http://localhost:8181/v1/data/httpapi/authz/allow
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 14 21:50:16 GMT 2023 - 5.8K bytes - Viewed (0) -
internal/handlers/forwarder.go
// ServeHTTP forwards HTTP traffic using the configured transport func (f *Forwarder) ServeHTTP(w http.ResponseWriter, inReq *http.Request) { outReq := new(http.Request) *outReq = *inReq // includes shallow copies of maps, but we handle this in Director revproxy := httputil.ReverseProxy{ Director: func(req *http.Request) { f.modifyRequest(req, inReq.URL) }, BufferPool: newBufPool(128 << 10), Transport: f.RoundTripper,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 07 05:42:10 GMT 2023 - 5.6K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
s.queue = controllers.NewQueue("ambient", controllers.WithGenericReconciler(s.reconcile), controllers.WithMaxAttempts(5), ) // We only need to handle pods on our node s.pods = kclient.NewFiltered[*corev1.Pod](kubeClient, kclient.Filter{FieldSelector: "spec.nodeName=" + NodeName}) s.pods.AddEventHandler(controllers.FromEventHandler(func(o controllers.Event) { s.queue.Add(o)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
cmd/routers.go
// Register bootstrap REST router for distributed setups. registerBootstrapRESTHandlers(globalGrid.Load()) // Register distributed namespace lock routers. registerLockRESTHandlers() // Add grid to router router.Handle(grid.RoutePath, adminMiddleware(globalGrid.Load().Handler(), noGZFlag, noObjLayerFlag)) } // List of some generic middlewares which are applied for all incoming requests. var globalMiddlewares = []mux.MiddlewareFunc{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 3.6K bytes - Viewed (1) -
internal/config/certsinfo.go
package config import ( "crypto/x509" "crypto/x509/pkix" "fmt" "net/http" "strings" color "github.com/minio/minio/internal/color" ) // Extra ASN1 OIDs that we may need to handle var ( oidEmailAddress = []int{1, 2, 840, 113549, 1, 9, 1} ) // printName prints the fields of a distinguished name, which include such // things as its common name and locality.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 16 17:28:29 GMT 2021 - 3.1K bytes - Viewed (0) -
internal/crypto/header.go
h.Del(xhttp.AmzMetaUnencryptedContentLength) h.Del(xhttp.AmzMetaUnencryptedContentMD5) } // SSECopy represents AWS SSE-C for copy requests. It provides // functionality to handle SSE-C copy requests. var SSECopy = ssecCopy{} type ssecCopy struct{} // IsRequested returns true if the HTTP headers contains // at least one SSE-C copy header. Regular SSE-C headers // are ignored.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 2.9K bytes - Viewed (0) -
internal/bucket/lifecycle/noncurrentversion.go
} // UnmarshalXML decodes NoncurrentVersionExpiration func (n *NoncurrentVersionExpiration) UnmarshalXML(d *xml.Decoder, startElement xml.StartElement) error { // To handle xml with MaxNoncurrentVersions from older MinIO releases. // note: only one of MaxNoncurrentVersions or NewerNoncurrentVersions would be present. type noncurrentExpiration struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Dec 14 17:41:44 GMT 2021 - 5.3K bytes - Viewed (1)