Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 175 for QStats (0.06 sec)

  1. istioctl/pkg/writer/compare/testdata/configdump.json

                              },
                              {
                                "name": "istio.stats",
                                "typed_config": {
                                  "@type": "type.googleapis.com/udpa.type.v1.TypedStruct",
                                  "type_url": "type.googleapis.com/stats.PluginConfig",
                                  "value": {
                                    "reporter": "SERVER_GATEWAY"
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Mar 12 10:02:09 UTC 2024
    - 52K bytes
    - Viewed (0)
  2. internal/disk/stat_openbsd.go

    	}
    	info.Used = info.Total - info.Free
    	return info, nil
    }
    
    // GetDriveStats returns IO stats of the drive by its major:minor
    func GetDriveStats(major, minor uint32) (iostats IOStats, err error) {
    	return IOStats{}, errors.New("operation unsupported")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  3. internal/disk/disk.go

    	Used       uint64
    	Files      uint64
    	Ffree      uint64
    	FSType     string
    	Major      uint32
    	Minor      uint32
    	Name       string
    	Rotational *bool
    	NRRequests uint64
    }
    
    // IOStats contains stats of a single drive
    type IOStats struct {
    	ReadIOs        uint64
    	ReadMerges     uint64
    	ReadSectors    uint64
    	ReadTicks      uint64
    	WriteIOs       uint64
    	WriteMerges    uint64
    	WriteSectors   uint64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  4. internal/logger/target/kafka/kafka.go

    func (h *Target) Endpoint() string {
    	return "kafka"
    }
    
    // String - kafka string
    func (h *Target) String() string {
    	return "kafka"
    }
    
    // Stats returns the target statistics.
    func (h *Target) Stats() types.TargetStats {
    	h.logChMu.RLock()
    	queueLength := len(h.logCh)
    	h.logChMu.RUnlock()
    
    	return types.TargetStats{
    		TotalMessages:  atomic.LoadInt64(&h.totalMessages),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  5. internal/disk/stat_windows.go

    		uintptr(unsafe.Pointer(&lpTotalNumberOfClusters)))
    
    	info.Files = uint64(lpTotalNumberOfClusters)
    	info.Ffree = uint64(lpNumberOfFreeClusters)
    
    	return info, nil
    }
    
    // GetDriveStats returns IO stats of the drive by its major:minor
    func GetDriveStats(major, minor uint32) (iostats IOStats, err error) {
    	return IOStats{}, errors.New("operation unsupported")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  6. internal/config/identity/plugin/config.go

    type Metrics struct {
    	LastReachableSecs, LastUnreachableSecs float64
    
    	// Last whole minute stats
    	TotalRequests, FailedRequests int64
    	AvgSuccRTTMs                  float64
    	MaxSuccRTTMs                  float64
    }
    
    // Metrics reports metrics related to plugin service reachability and stats for the last whole minute
    func (o *AuthNPlugin) Metrics() Metrics {
    	if o == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. internal/grid/grid_test.go

    		runtime.Gosched()
    		stats := c.Stats()
    		if stats.IncomingStreams != 0 {
    			if i > 0 {
    				time.Sleep(100 * time.Millisecond)
    				continue
    			}
    			var found []uint64
    			c.inStream.Range(func(key uint64, value *muxServer) bool {
    				found = append(found, key)
    				return true
    			})
    			t.Errorf("expected no active streams, got %d incoming: %v", stats.IncomingStreams, found)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java

    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 14K bytes
    - Viewed (0)
  9. internal/s3select/progress.go

    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return nil
    	}
    	pr.closed = true
    	if pr.closer != nil {
    		pr.closer.Close()
    	}
    	return pr.rc.Close()
    }
    
    func (pr *progressReader) Stats() (bytesScanned, bytesProcessed int64) {
    	if pr == nil {
    		return 0, 0
    	}
    	return pr.scannedReader.BytesRead(), pr.processedReader.BytesRead()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  10. internal/disk/stat_linux_32bit.go

    	}
    	info.Used = info.Total - info.Free
    	return info, nil
    }
    
    // GetDriveStats returns IO stats of the drive by its major:minor
    func GetDriveStats(major, minor uint32) (iostats IOStats, err error) {
    	return IOStats{}, errors.New("operation unsupported")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 2.6K bytes
    - Viewed (0)
Back to top