mdb

package
v1.0.3-rc2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 6, 2021 License: Apache-2.0 Imports: 32 Imported by: 4

Documentation

Index

Constants

View Source 
const COLLSCAN = "COLLSCAN"

COLLSCAN constance

View Source 
const Replica = "replica"

Replica set

View Source 
const Sharded = "sharded"

Sharded cluster

View Source 
const Standalone = "standalone"

Standalone server

Variables

View Source 
var CodeBlue = "\x1b[34;1m"

CodeBlue shows blue color

View Source 
var CodeDefault = "\x1b[0m"

CodeDefault shows default color

View Source 
var CodeGreen = "\x1b[32;1m"

CodeGreen shows green color

View Source 
var CodeRed = "\x1b[31;1m"

CodeRed shows red color

View Source 
var CodeYellow = "\x1b[33;1m"

CodeYellow shows yellow color

View Source 
var ExamplesCollection = "__examples"

ExamplesCollection default test colection

View Source 
var KeyholeDB = "_KEYHOLE_88800"

KeyholeDB default database

Functions

func GetAllServerURIs added in v1.0.1 

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

GetAllServerURIs returns URIs of all mongo servers

func GetAllShardURIs added in v1.0.1 

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

GetAllShardURIs returns URIs of all replicas

func GetClusterType added in v1.0.1 

func GetClusterType(serverStatus ServerStatus) string

GetClusterType returns cluster type

func GetDatabaseNames added in v1.0.3 

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

GetDatabaseNames gets all database names

func GetIndexSuggestion added in v1.0.1 

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

GetIndexSuggestion returns a recommended index by cardinalities index follows a principle of equality, sort, rnage

func GetKeys added in v1.0.1 

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

GetKeys gets all fields of a odc as an array

func MongoPipeline 

func MongoPipeline(str string) mongo.Pipeline

MongoPipeline gets aggregation pipeline from a string

func NewMongoClient 

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

NewMongoClient new mongo client

func ParseURI added in v1.0.1 

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

ParseURI checks if password is included

func RunAdminCommand 

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

RunAdminCommand executes admin Command

func RunCommandOnDB 

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

RunCommandOnDB execute admin Command at given database

func ToFloat64 added in v1.0.1 

func ToFloat64(num interface{}) float64

ToFloat64 converts to float64

func ToInt64 added in v1.0.1 

func ToInt64(num interface{}) int64

ToInt64 converts to in64

Types

type Accesses added in v1.0.1 

type Accesses struct {
	Ops   int       `json:"ops" bson:"ops"`
	Since time.Time `json:"since" bson:"since"`
}

Accesses stores index accesses

type BSONPrinter added in v1.0.1 

type BSONPrinter struct {
	// contains filtered or unexported fields
}

BSONPrinter stores bson printer info

func NewBSONPrinter added in v1.0.1 

func NewBSONPrinter(version string) *BSONPrinter

NewBSONPrinter returns BSONPrinter

func (*BSONPrinter) Print added in v1.0.1 

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

Print print summary or output json from bson

func (*BSONPrinter) SetNoColor added in v1.0.1 

func (p *BSONPrinter) SetNoColor(nocolor bool)

SetNoColor set nocolor flag

type BuildInfo added in v1.0.1 

type BuildInfo struct {
	GitVersion string   `bson:"gitVersion"`
	Modules    []string `bson:"modules"`
	Version    string   `bson:"version"`
}

BuildInfo stores build information

func GetBuildInfo added in v1.0.1 

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

GetBuildInfo returns MongoDB build information

type Cardinality 

type Cardinality struct {
	// contains filtered or unexported fields
}

Cardinality -

func NewCardinality 

func NewCardinality(client *mongo.Client) *Cardinality

NewCardinality returns cardinality constructor

func (*Cardinality) GetCardinalityArray added in v1.0.1 

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

GetCardinalityArray returns cardinality list

func (*Cardinality) GetSummary added in v1.0.1 

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

GetSummary get summary of cardinality

func (*Cardinality) SetVerbose 

func (card *Cardinality) SetVerbose(verbose bool)

SetVerbose -

type CardinalityCount added in v1.0.1 

type CardinalityCount struct {
	Field string
	Count int64
}

CardinalityCount stores cardinality counts

type CardinalitySummary added in v1.0.1 

type CardinalitySummary struct {
	SampledCount int64
	List         []CardinalityCount
}

