stats

package

Go to main page

Versions in this module

v1

v1.4.2

Jan 15, 2026

Changes in this version

+ const ACLDeniedCount

+ const ACLTotalCount

+ const AuthExpiredTokenCount

+ const AuthFailCount

+ const AuthInvalidIssCount

+ const AuthInvalidKidCount

+ const AuthInvalidTokenCount

+ const AuthIssHist

+ const AuthJWKSHist

+ const AuthNoTokenCount

+ const AuthSuccessCount

+ const AuthTotalCount

+ const KindHistogram

type Extra

+ Buckets []float64

type Prunner

+ func (r *Prunner) Observe(name string, val float64)

type Trunner

+ func (r *Trunner) Observe(name string, val float64)

v1.4.1

Dec 5, 2025

Changes in this version

+ const ErrGetBatchCount

+ const GetBatchCount

+ const GetBatchFileCount

+ const GetBatchFileSize

+ const GetBatchObjCount

+ const GetBatchObjSize

+ const GetBatchRxWaitTotal

+ const GetBatchSoftErrCount

+ const GetBatchThrottleTotal

v1.4.0

Oct 7, 2025

Changes in this version

+ const ErrGetBlobCount

+ const GetBlobCount

+ const GetBlobSize

+ const NgrPrompt

v1.3.31

Jul 25, 2025

v1.3.30

Jul 21, 2025

Changes in this version

+ const ETLInlineCount

+ const ETLInlineLatencyTotal

+ const ETLInlineSize

+ const ETLOfflineSize

v1.3.29

May 22, 2025

v1.3.28

May 9, 2025

Changes in this version

+ const ETLOfflineCount

+ const ETLOfflineLatencyTotal

+ const ErrDloadCount

+ const RatelimGetRetryCount

+ const RatelimGetRetryLatencyTotal

+ const RatelimPutRetryCount

+ const RatelimPutRetryLatencyTotal

+ const VlabBucket

+ const VlabMountpath

+ const VlabXkind

+ var BckVlabs = []string

+ var BckXlabs = []string

+ var EmptyBckVlabs = map[string]string

+ var EmptyBckXlabs = map[string]string

v1.3.27

Feb 14, 2025

v1.3.26

Feb 7, 2025

Changes in this version

+ const ConstlabNode

+ const DloadLatencyTotal

+ const DloadSize

+ const ErrPutCksumCount

+ const LcacheErrCount

+ const VarlabBucket

+ const VarlabMountpath

+ const VarlabXactID

+ const VarlabXactKind

+ var BckVarlabs = []string

+ var BckXactVarlabs = []string

+ var MpathVarlabs = []string

+ func SizeToThroughputCount(name, kind string) (string, string)

type Extra

+ VarLabs []string

type Prunner

+ func (*Prunner) PromHandler() http.Handler

+ func (r *Prunner) AddWith(nvs ...cos.NamedVal64)

+ func (r *Prunner) IncBck(name string, bck *cmn.Bck)

+ func (r *Prunner) IncWith(name string, vlabs map[string]string)

type Tracker

+ Inc func(metric string)

+ IncBck func(name string, bck *cmn.Bck)

+ IncWith func(metric string, vlabs map[string]string)

+ PromHandler func() http.Handler

type Trunner

+ func (*Trunner) PromHandler() http.Handler

+ func (r *Trunner) AddWith(nvs ...cos.NamedVal64)

+ func (r *Trunner) IncBck(name string, bck *cmn.Bck)

+ func (r *Trunner) IncWith(name string, vlabs map[string]string)

v1.3.25

Oct 6, 2024

v1.3.24

Sep 27, 2024

Changes in this version

+ const ErrAppendCount

+ const ErrFSHCCount

+ const ErrKaliveCount

+ const ErrRenameCount

+ const GetE2ELatencyTotal

+ const GetLatencyTotal

+ const HeadCount

+ const HeadLatency

+ const HeadLatencyTotal

+ const IOErrDeleteCount

+ const IOErrGetCount

+ const IOErrPutCount

+ const KindTotal

+ const NodeAlerts

+ const PutE2ELatencyTotal

+ const PutLatencyTotal

+ func IsIOErrMetric(name string) bool

+ func LatencyToCounter(latency string) string

+ type Extra struct

+ Help string

+ Labels cos.StrKVs

+ StrName string

type Node

+ Tcdf fs.Tcdf

type NodeV322

+ Tcdf fs.TargetCDFv322

type Prunner

+ func (r *Prunner) ClrFlag(name string, clr cos.NodeStateFlags)

+ func (r *Prunner) RegExtMetric(snode *meta.Snode, name, kind string, extra *Extra)

+ func (r *Prunner) SetClrFlag(name string, set, clr cos.NodeStateFlags)

+ func (r *Prunner) SetFlag(name string, set cos.NodeStateFlags)

type Tracker

+ RegExtMetric func(node *meta.Snode, name, kind string, extra *Extra)

type Trunner

+ Tcdf fs.Tcdf

+ func (r *Trunner) ClrFlag(name string, clr cos.NodeStateFlags)

+ func (r *Trunner) RegExtMetric(snode *meta.Snode, name, kind string, extra *Extra)

+ func (r *Trunner) SetClrFlag(name string, set, clr cos.NodeStateFlags)

+ func (r *Trunner) SetFlag(name string, set cos.NodeStateFlags)

v1.3.23

May 27, 2024

Changes in this version

+ const NodeStateFlags

type NodeStatus

+ Cluster cos.NodeStateInfo

+ Reserved1 string

+ Reserved2 string

+ Reserved3 int64

+ Reserved4 int64

+ type NodeStatusV322 struct

+ BuildTime string

+ DeploymentType string

+ K8sPodName string

+ MemCPUInfo apc.MemCPUInfo

+ RebSnap *core.Snap

+ SmapVersion int64

+ Status string

+ Version string

+ type NodeV322 struct

+ Snode *meta.Snode

+ TargetCDF fs.TargetCDFv322

+ Tracker copyTracker

type Prunner

+ func (r *Prunner) Flag(name string, set, clr cos.NodeStateFlags)

+ func (r *Prunner) GetStatsV322() (out *NodeV322)

type Tracker

+ GetStatsV322 func() *NodeV322

type Trunner

+ func (r *Trunner) Flag(name string, set, clr cos.NodeStateFlags)

+ func (r *Trunner) GetStatsV322() (out *NodeV322)

v1.3.22

Feb 25, 2024

Changes in this version

+ const RemoteDeletedDelCount

v1.3.21

Nov 5, 2023

Changes in this version

+ const DsortCreationReqCount

+ const DsortCreationRespCount

+ const DsortCreationRespLatency

+ const DsortExtractShardDskCnt

+ const DsortExtractShardMemCnt

+ const DsortExtractShardSize

+ const GetColdRwLatency

+ const LcacheCollisionCount

+ const LcacheEvictedCount

+ const LcacheFlushColdCount

v1.3.20

Sep 12, 2023

Changes in this version

+ const DSortExtractShardDskCnt

+ const DSortExtractShardMemCnt

+ const DSortExtractShardSize

v1.3.19

Aug 29, 2023

v1.3.18

Jul 9, 2023

v1.3.17

Apr 10, 2023

v1.3.16

Mar 31, 2023

Changes in this version

+ const ErrHTTPWriteCount

+ const ErrPutMirrorCount

+ const GetSize

+ const KindSize

+ const PutSize

+ const PutThroughput

+ func IsErrMetric(name string) bool

+ type Cluster struct

+ Proxy *Node

+ Target map[string]*Node

+ type ClusterRaw struct

+ Proxy *Node

+ Target cos.JSONRawMsgs

+ type Node struct

+ Snode *cluster.Snode

+ TargetCDF fs.TargetCDF

+ Tracker copyTracker

+ type NodeStatus struct

+ BuildTime string

+ DeploymentType string

+ K8sPodName string

+ MemCPUInfo apc.MemCPUInfo

+ RebSnap *cluster.Snap

+ SmapVersion int64

+ Status string

+ Version string

type Prunner

+ func (r *Prunner) GetMetricNames() cos.StrKVs

+ func (r *Prunner) GetStats() *Node

+ func (r *Prunner) Inc(name string)

+ func (r *Prunner) IncErr(metric string)

+ func (r *Prunner) ResetStats(errorsOnly bool)

type Tracker

+ GetMetricNames func() cos.StrKVs

+ GetStats func() *Node

+ IncErr func(metric string)

+ ResetStats func(errorsOnly bool)

type Trunner

+ TargetCDF fs.TargetCDF

+ func NewTrunner(t cluster.NodeMemCap) *Trunner

+ func (r *Trunner) GetMetricNames() cos.StrKVs

+ func (r *Trunner) GetStats() (ds *Node)

+ func (r *Trunner) Inc(name string)

+ func (r *Trunner) IncErr(metric string)

+ func (r *Trunner) InitCDF() error

+ func (r *Trunner) ResetStats(errorsOnly bool)

v1.3.15

Nov 13, 2022

v1.3.13

Nov 9, 2022

Changes in this version

+ func IsKindThroughput(name string) bool

v1.3.12

Nov 7, 2022

Changes in this version

+ const AppendCount

+ const AppendLatency

+ const CleanupStoreCount

+ const CleanupStoreSize

+ const DSortCreationReqCount

+ const DSortCreationReqLatency

