mdb

Jan 8, 2020

Changes in this version

+ func GetShardListWithURI(client *mongo.Client, uri string) ([]string, error)

type MongoCluster

+ func (mc *MongoCluster) SetConnString(connString connstring.ConnString)

type ServerInfo

+ Shards []ShardDoc

Dec 19, 2019

Changes in this version

type MongoCluster

+ func (mc *MongoCluster) SetDoodleMode(doodle bool)

+ func (mc *MongoCluster) SetFilename(filename string)

+ func (mc *MongoCluster) SetHost(host string)

type OplogStats

+ LogSizeMB int

+ TimeDiff int

+ UsedMB int

Aug 30, 2023

Changes in this version

type LogInfo

+ DBVersion string

Aug 2, 2022

Changes in this version

type LogInfo

+ Histograms []Histogram

type OpPattern

+ TotalReslen int64

+ type RawLog struct

+ Log string

+ Milli int

Jan 19, 2022

Changes in this version

+ func GetQueryParams(connString connstring.ConnString, isConnectDirect bool) string

type ClusterStats

+ func (p *ClusterStats) SetFastMode(fastMode bool)

type DatabaseStats

+ func (p *DatabaseStats) SetFastMode(fastMode bool)

type IndexStats

+ func (ix *IndexStats) SetFastMode(fastMode bool)

Dec 4, 2021

Changes in this version

type ClusterStats

+ func (p *ClusterStats) SetDBNames(dbNames []string)

Nov 30, 2021

Changes in this version

type Shard

+ Tags []string

Nov 11, 2021

Changes in this version

type DatabaseStats

+ func (p *DatabaseStats) SetNumberShards(n int)

type Index

+ Weights bson.D

type IndexStats

+ func (ix *IndexStats) CopyIndexes(client *mongo.Client, isDrop bool, namespaces ...[]string) error

+ func (ix *IndexStats) CopyIndexesWithDest(client *mongo.Client, namespaces []IndexNS, isDrop bool) error

Jun 29, 2019

Changes in this version

type ExplainCommand

+ func ReadQueryShape(buffer []byte) (ExplainCommand, string, error)

type MongoCluster

+ func (mc *MongoCluster) SetOutputFilename(filename string)

Jun 2, 2019

Changes in this version

+ func MilliToTimeString(milli float64) string

type LogInfo

+ OpsPatterns []OpPerformanceDoc

+ OutputFilename string

+ func (li *LogInfo) Analyze() (string, error)

+ type OpPerformanceDoc struct

+ Command string

+ Count int

+ Filter string

+ Index string

+ MaxMilli int

+ Namespace string

+ Scan string

+ TotalMilli int

type QueryExplainer

+ ExplainDoc ExplainCommand

+ func (qe *QueryExplainer) ReadQueryShapeFromFile(filename string) error

+ func (qe *QueryExplainer) SetCollection(collection string)

+ func (qe *QueryExplainer) SetDatabase(database string)

May 6, 2019

Changes in this version

+ type AccessesDoc struct

+ Ops int

+ Since time.Time

type IndexStatsDoc

+ Fields []string

+ IsDupped bool

+ IsShardKey bool

+ Name string

+ TotalOps int

+ type IndexesReader struct

+ func NewIndexesReader(client *mongo.Client) *IndexesReader

+ func (ir *IndexesReader) GetIndexes() (bson.M, error)

+ func (ir *IndexesReader) GetIndexesFromCollection(collection *mongo.Collection) []IndexStatsDoc

+ func (ir *IndexesReader) GetIndexesFromDB(dbName string) (bson.M, error)

+ func (ir *IndexesReader) Print(indexesMap bson.M)

+ func (ir *IndexesReader) SetDBName(dbName string)

+ func (ir *IndexesReader) SetVerbose(verbose bool)

type MongoCluster

+ func (mc *MongoCluster) WriteGzippedJSON(filename string) error

type UsageDoc

+ Accesses AccessesDoc

+ Host string

Mar 28, 2019

Changes in this version

