Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 212 for recDst (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/s3select/csv/reader.go

    						if err != nil {
    							return errCSVParsingError(err)
    						}
    						var recDst []string
    						if len(dst) > len(all) {
    							recDst = dst[len(all)]
    						}
    						if cap(recDst) < len(record) {
    							recDst = make([]string, len(record))
    						}
    						recDst = recDst[:len(record)]
    						copy(recDst, record)
    						all = append(all, recDst)
    					}
    				}()
    				if err != nil {
    					in.err = err
    				}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  2. cmd/peer-rest-client.go

    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/rest"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    // client to talk to peer Nodes.
    type peerRESTClient struct {
    	host       *xnet.Host
    	restClient *rest.Client
    	gridHost   string
    	// Function that returns the grid connection for this peer when initialized.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  3. cmd/peer-rest-server.go

    		if err != nil {
    			return np, grid.NewRemoteErr(err)
    		}
    	default:
    		return np, grid.NewRemoteErr(errUnsupportedSignal)
    	}
    	return np, nil
    }
    
    // ListenHandler sends http trace messages back to peer rest client
    func (s *peerRESTServer) ListenHandler(ctx context.Context, v *grid.URLValues, out chan<- *grid.Bytes) *grid.RemoteErr {
    	values := v.Values()
    	defer v.Recycle()
    	var prefix string
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  4. docs/en/docs/deployment/versions.md

    After you have tests, then you can upgrade the **FastAPI** version to a more recent one, and make sure that all your code is working correctly by running your tests.
    
    If everything is working, or after you make the necessary changes, and all your tests are passing, then you can pin your `fastapi` to that new recent version.
    
    ## About Starlette { #about-starlette }
    
    You shouldn't pin the version of `starlette`.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 09:15:41 GMT 2025
    - 3.5K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/smb2/lease/LeaseManagerTest.java

            assertEquals(1, cleaned);
            assertNull(leaseManager.getLease(key));
        }
    
        @Test
        @DisplayName("Should not clean up recent leases")
        void testCleanupRecentLeases() {
            String path = "/share/recent.txt";
            int requestedState = Smb2LeaseState.SMB2_LEASE_READ_CACHING;
    
            Smb2LeaseKey key = leaseManager.requestLease(path, requestedState);
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 21 00:16:17 GMT 2025
    - 13.2K bytes
    - Click Count (0)
  6. cmd/storage-rest-client.go

    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/rest"
    	xnet "github.com/minio/pkg/v3/net"
    	xbufio "github.com/philhofer/fwd"
    	"github.com/tinylib/msgp/msgp"
    )
    
    func isNetworkError(err error) bool {
    	if err == nil {
    		return false
    	}
    
    	if nerr, ok := err.(*rest.NetworkError); ok {
    		if down := xnet.IsNetworkOrHostDown(nerr.Err, false); down {
    			return true
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  7. cmd/storage-rest-common_gen_test.go

    Klaus Post <******@****.***> 1759093161 +0200
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  8. internal/s3select/sql/statement.go

    		switch v := txedRec.(type) {
    		case jstream.KVS:
    			kvs = v
    
    		case []any:
    			recs := make([]*Record, len(v))
    			for i, val := range v {
    				tmpRec := input.Clone(nil)
    				if err = tmpRec.Replace(val); err != nil {
    					return nil, err
    				}
    				recs[i] = &tmpRec
    			}
    			return recs, nil
    
    		default:
    			kvs = jstream.KVS{jstream.KV{Key: "_1", Value: v}}
    		}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9K bytes
    - Click Count (0)
  9. .github/bot_config.yml

       
          * Try Google Colab to use TensorFlow.
             * The easiest way to use TF will be to switch to [google colab](https://colab.sandbox.google.com/notebooks/welcome.ipynb#recent=true). You get pre-installed latest stable TF version. Also you can use ```pip install```  to install any other preferred TF version.
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Mon Jun 30 16:38:59 GMT 2025
    - 4K bytes
    - Click Count (1)
  10. docs/bucket/lifecycle/README.md

    ```
    
    ### 3.2 Automatic removal of noncurrent versions keeping only most recent ones after noncurrent days
    
    It is possible to configure automatic removal of older noncurrent versions keeping only the most recent `N` using `NewerNoncurrentVersions`.
    
    e.g, To remove noncurrent versions of all objects keeping the most recent 5 noncurrent versions under the prefix `user-uploads/` 30 days after they become noncurrent ,
    
    ```
    {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 9.1K bytes
    - Click Count (0)
Back to Top