Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 35 for albers (0.21 sec)

  1. cmd/metrics-v3-cluster-audit.go

    	audit := logger.CurrentStats()
    	for id, st := range audit {
    		labels := []string{targetID, id}
    		m.Set(auditFailedMessages, float64(st.FailedMessages), labels...)
    		m.Set(auditTargetQueueLength, float64(st.QueueLength), labels...)
    		m.Set(auditTotalMessages, float64(st.TotalMessages), labels...)
    	}
    
    	return nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 09:18:02 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  2. internal/config/scanner/scanner.go

    	EnvSpeed = "MINIO_SCANNER_SPEED"
    
    	IdleSpeed    = "idle_speed"
    	EnvIdleSpeed = "MINIO_SCANNER_IDLE_SPEED"
    
    	ExcessVersions    = "alert_excess_versions"
    	EnvExcessVersions = "MINIO_SCANNER_ALERT_EXCESS_VERSIONS"
    
    	ExcessFolders    = "alert_excess_folders"
    	EnvExcessFolders = "MINIO_SCANNER_ALERT_EXCESS_FOLDERS"
    
    	// All below are deprecated in October 2022 and
    	// replaced them with a single speed parameter
    	Delay            = "delay"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  3. internal/config/scanner/help.go

    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         ExcessVersions,
    			Description: `alert per object beyond this many versions` + defaultHelpPostfix(ExcessVersions),
    			Optional:    true,
    			Type:        "int",
    		},
    		config.HelpKV{
    			Key:         ExcessFolders,
    			Description: `alert beyond this many sub-folders per folder in an erasure set` + defaultHelpPostfix(ExcessFolders),
    			Optional:    true,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 07:41:53 GMT 2024
    - 1.6K bytes
    - Viewed (0)
  4. cmd/metacache.go

    		b = ""
    	}
    	if len(b) > 0 && !strings.HasSuffix(b, slashSeparator) {
    		b += slashSeparator
    	}
    	return b
    }
    
    // update cache with new status.
    // The updates are conditional so multiple callers can update with different states.
    func (m *metacache) update(update metacache) {
    	m.lastUpdate = UTCNow()
    
    	if m.lastHandout.After(m.lastHandout) {
    		m.lastHandout = UTCNow()
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5K bytes
    - Viewed (0)
  5. cmd/object-api-interface.go

    	PreserveETag                        string    // preserves this etag during a PUT call.
    	NoLock                              bool      // indicates to lower layers if the caller is expecting to hold locks.
    	ProxyRequest                        bool      // only set for GET/HEAD in active-active replication scenario
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  6. cmd/bucket-metadata-sys.go

    	globalNotificationSys.LoadBucketMetadata(bgContext(ctx), meta.Name) // Do not use caller context here
    	return nil
    }
    
    // Delete delete the bucket metadata for the specified bucket.
    // must be used by all callers instead of using Update() with nil configData.
    func (sys *BucketMetadataSys) Delete(ctx context.Context, bucket string, configFile string) (updatedAt time.Time, err error) {
    	if configFile == bucketLifecycleConfig {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 19.8K bytes
    - Viewed (0)
  7. internal/dsync/drwmutex.go

    			}
    		}
    	}()
    
    	return quorumLocked
    }
    
    // checkFailedUnlocks determines whether we have sufficiently unlocked all
    // resources to ensure no deadlocks for future callers
    func checkFailedUnlocks(locks []string, tolerance int) bool {
    	unlocksFailed := 0
    	for lockID := range locks {
    		if isLocked(locks[lockID]) {
    			unlocksFailed++
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  8. cmd/erasure-multipart.go

    		ChecksumSHA1:   partInfo.Checksums["SHA1"],
    		ChecksumSHA256: partInfo.Checksums["SHA256"],
    	}, nil
    }
    
    // GetMultipartInfo returns multipart metadata uploaded during newMultipartUpload, used
    // by callers to verify object states
    // - encrypted
    // - compressed
    // Does not contain currently uploaded parts by design.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  9. internal/config/dns/types.go

    	// a srv.Target domain name.  Normally we convert the full Key where
    	// the record lives to a DNS name and use this as the srv.Target. When
    	// TargetStrip > 0 we strip the left most TargetStrip labels from the
    	// DNS name.
    	TargetStrip int `json:"targetstrip,omitempty"`
    
    	// Group is used to group (or *not* to group) different services
    	// together. Services with an identical Group are returned in
    	// the same answer.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2K bytes
    - Viewed (0)
  10. cmd/http-stats.go

    	if bh == nil {
    		return
    	}
    
    	if w != nil {
    		// Increment the prometheus http request response histogram with API, Bucket
    		bucketHTTPRequestsDuration.With(prometheus.Labels{
    			"api":    api,
    			"bucket": bucket,
    		}).Observe(w.TimeToFirstByte.Seconds())
    	}
    
    	bh.Lock()
    	defer bh.Unlock()
    
    	hstats, ok := bh.httpStats[bucket]
    	if !ok {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 11.4K bytes
    - Viewed (0)
Back to top