collector_mongod

package

Go to main page

Versions in this module

v0

v0.11.2

Sep 3, 2020

v0.11.1

Aug 7, 2020

v0.11.0

Apr 21, 2020

v0.10.0

Sep 18, 2019

v0.9.0

Aug 30, 2019

Changes in this version

+ type MemberConf struct

+ ArbiterOnly bool

+ BuildIndexes bool

+ Hidden bool

+ Host string

+ ID int32

+ Priority int32

+ SlaveDelay float64

+ Tags map[string]string

+ Votes int32

+ type OuterReplSetConf struct

+ Config ReplSetConf

+ type ReplSetConf struct

+ ID string

+ Members []MemberConf

+ Version int

+ func GetReplSetConf(client *mongo.Client) *ReplSetConf

+ func (replConf *ReplSetConf) Describe(ch chan<- *prometheus.Desc)

+ func (replConf *ReplSetConf) Export(ch chan<- prometheus.Metric)

type ReplSetStatus

+ Ok float64

type ServerStatus

+ Ok float64

v0.8.0

Jun 27, 2019

Changes in this version

+ type TopStatusRaw struct

+ TopStats map[string]bson.Raw

+ func (tsr *TopStatusRaw) TopStatus() *TopStatus

v0.7.1

Jun 11, 2019

v0.7.0

Mar 11, 2019

v0.6.3

Feb 13, 2019

Changes in this version

+ type HistBucket struct

+ Count float64

+ Micros int64

type IndexUsageStats

+ Database string

+ type LatencyStat struct

+ Histogram []HistBucket

+ Latency float64

+ Ops float64

+ func (ls *LatencyStat) Update(op string)

type MetricsStats

+ TTL *TTLStats

+ type OpLatenciesStat struct

+ Commands *LatencyStat

+ Reads *LatencyStat

+ Writes *LatencyStat

+ func (stat *OpLatenciesStat) Describe(ch chan<- *prometheus.Desc)

+ func (stat *OpLatenciesStat) Export(ch chan<- prometheus.Metric)

type ServerStatus

+ OpLatencies *OpLatenciesStat

+ type TTLStats struct

+ DeletedDocuments float64

+ Passes float64

+ func (ttlStats *TTLStats) Export(ch chan<- prometheus.Metric)

v0.6.2

Sep 11, 2018

v0.6.1

Jun 15, 2018

v0.6.0

Jun 13, 2018

Changes in this version

type CollectionStatus

+ IndexSizes map[string]float64

+ type IndexStatsList struct

+ Items []IndexUsageStats

+ func GetIndexUsageStatList(session *mgo.Session) *IndexStatsList

+ func (indexStats *IndexStatsList) Describe(ch chan<- *prometheus.Desc)

+ func (indexStats *IndexStatsList) Export(ch chan<- prometheus.Metric)

+ type IndexUsageInfo struct

+ Ops float64

+ type IndexUsageStats struct

+ Accesses IndexUsageInfo

+ Collection string

+ Name string

+ type TopCounterStats struct

+ Count float64

+ Time float64

+ type TopStats struct

+ Commands TopCounterStats

+ GetMore TopCounterStats

+ Insert TopCounterStats

+ Queries TopCounterStats

+ ReadLock TopCounterStats

+ Remove TopCounterStats

+ Total TopCounterStats

+ Update TopCounterStats

+ WriteLock TopCounterStats

+ type TopStatsMap map[string]TopStats

+ func (topStats TopStatsMap) Export(ch chan<- prometheus.Metric)

+ type TopStatus struct

+ TopStats TopStatsMap

+ func GetTopStats(session *mgo.Session) (*TopStatus, error)

+ func GetTopStatus(session *mgo.Session) *TopStatus

+ func (status *TopStatus) Export(ch chan<- prometheus.Metric)

v0.5.0

May 24, 2018

Changes in this version

type ServerStatus

+ Version string