+ func GetStorageSize(num interface{}) string

+ type MongoCluster struct

+ func NewMongoCluster(client *mongo.Client) *MongoCluster

+ func (mc *MongoCluster) GetClusterInfo() (bson.M, error)

+ func (mc *MongoCluster) SetVerbose(verbose bool)

+ func (mc *MongoCluster) WriteJSON(filename string) error

Aug 26, 2021

Changes in this version

+ func OutputLogInOldFormat(filename string) error

+ type LogVersion2 struct

+ Attributes struct{ ... }

+ Component string

+ Context string

+ DateTime primitive.DateTime

+ ID int

+ Message string

+ Severity string

Aug 17, 2021

Changes in this version

+ const TopologyConnectionError

Jun 12, 2021

Changes in this version

+ const Debug

+ const Error

+ const Info

+ const Trace

+ const Warn

+ func DoesFileExist(filename string) bool

+ type IndexNS struct

+ From string

+ To string

type IndexStats

+ func (ix *IndexStats) CreateIndexesWithDest(client *mongo.Client, namespaces []IndexNS) error

type Logger

+ func GetLogger(fullVersion string) *Logger

+ func (p *Logger) Debug(v ...interface{})

+ func (p *Logger) Debugf(format string, v ...interface{})

+ func (p *Logger) Errorf(format string, v ...interface{})

+ func (p *Logger) Infof(format string, v ...interface{})

+ func (p *Logger) SetLoggerLevel(level int)

+ func (p *Logger) Trace(v ...interface{})

+ func (p *Logger) Tracef(format string, v ...interface{})

+ func (p *Logger) Warnf(format string, v ...interface{})

Apr 9, 2021

Changes in this version

type ServerStatus

+ WiredTiger struct{ ... }

Jan 31, 2021

Changes in this version

+ func SkipNamespace(namespace string, namespaceMap map[string]bool) bool

+ func SplitNamespace(namespace string) (string, string)

+ func ToInt(num interface{}) int

+ func ToInt32(num interface{}) int32

type ClusterStats

+ func NewClusterStats(version string) *ClusterStats

type DatabaseStats

+ Logger *Logger

Jan 15, 2021

Changes in this version

+ var CodeBlue = "\x1b[34;1m"

+ var CodeDefault = "\x1b[0m"

+ var CodeGreen = "\x1b[32;1m"

+ var CodeRed = "\x1b[31;1m"

+ var CodeYellow = "\x1b[33;1m"

+ func GetDatabaseNames(client *mongo.Client) ([]string, error)

+ func GetErrorCode(err error) int

+ func IsDuplicateKeyError(err error) bool

+ func IsUnauthorizedError(err error) bool

type Logger

+ func (p *Logger) Error(v ...interface{})

+ func (p *Logger) Info(v ...interface{})

+ func (p *Logger) Warning(message string)

Oct 22, 2020

Changes in this version

+ const COLLSCAN

+ const Replica

+ const Sharded

+ const Standalone

+ var ExamplesCollection = "__examples"

+ var KeyholeDB = "_KEYHOLE_88800"

+ func GetAllServerURIs(shards []Shard, connString connstring.ConnString) ([]string, error)

+ func GetAllShardURIs(shards []Shard, connString connstring.ConnString) ([]string, error)

+ func GetClusterType(serverStatus ServerStatus) string

+ func GetIndexSuggestion(explain ExplainCommand, cardList []CardinalityCount) gox.OrderedMap

+ func GetKeys(document bson.D, _range ...bool) []string

+ func ParseURI(uri string) (connstring.ConnString, error)

+ func ToFloat64(num interface{}) float64

+ func ToInt64(num interface{}) int64

+ type Accesses struct

+ Ops int

+ Since time.Time

+ type BSONPrinter struct

+ func NewBSONPrinter(version string) *BSONPrinter

+ func (p *BSONPrinter) Print(filename string) error

+ func (p *BSONPrinter) SetNoColor(nocolor bool)

+ type BuildInfo struct

