Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 731 - 740 of 1,019 for Var (0.01 seconds)

  1. cmd/background-newdisks-heal-ops.go

    		// When all disks == all command line endpoints
    		// this is a fresh setup, no need to trigger healing.
    		return Endpoints{}
    	}
    	return disksToHeal
    }
    
    var newDiskHealingTimeout = newDynamicTimeout(30*time.Second, 10*time.Second)
    
    var errRetryHealing = errors.New("some items failed to heal, we will retry healing this drive again")
    
    func healFreshDisk(ctx context.Context, z *erasureServerPools, endpoint Endpoint) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  2. cmd/endpoint_test.go

    		s, err := filepath.Abs(s)
    		if err != nil {
    			t.Fatal(err)
    		}
    		return s
    	}
    	getExpectedEndpoints := func(args []string, prefix string) ([]*url.URL, []bool) {
    		var URLs []*url.URL
    		var localFlags []bool
    		for _, arg := range args {
    			u, _ := url.Parse(arg)
    			URLs = append(URLs, u)
    			localFlags = append(localFlags, strings.HasPrefix(arg, prefix))
    		}
    
    		return URLs, localFlags
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  3. internal/config/identity/ldap/help.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package ldap
    
    import "github.com/minio/minio/internal/config"
    
    // Help template for LDAP identity feature.
    var (
    	defaultHelpPostfix = func(key string) string {
    		return config.DefaultHelpPostfix(DefaultKVS, key)
    	}
    
    	Help = config.HelpKVS{
    		config.HelpKV{
    			Key:         ServerAddr,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 3.8K bytes
    - Click Count (0)
  4. cmd/metrics-v3-replication.go

    	replicationMaxQueuedCount          = "max_queued_count"
    	replicationMaxDataTransferRate     = "max_data_transfer_rate"
    	replicationRecentBacklogCount      = "recent_backlog_count"
    )
    
    var (
    	replicationAverageActiveWorkersMD = NewGaugeMD(replicationAverageActiveWorkers,
    		"Average number of active replication workers")
    	replicationAverageQueuedBytesMD = NewGaugeMD(replicationAverageQueuedBytes,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 15 12:04:40 GMT 2024
    - 4.6K bytes
    - Click Count (0)
  5. internal/event/target/mysql.go

    		if err != nil {
    			return err
    		}
    		key := eventData.S3.Bucket.Name + "/" + objectName
    
    		if eventData.EventName == event.ObjectRemovedDelete {
    			_, err = target.deleteStmt.Exec(key)
    		} else {
    			var data []byte
    			if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil {
    				return err
    			}
    
    			_, err = target.updateStmt.Exec(key, data)
    		}
    
    		return err
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  6. chainable_api.go

    //	db.Clauses(clause.Locking{Strength: "UPDATE"}).Find(&users)
    //
    // [docs]: https://gorm.io/docs/sql_builder.html#Clauses
    func (db *DB) Clauses(conds ...clause.Expression) (tx *DB) {
    	tx = db.getInstance()
    	var whereConds []interface{}
    
    	for _, cond := range conds {
    		if c, ok := cond.(clause.Interface); ok {
    			tx.Statement.AddClause(c)
    		} else if optimizer, ok := cond.(StatementModifier); ok {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Sep 19 01:49:06 GMT 2025
    - 14.8K bytes
    - Click Count (0)
  7. build-logic/cleanup/src/main/kotlin/gradlebuild/cleanup/services/CachesCleaner.kt

            val gradleVersion: Property<String>
            val homeDir: DirectoryProperty
        }
    
        @get:Inject
        abstract val fileSystemOperations: FileSystemOperations
    
        private
        var hasCleaned = false
    
        val logger = Logging.getLogger(CachesCleaner::class.java)
    
        fun cleanUpCaches() {
            synchronized(this) {
                if (hasCleaned) {
                    return
                }
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Fri Jun 28 08:29:28 GMT 2024
    - 4.2K bytes
    - Click Count (1)
  8. docs/en/docs/js/custom.js

                return true;
            });
        }
        window.addEventListener("scroll", loadVisibleTermynals);
        createTermynals();
        loadVisibleTermynals();
    }
    
    function shuffle(array) {
        var currentIndex = array.length, temporaryValue, randomIndex;
        while (0 !== currentIndex) {
            randomIndex = Math.floor(Math.random() * currentIndex);
            currentIndex -= 1;
            temporaryValue = array[currentIndex];
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Mon Sep 22 15:11:52 GMT 2025
    - 6.3K bytes
    - Click Count (2)
  9. cmd/shared-lock.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"time"
    )
    
    var sharedLockTimeout = newDynamicTimeoutWithOpts(dynamicTimeoutOpts{
    	timeout:       30 * time.Second,
    	minimum:       10 * time.Second,
    	retryInterval: time.Minute,
    })
    
    type sharedLock struct {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Feb 13 09:26:38 GMT 2023
    - 2.3K bytes
    - Click Count (0)
  10. internal/mountinfo/mountinfo_windows.go

    // this is a dummy function and returns nil for now.
    func CheckCrossDevice(paths []string) error {
    	return nil
    }
    
    // mountPointCache contains results of IsLikelyMountPoint
    var mountPointCache sync.Map
    
    // IsLikelyMountPoint determines if a directory is a mountpoint.
    func IsLikelyMountPoint(path string) bool {
    	path = filepath.Dir(path)
    	if v, ok := mountPointCache.Load(path); ok {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 2.1K bytes
    - Click Count (0)
Back to Top