v0.4.0

Jan 17, 2018

Changes in this version

+ type CollectionStatList struct

+ Members []CollectionStatus

+ func GetCollectionStatList(session *mgo.Session) *CollectionStatList

+ func (collStatList *CollectionStatList) Describe(ch chan<- *prometheus.Desc)

+ func (collStatList *CollectionStatList) Export(ch chan<- prometheus.Metric)

+ type CollectionStatus struct

+ AvgObjSize int

+ Count int

+ Database string

+ Indexes int

+ IndexesSize int

+ Name string

+ Size int

+ StorageSize int

+ type DatabaseStatList struct

+ Members []DatabaseStatus

+ func GetDatabaseStatList(session *mgo.Session) *DatabaseStatList

+ func (dbStatList *DatabaseStatList) Describe(ch chan<- *prometheus.Desc)

+ func (dbStatList *DatabaseStatList) Export(ch chan<- prometheus.Metric)

+ type DatabaseStatus struct

+ Collections int

+ DataSize int

+ IndexSize int

+ Indexes int

+ Name string

+ Objects int

v0.3.2

Oct 17, 2017

v0.3.1

Sep 8, 2017

v0.3.0

Jul 7, 2017

v0.2.0

Jun 28, 2017

Changes in this version

+ type ReplExecutorStats struct

+ Counters map[string]float64

+ EventWaiters float64

+ Queues map[string]float64

+ UnsignaledEvents float64

+ func (replExecutorStats *ReplExecutorStats) Export(ch chan<- prometheus.Metric)

type ReplStats

+ Executor *ReplExecutorStats

type WTCacheStats

+ BytesInternalPages float64

+ BytesLeafPages float64

v0.1.0

Feb 16, 2017

v0.0.1

Feb 16, 2017

Changes in this version

+ var Namespace = "mongodb_mongod"

+ func BsonMongoTimestampToUnix(timestamp bson.MongoTimestamp) float64

+ func ParseStr(str string) float64

+ func ParseTime(str string) float64

+ func SplitByWs(str string) []string

+ type ApplyStats struct

+ Batches *BenchmarkStats

+ Ops float64

+ func (applyStats *ApplyStats) Export(ch chan<- prometheus.Metric)

+ type AssertsStats struct

+ Msg float64

+ Regular float64

+ Rollovers float64

+ User float64

+ Warning float64

+ func (asserts *AssertsStats) Describe(ch chan<- *prometheus.Desc)

+ func (asserts *AssertsStats) Export(ch chan<- prometheus.Metric)

+ type BenchmarkStats struct

+ Num float64

+ TotalMillis float64

+ type BufferStats struct

+ Count float64

+ MaxSizeBytes float64

+ SizeBytes float64

+ func (bufferStats *BufferStats) Export(ch chan<- prometheus.Metric)

+ type ClientStats struct

+ Readers float64

+ Total float64

+ Writers float64

+ func (clientStats *ClientStats) Export(ch chan<- prometheus.Metric)

+ type ConnectionStats struct

+ Available float64

+ Current float64

+ TotalCreated float64

+ func (connectionStats *ConnectionStats) Describe(ch chan<- *prometheus.Desc)

+ func (connectionStats *ConnectionStats) Export(ch chan<- prometheus.Metric)

+ type CursorStats struct

+ Open *CursorStatsOpen

+ TimedOut float64

+ func (cursorStats *CursorStats) Export(ch chan<- prometheus.Metric)

+ type CursorStatsOpen struct

+ NoTimeout float64

+ Pinned float64

+ Total float64

+ type Cursors struct

+ Pinned float64

+ TimeOut float64

+ TotalNoTimeout float64

+ TotalOpen float64

+ func (cursors *Cursors) Describe(ch chan<- *prometheus.Desc)

+ func (cursors *Cursors) Export(ch chan<- prometheus.Metric)

+ type DocumentStats struct

+ Deleted float64