CardinalitySummary stores Cardinality summary

type ChangeStream added in v1.0.1 

type ChangeStream struct {
	// contains filtered or unexported fields
}

ChangeStream defines what to watch? client, database or collection

func NewChangeStream added in v1.0.1 

func NewChangeStream() *ChangeStream

NewChangeStream gets a new ChangeStream

func (*ChangeStream) SetCollection added in v1.0.1 

func (cs *ChangeStream) SetCollection(collection string)

SetCollection sets collection

func (*ChangeStream) SetDatabase added in v1.0.1 

func (cs *ChangeStream) SetDatabase(database string)

SetDatabase sets database

func (*ChangeStream) SetPipeline added in v1.0.1 

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

SetPipeline sets pipeline

func (*ChangeStream) SetPipelineString added in v1.0.1 

func (cs *ChangeStream) SetPipelineString(pipe string)

SetPipelineString sets pipeline string

func (*ChangeStream) Watch added in v1.0.1 

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

Watch prints oplogs in JSON format

type ChartDataPoint added in v1.0.1 

type ChartDataPoint struct {
	// contains filtered or unexported fields
}

ChartDataPoint has chart data points key/value

type Chunk added in v1.0.1 

type Chunk struct {
	Empty   int64  `bson:"empty"`
	Jumbo   int64  `bson:"jumbo"`
	Objects int64  `bson:"objects"`
	Shard   string `bson:"shard"`
	Size    int64  `bson:"size"`
	Total   int64  `bson:"total"`
}

Chunk stores chunk stats

type ClusterStats added in v1.0.1 

type ClusterStats struct {
	BuildInfo        BuildInfo        `bson:"buildInfo"`
	CmdLineOpts      CmdLineOpts      `bson:"getCmdLineOpts"`
	Cluster          string           `bson:"cluster"`
	Databases        []Database       `bson:"databases"`
	Host             string           `bson:"host"`
	HostInfo         HostInfo         `bson:"hostInfo"`
	Logger           *Logger          `bson:"keyhole"`
	OplogStats       OplogStats       `bson:"oplog"`
	Process          string           `bson:"process"`
	ReplSetGetStatus ReplSetGetStatus `bson:"replSetGetStatus"`
	ServerStatus     ServerStatus     `bson:"serverStatus"`
	Shards           []Shard          `bson:"shards"`
	Version          string           `bson:"version"`
	// contains filtered or unexported fields
}

ClusterStats keeps slow ops struct

func NewStats added in v1.0.1 

func NewStats(version string) *ClusterStats

NewStats -

func (*ClusterStats) GetClusterShortSummary added in v1.0.1 

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

GetClusterShortSummary returns one line summary

func (*ClusterStats) GetClusterStats added in v1.0.1 

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

GetClusterStats collects cluster stats

func (*ClusterStats) GetClusterStatsSummary added in v1.0.1 

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

GetClusterStatsSummary collects cluster stats

func (*ClusterStats) GetServersStatsSummary added in v1.0.1 

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

GetServersStatsSummary returns cluster stats from all shards

func (*ClusterStats) GetShortSummary added in v1.0.1 

func (p *ClusterStats) GetShortSummary() string

GetShortSummary returns a short summary

func (*ClusterStats) OutputBSON added in v1.0.1 

func (p *ClusterStats) OutputBSON() error

OutputBSON writes bson data to a file

func (*ClusterStats) Print added in v1.0.1 

func (p *ClusterStats) Print()

Print prints a cluster short summary

func (*ClusterStats) SetRedaction added in v1.0.1 

func (p *ClusterStats) SetRedaction(redact bool)

SetRedaction sets redact

func (*ClusterStats) SetVerbose added in v1.0.1 

func (p *ClusterStats) SetVerbose(verbose bool)

SetVerbose sets verbose mode

type CmdLineOpts added in v1.0.1 

type CmdLineOpts struct {
	Argv   []string `bson:"argv"`
	Parsed bson.M   `bson:"parsed"`
}

CmdLineOpts stores build information

func GetCmdLineOpts added in v1.0.1 

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

GetCmdLineOpts returns MongoDB build information

type Collection added in v1.0.1 

