Versions in this module Expand all Collapse all v0 v0.2.23 May 14, 2021 Changes in this version + const DefaultOplogPushStatsPrefix + const DefaultStatsPrefix + func RefreshWithInterval(ctx context.Context, interval time.Duration, stats OplogPushUpdater, ...) + type OplogArchivedStatsReport struct + Bytes uint64 + Docs uint64 + LastTS models.Timestamp + type OplogArchivedStatsReporter interface + Report func() OplogArchivedStatsReport + type OplogPushReport struct + Archived OplogArchivedStatsReport + Mongo struct{ ... } + Status OplogPushStatus + type OplogPushStats struct + func NewOplogPushStats(ctx context.Context, opRep OplogArchivedStatsReporter, mc client.MongoDriver, ...) *OplogPushStats + func (st *OplogPushStats) RunLogging(logInterval time.Duration, logger logFunc) + func (st *OplogPushStats) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (st *OplogPushStats) Update() error + type OplogPushStatsOption func(*OplogPushStats) + func EnableHTTPHandler(httpPattern string, srv webserver.WebServer) OplogPushStatsOption + func EnableLogReport(logInterval time.Duration, logger logFunc) OplogPushStatsOption + type OplogPushStatus string + const OplogPushArchiving + const OplogPushStandBy + type OplogPushUpdater interface + Update func() error + type OplogUploadStats struct + func NewOplogUploadStats(lastUploadedTS models.Timestamp) *OplogUploadStats + func (r *OplogUploadStats) Report() OplogArchivedStatsReport + func (r *OplogUploadStats) Update(batchDocs, batchBytes int, lastArchivedTS models.Timestamp) + type OplogUploadStatsUpdater interface + Update func(batchDocs, batchBytes int, lastArchivedTS models.Timestamp)