telemetry

package

Go to main page

Versions in this module

v0

v0.14.0

Nov 8, 2024

Changes in this version

type Labels

+ func (labels Labels) WithHarnessLabels() Labels

v0.13.7

Oct 31, 2024

v0.13.6

Oct 25, 2024

Changes in this version

+ func ReexportMetricsFromPB(ctx context.Context, exps []sdkmetric.Exporter, ...) error

v0.13.5

Oct 10, 2024

v0.13.4

Oct 9, 2024

v0.13.3

Sep 20, 2024

v0.13.2

Sep 20, 2024

v0.13.1

Sep 18, 2024

Changes in this version

+ func ReexportLogsFromPB(ctx context.Context, exp sdklog.Exporter, ...) error

v0.13.0

Sep 11, 2024

v0.12.7

Sep 2, 2024

v0.12.6

Aug 30, 2024

v0.12.5

Aug 15, 2024

v0.12.4

Aug 2, 2024

v0.12.3

Jul 25, 2024

v0.12.2

Jul 22, 2024

v0.12.1

Jul 18, 2024

v0.12.0

Jul 12, 2024

Changes in this version

type Labels

+ func (labels Labels) WithJenkinsLabels() Labels

v0.11.9

Jun 24, 2024

v0.11.8

Jun 18, 2024

Changes in this version

type PubSub

+ func (ps *PubSub) ClientDisconnected(clientID string)

v0.11.7

Jun 11, 2024

Changes in this version

+ const HeartbeatInterval

+ const LogsSource_Subscribe_FullMethodName

+ const MetricsSource_Subscribe_FullMethodName

+ const TracesSource_Subscribe_FullMethodName

+ var File_servers_proto protoreflect.FileDescriptor

+ var LogsSource_ServiceDesc = grpc.ServiceDesc

+ var MetricsSource_ServiceDesc = grpc.ServiceDesc

+ var TracesSource_ServiceDesc = grpc.ServiceDesc

+ func ConfiguredCloudExporters(ctx context.Context) (sdktrace.SpanExporter, sdklog.Exporter, bool)

+ func MeasuringStreamClientInterceptor() grpc.StreamClientInterceptor

+ func MeasuringUnaryClientInterceptor() grpc.UnaryClientInterceptor

+ func MeasuringUnaryServerInterceptor() grpc.UnaryServerInterceptor

+ func RegisterLogsSourceServer(s grpc.ServiceRegistrar, srv LogsSourceServer)

+ func RegisterMetricsSourceServer(s grpc.ServiceRegistrar, srv MetricsSourceServer)

+ func RegisterTracesSourceServer(s grpc.ServiceRegistrar, srv TracesSourceServer)

+ func URLForTrace(ctx context.Context) (url string, msg string, ok bool)

+ type LabelFlag struct

+ func NewLabelFlag() LabelFlag

+ func (flag LabelFlag) Set(s string) error

+ func (flag LabelFlag) String() string

+ func (flag LabelFlag) Type() string

+ type Labels map[string]string

+ func LoadDefaultLabels(workdir, clientEngineVersion string) Labels

+ func (labels *Labels) UnmarshalJSON(dt []byte) error

+ func (labels Labels) UserAgent() string

+ func (labels Labels) WithAnonymousGitLabels(workdir string) Labels

+ func (labels Labels) WithCILabels() Labels

+ func (labels Labels) WithCircleCILabels() Labels

+ func (labels Labels) WithClientLabels(engineVersion string) Labels

+ func (labels Labels) WithEngineLabel(engineName string) Labels

+ func (labels Labels) WithGitHubLabels() Labels

+ func (labels Labels) WithGitLabLabels() Labels

+ func (labels Labels) WithGitLabels(workdir string) Labels

+ func (labels Labels) WithServerLabels(engineVersion, os, arch string, cacheEnabled bool) Labels

+ func (labels Labels) WithVCSLabels(workdir string) Labels

+ type LogsPubSub struct

+ func (ps LogsPubSub) Export(ctx context.Context, logs []sdklog.Record) error

+ type LogsServer struct

+ PubSub *PubSub

+ func (e *LogsServer) Export(ctx context.Context, req *colllogsv1.ExportLogsServiceRequest) (*colllogsv1.ExportLogsServiceResponse, error)

+ func (e *LogsServer) Subscribe(req *SubscribeRequest, stream LogsSource_SubscribeServer) error

+ type LogsSourceClient interface

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (LogsSource_SubscribeClient, error)

+ func NewLogsSourceClient(cc grpc.ClientConnInterface) LogsSourceClient

+ type LogsSourceServer interface

+ Subscribe func(*SubscribeRequest, LogsSource_SubscribeServer) error

+ type LogsSource_SubscribeClient interface

+ Recv func() (*v11.LogsData, error)

+ type LogsSource_SubscribeServer interface

+ Send func(*v11.LogsData) error

+ type MetricsPubSub struct

+ func (ps MetricsPubSub) Aggregation(kind sdkmetric.InstrumentKind) sdkmetric.Aggregation

