Documentation
¶
Index ¶
- type BlkStats
- type CPUStats
- type Cluster
- type Data
- func (s *Data) ArbitratorNames() []string
- func (s *Data) DeepCopy() *Data
- func (s *Data) GetNodeData(nodename string) *node.Node
- func (s *Data) GetNodeStatus(nodename string) *node.Status
- func (s *Data) GetObjectStatus(p naming.Path) object.Digest
- func (s *Data) ObjectPaths() naming.Paths
- func (s *Data) WithNamespace(namespaces ...string) *Data
- func (s *Data) WithSelector(selector string) *Data
- type MemStats
- type NetStats
- type NodeStatsBundle
- type ObjectStats
- type Stats
- type Status
- type ThreadStats
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlkStats ¶
type BlkStats struct {
Read uint64 `json:"r"`
ReadByte uint64 `json:"rb"`
Write uint64 `json:"w"`
WriteByte uint64 `json:"wb"`
}
BlkStats holds block devices resource usage metrics.
type CPUStats ¶
type CPUStats struct {
Time uint64 `json:"time"`
}
CPUStats holds CPU resource usage metrics.
type Data ¶
type Data struct {
Cluster Cluster `json:"cluster"`
Daemon daemonsubsystem.DaemonLocal `json:"daemon"`
}
Data describes the full Cluster state.
func (*Data) ArbitratorNames ¶
func (*Data) GetNodeData ¶
GetNodeData extracts from the cluster dataset all information relative to node data.
func (*Data) GetNodeStatus ¶
GetNodeStatus extracts from the cluster dataset all information relative to node status.
func (*Data) GetObjectStatus ¶
GetObjectStatus extracts from the cluster dataset all information relative to an object.
func (*Data) ObjectPaths ¶
func (*Data) WithNamespace ¶
WithNamespace purges the dataset from objects not matching the namespace
func (*Data) WithSelector ¶
WithSelector purges the dataset from objects not matching the selector expression
type MemStats ¶
type MemStats struct {
Total uint64 `json:"total"`
}
MemStats holds CPU resource usage metrics.
type NetStats ¶
type NetStats struct {
Read uint64 `json:"r"`
ReadByte uint64 `json:"rb"`
Write uint64 `json:"w"`
WriteByte uint64 `json:"wb"`
}
NetStats holds network resource usage metrics.
type NodeStatsBundle ¶
type NodeStatsBundle struct {
Time time.Time `json:"time"`
Collector ThreadStats `json:"collector"`
Daemon ThreadStats `json:"daemon"`
DNS ThreadStats `json:"dns"`
Scheduler ThreadStats `json:"scheduler"`
Listener ThreadStats `json:"listener"`
Monitor ThreadStats `json:"monitor"`
Heartbeats map[string]ThreadStats `json:"-"`
Objects map[string]ObjectStats `json:"objects"`
}
NodeStatsBundle embeds all daemon threads and each object system resource usage metrics.
func (*NodeStatsBundle) UnmarshalJSON ¶
func (t *NodeStatsBundle) UnmarshalJSON(b []byte) error
UnmarshalJSON loads a byte array into a DaemonStatus struct
type ObjectStats ¶
type ObjectStats struct {
Blk BlkStats `json:"blk"`
Net NetStats `json:"net"`
Mem MemStats `json:"mem"`
CPU CPUStats `json:"cpu"`
Tasks uint64 `json:"tasks"`
CreatedAt time.Time `json:"created_at"`
}
ObjectStats holds an object (ie cgroup) system resource usage metrics