Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for TS (0.15 sec)

  1. internal/s3select/parquet/reader.go

    			if ts := logicalType.GetTIMESTAMP(); ts != nil {
    				var duration time.Duration
    				// Only support UTC normalized timestamps.
    				if ts.IsAdjustedToUTC {
    					switch {
    					case ts.Unit.IsSetNANOS():
    						duration = time.Duration(val) * time.Nanosecond
    					case ts.Unit.IsSetMILLIS():
    						duration = time.Duration(val) * time.Millisecond
    					case ts.Unit.IsSetMICROS():
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 14 13:54:47 GMT 2022
    - 4.5K bytes
    - Viewed (0)
  2. cmd/tier-last-day-stats.go

    //go:generate msgp -file=$GOFILE -unexported
    
    type lastDayTierStats struct {
    	Bins      [24]tierStats
    	UpdatedAt time.Time
    }
    
    func (l *lastDayTierStats) addStats(ts tierStats) {
    	now := time.Now()
    	l.forwardTo(now)
    
    	nowIdx := now.Hour()
    	l.Bins[nowIdx] = l.Bins[nowIdx].add(ts)
    }
    
    // forwardTo moves time to t, clearing entries between last update and t.
    func (l *lastDayTierStats) forwardTo(t time.Time) {
    	if t.IsZero() {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  3. internal/s3select/sql/funceval.go

    	if !ok {
    		return nil, fmt.Errorf("QUANTITY must be a numeric argument to %s()", sqlFnDateAdd)
    	}
    
    	ts, err := d.Timestamp.evalNode(r, tableAlias)
    	if err != nil {
    		return nil, err
    	}
    	if err = inferTypeAsTimestamp(ts); err != nil {
    		return nil, err
    	}
    	t, ok := ts.ToTimestamp()
    	if !ok {
    		return nil, fmt.Errorf("%s() expects a timestamp argument", sqlFnDateAdd)
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 13.2K bytes
    - Viewed (0)
  4. cmd/bucket-lifecycle.go

    					}
    				}
    			} else {
    				ts := tierStats{
    					TotalSize:   uint64(task.objInfo.Size),
    					NumVersions: 1,
    				}
    				if task.objInfo.IsLatest {
    					ts.NumObjects = 1
    				}
    				t.addLastDayStats(task.event.StorageClass, ts)
    			}
    			t.activeTasks.Add(-1)
    		}
    	}
    }
    
    func (t *transitionState) addLastDayStats(tier string, ts tierStats) {
    	t.lastDayMu.Lock()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  5. cmd/data-usage-cache.go

    type tierStats struct {
    	TotalSize   uint64 `msg:"ts"`
    	NumVersions int    `msg:"nv"`
    	NumObjects  int    `msg:"no"`
    }
    
    func (ts tierStats) add(u tierStats) tierStats {
    	return tierStats{
    		TotalSize:   ts.TotalSize + u.TotalSize,
    		NumVersions: ts.NumVersions + u.NumVersions,
    		NumObjects:  ts.NumObjects + u.NumObjects,
    	}
    }
    
    //msgp:tuple replicationStatsV1
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  6. cmd/metrics-v3-system-cpu.go

    		m.Set(sysCPULoadPerc, math.Round(perc*100)/100)
    	}
    
    	ts := cpuMetrics.TimesStat
    	tot := ts.User + ts.System + ts.Idle + ts.Iowait + ts.Nice + ts.Steal
    	cpuUserVal := math.Round(ts.User/tot*100*100) / 100
    	m.Set(sysCPUUser, cpuUserVal)
    	cpuSystemVal := math.Round(ts.System/tot*100*100) / 100
    	m.Set(sysCPUSystem, cpuSystemVal)
    	cpuNiceVal := math.Round(ts.Nice/tot*100*100) / 100
    	m.Set(sysCPUNice, cpuNiceVal)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 3K bytes
    - Viewed (0)
  7. cmd/metrics-resource.go

    			}
    			if hm.CPU != nil {
    				labels := map[string]string{}
    				ts := hm.CPU.TimesStat
    				if ts != nil {
    					tot := ts.User + ts.System + ts.Idle + ts.Iowait + ts.Nice + ts.Steal
    					cpuUserVal := math.Round(ts.User/tot*100*100) / 100
    					updateResourceMetrics(cpuSubsystem, cpuUser, cpuUserVal, labels, false)
    					cpuSystemVal := math.Round(ts.System/tot*100*100) / 100
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 17.4K bytes
    - Viewed (0)
  8. cmd/data-usage-utils.go

    	if dui.TierStats == nil {
    		return nil
    	}
    
    	if globalTierConfigMgr.Empty() {
    		return nil
    	}
    
    	ts := make(map[string]madmin.TierStats)
    	dui.TierStats.populateStats(ts)
    
    	infos := make([]madmin.TierInfo, 0, len(ts))
    	for tier, stats := range ts {
    		infos = append(infos, madmin.TierInfo{
    			Name:  tier,
    			Type:  globalTierConfigMgr.TierType(tier),
    			Stats: stats,
    		})
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  9. cmd/data-usage-cache_gen.go

    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 1
    	// string "ts"
    	o = append(o, 0x81, 0xa2, 0x74, 0x73)
    	o = msgp.AppendMapHeader(o, uint32(len(z.Tiers)))
    	for za0001, za0002 := range z.Tiers {
    		o = msgp.AppendString(o, za0001)
    		// map header, size 3
    		// string "ts"
    		o = append(o, 0x83, 0xa2, 0x74, 0x73)
    		o = msgp.AppendUint64(o, za0002.TotalSize)
    		// string "nv"
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 100.8K bytes
    - Viewed (0)
  10. cmd/bucket-targets.go

    func (sys *BucketTargetSys) ListTargets(ctx context.Context, bucket, arnType string) (targets []madmin.BucketTarget) {
    	h := sys.healthStats()
    
    	if bucket != "" {
    		if ts, err := sys.ListBucketTargets(ctx, bucket); err == nil {
    			for _, t := range ts.Targets {
    				if string(t.Type) == arnType || arnType == "" {
    					if hs, ok := h[t.URL().Host]; ok {
    						t.TotalDowntime = hs.offlineDuration
    						t.Online = hs.Online
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.9K bytes
    - Viewed (0)
Back to top