+ Inserted float64

+ Returned float64

+ Updated float64

+ func (documentStats *DocumentStats) Export(ch chan<- prometheus.Metric)

+ type DurStats struct

+ Commits float64

+ CommitsInWriteLock float64

+ Compression float64

+ EarlyCommits float64

+ JournaledMB float64

+ TimeMs DurTiming

+ WriteToDataFilesMB float64

+ func (durStats *DurStats) Collect(ch chan<- prometheus.Metric)

+ func (durStats *DurStats) Describe(ch chan<- *prometheus.Desc)

+ func (durStats *DurStats) Export(ch chan<- prometheus.Metric)

+ type DurTiming struct

+ Dt float64

+ PrepLogBuffer float64

+ RemapPrivateView float64

+ WriteToDataFiles float64

+ WriteToJournal float64

+ func (durTiming *DurTiming) Export(ch chan<- prometheus.Metric)

+ type ExtraInfo struct

+ HeapUsageBytes float64

+ PageFaults float64

+ func (extraInfo *ExtraInfo) Describe(ch chan<- *prometheus.Desc)

+ func (extraInfo *ExtraInfo) Export(ch chan<- prometheus.Metric)

+ type FlushStats struct

+ AverageMs float64

+ Flushes float64

+ LastFinished time.Time

+ LastMs float64

+ TotalMs float64

+ func (flushStats *FlushStats) Describe(ch chan<- *prometheus.Desc)

+ func (flushStats *FlushStats) Export(ch chan<- prometheus.Metric)

+ type GetLastErrorStats struct

+ Wtime *BenchmarkStats

+ Wtimeouts float64

+ func (getLastErrorStats *GetLastErrorStats) Export(ch chan<- prometheus.Metric)

+ type GlobalLockStats struct

+ ActiveClients *ClientStats

+ CurrentQueue *QueueStats

+ LockTime float64

+ Ratio float64

+ TotalTime float64

+ func (globalLock *GlobalLockStats) Describe(ch chan<- *prometheus.Desc)

+ func (globalLock *GlobalLockStats) Export(ch chan<- prometheus.Metric)

+ type IndexCounterStats struct

+ Accesses float64

+ Hits float64

+ MissRatio float64

+ Misses float64

+ Resets float64

+ func (indexCountersStats *IndexCounterStats) Describe(ch chan<- *prometheus.Desc)

+ func (indexCountersStats *IndexCounterStats) Export(ch chan<- prometheus.Metric)

+ type LockStats struct

+ TimeAcquiringMicros ReadWriteLockTimes

+ TimeLockedMicros ReadWriteLockTimes

+ type LockStatsMap map[string]LockStats

+ func (locks LockStatsMap) Describe(ch chan<- *prometheus.Desc)

+ func (locks LockStatsMap) Export(ch chan<- prometheus.Metric)

+ type MemStats struct

+ Bits float64

+ Mapped float64

+ MappedWithJournal float64

+ Resident float64

+ Virtual float64

+ func (memStats *MemStats) Describe(ch chan<- *prometheus.Desc)

+ func (memStats *MemStats) Export(ch chan<- prometheus.Metric)

+ type Member struct

+ ConfigVersion *int32

+ ElectionDate *time.Time

+ ElectionTime *time.Time

+ Health *int32

+ LastHeartbeat *time.Time

+ LastHeartbeatMessage *string

+ LastHeartbeatRecv *time.Time

+ Name string

+ Optime interface{}

+ OptimeDate time.Time

+ PingMs *float64

+ Self *bool

+ State int32

+ StateStr string

+ SyncingTo *string

+ Uptime float64

+ type MetricsNetworkStats struct

+ Bytes float64

+ GetMores *BenchmarkStats

+ Ops float64

+ ReadersCreated float64

+ func (metricsNetworkStats *MetricsNetworkStats) Export(ch chan<- prometheus.Metric)

+ type MetricsStats struct

