- Sort Score
- Num 10 results
- Language All
Results 311 - 320 of 812 for handle (0.11 seconds)
-
fastapi/routing.py
prefix + route.path, route.endpoint, name=route.name ) for handler in router.on_startup: self.add_event_handler("startup", handler) for handler in router.on_shutdown: self.add_event_handler("shutdown", handler) self.lifespan_context = _merge_lifespan_context( self.lifespan_context, router.lifespan_context,Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Dec 27 12:54:56 GMT 2025 - 174.6K bytes - Click Count (0) -
docs/bucket/notifications/README.md
log.Println("Connected") // Subscribe to subject log.Printf("Subscribing to subject 'bucketevents'\n") natsConnection.Subscribe("bucketevents", func(msg *nats.Msg) { // Handle the message log.Printf("Received message '%s\n", string(msg.Data)+"'") }) // Keep the connection alive runtime.Goexit() } ``` ``` go run nats.go 2016/10/12 06:39:18 Connected
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 84.2K bytes - Click Count (0) -
internal/bucket/lifecycle/lifecycle_test.go
t.Fatalf("%d: Expected %v during validation but got %v", i+1, tc.expectedValidationErr, err) } }) } } // TestMarshalLifecycleConfig checks if lifecycleconfig xml // marshaling/unmarshaling can handle output from each other func TestMarshalLifecycleConfig(t *testing.T) { // Time at midnight UTC midnightTS := ExpirationDate{time.Date(2019, time.April, 20, 0, 0, 0, 0, time.UTC)} lc := Lifecycle{ Rules: []Rule{
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 55.5K bytes - Click Count (0) -
src/bytes/bytes.go
} // Title treats s as UTF-8-encoded bytes and returns a copy with all Unicode letters that begin // words mapped to their title case. // // Deprecated: The rule Title uses for word boundaries does not handle Unicode // punctuation properly. Use golang.org/x/text/cases instead. func Title(s []byte) []byte { // Use a closure here to remember state. // Hackish but effective. Depends on Map scanning in order and calling
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Sep 16 16:42:15 GMT 2025 - 35.5K bytes - Click Count (0) -
.bazelrc
common:windows --host_copt=/d2ReducedOptimizeHugeFunctions # Before VS 2017 15.8, the member "type" would non-conformingly have an # alignment of only alignof(max_align_t). VS 2017 15.8 was fixed to handle this # correctly, but the fix inherently changes layout and breaks binary # compatibility (*only* for uses of aligned_storage with extended alignments). common:windows --copt=-D_ENABLE_EXTENDED_ALIGNED_STORAGE
Created: Tue Dec 30 12:39:10 GMT 2025 - Last Modified: Fri Dec 26 23:20:26 GMT 2025 - 56.8K bytes - Click Count (0) -
impl/maven-core/src/site/apt/artifact-handlers.apt
~~ specific language governing permissions and limitations ~~ under the License. --- Legacy Artifact Handlers Reference --- Hervé Boutemy --- 2013-08-02 --- Legacy Artifact Handlers Reference Maven 3 artifact handlers (see {{{../../compat/maven-artifact/apidocs/org/apache/maven/artifact/handler/ArtifactHandler.html} API}})Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sun Nov 16 18:16:44 GMT 2025 - 4.6K bytes - Click Count (0) -
cmd/handler-utils.go
success = true // Make sure we remove any existing headers before // proxying the request to another node. for k := range w.Header() { w.Header().Del(k) } f := handlers.NewForwarder(&handlers.Forwarder{ PassHost: true, RoundTripper: ep.Transport, ErrorHandler: func(w http.ResponseWriter, r *http.Request, err error) { success = false
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 16.4K bytes - Click Count (1) -
cmd/bucket-policy-handlers_test.go
t.Fatalf("Test %d: Failed to create HTTP request for GetBucketPolicyHandler: <ERROR> %v", i+1, err) } // Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler. // Call the ServeHTTP to execute the handler, GetBucketPolicyHandler handles the request. apiRouter.ServeHTTP(recV4, reqV4) // Assert the response code with the expected status. if recV4.Code != testCase.expectedRespStatus {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 32.9K bytes - Click Count (0) -
cmd/sts-handlers.go
noQueries := len(r.URL.RawQuery) == 0 return ctypeOk && authOk && noQueries }).HandlerFunc(httpTraceAll(sts.AssumeRole)) // Assume roles with JWT handler, handles both ClientGrants and WebIdentity. stsRouter.Methods(http.MethodPost).MatcherFunc(func(r *http.Request, rm *mux.RouteMatch) bool {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 36.6K bytes - Click Count (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) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Jun 26 07:44:34 GMT 2024 - 6.9K bytes - Click Count (0)