Versions in this module Expand all Collapse all v1 v1.0.5 Apr 8, 2024 v1.0.3 Apr 8, 2024 Changes in this version + var Usage = ... + type AsyncClusterMonitor struct + Consumer *stat_consumer.StatConsumer + Discover bool + ErrorChan chan *status.NodeError + LastStatLines map[string]*line.StatLine + ReportChan chan *status.ServerStatus + func (cluster *AsyncClusterMonitor) Monitor(sleep time.Duration) error + func (cluster *AsyncClusterMonitor) Update(stat *status.ServerStatus, err *status.NodeError) + type ClusterMonitor interface + Monitor func(sleep time.Duration) error + Update func(stat *status.ServerStatus, err *status.NodeError) + type ConfigShard struct + Host string + Id string + type MongoStat struct + Cluster ClusterMonitor + Discovered chan string + Nodes map[string]*NodeMonitor + Options *options.ToolOptions + SleepInterval time.Duration + StatOptions *StatOptions + func (mstat *MongoStat) AddNewNode(fullhost string) error + func (mstat *MongoStat) Run() error + type NodeMonitor struct + Err error + LastUpdate time.Time + func NewNodeMonitor(opts options.ToolOptions, fullHost string) (*NodeMonitor, error) + func (node *NodeMonitor) Disconnect() + func (node *NodeMonitor) Poll(discover chan string, checkShards bool) (*status.ServerStatus, error) + func (node *NodeMonitor) Watch(sleep time.Duration, discover chan string, cluster ClusterMonitor) + type Options struct + SleepInterval int + func ParseOptions(rawArgs []string, versionStr, gitCommit string) (Options, error) + type StatOptions struct + All bool + AppendColumns string + Columns string + Deprecated bool + Discover bool + Http bool + HumanReadable string + Interactive bool + Json bool + NoHeaders bool + RowCount int64 + func (*StatOptions) Name() string + type SyncClusterMonitor struct + Consumer *stat_consumer.StatConsumer + ErrorChan chan *status.NodeError + ReportChan chan *status.ServerStatus + func (cluster *SyncClusterMonitor) Monitor(_ time.Duration) error + func (cluster *SyncClusterMonitor) Update(stat *status.ServerStatus, err *status.NodeError)
Go to main page