type Collection struct {
	Chunks   []Chunk `bson:"chunks,truncate"`
	Document bson.M  `bson:"document,truncate"`
	Indexes  []Index `bson:"indexes,truncate"`
	Name     string  `bson:"name,truncate"`
	NS       string  `bson:"namespace,truncate"`
	Stats    struct {
		Count          int64   `bson:"count,truncate"`
		IndexDetails   bson.M  `bson:"indexDetails,truncate"`
		AvgObjSize     float64 `bson:"avgObjSize,truncate"`
		WiredTiger     bson.M  `bson:"wiredTiger,truncate"`
		IndexSizes     bson.M  `bson:"indexSizes,truncate"`
		Capped         bool    `bson:"capped,truncate"`
		TotalIndexSize int64   `bson:"totalIndexSize,truncate"`
		MaxSize        int64   `bson:"maxSize,truncate"`
		Nindexes       int64   `bson:"nindexes,truncate"`
		Shards         bson.M  `bson:"shards,truncate"`
		NS             string  `bson:"namespace,truncate"`
		Nchunks        int64   `bson:"nchunks,truncate"`
		Sharded        bool    `bson:"sharded,truncate"`
		Size           int64   `bson:"size,truncate"`
		StorageSize    int64   `bson:"storageSize,truncate"`
	} `bson:"stats"`
}

Collection stores struct

type DBStats 

type DBStats struct {
	DB        string `json:"db" bson:"db"`
	DataSize  int    `json:"dataSize" bson:"dataSize"`
	IndexSize int    `json:"indexSize" bson:"indexSize"`
	Objects   int    `json:"objects" bson:"objects"`
}

DBStats contains info from db.stats()

type Database added in v1.0.1 

type Database struct {
	Name        string       `bson:"name"`
	Collections []Collection `bson:"collections,truncate"`
	SizeOnDisk  int64        `bson:"sizeOnDisk,truncate"`
	Empty       bool         `bson:"empty,truncate"`
	Shards      bson.M       `bson:"shards,truncate"`
	Stats       struct {
		Raw         bson.M `bson:"raw,truncate"`
		Objects     int64  `bson:"objects,truncate"`
		IndexSize   int64  `bson:"indexSize,truncate"`
		FileSize    int64  `bson:"fileSize,truncate"`
		Indexes     int64  `bson:"indexes,truncate"`
		ScaleFactor int64  `bson:"scaleFactor,truncate"`
		AvgObjSize  int64  `bson:"avgObjSize,truncate"`
		DataSize    int64  `bson:"dataSize,truncate"`
		StorageSize int64  `bson:"storageSize,truncate"`
		NumExtents  int64  `bson:"numExtents,truncate"`
	}
}

Database stores database stats

type DatabaseStats added in v1.0.1 

type DatabaseStats struct {
	// contains filtered or unexported fields
}

DatabaseStats stores struct

func NewDatabaseStats added in v1.0.1 

func NewDatabaseStats(version string) *DatabaseStats

NewDatabaseStats returns DatabaseStats

func (*DatabaseStats) GetAllDatabasesStats added in v1.0.1 

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

GetAllDatabasesStats gets all db info

func (*DatabaseStats) SetLogger added in v1.0.1 

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

SetLogger sets logger

func (*DatabaseStats) SetNumberThreads added in v1.0.1 

func (p *DatabaseStats) SetNumberThreads(threads int)

SetNumberThreads set # of threads

func (*DatabaseStats) SetRedaction added in v1.0.1 

func (p *DatabaseStats) SetRedaction(redaction bool)

SetRedaction sets redaction

func (*DatabaseStats) SetVerbose added in v1.0.1 

func (p *DatabaseStats) SetVerbose(verbose bool)

SetVerbose sets verbosity

type Explain added in v1.0.1 

type Explain struct {
	// contains filtered or unexported fields
}

Explain stores explain object info

func NewExplain added in v1.0.1 

func NewExplain() *Explain

NewExplain returns Explain struct

func (*Explain) ExecuteAllPlans added in v1.0.1 

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

ExecuteAllPlans calls queryPlanner and cardinality

func (*Explain) PrintExplainResults added in v1.0.1 

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

PrintExplainResults prints explain results

func (*Explain) SetVerbose added in v1.0.1 

func (e *Explain) SetVerbose(verbose bool)

SetVerbose sets verbosity

type ExplainCommand added in v1.0.1 

