Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 78 for colonne (0.15 sec)

  1. cmd/data-usage-cache.go

    	return hashPath(d.Info.Name)
    }
    
    // clone returns a copy of the cache with no references to the existing.
    func (d *dataUsageCache) clone() dataUsageCache {
    	clone := dataUsageCache{
    		Info:  d.Info,
    		Cache: make(map[string]dataUsageEntry, len(d.Cache)),
    	}
    	for k, v := range d.Cache {
    		clone.Cache[k] = v.clone()
    	}
    	return clone
    }
    
    // merge root of other into d.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  2. internal/config/lambda/event/targetidset.go

    type TargetIDSet map[TargetID]struct{}
    
    // IsEmpty returns true if the set is empty.
    func (set TargetIDSet) IsEmpty() bool {
    	return len(set) != 0
    }
    
    // Clone - returns copy of this set.
    func (set TargetIDSet) Clone() TargetIDSet {
    	setCopy := NewTargetIDSet()
    	for k, v := range set {
    		setCopy[k] = v
    	}
    	return setCopy
    }
    
    // add - adds TargetID to the set.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  3. cmd/admin-handlers-idp-config.go

    		return
    	}
    
    	var cfgList []madmin.IDPListItem
    	var err error
    	switch idpCfgType {
    	case madmin.OpenidIDPCfg:
    		cfg := globalServerConfig.Clone()
    		cfgList, err = globalIAMSys.OpenIDConfig.GetConfigList(cfg)
    	case madmin.LDAPIDPCfg:
    		cfg := globalServerConfig.Clone()
    		cfgList, err = globalIAMSys.LDAPConfig.GetConfigList(cfg)
    
    	default:
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  4. internal/config/batch/batch.go

    // would wait before working on next object.
    func (opts Config) KeyRotationWait() time.Duration {
    	configMu.RLock()
    	defer configMu.RUnlock()
    
    	return opts.KeyRotationWorkersWait
    }
    
    // Clone returns a copy of Config value
    func (opts Config) Clone() Config {
    	configMu.RLock()
    	defer configMu.RUnlock()
    
    	return Config{
    		ReplicationWorkersWait: opts.ReplicationWorkersWait,
    		KeyRotationWorkersWait: opts.KeyRotationWorkersWait,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Dec 06 09:09:22 GMT 2023
    - 4.7K bytes
    - Viewed (0)
  5. internal/s3select/sql/statement.go

    		}
    
    		var kvs jstream.KVS
    		switch v := txedRec.(type) {
    		case jstream.KVS:
    			kvs = v
    
    		case []interface{}:
    			recs := make([]*Record, len(v))
    			for i, val := range v {
    				tmpRec := input.Clone(nil)
    				if err = tmpRec.Replace(val); err != nil {
    					return nil, err
    				}
    				recs[i] = &tmpRec
    			}
    			return recs, nil
    
    		default:
    			kvs = jstream.KVS{jstream.KV{Key: "_1", Value: v}}
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 09 17:19:11 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  6. internal/s3select/json/record.go

    	return nil, errors.New("not implemented here")
    }
    
    // Reset the record.
    func (r *Record) Reset() {
    	if len(r.KVS) > 0 {
    		r.KVS = r.KVS[:0]
    	}
    }
    
    // Clone the record and if possible use the destination provided.
    func (r *Record) Clone(dst sql.Record) sql.Record {
    	other, ok := dst.(*Record)
    	if !ok {
    		other = &Record{}
    	}
    	if len(other.KVS) > 0 {
    		other.KVS = other.KVS[:0]
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 5.2K bytes
    - Viewed (0)
  7. internal/config/config.go

    // to operate on list of key values.
    type KVS []KV
    
    // Empty - return if kv is empty
    func (kvs KVS) Empty() bool {
    	return len(kvs) == 0
    }
    
    // Clone - returns a copy of the KVS
    func (kvs KVS) Clone() KVS {
    	return append(make(KVS, 0, len(kvs)), kvs...)
    }
    
    // GetWithDefault - returns default value if key not set
    func (kvs KVS) GetWithDefault(key string, defaultKVS KVS) string {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 37.3K bytes
    - Viewed (0)
  8. cmd/data-scanner-metric.go

    	}
    	val := p.actionsLatency[a].total()
    	return val
    }
    
    // setCycle updates the current cycle metrics.
    func (p *scannerMetrics) setCycle(c *currentScannerCycle) {
    	if c != nil {
    		c2 := c.clone()
    		c = &c2
    	}
    	p.cycleInfoMu.Lock()
    	p.cycleInfo = c
    	p.cycleInfoMu.Unlock()
    }
    
    // getCycle returns the current cycle metrics.
    // If not nil, the returned value can safely be modified.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 25 05:15:31 GMT 2023
    - 9.1K bytes
    - Viewed (0)
  9. cmd/bucket-replication-metrics.go

    	Peak    float64          `json:"peakRate" msg:"p"`
    	N       int64            `json:"n" msg:"n"`
    	measure *rateMeasurement `json:"-"`
    	sma     *SMA             `json:"-"`
    }
    
    // Clone returns a copy of XferStats
    func (rx *XferStats) Clone() *XferStats {
    	curr := rx.curr()
    	peak := rx.Peak
    	if curr > peak {
    		peak = curr
    	}
    	return &XferStats{
    		Curr:    curr,
    		Avg:     rx.Avg,
    		Peak:    peak,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/netns_linux.go

    	}
    	i, err := inodeForFd(n)
    	if err != nil {
    		n.Close()
    		return nil, err
    	}
    	return &NetnsWrapper{innerNetns: n, inode: i}, nil
    }
    
    func NetnsSet(n NetnsFd) error {
    	if err := unix.Setns(int(n.Fd()), unix.CLONE_NEWNET); err != nil {
    		return fmt.Errorf("Error switching to ns fd %v: %v", n.Fd(), err)
    	}
    	return nil
    }
    
    // inspired by netns.Do() but with an existing fd.
    func NetnsDo(fdable NetnsFd, toRun func() error) error {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Jan 31 10:05:36 GMT 2024
    - 2.7K bytes
    - Viewed (0)
Back to top