Versions in this module Expand all Collapse all v1 v1.0.5 Nov 9, 2021 v1.0.4 Nov 9, 2021 v1.0.3 Nov 9, 2021 v1.0.2 Nov 4, 2021 v1.0.1 Nov 3, 2021 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