mii/prometheus-android-exporter
1
0
Fork 0
mirror of https://github.com/mii443/prometheus-android-exporter.git synced 2025-08-22 15:15:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

remote write compiles

Browse Source
This commit is contained in:
Martin Ptáček
2023-06-13 09:20:12 +02:00
parent 3070d256ad
commit 26244f8fed
2 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
client/app/src/main/java/com/birdthedeveloper/prometheus/android/prometheus/android/exporter/worker/RemoteWriteSender.kt
View File

@ -152,7 +152,7 @@ class RemoteWriteSender(private val config: RemoteWriteConfiguration) {
delay(checkDelay)
}
}
private suspend fun sendAll(){
scrapesAreBeingSent = true
while (!storage.isEmpty()){

10
client/app/src/main/java/com/birdthedeveloper/prometheus/android/prometheus/android/exporter/worker/RemoteWriteSenderStorage.kt
View File

@ -4,7 +4,7 @@ import android.util.Log
import com.google.protobuf.value
import io.prometheus.client.Collector
import io.prometheus.client.Collector.MetricFamilySamples
import org.xerial.snappy.Snappy
import org.iq80.snappy.Snappy
import remote.write.RemoteWrite.Label
import remote.write.RemoteWrite.Sample
import remote.write.RemoteWrite.TimeSeries
@ -85,15 +85,17 @@ abstract class RemoteWriteSenderStorage {
return result.toList()
}
private fun getTimeSeriesSample(sample : Collector.MetricFamilySamples.Sample) : TimeSeriesSample{
private fun getTimeSeriesSample(sample : MetricFamilySamples.Sample) : TimeSeriesSample{
val timestampMs : Long = sample.timestampMs ?: System.currentTimeMillis()
return TimeSeriesSample(
value = sample.value,
timeStampMs = sample.timestampMs,
timeStampMs = timestampMs,
)
}
private fun processTimeSeries(
hashMap: ConverterHashMap, familySample : Collector.MetricFamilySamples){
hashMap: ConverterHashMap, familySample : MetricFamilySamples){
val familySampleName : String = familySample.name