forked from voc/srtrelay
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #1 from voc/master
Marge upstream
- Loading branch information
Showing
24 changed files
with
538 additions
and
100 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,10 @@ | ||
| version: 2 | ||
| updates: | ||
| - package-ecosystem: "gomod" | ||
| directory: "/" | ||
| schedule: | ||
| interval: "monthly" | ||
| - package-ecosystem: "github-actions" | ||
| directory: "/" | ||
| schedule: | ||
| interval: "monthly" |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,36 @@ | ||
| --- | ||
| name: golangci-lint | ||
| on: | ||
| push: | ||
| paths: | ||
| - "go.sum" | ||
| - "go.mod" | ||
| - "**.go" | ||
| - ".github/workflows/golangci-lint.yml" | ||
| - ".golangci.yml" | ||
| pull_request: | ||
|
|
||
| permissions: # added using https://github.com/step-security/secure-repo | ||
| contents: read | ||
|
|
||
| jobs: | ||
| golangci: | ||
| permissions: | ||
| contents: read # for actions/checkout to fetch code | ||
| pull-requests: read # for golangci/golangci-lint-action to fetch pull requests | ||
| name: lint | ||
| runs-on: ubuntu-latest | ||
| steps: | ||
| - name: Checkout repository | ||
| uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4.2.2 | ||
| - name: Install Go | ||
| uses: actions/setup-go@3041bf56c941b39c61721a86cd11f3bb1338122a # v5.2.0 | ||
| with: | ||
| go-version: 1.23.x | ||
| - name: Install dependencies | ||
| run: ./scripts/install-dependencies.sh | ||
| - name: Lint | ||
| uses: golangci/golangci-lint-action@971e284b6050e8a5849b72094c50ab08da042db8 # v6.1.1 | ||
| with: | ||
| args: --verbose | ||
| version: v1.62.0 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,3 +1,7 @@ | ||
| srtrelay | ||
| config.toml | ||
| /.vscode | ||
| # VSCode | ||
| /.vscode | ||
| # Jetbrains | ||
| /.idea | ||
| *.iml |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,11 @@ | ||
| --- | ||
| linters: | ||
| enable: | ||
| - goimports | ||
| - misspell | ||
|
|
||
| issues: | ||
| exclude-rules: | ||
| - path: _test.go | ||
| linters: | ||
| - errcheck |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,202 @@ | ||
| package api | ||
|
|
||
| import ( | ||
| "github.com/voc/srtrelay/internal/metrics" | ||
| "github.com/voc/srtrelay/srt" | ||
|
|
||
| "github.com/prometheus/client_golang/prometheus" | ||
| ) | ||
|
|
||
| const srtSubsystem = "srt" | ||
|
|
||
| var ( | ||
| activeSocketsDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "active_sockets"), | ||
| "The number of active SRT sockets", | ||
| nil, nil, | ||
| ) | ||
|
|
||
| // Metrics from: https://pkg.go.dev/github.com/haivision/srtgo#SrtStats | ||
| pktSentTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "sent_packets_total"), | ||
| "total number of sent data packets, including retransmissions", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| pktRecvTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "receive_packets_total"), | ||
| "total number of received packets", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| pktSndLossTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "sent_lost_packets_total"), | ||
| "total number of lost packets (sender side)", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| pktRcvLossTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "receive_lost_packets_total"), | ||
| "total number of lost packets (receive_side)", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| pktRetransTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "retransmitted_packets_total"), | ||
| "total number of retransmitted packets", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| pktSentACKTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "sent_ack_packets_total"), | ||
| "total number of sent ACK packets", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| pktRecvACKTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "receive_ack_packets_total"), | ||
| "total number of received ACK packets", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| pktSentNAKTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "sent_nak_packets_total"), | ||
| "total number of received NAK packets", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| pktRecvNAKTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "receive_nak_packets_total"), | ||
| "total number of received NAK packets", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| sndDurationTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "udt_sent_duration_seconds_total"), | ||
| "total time duration when UDT is sending data (idle time exclusive)", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| pktSndDropTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "sent_dropped_packets_total"), | ||
| "number of too-late-to-send dropped packets", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| pktRcvDropTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "receive_dropped_packets_total"), | ||
| "number of too-late-to play missing packets", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| pktRcvUndecryptTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "receive_undecrypted_packets_total"), | ||
| "number of undecrypted packets", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| byteSentTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "sent_bytes_total"), | ||
| "total number of sent data bytes, including retransmissions", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| byteRecvTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "receive_bytes_total"), | ||
| "total number of received bytes", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| byteRcvLossTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "receive_lost_bytes_total"), | ||
| "total number of lost bytes", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| byteRetransTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "retransmitted_bytes_total"), | ||
| "total number of retransmitted bytes", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| byteSndDropTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "sent_dropped_bytes_total"), | ||
| "number of too-late-to-send dropped bytes", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| byteRcvDropTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "receive_dropped_bytes_total"), | ||
| "number of too-late-to play missing bytes (estimate based on average packet size)", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
|
|
||
| byteRcvUndecryptTotalDesc = prometheus.NewDesc( | ||
| prometheus.BuildFQName(metrics.Namespace, srtSubsystem, "receive_undecrypted_bytes_total"), | ||
| "number of undecrypted bytes", | ||
| []string{"address", "stream_id"}, nil, | ||
| ) | ||
| ) | ||
|
|
||
| // Exporter collects metrics. It implements prometheus.Collector. | ||
| type Exporter struct { | ||
| server srt.Server | ||
| } | ||
|
|
||
| func NewExporter(s srt.Server) *Exporter { | ||
| e := Exporter{server: s} | ||
| return &e | ||
| } | ||
|
|
||
| // Describe implements prometheus.Collector. | ||
| func (e *Exporter) Describe(ch chan<- *prometheus.Desc) { | ||
| ch <- activeSocketsDesc | ||
| ch <- pktSentTotalDesc | ||
| ch <- pktRecvTotalDesc | ||
| ch <- pktSndLossTotalDesc | ||
| ch <- pktRcvLossTotalDesc | ||
| ch <- pktRetransTotalDesc | ||
| ch <- pktSentACKTotalDesc | ||
| ch <- pktRecvACKTotalDesc | ||
| ch <- pktSentNAKTotalDesc | ||
| ch <- pktRecvNAKTotalDesc | ||
| ch <- sndDurationTotalDesc | ||
| ch <- pktSndDropTotalDesc | ||
| ch <- pktRcvDropTotalDesc | ||
| ch <- pktRcvUndecryptTotalDesc | ||
| ch <- byteSentTotalDesc | ||
| ch <- byteRecvTotalDesc | ||
| ch <- byteRcvLossTotalDesc | ||
| ch <- byteRetransTotalDesc | ||
| ch <- byteSndDropTotalDesc | ||
| ch <- byteRcvDropTotalDesc | ||
| ch <- byteRcvUndecryptTotalDesc | ||
| } | ||
|
|
||
| // Collect implements prometheus.Collector. | ||
| func (e *Exporter) Collect(ch chan<- prometheus.Metric) { | ||
| stats := e.server.GetSocketStatistics() | ||
| ch <- prometheus.MustNewConstMetric(activeSocketsDesc, prometheus.GaugeValue, float64(len(stats))) | ||
| for _, stat := range stats { | ||
| ch <- prometheus.MustNewConstMetric(pktSentTotalDesc, prometheus.CounterValue, float64(stat.Stats.PktSentTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(pktRecvTotalDesc, prometheus.CounterValue, float64(stat.Stats.PktRecvTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(pktSndLossTotalDesc, prometheus.CounterValue, float64(stat.Stats.PktSndLossTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(pktRcvLossTotalDesc, prometheus.CounterValue, float64(stat.Stats.PktRcvLossTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(pktRetransTotalDesc, prometheus.CounterValue, float64(stat.Stats.PktRetransTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(pktSentACKTotalDesc, prometheus.CounterValue, float64(stat.Stats.PktSentACKTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(pktRecvACKTotalDesc, prometheus.CounterValue, float64(stat.Stats.PktRecvACKTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(pktSentNAKTotalDesc, prometheus.CounterValue, float64(stat.Stats.PktSentNAKTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(pktRecvNAKTotalDesc, prometheus.CounterValue, float64(stat.Stats.PktRecvNAKTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(sndDurationTotalDesc, prometheus.CounterValue, float64(stat.Stats.UsSndDurationTotal)/1_000_000.0, stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(pktSndDropTotalDesc, prometheus.CounterValue, float64(stat.Stats.PktSndDropTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(pktRcvDropTotalDesc, prometheus.CounterValue, float64(stat.Stats.PktRcvDropTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(pktRcvUndecryptTotalDesc, prometheus.CounterValue, float64(stat.Stats.PktRcvUndecryptTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(byteSentTotalDesc, prometheus.CounterValue, float64(stat.Stats.ByteSentTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(byteRecvTotalDesc, prometheus.CounterValue, float64(stat.Stats.ByteRecvTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(byteRcvLossTotalDesc, prometheus.CounterValue, float64(stat.Stats.ByteRcvLossTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(byteRetransTotalDesc, prometheus.CounterValue, float64(stat.Stats.ByteRetransTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(byteSndDropTotalDesc, prometheus.CounterValue, float64(stat.Stats.ByteSndDropTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(byteRcvDropTotalDesc, prometheus.CounterValue, float64(stat.Stats.ByteRcvDropTotal), stat.Address, stat.StreamID) | ||
| ch <- prometheus.MustNewConstMetric(byteRcvUndecryptTotalDesc, prometheus.CounterValue, float64(stat.Stats.ByteRcvUndecryptTotal), stat.Address, stat.StreamID) | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.