+ func (ps MetricsPubSub) Export(ctx context.Context, metrics *metricdata.ResourceMetrics) error

+ func (ps MetricsPubSub) MetricSubscribers(topic Topic) []sdkmetric.Exporter

+ func (ps MetricsPubSub) Temporality(kind sdkmetric.InstrumentKind) metricdata.Temporality

+ type MetricsServer struct

+ PubSub *PubSub

+ func (e *MetricsServer) Export(ctx context.Context, req *collmetricsv1.ExportMetricsServiceRequest) (*collmetricsv1.ExportMetricsServiceResponse, error)

+ func (e *MetricsServer) Subscribe(req *SubscribeRequest, srv MetricsSource_SubscribeServer) error

+ type MetricsSourceClient interface

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (MetricsSource_SubscribeClient, error)

+ func NewMetricsSourceClient(cc grpc.ClientConnInterface) MetricsSourceClient

+ type MetricsSourceServer interface

+ Subscribe func(*SubscribeRequest, MetricsSource_SubscribeServer) error

+ type MetricsSource_SubscribeClient interface

+ Recv func() (*v12.MetricsData, error)

+ type MetricsSource_SubscribeServer interface

+ Send func(*v12.MetricsData) error

+ type PubSub struct

+ func NewPubSub() *PubSub

+ func (ps *PubSub) Drain(client string, immediate bool)

+ func (ps *PubSub) ForceFlush(ctx context.Context) error

+ func (ps *PubSub) LogSubscribers(topic Topic) []sdklog.Exporter

+ func (ps *PubSub) Logs() sdklog.Exporter

+ func (ps *PubSub) LogsHandler(rw http.ResponseWriter, r *http.Request)

+ func (ps *PubSub) Metrics() sdkmetric.Exporter

+ func (ps *PubSub) MetricsHandler(rw http.ResponseWriter, r *http.Request)

+ func (ps *PubSub) Processor() sdktrace.SpanProcessor

+ func (ps *PubSub) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (ps *PubSub) Shutdown(ctx context.Context) error

+ func (ps *PubSub) SpanSubscribers(topic Topic) []sdktrace.SpanExporter

+ func (ps *PubSub) Spans() sdktrace.SpanExporter

+ func (ps *PubSub) SubscribeToLogs(ctx context.Context, topic Topic, exp sdklog.Exporter) error

+ func (ps *PubSub) SubscribeToSpans(ctx context.Context, topic Topic, exp sdktrace.SpanExporter) error

+ func (ps *PubSub) TracesHandler(rw http.ResponseWriter, r *http.Request)

+ type SpanHeartbeater struct

+ func NewSpanHeartbeater(exp sdktrace.SpanExporter) *SpanHeartbeater

+ func (p *SpanHeartbeater) ExportSpans(ctx context.Context, spans []sdktrace.ReadOnlySpan) error

+ func (p *SpanHeartbeater) Shutdown(ctx context.Context) error

+ type SpansPubSub struct

+ func (ps SpansPubSub) ExportSpans(ctx context.Context, spans []sdktrace.ReadOnlySpan) error

+ type SubscribeRequest struct

+ ClientId string

+ TraceId []byte

+ func (*SubscribeRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeRequest) ProtoMessage()

+ func (x *SubscribeRequest) GetClientId() string

+ func (x *SubscribeRequest) GetTraceId() []byte

+ func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

+ func (x *SubscribeRequest) Reset()

+ func (x *SubscribeRequest) String() string

+ type Topic struct

+ ClientID string

+ TraceID trace.TraceID

+ func (t Topic) String() string

+ type TraceServer struct

+ PubSub *PubSub

+ func (e *TraceServer) Export(ctx context.Context, req *colltracev1.ExportTraceServiceRequest) (*colltracev1.ExportTraceServiceResponse, error)

+ func (e *TraceServer) Subscribe(req *SubscribeRequest, srv TracesSource_SubscribeServer) error

+ type TracesSourceClient interface

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (TracesSource_SubscribeClient, error)

+ func NewTracesSourceClient(cc grpc.ClientConnInterface) TracesSourceClient

+ type TracesSourceServer interface

+ Subscribe func(*SubscribeRequest, TracesSource_SubscribeServer) error

+ type TracesSource_SubscribeClient interface

+ Recv func() (*v1.TracesData, error)

+ type TracesSource_SubscribeServer interface

+ Send func(*v1.TracesData) error

+ type UnimplementedLogsSourceServer struct

+ func (UnimplementedLogsSourceServer) Subscribe(*SubscribeRequest, LogsSource_SubscribeServer) error

+ type UnimplementedMetricsSourceServer struct

+ func (UnimplementedMetricsSourceServer) Subscribe(*SubscribeRequest, MetricsSource_SubscribeServer) error

+ type UnimplementedTracesSourceServer struct

+ func (UnimplementedTracesSourceServer) Subscribe(*SubscribeRequest, TracesSource_SubscribeServer) error

+ type UnsafeLogsSourceServer interface

+ type UnsafeMetricsSourceServer interface

+ type UnsafeTracesSourceServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL