Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for track (6.31 sec)

  1. internal/rest/client.go

    	_         int32 // For 64 bits alignment
    	lastConn  int64
    
    	// HealthCheckFn is the function set to test for health.
    	// If not set the client will not keep track of health.
    	// Calling this returns true or false if the target
    	// is online or offline.
    	HealthCheckFn func() bool
    
    	// HealthCheckRetryUnit will be used to calculate the exponential
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 14.4K bytes
    - Viewed (0)
  2. cmd/metacache-server-pool.go

    	go func(o listPathOptions) {
    		err := z.listMerged(listCtx, o, inCh)
    		if err != nil {
    			meta.setErr(err.Error())
    		}
    		o.debugln("listAndSave: listing", o.ID, "finished with ", err)
    	}(*o)
    
    	// Keep track of when we return since we no longer have to send entries to output.
    	var funcReturned bool
    	var funcReturnedMu sync.Mutex
    	defer func() {
    		funcReturnedMu.Lock()
    		funcReturned = true
    		funcReturnedMu.Unlock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  3. cmd/batch-expire.go

    			for _, exp := range toExpire {
    				if exp.ExpireAll {
    					toExpireAll = append(toExpireAll, exp.ObjectInfo)
    					continue
    				}
    				// Cache ObjectInfo value via pointers for
    				// subsequent use to track objects which
    				// couldn't be deleted.
    				od := ObjectToDelete{
    					ObjectV: ObjectV{
    						ObjectName: exp.Name,
    						VersionID:  exp.VersionID,
    					},
    				}
    				toDel = append(toDel, od)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
  4. cmd/xl-storage-disk-id-check.go

    		Path:      path,
    		Custom:    custom,
    	}
    }
    
    // Update storage metrics
    func (p *xlStorageDiskIDCheck) updateStorageMetrics(s storageMetric, paths ...string) func(err *error) {
    	startTime := time.Now()
    	trace := globalTrace.NumSubscribers(madmin.TraceStorage) > 0
    	return func(errp *error) {
    		duration := time.Since(startTime)
    
    		var err error
    		if errp != nil && *errp != nil {
    			err = *errp
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  5. cmd/globals.go

    	globalHTTPServer        *xhttp.Server
    	globalTCPOptions        xhttp.TCPOptions
    	globalHTTPServerErrorCh = make(chan error)
    	globalOSSignalCh        = make(chan os.Signal, 1)
    
    	// global Trace system to send HTTP request/response
    	// and Storage/OS calls info to registered listeners.
    	globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  6. cmd/admin-heal-ops.go

    // structure to hold state of all heal sequences in server memory
    type allHealState struct {
    	sync.RWMutex
    
    	// map of heal path to heal sequence
    	healSeqMap map[string]*healSequence // Indexed by endpoint
    	// keep track of the healing status of disks in the memory
    	//   false: the disk needs to be healed but no healing routine is started
    	//    true: the disk is currently healing
    	healLocalDisks map[Endpoint]bool
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  7. docs/config/README.md

    MINIO_SITE_COMMENT  (sentence)  optionally add a comment to this setting
    ```
    
    Example:
    
    ```sh
    export MINIO_SITE_REGION="us-west-0"
    export MINIO_SITE_NAME="sfo-rack-1"
    minio server /data
    ```
    
    ### Storage Class
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 17.7K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-rebalance.go

    		return nil
    	}
    
    	if cancel := r.cancel; cancel != nil {
    		// cancel != nil only on pool leaders
    		r.cancel = nil
    		cancel()
    	}
    	return nil
    }
    
    // for rebalance trace support
    type rebalanceMetrics struct{}
    
    var globalRebalanceMetrics rebalanceMetrics
    
    //go:generate stringer -type=rebalanceMetric -trimprefix=rebalanceMetric $GOFILE
    type rebalanceMetric uint8
    
    const (
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  9. cmd/bucket-lifecycle.go

    		Duration:  duration,
    		Path:      pathJoin(oi.Bucket, oi.Name),
    		Error:     "",
    		Message:   getSource(4),
    		Custom:    map[string]string{"version-id": oi.VersionID},
    	}
    }
    
    func (sys *LifecycleSys) trace(oi ObjectInfo) func(event string) {
    	startTime := time.Now()
    	return func(event string) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceILM) > 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  10. internal/grid/connection.go

    func (c *Connection) Subroute(s string) *Subroute {
    	if c == nil {
    		return nil
    	}
    	return &Subroute{
    		Connection: c,
    		route:      s,
    		subID:      makeSubHandlerID(0, s),
    		trace:      c.trace.subroute(s),
    	}
    }
    
    // Subroute adds a subroute to the subroute.
    // The subroutes are combined with '/'.
    func (c *Subroute) Subroute(s string) *Subroute {
    	route := strings.Join([]string{c.route, s}, "/")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
Back to top