type ExplainCommand struct {
	Collection string `bson:"find"`
	Filter     bson.D `bson:"filter"`
	Sort       bson.D `bson:"sort,omitempty"`
	Hint       bson.D `bson:"hint,omitempty"`
	Group      string `bson:"group,omitempty"`
}

ExplainCommand stores explain document

type ExplainSummary added in v1.0.1 

type ExplainSummary struct {
	ShardName              string       `json:"shardName"`
	ExecutionStats         StageStats   `json:"executionStats"`
	AllPlansExecutionStats []StageStats `json:"allPlansExecution"`
}

ExplainSummary stores explain summary

type Histogram added in v1.0.1 

type Histogram struct {
	UTC string         `bson:"utc"`
	Ops map[string]int `bson:"Ops"`
}

Histogram stores ops info

type HostInfo added in v1.0.1 

type HostInfo struct {
	Extra struct {
		KernelVersion string
	}
	OS struct {
		Name    string
		Type    string
		Version string
	}
	System struct {
		CPUAddrSize int    `bson:"cpuAddrSize,truncate"`
		CPUArch     string `bson:"cpuArch"`
		Hostname    string `bson:"hostname"`
		MemLimitMB  int    `bson:"memLimitMB,truncate"`
		MemSizeMB   int    `bson:"memSizeMB,truncate"`
		NumaEnabled bool   `bson:"numaEnabled"`
		NumCores    int    `bson:"numCores,truncate"`
	}
}

HostInfo stores build information

func GetHostInfo added in v1.0.1 

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

GetHostInfo returns MongoDB build information

type Index added in v1.0.1 

type Index struct {
	Background              bool   `json:"background" bson:"background"`
	Collation               bson.D `json:"collation" bson:"collation"`
	ExpireAfterSeconds      int32  `json:"expireAfterSeconds" bson:"expireAfterSeconds,truncate,omitempty"`
	Key                     bson.D `json:"key" bson:"key"`
	Name                    string `json:"name" bson:"name,truncate"`
	PartialFilterExpression bson.D `json:"partialFilterExpression" bson:"partialFilterExpression"`
	Sparse                  bool   `json:"sparse" bson:"sparse"`
	Unique                  bool   `json:"unique" bson:"unique"`
	Version                 int32  `json:"v" bson:"v,truncate"`

	EffectiveKey string       `json:"effectiveKey" bson:"effectiveKey"`
	Fields       []string     `json:"fields" bson:"fields"`
	IsDupped     bool         `json:"isDupped" bson:"isDupped"`
	IsShardKey   bool         `json:"isShardkey" bson:"isShardkey"`
	KeyString    string       `json:"keyString" bson:"keyString"`
	TotalOps     int          `json:"totalOps" bson:"totalOps"`
	Usage        []IndexUsage `json:"usage" bson:"usage"`
}

Index stores indexes stats

type IndexScore added in v1.0.1 

type IndexScore struct {
	Index gox.OrderedMap `json:"index"`
	Score float64        `json:"score"`
}

IndexScore keeps index score

type IndexStats added in v1.0.1 

type IndexStats struct {
	Databases []Database `bson:"databases"`
	Logger    *Logger    `bson:"keyhole"`
	// contains filtered or unexported fields
}

IndexStats holder indexes reader struct

func NewIndexStats added in v1.0.1 

func NewIndexStats(version string) *IndexStats

NewIndexStats establish seeding parameters

func (*IndexStats) CreateIndexes added in v1.0.1 

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

CreateIndexes creates indexes

func (*IndexStats) GetIndexes added in v1.0.1 

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

GetIndexes list all indexes of collections of databases

func (*IndexStats) GetIndexesFromCollection added in v1.0.1 

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

GetIndexesFromCollection gets indexes from a collection

func (*IndexStats) GetIndexesFromDB added in v1.0.1 

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

GetIndexesFromDB list all indexes of collections of a database

func (*IndexStats) OutputBSON added in v1.0.1 

func (ix *IndexStats) OutputBSON() error

OutputBSON writes index stats bson to a file

func (*IndexStats) OutputJSON added in v1.0.1 

func (ix *IndexStats) OutputJSON() error

OutputJSON writes json data to a file

func (*IndexStats) Print added in v1.0.1 

func (ix *IndexStats) Print()

Print prints indexes

func (*IndexStats) PrintIndexesOf added in v1.0.1 

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

PrintIndexesOf prints indexes

func (*IndexStats) SetClusterDetailsFromFile added in v1.0.1 

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

SetClusterDetailsFromFile File sets cluster details from a file

func (*IndexStats) SetFilename added in v1.0.1 

func (ix *IndexStats) SetFilename(filename string)

SetFilename sets output file name

func (*IndexStats) SetLogger added in v1.0.1 

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

SetLogger sets logger

func (*IndexStats) SetNoColor added in v1.0.1 

func (ix *IndexStats) SetNoColor(nocolor bool)

SetNoColor set nocolor flag

func (*IndexStats) SetVerbose added in v1.0.1 

func (ix *IndexStats) SetVerbose(verbose bool)

SetVerbose sets verbose level

type IndexUsage added in v1.0.1 

type IndexUsage struct {
	Accesses Accesses `json:"accesses" bson:"accesses"`
	Host     string   `json:"host" bson:"host"`
	Name     string   `json:"name" bson:"name"`
	Shard    string   `json:"shard" bson:"shard"`
}

IndexUsage stores index accesses

type ListDatabases added in v1.0.1 

type ListDatabases struct {
	Databases   []Database `bson:"databases"`
	TotalSize   int64      `bson:"totalSize"`
	TotalSizeMB int64      `bson:"totalSizeMb"`
}

ListDatabases stores listDatabases

type LogInfo added in v1.0.1 

type LogInfo struct {
	Collscan   bool        `bson:"collscan"`
	Histogram  []Histogram `bson:"histogram"`
	Logger     *Logger     `bson:"keyhole"`
	LogType    string      `bson:"type"`
	Regex      string      `bson:"regex"`
	OpPatterns []OpPattern `bson:"opPatterns"`
	Redaction  bool        `bson:"redact"`
	SlowOps    []SlowOps   `bson:"slowOps"`
	// contains filtered or unexported fields
}

LogInfo keeps loginfo struct

func NewLogInfo added in v1.0.1 

func NewLogInfo(version string) *LogInfo

NewLogInfo -

func (*LogInfo) AnalyzeFile added in v1.0.1 

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

AnalyzeFile analyze logs from a file

func (*LogInfo) OutputBSON added in v1.0.1 

func (li *LogInfo) OutputBSON() error

OutputBSON writes loginfo bson data

func (*LogInfo) OutputJSON added in v1.0.1 

func (li *LogInfo) OutputJSON() error

OutputJSON writes json data to a file

func (*LogInfo) Parse added in v1.0.1 

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

Parse parse text or json

func (*LogInfo) ParseLog added in v1.0.1 

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

ParseLog - parses text message before v4.4

func (*LogInfo) ParseLogv2 added in v1.0.1 

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

ParseLogv2 - parses text message before v4.4

func (*LogInfo) Print added in v1.0.1 

func (li *LogInfo) Print()

Print prints indexes

func (*LogInfo) SetCollscan added in v1.0.1 

func (li *LogInfo) SetCollscan(collscan bool)

SetCollscan -

func (*LogInfo) SetRedaction added in v1.0.1 

func (li *LogInfo) SetRedaction(redaction bool)

SetRedaction sets redaction

func (*LogInfo) SetRegexPattern added in v1.0.1 

func (li *LogInfo) SetRegexPattern(regex string)

SetRegexPattern sets Regex patthen

func (*LogInfo) SetSilent added in v1.0.1 

func (li *LogInfo) SetSilent(silent bool)

SetSilent -

func (*LogInfo) SetVerbose added in v1.0.1 

func (li *LogInfo) SetVerbose(verbose bool)

SetVerbose -

type LogStats added in v1.0.1 

type LogStats struct {
	// contains filtered or unexported fields
}

LogStats log stats structure

type Logger added in v1.0.1 

type Logger struct {
	Collected time.Time `bson:"collected"`
	Warnings  []string  `bson:"warnings"`
	Logs      []string  `bson:"logs"`
	Params    string    `bson:"params"`
	Version   string    `bson:"version"`
	// contains filtered or unexported fields
}

Logger stores logger info

func NewLogger added in v1.0.1 

func NewLogger(fullVersion string, params string) *Logger

NewLogger returns Logger

func (*Logger) Add added in v1.0.1 

func (p *Logger) Add(message string)

Add adds a message

func (*Logger) Log added in v1.0.1 

func (p *Logger) Log(message string)

Log adds and prints a message

func (*Logger) Print added in v1.0.1 

