Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

collector_mongod

package

Go to main page

Versions in this module

v0

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)