+ Cursor *CursorStats

+ Document *DocumentStats

+ GetLastError *GetLastErrorStats

+ Operation *OperationStats

+ QueryExecutor *QueryExecutorStats

+ Record *RecordStats

+ Repl *ReplStats

+ Storage *StorageStats

+ func (metricsStats *MetricsStats) Describe(ch chan<- *prometheus.Desc)

+ func (metricsStats *MetricsStats) Export(ch chan<- prometheus.Metric)

+ type NetworkStats struct

+ BytesIn float64

+ BytesOut float64

+ NumRequests float64

+ func (networkStats *NetworkStats) Describe(ch chan<- *prometheus.Desc)

+ func (networkStats *NetworkStats) Export(ch chan<- prometheus.Metric)

+ type OpcountersReplStats struct

+ Command float64

+ Delete float64

+ GetMore float64

+ Insert float64

+ Query float64

+ Update float64

+ func (opCounters *OpcountersReplStats) Describe(ch chan<- *prometheus.Desc)

+ func (opCounters *OpcountersReplStats) Export(ch chan<- prometheus.Metric)

+ type OpcountersStats struct

+ Command float64

+ Delete float64

+ GetMore float64

+ Insert float64

+ Query float64

+ Update float64

+ func (opCounters *OpcountersStats) Describe(ch chan<- *prometheus.Desc)

+ func (opCounters *OpcountersStats) Export(ch chan<- prometheus.Metric)

+ type OperationStats struct

+ Fastmod float64

+ Idhack float64

+ ScanAndOrder float64

+ func (operationStats *OperationStats) Export(ch chan<- prometheus.Metric)

+ type OplogCollectionStats struct

+ Count float64

+ Size float64

+ StorageSize float64

+ func GetOplogCollectionStats(session *mgo.Session) (*OplogCollectionStats, error)

+ type OplogStatus struct

+ CollectionStats *OplogCollectionStats

+ OplogTimestamps *OplogTimestamps

+ func GetOplogStatus(session *mgo.Session) *OplogStatus

+ func (status *OplogStatus) Describe(ch chan<- *prometheus.Desc)

+ func (status *OplogStatus) Export(ch chan<- prometheus.Metric)

+ type OplogTimestamps struct

+ Head float64

+ Tail float64

+ func GetOplogTimestamps(session *mgo.Session) (*OplogTimestamps, error)

+ type PreloadStats struct

+ Docs *BenchmarkStats

+ Indexes *BenchmarkStats

+ func (preloadStats *PreloadStats) Export(ch chan<- prometheus.Metric)

+ type QueryExecutorStats struct

+ Scanned float64

+ ScannedObjects float64

+ func (queryExecutorStats *QueryExecutorStats) Export(ch chan<- prometheus.Metric)

+ type QueueStats struct

+ Readers float64

+ Total float64

+ Writers float64

+ func (queueStats *QueueStats) Export(ch chan<- prometheus.Metric)

+ type ReadWriteLockTimes struct

+ Read float64

+ ReadLower float64

+ Write float64

+ WriteLower float64

+ type RecordStats struct

+ Moves float64

+ func (recordStats *RecordStats) Export(ch chan<- prometheus.Metric)

+ type ReplSetStatus struct

+ Date time.Time

+ HeartbeatIntervalMillis *float64

+ Members []Member

+ MyState int32

+ Set string

+ Term *int32

+ func GetReplSetStatus(session *mgo.Session) *ReplSetStatus

+ func (replStatus *ReplSetStatus) Describe(ch chan<- *prometheus.Desc)

+ func (replStatus *ReplSetStatus) Export(ch chan<- prometheus.Metric)

+ type ReplStats struct

+ Apply *ApplyStats

+ Buffer *BufferStats

+ Network *MetricsNetworkStats

+ PreloadStats *PreloadStats

+ func (replStats *ReplStats) Export(ch chan<- prometheus.Metric)

