- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for Sander (0.17 sec)
-
cmd/auth-handler.go
_, ok := supportedS3AuthTypes[aType] return ok } // setAuthMiddleware to validate authorization header for the incoming request. func setAuthMiddleware(h http.Handler) http.Handler { // handler for validating incoming authorization headers. return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26K bytes - Viewed (0) -
cmd/healthcheck-handler.go
} return } } writeResponse(w, http.StatusOK, nil, mimeNone) } // LivenessCheckHandler checks whether MinIO is up. It differs from the // readiness handler since a failing liveness check causes pod restarts // in K8S environments. Therefore, it does not contact external systems. func LivenessCheckHandler(w http.ResponseWriter, r *http.Request) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 03 21:13:20 GMT 2024 - 6.5K bytes - Viewed (0) -
cmd/handler-api.go
errorCodes.ToAPIErr(ErrTooManyRequests), r.URL) globalHTTPStats.addRequestsInQueue(-1) return case <-r.Context().Done(): // When the client disconnects before getting the S3 handler // status code response, set the status code to 499 so this request // will be properly audited and traced. w.WriteHeader(499) globalHTTPStats.addRequestsInQueue(-1) return } } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 09:22:27 GMT 2024 - 10K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/SisuDiBridgeModule.java
AnnotatedBindingBuilder<Object> binder = bind(itf); if (key.getQualifier() instanceof String s) { binder.annotatedWith(Names.named(s)); } else if (key.getQualifier() instanceof Annotation a) { binder.annotatedWith(a); } binder.toProvider(() -> injector.getInstance(clazz));
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Thu Apr 25 14:13:36 GMT 2024 - 8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
private val finder = FastFallbackExchangeFinder(routePlanner, taskRunner) @AfterEach fun tearDown() { taskFaker.close() routePlanner.close() } @Test fun takeConnectedConnection() { val plan0 = routePlanner.addPlan() plan0.connectState = TLS_CONNECTED taskRunner.newQueue().execute("connect") { val result0 = finder.find()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/handler-utils.go
// Copyright (c) 2015-2021 MinIO, Inc. // // This file is part of MinIO Object Storage stack // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.5K bytes - Viewed (3) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/scopes/DeclarationsInPackageProvider.kt
val psiPackage = PsiPackageImpl(PsiManager.getInstance(analysisSession.project), packageFqName.asString()) forEachNonKotlinPsiElementFinder(analysisSession.project) { finder -> finder.getClassNames(psiPackage, analysisSession.useSiteAnalysisScope) .mapNotNullTo(this, Name::identifier) } } }
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Tue Apr 23 10:55:55 GMT 2024 - 5.4K bytes - Viewed (0) -
cmd/bucket-versioning-handler.go
// Copyright (c) 2015-2021 MinIO, Inc. // // This file is part of MinIO Object Storage stack // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
for _, val := range v { s = append(s, fmt.Sprintf("%v", val)) } err := fmt.Errorf("metrics handler error: %v", strings.Join(s, " ")) metricsLogIf(GlobalContext, err) } type metricsV3Server struct { registry *prometheus.Registry opts promhttp.HandlerOpts authFn func(http.Handler) http.Handler metricsData *metricsV3Collection }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.4K bytes - Viewed (0) -
internal/grid/manager.go
router.Handle(RoutePath, m.Handler()) } // Handler returns a handler that can be used to serve grid requests. // This should be connected on RoutePath to the main server. func (m *Manager) Handler() http.HandlerFunc { return func(w http.ResponseWriter, req *http.Request) { defer func() { if debugPrint { fmt.Printf("grid: Handler returning from: %v %v\n", req.Method, req.URL) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0)