Documentation
¶
Overview ¶
Package reporter holds reporters contain official reporter implementations.
Index ¶
- func NewGRPCReporter(serverAddr string, opts ...GRPCReporterOption) (pobpgo.Reporter, error)
- func NewLogReporter() (pobpgo.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 WithTransportCredentials(creds credentials.TransportCredentials) GRPCReporterOption
- type ProcessReportStatus
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGRPCReporter ¶
func NewGRPCReporter(serverAddr string, opts ...GRPCReporterOption) (pobpgo.Reporter, error)
NewGRPCReporter create a new reporter to send data to gRPC oap server. Only one backend address is allowed.
func NewLogReporter ¶
func NewLogReporter() (pobpgo.Reporter, error)
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 ¶
func WithAuthentication(auth string) GRPCReporterOption
WithAuthentication used Authentication for gRPC
func WithCDS ¶
func WithCDS(interval time.Duration) GRPCReporterOption
WithCDS setup Configuration Discovery Service to dynamic config
func WithCheckInterval ¶
func WithCheckInterval(interval time.Duration) GRPCReporterOption
WithCheckInterval setup service and endpoint registry check interval
func WithInstanceProps ¶
func WithInstanceProps(props map[string]string) GRPCReporterOption
WithInstanceProps setup service instance properties eg: org=SkyAPM
func WithLog ¶
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 ¶
func WithMaxSendQueueSize(maxSendQueueSize int) GRPCReporterOption
WithMaxSendQueueSize setup send span queue buffer length
func WithProcessLabels ¶
func WithProcessLabels(labels []string) GRPCReporterOption
WithProcessLabels setup labels bind to process
func WithProcessStatusHook ¶
func WithProcessStatusHook(enable bool) GRPCReporterOption
WithProcessStatusHook setup is enabled the process status
func WithTransportCredentials ¶
func WithTransportCredentials(creds credentials.TransportCredentials) GRPCReporterOption
WithTransportCredentials setup transport layer security
type ProcessReportStatus ¶
type ProcessReportStatus int8
const ( ProcessLabelKey = "processLabels" NotInit ProcessReportStatus = iota Reported Closed )
Source Files
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. |