+ type RocksDbLevelStats struct

+ AvgSec float64

+ CompCnt float64

+ CompSec float64

+ Files *RocksDbLevelStatsFiles

+ KeyDrop float64

+ KeyIn float64

+ Level string

+ MovedGB float64

+ RdMBPSec float64

+ ReadGB float64

+ RnGB float64

+ Rnp1GB float64

+ Score float64

+ SizeMB float64

+ WAmp float64

+ WnewGB float64

+ WrMBPSec float64

+ WriteGB float64

+ func ProcessLevelStatsLine(line string) *RocksDbLevelStats

+ type RocksDbLevelStatsFiles struct

+ CompThreads float64

+ Num float64

+ func ProcessLevelStatsLineFiles(str string) *RocksDbLevelStatsFiles

+ type RocksDbStats struct

+ BackgroundErrors string

+ BlockCacheUsage string

+ CompactionPending string

+ Counters *RocksDbStatsCounters

+ CurSizeAllMemTables string

+ CurSizeMemTableActive string

+ EstimateTableReadersMem string

+ MemTableFlushPending string

+ NumEntriesImmMemTables string

+ NumEntriesMemTableActive string

+ NumImmutableMemTable string

+ NumLiveVersions string

+ NumSnapshots string

+ OldestSnapshotTime string

+ Stats []string

+ ThreadStatus []string

+ TotalLiveRecoveryUnits float64

+ TransactionEngineKeys float64

+ TransactionEngineSnapshots float64

+ func (stats *RocksDbStats) Describe(ch chan<- *prometheus.Desc)

+ func (stats *RocksDbStats) Export(ch chan<- prometheus.Metric)

+ func (stats *RocksDbStats) GetStatsLine(section_prefix string, line_prefix string) []string

+ func (stats *RocksDbStats) GetStatsLineField(section_prefix string, line_prefix string, idx int) float64

+ func (stats *RocksDbStats) GetStatsSection(section_prefix string) []string

+ func (stats *RocksDbStats) ProcessLevelStats()

+ func (stats *RocksDbStats) ProcessReadLatencyStats()

+ func (stats *RocksDbStats) ProcessStalls()

+ type RocksDbStatsCounters struct

+ BlockCacheHits float64

+ BlockCacheMisses float64

+ BloomFilterUseful float64

+ BytesReadIteration float64

+ BytesReadPointLookup float64

+ BytesWritten float64

+ CompactionBytesRead float64

+ CompactionBytesWritten float64

+ FlushBytesWritten float64

+ NumBackwardIter float64

+ NumForwardIter float64

+ NumKeysRead float64

+ NumKeysWritten float64

+ NumSeeks float64

+ func (stats *RocksDbStatsCounters) Describe(ch chan<- *prometheus.Desc)

+ func (stats *RocksDbStatsCounters) Export(ch chan<- prometheus.Metric)

+ type ServerStatus struct

+ Asserts *AssertsStats

+ BackgroundFlushing *FlushStats

+ Connections *ConnectionStats

+ Cursors *Cursors

+ Dur *DurStats

+ ExtraInfo *ExtraInfo

+ GlobalLock *GlobalLockStats

+ InMemory *WiredTigerStats

+ IndexCounter *IndexCounterStats

+ LocalTime time.Time

+ Locks LockStatsMap

+ Mem *MemStats

+ Metrics *MetricsStats

+ Network *NetworkStats

+ Opcounters *OpcountersStats

+ OpcountersRepl *OpcountersReplStats

+ RocksDb *RocksDbStats

+ StorageEngine *StorageEngineStats

+ Uptime float64

+ UptimeEstimate float64

+ WiredTiger *WiredTigerStats

+ func GetServerStatus(session *mgo.Session) *ServerStatus

+ func (status *ServerStatus) Describe(ch chan<- *prometheus.Desc)

+ func (status *ServerStatus) Export(ch chan<- prometheus.Metric)