func (p *Logger) Print() string

Print prints keyhole info

func (*Logger) SetNoColor added in v1.0.1 

func (p *Logger) SetNoColor(nocolor bool)

SetNoColor set nocolor flag

func (*Logger) Warn added in v1.0.1 

func (p *Logger) Warn(message string)

Warn adds an warning message

type Logv2 added in v1.0.1 

type Logv2 struct {
	Attributes struct {
		Command            map[string]interface{} `json:"command" bson:"command"`
		Milli              int                    `json:"durationMillis" bson:"durationMillis"`
		NS                 string                 `json:"ns" bson:"ns"`
		OriginatingCommand map[string]interface{} `json:"originatingCommand" bson:"originatingCommand"`
		PlanSummary        string                 `json:"planSummary" bson:"planSummary"`
		Type               string                 `json:"type" bson:"type"`
	} `json:"attr" bson:"attr"`
	Component string            `json:"c" bson:"c"`
	ID        int               `json:"id" bson:"id"`
	Message   string            `json:"msg" bson:"msg"`
	Severity  string            `json:"s" bson:"s"`
	Timestamp map[string]string `json:"t" bson:"t"`
}

Logv2 stores logv2 info

type OpPattern added in v1.0.1 

type OpPattern struct {
	Command    string `bson:"command"`    // count, delete, find, remove, and update
	Count      int    `bson:"count"`      // number of ops
	Filter     string `bson:"filter"`     // query pattern
	MaxMilli   int    `bson:"maxmilli"`   // max millisecond
	Namespace  string `bson:"ns"`         // database.collectin
	Scan       string `bson:"scan"`       // COLLSCAN
	TotalMilli int    `bson:"totalmilli"` // total milliseconds
	Index      string `bson:"index"`      // index used
}

OpPattern stores performance data

type OplogStats added in v1.0.1 

type OplogStats struct {
	Count             int   `bson:"count"`
	DurationInSeconds int64 `bson:"durationInSeconds"`
	MaxSize           int64 `bson:"maxSize"`
	Size              int64 `bson:"size"`
}

OplogStats stores oplog stats

func GetOplogStats added in v1.0.1 

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

GetOplogStats returns oplog stats

type QueryExplainer added in v1.0.1 

type QueryExplainer struct {
	ExplainCmd ExplainCommand `bson:"explain"`
	NameSpace  string
	// contains filtered or unexported fields
}

QueryExplainer stores query analyzer info

func NewQueryExplainer added in v1.0.1 

func NewQueryExplainer(client *mongo.Client) *QueryExplainer

NewQueryExplainer returns QueryExplainer

func (*QueryExplainer) Explain added in v1.0.1 

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

Explain explains query plans

func (*QueryExplainer) GetExplainDetails added in v1.0.1 

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

GetExplainDetails returns summary from a doc

func (*QueryExplainer) GetFilter added in v1.0.1 

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

GetFilter sets verbosity

func (*QueryExplainer) GetIndexesScores added in v1.0.1 

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

GetIndexesScores returns a list of indexes scores

func (*QueryExplainer) GetSummary added in v1.0.1 

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

GetSummary get summary of explain executionStats

func (*QueryExplainer) ReadQueryShape added in v1.0.1 

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

ReadQueryShape parses filter map

func (*QueryExplainer) SetVerbose added in v1.0.1 

func (qe *QueryExplainer) SetVerbose(verbose bool)

SetVerbose sets verbosity

type Redactor added in v1.0.1 

type Redactor struct {
	// contains filtered or unexported fields
}

Redactor stores Redact struct

func NewRedactor added in v1.0.1 

func NewRedactor() *Redactor

NewRedactor returns Redact struct

func (*Redactor) SetVerbose added in v1.0.1 

func (r *Redactor) SetVerbose(verbose bool)

SetVerbose sets verbosity

type ReplSetGetStatus added in v1.0.1 

type ReplSetGetStatus struct {
	Members []struct {
		ID     int    `bson:"_id"`
		Health int    `bson:"health"`
		Name   string `bson:"name"`
		// Optime         primitive.Timestamp `bson:"optime"`
		State          int    `bson:"state"`
		StateStr       string `bson:"stateStr"`
		SyncingTo      string `bson:"syncingTo"`
		SyncSourceHost string `bson:"syncSourceHost"`
		Uptime         int64  `bson:"uptime"`
	} `bson:"members"`
	Set            string `bson:"set"`
	SyncingTo      string `bson:"syncingTo"`
	SyncSourceHost string `bson:"syncSourceHost"`
}