+ GitVersion string

+ Modules []string

+ Version string

+ func GetBuildInfo(client *mongo.Client) (BuildInfo, error)

type Cardinality

+ func (card *Cardinality) GetCardinalityArray(database string, collection string, keys ...[]string) (CardinalitySummary, error)

+ func (card *Cardinality) GetSummary(summary CardinalitySummary) string

+ type CardinalityCount struct

+ Count int64

+ Field string

+ type CardinalitySummary struct

+ List []CardinalityCount

+ SampledCount int64

+ type ChangeStream struct

+ func NewChangeStream() *ChangeStream

+ func (cs *ChangeStream) SetCollection(collection string)

+ func (cs *ChangeStream) SetDatabase(database string)

+ func (cs *ChangeStream) SetPipeline(pipeline []bson.D)

+ func (cs *ChangeStream) SetPipelineString(pipe string)

+ func (cs *ChangeStream) Watch(client *mongo.Client, cb callback)

+ type ChartDataPoint struct

+ type Chunk struct

+ Empty int64

+ Jumbo int64

+ Objects int64

+ Shard string

+ Size int64

+ Total int64

+ type ClusterStats struct

+ BuildInfo BuildInfo

+ Cluster string

+ CmdLineOpts CmdLineOpts

+ Databases []Database

+ Host string

+ HostInfo HostInfo

+ Logger *Logger

+ OplogStats OplogStats

+ Process string

+ ReplSetGetStatus ReplSetGetStatus

+ ServerStatus ServerStatus

+ Shards []Shard

+ Version string

+ func NewStats(version string) *ClusterStats

+ func (p *ClusterStats) GetClusterShortSummary(client *mongo.Client) string

+ func (p *ClusterStats) GetClusterStats(client *mongo.Client, connString connstring.ConnString) error

+ func (p *ClusterStats) GetClusterStatsSummary(client *mongo.Client) error

+ func (p *ClusterStats) GetServersStatsSummary(shards []Shard, connString connstring.ConnString) ([]Shard, error)

+ func (p *ClusterStats) GetShortSummary() string

+ func (p *ClusterStats) OutputBSON() error

+ func (p *ClusterStats) Print()

+ func (p *ClusterStats) SetRedaction(redact bool)

+ func (p *ClusterStats) SetVerbose(verbose bool)

+ type CmdLineOpts struct

+ Argv []string

+ Parsed bson.M

+ func GetCmdLineOpts(client *mongo.Client) (CmdLineOpts, error)

+ type Collection struct

+ Chunks []Chunk

+ Document bson.M

+ Indexes []Index

+ NS string

+ Name string

+ Stats struct{ ... }

+ type Database struct

+ Collections []Collection

+ Empty bool

+ Name string

+ Shards bson.M

+ SizeOnDisk int64

+ Stats struct{ ... }

+ type DatabaseStats struct

+ func NewDatabaseStats(version string) *DatabaseStats

+ func (p *DatabaseStats) GetAllDatabasesStats(client *mongo.Client) ([]Database, error)

+ func (p *DatabaseStats) SetLogger(logger *Logger)

+ func (p *DatabaseStats) SetNumberThreads(threads int)

+ func (p *DatabaseStats) SetRedaction(redaction bool)

+ func (p *DatabaseStats) SetVerbose(verbose bool)

+ type Explain struct

+ func NewExplain() *Explain

+ func (e *Explain) ExecuteAllPlans(client *mongo.Client, filename string) error

+ func (e *Explain) PrintExplainResults(filename string) error

+ func (e *Explain) SetVerbose(verbose bool)

+ type ExplainCommand struct

+ Collection string

+ Filter bson.D

+ Group string

+ Hint bson.D

+ Sort bson.D

+ type ExplainSummary struct

+ AllPlansExecutionStats []StageStats

+ ExecutionStats StageStats

+ ShardName string

+ type Histogram struct

+ Ops map[string]int

+ UTC string

+ type HostInfo struct

+ Extra struct{ ... }

+ OS struct{ ... }

+ System struct{ ... }

+ func GetHostInfo(client *mongo.Client) (HostInfo, error)

+ type Index struct

+ Background bool

+ Collation bson.D

+ EffectiveKey string

+ ExpireAfterSeconds int32

+ Fields []string

+ IsDupped bool

+ IsShardKey bool

+ Key bson.D

+ KeyString string

+ Name string

+ PartialFilterExpression bson.D

+ Sparse bool

+ TotalOps int

+ Unique bool

+ Usage []IndexUsage

+ Version int32

+ type IndexScore struct

+ Index gox.OrderedMap

+ Score float64

+ type IndexStats struct

+ Databases []Database

+ Logger *Logger

+ func NewIndexStats(version string) *IndexStats

+ func (ix *IndexStats) CreateIndexes(client *mongo.Client) error

+ func (ix *IndexStats) GetIndexes(client *mongo.Client) ([]Database, error)

+ func (ix *IndexStats) GetIndexesFromCollection(client *mongo.Client, collection *mongo.Collection) ([]Index, error)

+ func (ix *IndexStats) GetIndexesFromDB(client *mongo.Client, db string) ([]Collection, error)

+ func (ix *IndexStats) OutputBSON() error

+ func (ix *IndexStats) OutputJSON() error

+ func (ix *IndexStats) Print()

+ func (ix *IndexStats) PrintIndexesOf(databases []Database)

+ func (ix *IndexStats) SetClusterDetailsFromFile(filename string) error

+ func (ix *IndexStats) SetFilename(filename string)

+ func (ix *IndexStats) SetLogger(logger *Logger)

+ func (ix *IndexStats) SetNoColor(nocolor bool)

+ func (ix *IndexStats) SetVerbose(verbose bool)

+ type IndexUsage struct

+ Accesses Accesses

+ Host string

+ Name string

+ Shard string

+ type Keyhole struct

+ func NewKeyhole(version string) *Keyhole

+ func (k *Keyhole) CollectClusterStats(client *mongo.Client, connString connstring.ConnString) error

+ func (k *Keyhole) GetClusterSummary(client *mongo.Client) string

+ func (k *Keyhole) SetRedaction(redaction bool)

+ func (k *Keyhole) SetVerbose(verbose bool)

+ type ListDatabases struct

+ Databases []Database

+ TotalSize int64

+ TotalSizeMB int64

+ type LogInfo struct

+ Collscan bool

+ Histogram []Histogram

+ LogType string

+ Logger *Logger

+ OpPatterns []OpPattern

+ Redaction bool

+ Regex string

+ SlowOps []SlowOps

+ func NewLogInfo(version string) *LogInfo

+ func (li *LogInfo) AnalyzeFile(filename string) error

+ func (li *LogInfo) OutputBSON() error

+ func (li *LogInfo) OutputJSON() error

+ func (li *LogInfo) Parse(reader *bufio.Reader, counts ...int) error

+ func (li *LogInfo) ParseLog(str string) (LogStats, error)

+ func (li *LogInfo) ParseLogv2(str string) (LogStats, error)

+ func (li *LogInfo) Print()

+ func (li *LogInfo) SetCollscan(collscan bool)

+ func (li *LogInfo) SetRedaction(redaction bool)

+ func (li *LogInfo) SetRegexPattern(regex string)

+ func (li *LogInfo) SetSilent(silent bool)

+ func (li *LogInfo) SetVerbose(verbose bool)

+ type LogStats struct

+ type Logger struct

+ Collected time.Time

+ Logs []string

+ Params string

+ Version string

+ Warnings []string

+ func NewLogger(fullVersion string, params string) *Logger

+ func (p *Logger) Add(message string)

+ func (p *Logger) Log(message string)

+ func (p *Logger) Print() string

+ func (p *Logger) SetNoColor(nocolor bool)

+ func (p *Logger) Warn(message string)

+ type Logv2 struct

+ Attributes struct{ ... }

+ Component string

+ ID int

+ Message string

+ Severity string

