metric

Nov 26, 2024

Changes in this version

+ const CsiGrpcExecTimeCollectorName

+ const CsiGrpcExecTimeLabelCode

+ const CsiGrpcExecTimeLabelMethod

+ const CsiGrpcExecTimeLabelType

+ const GiBSize

+ const VolumeStatsCollectorName

+ const VolumeStatsLabelCode

+ const VolumeStatsLabelType

+ var CsiGrpcExecTimeCollector = csiGrpcExecTimeCollector

+ var VolumeStatCollector = volumeStatCollector

type Collector

+ func GetCsiGrpcExecTimeCollector() (Collector, error)

+ func GetVolumeStatCollector() (Collector, error)

+ type VolumeStatType uint8

+ const VolumeAttachTimeStat

Apr 10, 2024

Changes in this version

type Collector

+ func NewKubeletStatsSummaryCollector() (Collector, error)

Dec 4, 2023

Changes in this version

+ type StorageMonitorClient struct

+ func NewStorageMonitorClient(kubeClient kubernetes.Interface) *StorageMonitorClient

+ func (c *StorageMonitorClient) GetNasCapacityInfo(pv string) (*nfsCapacityInfo, error)

Aug 8, 2023

Changes in this version

+ const UnknownValue

+ var ErrUnexpectedVolumeType = errors.New("VolumeType is not the expected type")

type Collector

+ func NewLocalStatCollector() (Collector, error)

May 29, 2023

Changes in this version

+ const NFSMetricsCount

Mar 21, 2023

Changes in this version

type Collector

+ func NewFuseStatCollector() (Collector, error)

+ type UDSClient struct

+ func NewUDSClient(socketPath string) *UDSClient

+ func (u *UDSClient) Close(resp *http.Response)

+ func (u *UDSClient) Get(url string) (*http.Response, error)

+ func (u *UDSClient) ReadBody(resp *http.Response) string

Sep 6, 2021

Changes in this version

+ const GBSIZE

+ type HTTPClient struct

+ func NewHTTPClient() *HTTPClient

+ func (h *HTTPClient) Close(response *http.Response)

+ func (h *HTTPClient) Get(key string, val string) (*http.Response, error)

+ func (h *HTTPClient) ReadBody(response *http.Response) string

Mar 30, 2021

Changes in this version

type Collector

+ func NewNfsStatCollector() (Collector, error)

+ type Mount struct

+ Device string

+ Mount string

+ Stats MountStats

+ Type string

+ type MountStats interface

+ type MountStatsNFS struct

+ Age time.Duration

+ Bytes NFSBytesStats

+ Events NFSEventsStats

+ Operations []NFSOperationStats

+ Opts map[string]string

+ StatVersion string

+ Transport NFSTransportStats

+ type NFSBytesStats struct

+ DirectRead uint64

+ DirectWrite uint64

+ Read uint64

+ ReadPages uint64

+ ReadTotal uint64

+ Write uint64

+ WritePages uint64

+ WriteTotal uint64

+ type NFSEventsStats struct

+ AttributeInvalidate uint64

+ CongestionWait uint64

+ DataInvalidate uint64

+ DnodeRevalidate uint64

+ InodeRevalidate uint64

+ JukeboxDelay uint64

+ PNFSRead uint64

+ PNFSWrite uint64

+ ShortRead uint64

+ ShortWrite uint64

+ SillyRename uint64

+ Truncation uint64

+ VFSAccess uint64

+ VFSFileRelease uint64

+ VFSFlush uint64

+ VFSFsync uint64

+ VFSGetdents uint64

+ VFSLock uint64

+ VFSLookup uint64

+ VFSOpen uint64

+ VFSReadPage uint64

+ VFSReadPages uint64

+ VFSSetattr uint64

+ VFSUpdatePage uint64

+ VFSWritePage uint64

+ VFSWritePages uint64

+ WriteExtension uint64

+ type NFSOperationStats struct

+ BytesReceived uint64

+ BytesSent uint64

+ CumulativeQueueMilliseconds uint64

+ CumulativeTotalRequestMilliseconds uint64

+ CumulativeTotalResponseMilliseconds uint64

+ Errors uint64

+ MajorTimeouts uint64

+ Operation string

+ Requests uint64

+ Transmissions uint64

+ type NFSTransportStats struct

+ BadTransactionIDs uint64

+ Bind uint64

+ Connect uint64

+ ConnectIdleTime uint64

+ CumulativeActiveRequests uint64

+ CumulativeBacklog uint64

+ CumulativePendingQueue uint64

+ CumulativeSendingQueue uint64

+ IdleTimeSeconds uint64

+ MaximumRPCSlotsUsed uint64

+ Port uint64

+ Protocol string

+ Receives uint64

+ Sends uint64

Jan 13, 2021

Changes in this version

type Collector

+ func NewPfsRawBlockStatCollector() (Collector, error)

+ type ExecResult struct

+ ExitCode int

Nov 2, 2020

Changes in this version

+ const DiskStorageName

+ const NasStorageName

+ const OssStorageName

+ var ErrNoData = errors.New("Collector returned no data")

+ func ExecCheckOutput(cmd string, args ...string) (io.Reader, error)

+ func FindLines(reader io.Reader, keyword string) []string

+ func GetDeviceByVolumeID(volumeID string) (device string, err error)

+ func IsNoDataError(err error) bool

+ func IsVFNode() bool

+ func NewCSICollector() error

+ type CSICollector struct

+ Collectors map[string]Collector

+ var CSICollectorInstance *CSICollector

+ func (csi CSICollector) Collect(ch chan<- prometheus.Metric)

+ func (csi CSICollector) Describe(ch chan<- *prometheus.Desc)

+ type Collector interface

+ Update func(ch chan<- prometheus.Metric) error

+ func NewDiskStatCollector() (Collector, error)

+ type Handler struct

+ func NewMetricHandler(serviceType string) *Handler

+ func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)