Search Options

Results per page
Sort
Preferred Languages
Advance

Results 531 - 540 of 659 for kInput (0.07 sec)

  1. internal/s3select/sql/value.go

    // If the content is valid JSON, the type will still be bytes.
    func (v *Value) InferBytesType() (err error) {
    	b, ok := v.ToBytes()
    	if !ok {
    		return fmt.Errorf("InferByteType: Input is not bytes, but %v", v.GetTypeString())
    	}
    
    	// Check for numeric inference
    	if x, ok := v.bytesToInt(); ok {
    		v.setInt(x)
    		return nil
    	}
    	if x, ok := v.bytesToFloat(); ok {
    		v.setFloat(x)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Feb 25 20:31:19 UTC 2022
    - 20.2K bytes
    - Viewed (0)
  2. cmd/bucket-handlers.go

    		if _, ok := objectsToDelete[object]; !ok {
    			objectsToDelete[object] = index
    		}
    	}
    
    	toNames := func(input map[ObjectToDelete]int) (output []ObjectToDelete) {
    		output = make([]ObjectToDelete, len(input))
    		idx := 0
    		for obj := range input {
    			output[idx] = obj
    			idx++
    		}
    		return
    	}
    
    	// Disable timeouts and cancellation
    	ctx = bgContext(ctx)
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  3. internal/grid/muxclient.go

    		return
    	}
    
    	// Route directly to output.
    	m.respWait = out
    }
    
    // RequestStream will send a single payload request and stream back results.
    // 'requests' can be nil, in which case only req is sent as input.
    // It will however take less resources.
    func (m *muxClient) RequestStream(h HandlerID, payload []byte, requests chan []byte, responses chan Response) (*Stream, error) {
    	if m.init {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  4. cmd/metacache-entries_test.go

    			wantSelected: &inputSerialized[9],
    			wantOk:       true,
    		},
    	}
    
    	for testID, tt := range tests {
    		rng := rand.New(rand.NewSource(0))
    		// Run for a number of times, shuffling the input to ensure that output is consistent.
    		for i := 0; i < 10; i++ {
    			t.Run(fmt.Sprintf("test-%d-%s-run-%d", testID, tt.name, i), func(t *testing.T) {
    				if i > 0 {
    					rng.Shuffle(len(tt.m), func(i, j int) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 31.6K bytes
    - Viewed (0)
  5. README.md

    * Validation of data:
        * Automatic and clear errors when the data is invalid.
        * Validation even for deeply nested JSON objects.
    * <abbr title="also known as: serialization, parsing, marshalling">Conversion</abbr> of input data: coming from the network to Python data and types. Reading from:
        * JSON.
        * Path parameters.
        * Query parameters.
        * Cookies.
        * Headers.
        * Forms.
        * Files.
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Sun Oct 20 19:20:23 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  6. docs/zh/docs/async.md

    接下来,它 🤖 完成第一个任务(比如是我们的"慢文件"📝) 并继续与之相关的一切。
    
    这个"等待其他事情"通常指的是一些相对较慢(与处理器和 RAM 存储器的速度相比)的 <abbr title="Input and Output">I/O</abbr> 操作,比如说:
    
    * 通过网络发送来自客户端的数据
    * 客户端接收来自网络中的数据
    * 磁盘中要由系统读取并提供给程序的文件的内容
    * 程序提供给系统的要写入磁盘的内容
    * 一个 API 的远程调用
    * 一个数据库操作,直到完成
    * 一个数据库查询,直到返回结果
    * 等等.
    
    这个执行的时间大多是在等待 <abbr title="Input and Output">I/O</abbr> 操作,因此它们被叫做 "I/O 密集型" 操作。
    
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  7. cmd/metacache-entries.go

    			metaDataPoolPut(entry.metadata)
    			m.o[i].metadata = nil
    		}
    	}
    	m.o = m.o[idx:]
    }
    
    // mergeEntryChannels will merge entries from in and return them sorted on out.
    // To signify no more results are on an input channel, close it.
    // The output channel will be closed when all inputs are emptied.
    // If file names are equal, compareMeta is called to select which one to choose.
    // The entry not chosen will be discarded.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  8. cmd/post-policy_test.go

    			data:               []byte("Hello, World"),
    			expectedRespStatus: http.StatusForbidden,
    			accessKey:          "",
    			secretKey:          "",
    			malformedBody:      false,
    		},
    		// Bad case malformed input.
    		{
    			objectName:         "test",
    			data:               []byte("Hello, World"),
    			expectedRespStatus: http.StatusBadRequest,
    			accessKey:          credentials.AccessKey,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  9. cmd/xl-storage_test.go

    	f, _ := os.Create(tmpFileName)
    	f.Close()
    	defer os.Remove(tmpFileName)
    
    	// List of all tests for xlStorage initialization.
    	testCases := []struct {
    		name string
    		err  error
    	}{
    		// Validates input argument cannot be empty.
    		{
    			"",
    			errInvalidArgument,
    		},
    		// Validates if the directory does not exist and
    		// gets automatically created.
    		{
    			tmpDirName,
    			nil,
    		},
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  10. cmd/testdata/xl-meta-merge.zip

    enabled (RHEL, CentOS, etc), you can use `iptables` command to enable all traffic coming to specific ports. Use below command to allow access to port 9000 ```sh iptables -A INPUT -p tcp --dport 9000 -j ACCEPT service iptables restart ``` Below command enables all incoming traffic to ports ranging from 9000 to 9010. ```sh iptables -A INPUT -p tcp --dport 9000:9010 -j ACCEPT service iptables restart ``` ## Test MinIO Connectivity ### Test using MinIO Console MinIO Server comes with an embedded web based object...
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 30.2K bytes
    - Viewed (0)
Back to top