Documentation
¶
Index ¶
- Variables
- func AkamaiMitigatedIncr()
- func ArchiverRoutinesDecr()
- func ArchiverRoutinesIncr()
- func CFMitigatedIncr()
- func FinisherRoutinesDecr()
- func FinisherRoutinesIncr()
- func GetMapTUI() map[string]any
- func HTTPReturnCodesIncr(key string)
- func Init() error
- func MeanHTTPRespTimeAdd(value time.Duration)
- func MeanProcessBodyTimeAdd(value time.Duration)
- func MeanWaitOnFeedbackTimeAdd(value time.Duration)
- func PausedReset()
- func PausedSet()
- func PausedUnset()
- func PostprocessorRoutinesDecr()
- func PostprocessorRoutinesIncr()
- func PreprocessorRoutinesDecr()
- func PreprocessorRoutinesIncr()
- func PrometheusHandler() http.Handler
- func Reset()
- func SeedsFinishedIncr()
- func SeencheckFailuresIncr()
- func URLsCrawledIncr()
- func WARCCDXDedupeTotalBytesSet(value int64)
- func WARCCDXDedupeTotalSet(value int64)
- func WARCDataTotalBytesSet(value int64)
- func WARCDoppelgangerDedupeTotalBytesSet(value int64)
- func WARCDoppelgangerDedupeTotalSet(value int64)
- func WARCLocalDedupeTotalBytesSet(value int64)
- func WARCLocalDedupeTotalSet(value int64)
- func WarcWritingQueueSizeSet(value int64)
Constants ¶
This section is empty.
Variables ¶
var ( // ErrStatsNotInitialized is returned when the stats package is not initialized ErrStatsNotInitialized = errors.New("stats not initialized") // ErrStatsAlreadyInitialized is returned when the stats package is already initialized ErrStatsAlreadyInitialized = errors.New("stats already initialized") )
Functions ¶
func AkamaiMitigatedIncr ¶
func AkamaiMitigatedIncr()
AkamaiMitigatedIncr increments the AkamaiMitigated counter by 1.
func ArchiverRoutinesDecr ¶
func ArchiverRoutinesDecr()
ArchiverRoutinesDecr decrements the ArchiverRoutines counter by 1.
func ArchiverRoutinesIncr ¶
func ArchiverRoutinesIncr()
ArchiverRoutinesIncr increments the ArchiverRoutines counter by 1.
func CFMitigatedIncr ¶
func CFMitigatedIncr()
CFMitigatedIncr increments the CFMitigated counter by 1.
func FinisherRoutinesDecr ¶
func FinisherRoutinesDecr()
FinisherRoutinesDecr decrements the FinisherRoutines counter by 1.
func FinisherRoutinesIncr ¶
func FinisherRoutinesIncr()
FinisherRoutinesIncr increments the FinisherRoutines counter by 1.
func GetMapTUI ¶
GetMapTUI returns a map of the current stats. This is used by the TUI to update the stats table.
func HTTPReturnCodesIncr ¶
func HTTPReturnCodesIncr(key string)
HTTPReturnCodesIncr increments the HTTPReturnCodes counter for the given key by 1.
func MeanHTTPRespTimeAdd ¶
MeanHTTPRespTimeAdd adds the given value to the MeanHTTPRespTime.
func MeanProcessBodyTimeAdd ¶
MeanProcessBodyTimeAdd adds the given value to the MeanProcessBodyTime.
func MeanWaitOnFeedbackTimeAdd ¶
MeanWaitOnFeedbackTimeAdd adds the given value to the MeanWaitOnFeedbackTime.
func PostprocessorRoutinesDecr ¶
func PostprocessorRoutinesDecr()
PostprocessorRoutinesDecr decrements the PostprocessorRoutines counter by 1.
func PostprocessorRoutinesIncr ¶
func PostprocessorRoutinesIncr()
PostprocessorRoutinesIncr increments the PostprocessorRoutines counter by 1.
func PreprocessorRoutinesDecr ¶
func PreprocessorRoutinesDecr()
PreprocessorRoutinesDecr decrements the PreprocessorRoutines counter by 1.
func PreprocessorRoutinesIncr ¶
func PreprocessorRoutinesIncr()
PreprocessorRoutinesIncr increments the PreprocessorRoutines counter by 1.
func PrometheusHandler ¶
func SeedsFinishedIncr ¶
func SeedsFinishedIncr()
SeedsFinishedIncr increments the SeedsFinished counter by 1.
func SeencheckFailuresIncr ¶
func SeencheckFailuresIncr()
SeencheckFailuresIncr increments the SeencheckFailures counter by 1.
func URLsCrawledIncr ¶
func URLsCrawledIncr()
URLsCrawledIncr increments the URLsCrawled counter by 1.
func WARCCDXDedupeTotalBytesSet ¶
func WARCCDXDedupeTotalBytesSet(value int64)
WARCCDXDedupeTotalBytesSet sets the WARC CDX dedupe total bytes metric.
func WARCCDXDedupeTotalSet ¶
func WARCCDXDedupeTotalSet(value int64)
WARCCDXDedupeTotalSet sets the WARC CDX dedupe total count metric.
func WARCDataTotalBytesSet ¶
func WARCDataTotalBytesSet(value int64)
WARCDataTotalBytesSet sets the WARC data total bytes metric.
func WARCDoppelgangerDedupeTotalBytesSet ¶
func WARCDoppelgangerDedupeTotalBytesSet(value int64)
WARCDoppelgangerDedupeTotalBytesSet sets the WARC Doppelganger dedupe total bytes metric.
func WARCDoppelgangerDedupeTotalSet ¶
func WARCDoppelgangerDedupeTotalSet(value int64)
WARCDoppelgangerDedupeTotalSet sets the WARC Doppelganger dedupe total count metric.
func WARCLocalDedupeTotalBytesSet ¶
func WARCLocalDedupeTotalBytesSet(value int64)
WARCLocalDedupeTotalBytesSet sets the WARC local dedupe total bytes metric.
func WARCLocalDedupeTotalSet ¶
func WARCLocalDedupeTotalSet(value int64)
WARCLocalDedupeTotalSet sets the WARC local dedupe total count metric.
func WarcWritingQueueSizeSet ¶
func WarcWritingQueueSizeSet(value int64)
WarcWritingQueueSizeSet sets the WarcWritingQueueSize to the given value.
Types ¶
This section is empty.
Source Files