+ Timestamp map[string]string

+ type OpPattern struct

+ Command string

+ Count int

+ Filter string

+ Index string

+ MaxMilli int

+ Namespace string

+ Scan string

+ TotalMilli int

+ type OplogStats struct

+ Count int

+ DurationInSeconds int64

+ MaxSize int64

+ Size int64

+ func GetOplogStats(client *mongo.Client) (OplogStats, error)

+ type QueryExplainer struct

+ ExplainCmd ExplainCommand

+ NameSpace string

+ func NewQueryExplainer(client *mongo.Client) *QueryExplainer

+ func (qe *QueryExplainer) Explain() (ExplainSummary, error)

+ func (qe *QueryExplainer) GetExplainDetails(doc bson.M) ExplainSummary

+ func (qe *QueryExplainer) GetFilter() bson.D

+ func (qe *QueryExplainer) GetIndexesScores(keys []string) []IndexScore

+ func (qe *QueryExplainer) GetSummary(summary ExplainSummary) string

+ func (qe *QueryExplainer) ReadQueryShape(buffer []byte) error

+ func (qe *QueryExplainer) SetVerbose(verbose bool)

+ type Redactor struct

+ func NewRedactor() *Redactor

+ func (r *Redactor) SetVerbose(verbose bool)

+ type ReplSetGetStatus struct

+ Members []struct{ ... }

+ Set string

+ SyncSourceHost string

+ SyncingTo string

+ func GetReplSetGetStatus(client *mongo.Client) (ReplSetGetStatus, error)

+ type ServerStatus struct

+ Connections struct{ ... }

+ Host string

+ LocalTime time.Time

+ Mem struct{ ... }

+ Metrics struct{ ... }

+ OpCounters struct{ ... }

+ Process string

+ Repl struct{ ... }

+ Sharding struct{ ... }

+ StorageEngine struct{ ... }

+ Version string

+ func GetServerStatus(client *mongo.Client) (ServerStatus, error)

+ type Shard struct

+ Host string

+ ID string

+ Servers []ClusterStats

+ State int

+ type SlowOps struct

+ Log string

+ Milli int

+ type StageStats struct

+ Advanced int32

+ ExecTimeMillisEst int32

+ Filter *gox.OrderedMap

+ InputStages []StageStats

+ KeyPattern *gox.OrderedMap

+ Level int

+ Score float64

+ Stage string

+ TotalDocsExamined int32

+ TotalKeysExamined int32

+ Works int32

+ type WiredTigerCache struct

+ func NewWiredTigerCache(version string) *WiredTigerCache

+ func (wtc *WiredTigerCache) GetAllDatabasesStats(client *mongo.Client) error

+ func (wtc *WiredTigerCache) GetWiredTigerCacheData(w http.ResponseWriter, r *http.Request)

+ func (wtc *WiredTigerCache) Handler(w http.ResponseWriter, r *http.Request)

+ func (wtc *WiredTigerCache) Start(client *mongo.Client)

Mar 13, 2019

Changes in this version

+ const KEYHOLEDB

+ const PRIMARY

+ const REPLICA

+ const SECONDARY

+ const SHARDED

+ const STANDALONE

+ func GetIndexes(client *mongo.Client, dbName string) string

+ func GetIndexesFromDB(client *mongo.Client, dbName string) string

+ func GetOptime(optime interface{}) int64

+ func GetShards(client *mongo.Client, uri string) ([]string, error)

+ func GetShardsURIList(client *mongo.Client, uri string) ([]string, error)

+ func IsMaster(client *mongo.Client) (bson.M, error)

+ func ListDatabaseNames(client *mongo.Client) ([]string, error)

+ func MongoPipeline(str string) mongo.Pipeline

+ func NewMongoClient(uri string, opts ...string) (*mongo.Client, error)

+ func Parse(uri string) (string, error)

+ func ReadPasswordFromStdin() (string, error)

+ func RunAdminCommand(client *mongo.Client, command string) (bson.M, error)