+ const DSortCreationRespCount

+ const DSortCreationRespLatency

+ const DeleteCount

+ const DownloadLatency

+ const DownloadSize

+ const ErrCksumCount

+ const ErrCksumSize

+ const ErrCount

+ const ErrDeleteCount

+ const ErrDownloadCount

+ const ErrGetCount

+ const ErrHeadCount

+ const ErrIOCount

+ const ErrListCount

+ const ErrMetadataCount

+ const ErrPostCount

+ const ErrPutCount

+ const ErrRangeCount

+ const GetColdCount

+ const GetColdSize

+ const GetCount

+ const GetLatency

+ const GetRedirLatency

+ const GetThroughput

+ const KeepAliveLatency

+ const KindComputedThroughput

+ const KindCounter

+ const KindGauge

+ const KindLatency

+ const KindSpecial

+ const KindThroughput

+ const ListCount

+ const ListLatency

+ const LruEvictCount

+ const LruEvictSize

+ const PutCount

+ const PutLatency

+ const PutRedirLatency

+ const RenameCount

+ const RestartCount

+ const StreamsInObjCount

+ const StreamsInObjSize

+ const StreamsOutObjCount

+ const StreamsOutObjSize

+ const Uptime

+ const VerChangeCount

+ const VerChangeSize

+ type ClusterStats struct

+ Proxy *DaemonStats

+ Target map[string]*DaemonStats

+ type ClusterStatsRaw struct

+ Proxy *DaemonStats

+ Target cos.JSONRawMsgs

+ type CoreStats struct

+ Tracker statsTracker

+ func (s *CoreStats) MarshalJSON() ([]byte, error)

+ func (s *CoreStats) UnmarshalJSON(b []byte) error

+ type DaemonStats struct

+ MPCap fs.MPCap

+ Tracker copyTracker

+ type DaemonStatus struct

+ BuildTime string

+ Capacity fs.MPCap

+ DeploymentType string

+ K8sPodName string

+ MemCPUInfo cos.MemCPUInfo

+ RebSnap *RebalanceSnap

+ SmapVersion int64

+ Snode *cluster.Snode

+ Stats *CoreStats

+ Status string

+ Version string

+ type DaemonStatusMap map[string]*DaemonStatus

+ type Prunner struct

+ func (r *Prunner) Add(name string, val int64)

+ func (r *Prunner) AddErrorHTTP(method string, val int64)

+ func (r *Prunner) AddMany(nvs ...cos.NamedVal64)

+ func (r *Prunner) Collect(ch chan<- prometheus.Metric)

+ func (r *Prunner) CoreStats() *CoreStats

+ func (r *Prunner) Describe(ch chan<- *prometheus.Desc)

+ func (r *Prunner) Get(name string) (val int64)

+ func (r *Prunner) GetWhatStats() *DaemonStats

+ func (r *Prunner) Init(p cluster.Node) *atomic.Bool

+ func (r *Prunner) IsPrometheus() bool

+ func (r *Prunner) Name() string

+ func (r *Prunner) RegMetrics(node *cluster.Snode)

+ func (r *Prunner) Run() error

+ func (r *Prunner) StartedUp() bool

+ func (r *Prunner) Stop(err error)

+ type RebalanceSnap struct

+ RebID int64

+ type Tracker interface

+ AddErrorHTTP func(method string, val int64)

+ CoreStats func() *CoreStats

+ GetWhatStats func() *DaemonStats

+ IsPrometheus func() bool

+ RegMetrics func(node *cluster.Snode)

+ StartedUp func() bool

+ type Trunner struct

+ MPCap fs.MPCap

+ T cluster.Target

+ func (r *Trunner) Add(name string, val int64)

+ func (r *Trunner) AddErrorHTTP(method string, val int64)

+ func (r *Trunner) AddMany(nvs ...cos.NamedVal64)

+ func (r *Trunner) Collect(ch chan<- prometheus.Metric)

+ func (r *Trunner) CoreStats() *CoreStats

+ func (r *Trunner) Describe(ch chan<- *prometheus.Desc)

+ func (r *Trunner) Get(name string) (val int64)

+ func (r *Trunner) GetWhatStats() (ds *DaemonStats)

+ func (r *Trunner) Init(t cluster.Target) *atomic.Bool

+ func (r *Trunner) InitCapacity() error

+ func (r *Trunner) IsPrometheus() bool

+ func (r *Trunner) Name() string

+ func (r *Trunner) RegDiskMetrics(disk string)

+ func (r *Trunner) RegMetrics(node *cluster.Snode)

+ func (r *Trunner) Run() error

+ func (r *Trunner) Standby(v bool)

+ func (r *Trunner) StartedUp() bool

+ func (r *Trunner) Stop(err error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL