3pp-mirror/pomerium
1
0
Fork 0
mirror of https://github.com/pomerium/pomerium.git synced 2025-08-04 01:09:36 +02:00
Code Issues Projects Releases Packages Wiki Activity

zero/telemetry: add hostname and version (#5146)

Browse source
This commit is contained in:
Denis Mishin 2024-06-24 21:33:37 -04:00 • committed by GitHub
parent 7eca911292
commit a7dd30ad29
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 98 additions and 65 deletions
Download patch file Download diff file Expand all files Collapse all files

11
internal/zero/connect-mux/service.go
View file

@ -5,11 +5,13 @@ import (
"context"
"errors"
"fmt"
"os"
"sync/atomic"
"github.com/cenkalti/backoff/v4"
"github.com/rs/zerolog/log"
"github.com/pomerium/pomerium/internal/version"
"github.com/pomerium/pomerium/internal/zero/apierror"
"github.com/pomerium/pomerium/pkg/fanout"
"github.com/pomerium/pomerium/pkg/health"
@ -69,7 +71,14 @@ func (svc *Mux) subscribeAndDispatch(ctx context.Context, onConnected func()) (e
ctx, cancel := context.WithCancel(ctx)
defer cancel()
stream, err := svc.client.Subscribe(ctx, &connect.SubscribeRequest{})
hostname, err := os.Hostname()
if err != nil {
hostname = "__unknown__"
}
stream, err := svc.client.Subscribe(ctx, &connect.SubscribeRequest{
Hostname: hostname,
Version: version.FullVersion(),
})
if err != nil {
return fmt.Errorf("subscribe: %w", err)
}