| 1956 | } |
| 1957 | |
| 1958 | func (d *DbStats) InitDeltaSyncStats() error { |
| 1959 | var err error |
| 1960 | resUtil := &DeltaSyncStats{} |
| 1961 | labelKeys := []string{DatabaseLabelKey} |
| 1962 | labelVals := []string{d.dbName} |
| 1963 | |
| 1964 | resUtil.DeltasRequested, err = NewIntStat(SubsystemDeltaSyncKey, "deltas_requested", StatUnitNoUnits, DeltasRequestedDesc, StatAddedVersion3dot0dot0, StatDeprecatedVersionNotDeprecated, StatStabilityCommitted, labelKeys, labelVals, prometheus.CounterValue, 0) |
| 1965 | if err != nil { |
| 1966 | return err |
| 1967 | } |
| 1968 | resUtil.DeltasSent, err = NewIntStat(SubsystemDeltaSyncKey, "deltas_sent", StatUnitNoUnits, DeltasSentDesc, StatAddedVersion3dot0dot0, StatDeprecatedVersionNotDeprecated, StatStabilityCommitted, labelKeys, labelVals, prometheus.CounterValue, 0) |
| 1969 | if err != nil { |
| 1970 | return err |
| 1971 | } |
| 1972 | resUtil.DeltaPullReplicationCount, err = NewIntStat(SubsystemDeltaSyncKey, "delta_pull_replication_count", StatUnitNoUnits, DeltaPullReplicationCountDesc, StatAddedVersion3dot0dot0, StatDeprecatedVersionNotDeprecated, StatStabilityCommitted, labelKeys, labelVals, prometheus.CounterValue, 0) |
| 1973 | if err != nil { |
| 1974 | return err |
| 1975 | } |
| 1976 | resUtil.DeltaCacheHit, err = NewIntStat(SubsystemDeltaSyncKey, "delta_cache_hit", StatUnitNoUnits, DeltaCacheHitDesc, StatAddedVersion3dot0dot0, StatDeprecatedVersionNotDeprecated, StatStabilityCommitted, labelKeys, labelVals, prometheus.CounterValue, 0) |
| 1977 | if err != nil { |
| 1978 | return err |
| 1979 | } |
| 1980 | resUtil.DeltaCacheMiss, err = NewIntStat(SubsystemDeltaSyncKey, "delta_sync_miss", StatUnitNoUnits, DeltaCacheMissDesc, StatAddedVersion3dot0dot0, StatDeprecatedVersionNotDeprecated, StatStabilityCommitted, labelKeys, labelVals, prometheus.CounterValue, 0) |
| 1981 | if err != nil { |
| 1982 | return err |
| 1983 | } |
| 1984 | resUtil.DeltaPushDocCount, err = NewIntStat(SubsystemDeltaSyncKey, "delta_push_doc_count", StatUnitNoUnits, DeltaPushDocCountDesc, StatAddedVersion3dot0dot0, StatDeprecatedVersionNotDeprecated, StatStabilityCommitted, labelKeys, labelVals, prometheus.CounterValue, 0) |
| 1985 | if err != nil { |
| 1986 | return err |
| 1987 | } |
| 1988 | |
| 1989 | d.DeltaSyncStats = resUtil |
| 1990 | return nil |
| 1991 | } |
| 1992 | |
| 1993 | func (d *DbStats) unregisterDeltaSyncStats() { |
| 1994 | prometheus.Unregister(d.DeltaSyncStats.DeltasRequested) |