ReplSetGetStatus stores replset info

func GetReplSetGetStatus added in v1.0.1 

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

GetReplSetGetStatus returns MongoDB build information

type ServerStatus added in v1.0.1 

type ServerStatus struct {
	Connections struct {
		Active       int `bson:"active"`
		Current      int `bson:"current"`
		Available    int `bson:"available"`
		TotalCreated int `bson:"totalCreated"`
	} `bson:"connections"`
	Host      string    `bson:"host"`
	LocalTime time.Time `bson:"localTime"`
	Mem       struct {
		Virtual   int  `bson:"virtual"`
		Supported bool `bson:"supported"`
		Bits      int  `bson:"bits"`
		Resident  int  `bson:"resident"`
	} `bson:"mem"`
	Metrics struct {
		Cursor struct {
			Open struct {
				Pinned int `bson:"pinned"`
				Total  int `bson:"total"`
			} `bson:"open"`
		} `bson:"cursor"`
	} `bson:"metrics"`
	OpCounters struct {
		Command int `bson:"command"`
		Insert  int `bson:"insert"`
		Query   int `bson:"query"`
		Update  int `bson:"update"`
		Delete  int `bson:"delete"`
		GetMore int `bson:"getmore"`
	} `bson:"opcounters"`
	Process string `bson:"process"`
	Repl    struct {
		Hosts     []string `bson:"hosts"`
		IsMaster  bool     `bson:"isMaster"`
		Me        string   `bson:"me"`
		Primary   string   `bson:"primary"`
		SetName   string   `bson:"setName"`
		Secondary bool     `bson:"secondary"`
	} `bson:"repl"`
	Sharding struct {
		ConfigsvrConnectionString string `bson:"configsvrConnectionString"`
		MaxChunkSizeInBytes       int    `bson:"maxChunkSizeInBytes"`
	} `bson:"sharding"`
	StorageEngine struct {
		Name string `bson:"name"`
	} `bson:"storageEngine"`
	Version string `bson:"version"`
}

ServerStatus stores build information

func GetServerStatus added in v1.0.1 

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

GetServerStatus returns MongoDB build information

type Shard added in v1.0.1 

type Shard struct {
	ID      string         `bson:"_id"`
	Host    string         `bson:"host"`
	State   int            `bson:"state"`
	Servers []ClusterStats `bson:"servers"`
}

Shard store shard information

func GetShards 

func GetShards(client *mongo.Client) ([]Shard, error)

GetShards return all shards from listShards command

type SlowOps added in v1.0.1 

type SlowOps struct {
	Milli int
	Log   string
}

SlowOps holds slow ops log and time

type StageStats added in v1.0.1 

type StageStats struct {
	Level             int
	Score             float64         `json:"Score"`
	Stage             string          `json:"stage"`
	Filter            *gox.OrderedMap `json:"filter"`
	KeyPattern        *gox.OrderedMap `json:"keyPattern"`
	Advanced          int32           `json:"advanced"`
	Works             int32           `json:"works"`
	ExecTimeMillisEst int32           `json:"executionTimeMillisEstimate"`
	TotalKeysExamined int32           `json:"totalKeysExamined"`
	TotalDocsExamined int32           `json:"totalDocsExamined"`
	InputStages       []StageStats    `json:"inputStages"`
}

StageStats stores stats for each stage

type WiredTigerCache added in v1.0.1 

type WiredTigerCache struct {
	// contains filtered or unexported fields
}

WiredTigerCache stores wiredTiger cache structure

func NewWiredTigerCache added in v1.0.1 

func NewWiredTigerCache(version string) *WiredTigerCache

NewWiredTigerCache returns *WiredTigerCache

func (*WiredTigerCache) GetAllDatabasesStats added in v1.0.1 

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

GetAllDatabasesStats returns db info

func (*WiredTigerCache) GetWiredTigerCacheData added in v1.0.1 

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

GetWiredTigerCacheData gets WT cache data

func (*WiredTigerCache) Handler added in v1.0.1 

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

Handler supports resetful calls

func (*WiredTigerCache) Start added in v1.0.1 

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

Start starts a web server and a thread to collect caches

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.