Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for colonne (0.37 sec)

  1. cmd/bucket-targets.go

    						t.LastOnline = hs.lastOnline
    						t.Latency = madmin.LatencyStat{
    							Curr: hs.latency.curr,
    							Avg:  hs.latency.avg,
    							Max:  hs.latency.peak,
    						}
    					}
    					targets = append(targets, t.Clone())
    				}
    			}
    		}
    		return targets
    	}
    	sys.RLock()
    	defer sys.RUnlock()
    	for _, tgts := range sys.targetsMap {
    		for _, t := range tgts {
    			if string(t.Type) == arnType || arnType == "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  2. internal/bucket/lifecycle/rule.go

    		return errXMLNotWellFormed
    	}
    	return nil
    }
    
    // CloneNonTransition - returns a clone of the object containing non transition rules
    func (r Rule) CloneNonTransition() Rule {
    	return Rule{
    		XMLName:                     r.XMLName,
    		ID:                          r.ID,
    		Status:                      r.Status,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    			if g.metricsGroupOpts.dependBucketTargetSys {
    				if globalBucketTargetSys == nil {
    					return []MetricV2{}, nil
    				}
    			}
    			return read(GlobalContext), nil
    		},
    	)
    }
    
    func (m *MetricV2) clone() MetricV2 {
    	metric := MetricV2{
    		Description:          m.Description,
    		Value:                m.Value,
    		HistogramBucketLabel: m.HistogramBucketLabel,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    			return
    		}
    	}
    
    	cachedResult := globalCacheConfig.Enabled() && opts.VersionID == ""
    
    	var update bool
    	if cachedResult {
    		rc := &cache.CondCheck{}
    		h := r.Header.Clone()
    		if opts.PartNumber > 0 {
    			h.Set(xhttp.PartNumber, strconv.Itoa(opts.PartNumber))
    		}
    		rc.Init(bucket, object, h)
    
    		ci, err := globalCacheConfig.Get(rc)
    		if ci != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    }
    
    // update restore status header in the metadata
    func (er erasureObjects) updateRestoreMetadata(ctx context.Context, bucket, object string, objInfo ObjectInfo, opts ObjectOptions) error {
    	oi := objInfo.Clone()
    	oi.metadataOnly = true // Perform only metadata updates.
    
    	// allow retry in the case of failure to restore
    	delete(oi.UserDefined, xhttp.AmzRestore)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  6. cmd/format-erasure.go

    		if format == nil {
    			continue
    		}
    		if format.Drives() == maxDrives {
    			format := formats[i].Clone()
    			format.Erasure.This = ""
    			return format, nil
    		}
    	}
    
    	return nil, errErasureReadQuorum
    }
    
    func formatErasureV3Check(reference *formatErasureV3, format *formatErasureV3) error {
    	tmpFormat := format.Clone()
    	this := tmpFormat.Erasure.This
    	tmpFormat.Erasure.This = ""
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-decom.go

    	Decommission *PoolDecommissionInfo `json:"decommissionInfo,omitempty" msg:"dec"`
    }
    
    // Clone returns a copy of PoolStatus
    func (ps PoolStatus) Clone() PoolStatus {
    	return PoolStatus{
    		ID:           ps.ID,
    		CmdLine:      ps.CmdLine,
    		LastUpdate:   ps.LastUpdate,
    		Decommission: ps.Decommission.Clone(),
    	}
    }
    
    //go:generate msgp -file $GOFILE -unexported
    type poolMeta struct {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  8. cmd/admin-handlers-config-kv.go

    	ctx := r.Context()
    
    	objectAPI, cred := validateAdminReq(ctx, w, r, policy.ConfigUpdateAdminAction)
    	if objectAPI == nil {
    		return
    	}
    
    	cfg := globalServerConfig.Clone()
    	vars := mux.Vars(r)
    	key := vars["key"]
    
    	var subSys, target string
    	{
    		ws := strings.SplitN(key, madmin.SubSystemSeparator, 2)
    		subSys = ws[0]
    		if len(ws) == 2 {
    			if ws[1] == "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.7K bytes
    - Viewed (0)
  9. internal/event/targetlist.go

    	wg.Wait()
    	list.totalEvents.Add(1)
    }
    
    func (list *TargetList) sendAsync(event Event, targetIDset TargetIDSet) {
    	select {
    	case list.queue <- asyncEvent{
    		ev:        event,
    		targetSet: targetIDset.Clone(),
    	}:
    	case <-list.ctx.Done():
    		list.eventsSkipped.Add(int64(len(list.queue)))
    		return
    	default:
    		list.eventsSkipped.Add(1)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  10. cmd/tier.go

    	config.RLock()
    	defer config.RUnlock()
    
    	var tierCfgs []madmin.TierConfig
    	for _, tier := range config.Tiers {
    		// This makes a local copy of tier config before
    		// passing a reference to it.
    		tier := tier.Clone()
    		tierCfgs = append(tierCfgs, tier)
    	}
    	return tierCfgs
    }
    
    // Edit replaces the credentials of the remote tier specified by tierName with creds.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
Back to top