Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 171 for Start (0.02 seconds)

  1. internal/s3select/select.go

    		if start < 0 {
    			return 0, 0, errors.New("ScanRange: Start after EOF")
    		}
    		return start, -1, nil
    	}
    	if s.Start == nil {
    		// Suffix length
    		end := int64(*s.End)
    		if end < 0 {
    			return 0, 0, errors.New("ScanRange: End bigger than file")
    		}
    		// Suffix length
    		return -end, -1, nil
    	}
    	start = int64(*s.Start)
    	end := int64(*s.End)
    	return start, end - start + 1, nil
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  2. docs/metrics/prometheus/list.md

    | `minio_node_scanner_bucket_scans_started`  | Total number of bucket scans started since server start.    |
    | `minio_node_scanner_directories_scanned`   | Total number of directories scanned since server start.     |
    | `minio_node_scanner_objects_scanned`       | Total number of unique objects scanned since server start.  |
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 43.4K bytes
    - Click Count (0)
  3. src/bufio/scan.go

    		if s.err != nil {
    			// Shut it down.
    			s.start = 0
    			s.end = 0
    			return false
    		}
    		// Must read more data.
    		// First, shift data to beginning of buffer if there's lots of empty space
    		// or space is needed.
    		if s.start > 0 && (s.end == len(s.buf) || s.start > len(s.buf)/2) {
    			copy(s.buf, s.buf[s.start:s.end])
    			s.end -= s.start
    			s.start = 0
    		}
    		// Is the buffer full? If so, resize.
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed May 21 18:05:26 GMT 2025
    - 14.2K bytes
    - Click Count (0)
  4. internal/grid/grid_test.go

    		start := time.Now()
    		resp, err := remoteConn.Request(t.Context(), handlerTest2, []byte(testPayload))
    		t.Log("Roundtrip:", time.Since(start))
    		if len(resp) != 0 {
    			t.Errorf("want nil, got %q", string(resp))
    		}
    		if err != RemoteErr(testPayload) {
    			t.Errorf("want error %v(%T), got %v(%T)", RemoteErr(testPayload), RemoteErr(testPayload), err, err)
    		}
    		t.Log("Roundtrip:", time.Since(start))
    	})
    
    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)
  5. cmd/local-locker_test.go

    								Quorum:    &quorum,
    							})
    							if !ok || err != nil {
    								t.Fatal("failed:", err, ok)
    							}
    						}
    					}
    					start := time.Now()
    					l.expireOldLocks(time.Hour)
    					t.Logf("Scan Took: %v. Left: %d/%d", time.Since(start).Round(time.Millisecond), len(l.lockUID), len(l.lockMap))
    					if len(l.lockMap) != locks {
    						t.Fatalf("objects deleted, want %d != got %d", locks, len(l.lockMap))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  6. src/bytes/bytes.go

    	start := -1 // valid span start if >= 0
    	for i := 0; i < len(s); {
    		r, size := utf8.DecodeRune(s[i:])
    		if f(r) {
    			if start >= 0 {
    				spans = append(spans, span{start, i})
    				start = -1
    			}
    		} else {
    			if start < 0 {
    				start = i
    			}
    		}
    		i += size
    	}
    
    	// Last field might end at EOF.
    	if start >= 0 {
    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)
  7. cmd/sftp-server.go

    		}
    	}
    	if len(filteredAlgos) == 0 {
    		logger.Fatal(fmt.Errorf("no valid algorithms passed to --sftp=%s\nValid algorithms: %v", arg, strings.Join(allowed, ", ")), "unable to start SFTP server")
    	}
    	return filteredAlgos
    }
    
    func startSFTPServer(args []string) {
    	var (
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  8. internal/kms/kms.go

    		req.Name = k.DefaultKey
    	}
    
    	start := time.Now()
    	dek, err := k.conn.GenerateKey(ctx, req)
    	k.updateMetrics(err, time.Since(start))
    
    	return dek, err
    }
    
    // Decrypt decrypts a ciphertext using the master key req.Name.
    // It returns ErrKeyNotFound if the key does not exist.
    func (k *KMS) Decrypt(ctx context.Context, req *DecryptRequest) ([]byte, error) {
    	start := time.Now()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Apr 24 15:33:57 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  9. internal/event/name.go

    }
    
    // MarshalXML - encodes to XML data.
    func (name Name) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    	return e.EncodeElement(name.String(), start)
    }
    
    // UnmarshalXML - decodes XML data.
    func (name *Name) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	var s string
    	if err := d.DecodeElement(&s, &start); err != nil {
    		return err
    	}
    
    	eventName, err := ParseName(s)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  10. compat/maven-model-builder/src/main/java/org/apache/maven/model/interpolation/reflection/ReflectionValueExtractor.java

                int start = idx;
    
                while (idx < expression.length() && delimiter != expression.charAt(idx)) {
                    idx++;
                }
    
                // delimiter MUST be present
                if (idx <= start || idx >= expression.length()) {
                    return null;
                }
    
                return expression.substring(start, idx++);
            }
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 10.8K bytes
    - Click Count (0)
Back to Top