telemetry

Documentation

Index

• func NewProxyServer(logger *slog.Logger, reporter Reporter) (string, http.Handler)
• func StripS3EndpointURL(endpointURL string) (string, error)
• type PanicReporter
  • func NewPanicReporter(logger *slog.Logger, reporter Reporter) *PanicReporter
  • func (r *PanicReporter) OnPanic(c echo.Context, reportedError error, reportedStack []byte) error
• type ProxyServer
  • func (s *ProxyServer) Report(_ context.Context, req *connect.Request[v1alpha1.TelemetryEvent]) (*connect.Response[emptypb.Empty], error)
• type RemoteReporter
  • func (r *RemoteReporter) Close() error
  • func (r *RemoteReporter) ReportEvent(event *v1alpha1.TelemetryEvent)
  • func (r *RemoteReporter) ReportStart(ctx context.Context, endpointURL string) error
• type Reporter
  • func NewRemoteReporter(ctx context.Context, logger *slog.Logger, httpClient connect.HTTPClient, ...) Reporter

Functions

func NewProxyServer

func NewProxyServer(logger *slog.Logger, reporter Reporter) (string, http.Handler)

func StripS3EndpointURL

func StripS3EndpointURL(endpointURL string) (string, error)

StripS3EndpointURL removes user identifiable information from an S3 endpoint URL.

Types

type PanicReporter

type PanicReporter struct {
	// contains filtered or unexported fields
}

PanicReporter reports crashes to our telemetry server.

func NewPanicReporter

func NewPanicReporter(logger *slog.Logger, reporter Reporter) *PanicReporter

func (*PanicReporter) OnPanic

func (r *PanicReporter) OnPanic(c echo.Context, reportedError error, reportedStack []byte) error

type ProxyServer

type ProxyServer struct {
	http.Handler
	// contains filtered or unexported fields
}

ProxyServer proxies telemetry events from the browser.

func (*ProxyServer) Report

func (s *ProxyServer) Report(_ context.Context, req *connect.Request[v1alpha1.TelemetryEvent]) (*connect.Response[emptypb.Empty], error)

type RemoteReporter

type RemoteReporter struct {
	// contains filtered or unexported fields
}

func (*RemoteReporter) Close

func (r *RemoteReporter) Close() error

func (*RemoteReporter) ReportEvent

func (r *RemoteReporter) ReportEvent(event *v1alpha1.TelemetryEvent)

func (*RemoteReporter) ReportStart

func (r *RemoteReporter) ReportStart(ctx context.Context, endpointURL string) error

type Reporter

type Reporter interface {
	io.Closer
	ReportStart(ctx context.Context, endpointURL string) error
	ReportEvent(event *v1alpha1.TelemetryEvent)
}

func NewRemoteReporter

func NewRemoteReporter(ctx context.Context, logger *slog.Logger, httpClient connect.HTTPClient, baseURL string) Reporter