Documentation ¶
Overview ¶
Package reporter holds reporters contain official reporter implementations.
Index ¶
- func NewGRPCReporter(serverAddr string, opts ...GRPCReporterOption) (go2sky.Reporter, error)
- func NewLogReporter() (go2sky.Reporter, error)
- type GRPCReporterOption
- func WithAuthentication(auth string) GRPCReporterOption
- func WithCDS(interval time.Duration) GRPCReporterOption
- func WithCheckInterval(interval time.Duration) GRPCReporterOption
- func WithFAASLayer() GRPCReporterOption
- func WithInstanceProps(props map[string]string) GRPCReporterOption
- func WithLayer(layer string) GRPCReporterOption
- func WithLog(logger logger.Log) GRPCReporterOption
- func WithLogger(log *log.Logger) GRPCReporterOption
- func WithMaxSendQueueSize(maxSendQueueSize int) GRPCReporterOption
- func WithProcessLabels(labels []string) GRPCReporterOption
- func WithProcessStatusHook(enable bool) GRPCReporterOption
- func WithReportStrategy(rs ReportStrategy) GRPCReporterOption
- func WithTransportCredentials(creds credentials.TransportCredentials) GRPCReporterOption
- type ProcessReportStatus
- type ReportStrategy
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGRPCReporter ¶
func NewGRPCReporter(serverAddr string, opts ...GRPCReporterOption) (go2sky.Reporter, error)
NewGRPCReporter create a new reporter to send data to gRPC oap server. Only one backend address is allowed.
func NewLogReporter ¶
Types ¶
type GRPCReporterOption ¶
type GRPCReporterOption func(r *gRPCReporter)
GRPCReporterOption allows for functional options to adjust behaviour of a gRPC reporter to be created by NewGRPCReporter
func WithAuthentication ¶ added in v0.4.0
func WithAuthentication(auth string) GRPCReporterOption
WithAuthentication used Authentication for gRPC
func WithCDS ¶ added in v1.1.0
func WithCDS(interval time.Duration) GRPCReporterOption
WithCDS setup Configuration Discovery Service to dynamic config
func WithCheckInterval ¶ added in v0.4.0
func WithCheckInterval(interval time.Duration) GRPCReporterOption
WithCheckInterval setup service and endpoint registry check interval
func WithFAASLayer ¶ added in v1.4.1
func WithFAASLayer() GRPCReporterOption
WithFAASLayer set layer to FAAS
func WithInstanceProps ¶ added in v0.4.0
func WithInstanceProps(props map[string]string) GRPCReporterOption
WithInstanceProps setup service instance properties eg: org=SkyAPM
func WithLayer ¶ added in v1.4.1
func WithLayer(layer string) GRPCReporterOption
WithLayer setup layer
func WithLog ¶ added in v1.4.0
func WithLog(logger logger.Log) GRPCReporterOption
WithLog setup log for gRPC reporter
func WithLogger ¶
func WithLogger(log *log.Logger) GRPCReporterOption
WithLogger setup logger for gRPC reporter Deprecated: WithLog is recommended
func WithMaxSendQueueSize ¶ added in v0.4.0
func WithMaxSendQueueSize(maxSendQueueSize int) GRPCReporterOption
WithMaxSendQueueSize setup send span queue buffer length
func WithProcessLabels ¶ added in v1.5.0
func WithProcessLabels(labels []string) GRPCReporterOption
WithProcessLabels setup labels bind to process
func WithProcessStatusHook ¶ added in v1.5.0
func WithProcessStatusHook(enable bool) GRPCReporterOption
WithProcessStatusHook setup is enabled the process status
func WithReportStrategy ¶ added in v1.5.0
func WithReportStrategy(rs ReportStrategy) GRPCReporterOption
WithReportStrategy set report strategy
func WithTransportCredentials ¶ added in v0.4.0
func WithTransportCredentials(creds credentials.TransportCredentials) GRPCReporterOption
WithTransportCredentials setup transport layer security
type ProcessReportStatus ¶ added in v1.5.0
type ProcessReportStatus int8
const ( ProcessLabelKey = "processLabels" NotInit ProcessReportStatus = iota Reported Closed )
type ReportStrategy ¶ added in v1.5.0
type ReportStrategy func(s *agentv3.SegmentObject) bool
ReportStrategy allowed to set a custom filter to filter the reported segment
Directories ¶
Path | Synopsis |
---|---|
grpc
|
|
language-agent/mock_trace
Package mock_v3 is a generated GoMock package.
|
Package mock_v3 is a generated GoMock package. |
management/mock_management
Package mock_v3 is a generated GoMock package.
|
Package mock_v3 is a generated GoMock package. |