Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 351 - 360 of 950 for cast (0.01 seconds)

  1. cmd/http-stats.go

    	hstats.totalS3Requests.Inc(api)
    	code := w.StatusCode
    
    	switch {
    	case code == 0:
    	case code == 499:
    		// 499 is a good error, shall be counted as canceled.
    		hstats.totalS3Canceled.Inc(api)
    	case code >= http.StatusBadRequest:
    		if code >= http.StatusInternalServerError {
    			hstats.totalS35xxErrors.Inc(api)
    		} else {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Sep 24 17:13:00 GMT 2024
    - 11.4K bytes
    - Click Count (0)
  2. cmd/policy_test.go

    		expectErr := (err != nil)
    
    		if expectErr != testCase.expectErr {
    			t.Fatalf("case %v: error: expected: %v, got: %v\n", i+1, testCase.expectErr, expectErr)
    		}
    
    		if !testCase.expectErr {
    			if !reflect.DeepEqual(result, testCase.expectedResult) {
    				t.Fatalf("case %v: result: expected: %+v, got: %+v\n", i+1, testCase.expectedResult, result)
    			}
    		}
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 8.9K bytes
    - Click Count (0)
  3. internal/s3select/json/preader.go

    			q := queueItem{
    				input: next,
    				dst:   make(chan []jstream.KVS, 1),
    				err:   err,
    			}
    			select {
    			case <-r.close:
    				return
    			case r.queue <- &q:
    			}
    
    			select {
    			case <-r.close:
    				return
    			case r.input <- &q:
    			}
    			if err != nil {
    				// Exit on any error.
    				return
    			}
    		}
    	}()
    
    	// Start parsers
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  4. internal/config/identity/openid/provider/keycloak.go

    	}
    	defer resp.Body.Close()
    	switch resp.StatusCode {
    	case http.StatusOK, http.StatusPartialContent:
    		var u User
    		if err = json.NewDecoder(resp.Body).Decode(&u); err != nil {
    			return User{}, err
    		}
    		return u, nil
    	case http.StatusNotFound:
    		return User{
    			ID:      userid,
    			Enabled: false,
    		}, nil
    	case http.StatusUnauthorized:
    		return User{}, ErrAccessTokenExpired
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Jul 14 18:12:07 GMT 2024
    - 4.6K bytes
    - Click Count (0)
  5. internal/bucket/lifecycle/lifecycle.go

    			// and noncurrent versions when,
    			// - now is past the expected time to action
    			// - expected time to action is the same for both actions
    			if now.After(a.Due) && now.After(b.Due) || a.Due.Equal(b.Due) {
    				switch a.Action {
    				case DeleteAllVersionsAction, DelMarkerDeleteAllVersionsAction,
    					DeleteAction, DeleteVersionAction:
    					return -1
    				}
    				switch b.Action {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Apr 03 06:45:06 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  6. internal/grid/grid_test.go

    			}
    			for {
    				select {
    				case <-nowBlocking:
    					return
    				case <-st.Done():
    				case st.Requests <- []byte{1}:
    					time.Sleep(10 * time.Millisecond)
    				}
    			}
    		}()
    	}
    	// Check that local returned.
    	err = st.Results(func(b []byte) error {
    		<-st.Done()
    		return ctx.Err()
    	})
    	mu.Lock()
    	select {
    	case <-nowBlocking:
    	default:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
  7. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/metadata/ArtifactMetadataSource.java

         * @param remoteRepositories remote repositories, {@link List} $lt; {@link ArtifactRepository} &gt;
         * @return {@link List} $lt; {@link ArtifactVersion} &gt;
         * @throws ArtifactMetadataRetrievalException
         *          in case of error while retrieving repository metadata from the repository.
         */
        List<ArtifactVersion> retrieveAvailableVersions(
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 3.5K bytes
    - Click Count (0)
  8. internal/dsync/locker.go

    	// In that case, the resource may or may not be unlocked.
    	RUnlock(ctx context.Context, args LockArgs) (bool, error)
    
    	// Do write unlock for given LockArgs. It should return
    	// * a boolean to indicate success/failure of the operation
    	// * an error on failure of unlock request operation.
    	// Canceling the context will abort the remote call.
    	// In that case, the resource may or may not be unlocked.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jan 18 20:44:38 GMT 2022
    - 2.7K bytes
    - Click Count (0)
  9. logger/slog.go

    		fields = append(fields, slog.Int64("rows", rows))
    	}
    
    	switch {
    	case err != nil && (!l.IgnoreRecordNotFoundError || !errors.Is(err, ErrRecordNotFound)):
    		fields = append(fields, slog.String("error", err.Error()))
    		l.log(ctx, slog.LevelError, "SQL executed", slog.Attr{
    			Key:   "trace",
    			Value: slog.GroupValue(fields...),
    		})
    
    	case l.SlowThreshold != 0 && elapsed > l.SlowThreshold:
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Thu Oct 30 10:56:26 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  10. docs/en/docs/how-to/graphql.md

    /// tip
    
    **GraphQL** solves some very specific use cases.
    
    It has **advantages** and **disadvantages** when compared to common **web APIs**.
    
    Make sure you evaluate if the **benefits** for your use case compensate the **drawbacks**. 🤓
    
    ///
    
    ## GraphQL Libraries { #graphql-libraries }
    
    Here are some of the **GraphQL** libraries that have **ASGI** support. You could use them with **FastAPI**:
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Fri Dec 26 10:43:02 GMT 2025
    - 3.4K bytes
    - Click Count (0)
Back to Top