+ type StorageEngineStats struct

+ Name string

+ func (stats *StorageEngineStats) Describe(ch chan<- *prometheus.Desc)

+ func (stats *StorageEngineStats) Export(ch chan<- prometheus.Metric)

+ type StorageStats struct

+ BucketExhausted float64

+ Requests float64

+ Scanned float64

+ func (storageStats *StorageStats) Export(ch chan<- prometheus.Metric)

+ type WTBlockManagerStats struct

+ BlocksPreLoaded float64

+ BlocksRead float64

+ BlocksWritten float64

+ BytesRead float64

+ BytesWritten float64

+ MappedBlocksRead float64

+ MappedBytesRead float64

+ func (stats *WTBlockManagerStats) Describe(ch chan<- *prometheus.Desc)

+ func (stats *WTBlockManagerStats) Export(ch chan<- prometheus.Metric)

+ type WTCacheStats struct

+ BytesDirty float64

+ BytesReadInto float64

+ BytesTotal float64

+ BytesWrittenFrom float64

+ EvictedModified float64

+ EvictedUnmodified float64

+ MaxBytes float64

+ PagesDirty float64

+ PagesReadInto float64

+ PagesTotal float64

+ PagesWrittenFrom float64

+ PercentOverhead float64

+ func (stats *WTCacheStats) Describe(ch chan<- *prometheus.Desc)

+ func (stats *WTCacheStats) Export(ch chan<- prometheus.Metric)

+ type WTConcurrentTransactionsStats struct

+ Read *WTConcurrentTransactionsTypeStats

+ Write *WTConcurrentTransactionsTypeStats

+ func (stats *WTConcurrentTransactionsStats) Describe(ch chan<- *prometheus.Desc)

+ func (stats *WTConcurrentTransactionsStats) Export(ch chan<- prometheus.Metric)

+ type WTConcurrentTransactionsTypeStats struct

+ Available float64

+ Out float64

+ TotalTickets float64

+ type WTLogStats struct

+ BytesPayloadData float64

+ BytesWritten float64

+ LogFlushes float64

+ LogReads float64

+ LogScans float64

+ LogScansDouble float64

+ LogSyncDirs float64

+ LogSyncs float64

+ LogWrites float64

+ MaxLogSize float64

+ RecordsCompressed float64

+ RecordsProcessedLogScan float64

+ RecordsUncompressed float64

+ TotalBufferSize float64

+ TotalSizeCompressed float64

+ func (stats *WTLogStats) Describe(ch chan<- *prometheus.Desc)

+ func (stats *WTLogStats) Export(ch chan<- prometheus.Metric)

+ type WTSessionStats struct

+ Cursors float64

+ Sessions float64

+ func (stats *WTSessionStats) Describe(ch chan<- *prometheus.Desc)

+ func (stats *WTSessionStats) Export(ch chan<- prometheus.Metric)

+ type WTTransactionStats struct

+ Begins float64

+ CacheOverflowFailure float64

+ CheckpointLastMs float64

+ CheckpointMaxMs float64

+ CheckpointMinMs float64

+ CheckpointTotalMs float64

+ Checkpoints float64

+ CheckpointsRunning float64

+ Committed float64

+ RolledBack float64

+ func (stats *WTTransactionStats) Describe(ch chan<- *prometheus.Desc)

+ func (stats *WTTransactionStats) Export(ch chan<- prometheus.Metric)

+ type WiredTigerStats struct

+ BlockManager *WTBlockManagerStats

+ Cache *WTCacheStats

+ ConcurrentTransactions *WTConcurrentTransactionsStats

+ Log *WTLogStats

+ Session *WTSessionStats

+ Transaction *WTTransactionStats

+ func (stats *WiredTigerStats) Describe(ch chan<- *prometheus.Desc)

+ func (stats *WiredTigerStats) Export(ch chan<- prometheus.Metric)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL