Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 311 - 320 of 812 for handle (0.11 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. .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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top