+ func RunCommandOnDB(client *mongo.Client, command string, db string) (bson.M, error)

+ func Silent(data interface{})

+ func Stringify(doc interface{}, opts ...string) string

+ type Cardinality struct

+ func NewCardinality(database string, collection string) *Cardinality

+ func (card *Cardinality) CheckCardinality(client *mongo.Client) (bson.M, error)

+ func (card *Cardinality) SetVerbose(verbose bool)

+ type ConcurrentTransactionsCountDoc struct

+ Available int64

+ Out int64

+ TotalTickets int64

+ type ConcurrentTransactionsDoc struct

+ Read ConcurrentTransactionsCountDoc

+ Write ConcurrentTransactionsCountDoc

+ type ConnectionsDoc struct

+ Available int64

+ Current int64

+ TotalCreated int64

+ type DBStats struct

+ DB string

+ DataSize int

+ IndexSize int

+ Objects int

+ type DocumentDoc struct

+ Deleted int

+ Inserted int

+ Returned int

+ Updated int

+ type ExtraInfoDoc struct

+ PageFaults int64

+ type GlobalLockDoc struct

+ ActiveClients GlobalLockSubDoc

+ CurrentQueue GlobalLockSubDoc

+ TotalTime int

+ type GlobalLockSubDoc struct

+ Readers int64

+ Total int64

+ Writers int64

+ type IndexStatsDoc struct

+ EffectiveKey string

+ Key string

+ Usage []UsageDoc

+ type MemDoc struct

+ Resident int64

+ Virtual int64

+ type MemberDoc struct

+ Name string

+ Optime interface{}

+ State int

+ type MetricsDoc struct

+ Document DocumentDoc

+ Operation OperationDoc

+ QueryExecutor QueryExecutorDoc

+ type OpCountersDoc struct

+ Command int64

+ Delete int64

+ Getmore int64

+ Insert int64

+ Query int64

+ Update int64

+ type OpLatenciesDoc struct

+ Commands OpLatenciesOpDoc

+ Reads OpLatenciesOpDoc

+ Writes OpLatenciesOpDoc

+ type OpLatenciesOpDoc struct

+ Latency int64

+ Ops int64

+ type OperationDoc struct

+ ScanAndOrder int64

+ WriteConflicts int64

+ type OptimeDoc struct

+ T int64

+ TS int64

+ type QueryExecutorDoc struct

+ Scanned int64

+ ScannedObjects int64

+ type ReplSetStatusDoc struct

+ Date time.Time

+ Members []MemberDoc

+ type ServerInfo struct

+ Cluster string

+ Host string

+ Process string

+ Repl bson.M

+ Sharding bson.M

+ StorageSize bson.M

+ Version string

+ func GetServerInfo(client *mongo.Client) (ServerInfo, error)

+ type ServerStatusDoc struct

+ Connections ConnectionsDoc

+ ExtraInfo ExtraInfoDoc

+ GlobalLock GlobalLockDoc

+ Host string

+ LocalTime time.Time

+ Mem MemDoc

+ Metrics MetricsDoc

+ OpCounters OpCountersDoc

+ OpLatencies OpLatenciesDoc

+ Process string

+ Repl bson.M

+ Sharding bson.M

+ Uptime int64

+ Version string

+ WiredTiger WiredTigerDoc

+ type ShardDoc struct

+ Host string

+ ID string

+ State int

+ type ShardList struct

+ OK int

+ Shards []ShardDoc

+ type UsageDoc struct

+ Hostname string

+ Ops int

+ Since time.Time

+ type WiredTigerCacheDoc struct

+ CurrentlyInCache int64

+ MaxBytesConfigured int64

+ ModifiedPagesEvicted int64

+ PagesReadIntoCache int64

+ PagesWrittenFromCache int64

+ TrackedDirtyBytes int64

+ UnmodifiedPagesEvicted int64

+ type WiredTigerDoc struct

+ Cache WiredTigerCacheDoc

+ ConcurrentTransactions ConcurrentTransactionsDoc

+ Perf interface{}