Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 16 of 16 for scanMode (0.05 seconds)

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

  1. cmd/object-api-interface.go

    	NewNSLock(bucket string, objects ...string) RWLocker
    
    	// Storage operations.
    	Shutdown(context.Context) error
    	NSScanner(ctx context.Context, updates chan<- DataUsageInfo, wantCycle uint32, scanMode madmin.HealScanMode) error
    	BackendInfo() madmin.BackendInfo
    	Legacy() bool // Only returns true for deployments which use CRCMOD as its object distribution algorithm.
    	StorageInfo(ctx context.Context, metrics bool) StorageInfo
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.5K bytes
    - Click Count (0)
  2. cmd/admin-handlers_test.go

    		{},
    		{mgmtBucket: "bucket"},
    		{mgmtBucket: "bucket", mgmtPrefix: "objprefix"},
    	}
    
    	// Body is always valid - we do not test JSON decoding.
    	body := `{"recursive": false, "dryRun": true, "remove": false, "scanMode": 0}`
    
    	// Test all combinations!
    	for pIdx, params := range qParamsArr {
    		for vIdx, vars := range varsArr {
    			_, err := extractHealInitParams(vars, params, bytes.NewReader([]byte(body)))
    			isErrCase := false
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.9K bytes
    - Click Count (1)
  3. scan.go

    		field.NewValuePool.Put(values[idx])
    	}
    }
    
    // ScanMode scan data mode
    type ScanMode uint8
    
    // scan modes
    const (
    	ScanInitialized         ScanMode = 1 << 0 // 1
    	ScanUpdate              ScanMode = 1 << 1 // 2
    	ScanOnConflictDoNothing ScanMode = 1 << 2 // 4
    )
    
    // Scan scan rows into db statement
    func Scan(rows Rows, db *DB, mode ScanMode) {
    	var (
    		columns, _          = rows.Columns()
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sun May 25 07:40:40 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  4. callbacks/helper.go

    				values.Values[i] = make([]interface{}, len(columns))
    			}
    
    			values.Values[i][idx] = v
    		}
    	}
    	return
    }
    
    func hasReturning(tx *gorm.DB, supportReturning bool) (bool, gorm.ScanMode) {
    	if supportReturning {
    		if c, ok := tx.Statement.Clauses["RETURNING"]; ok {
    			returning, _ := c.Expression.(clause.Returning)
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Thu Apr 14 12:32:57 GMT 2022
    - 3.7K bytes
    - Click Count (0)
  5. cmd/xl-storage.go

    		buf, _, err := s.readMetadataWithDMTime(ctx, itemPath)
    		return buf, err
    	})
    }
    
    func (s *xlStorage) NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, weSleep func() bool) (dataUsageCache, error) {
    	atomic.AddInt32(&s.scanning, 1)
    	defer atomic.AddInt32(&s.scanning, -1)
    
    	var err error
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  6. build-conventions/src/main/java/org/elasticsearch/gradle/internal/conventions/PublishPlugin.java

        }
    
        private static void addScmInfo(XmlProvider xml, GitInfo gitInfo) {
            var root = xml.asNode();
            root.appendNode("url", gitInfo.urlFromOrigin());
            var scmNode = root.appendNode("scm");
            scmNode.appendNode("url", gitInfo.getOrigin());
        }
    
        /**
         * Adds a javadocJar task to generate a jar containing javadocs.
         */
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Wed Aug 11 07:30:51 GMT 2021
    - 8.9K bytes
    - Click Count (0)
Back to Top