reporter

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

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

func NewLogReporter() (go2sky.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 WithFAASLayer

func WithFAASLayer() GRPCReporterOption

WithFAASLayer set layer to FAAS

func WithInstanceProps

func WithInstanceProps(props map[string]string) GRPCReporterOption

WithInstanceProps setup service instance properties eg: org=SkyAPM

func WithLayer

func WithLayer(layer string) GRPCReporterOption

WithLayer setup layer

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 WithReportStrategy

func WithReportStrategy(rs ReportStrategy) GRPCReporterOption

WithReportStrategy set report strategy

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
)

type ReportStrategy

type ReportStrategy func(s *agentv3.SegmentObject) bool

ReportStrategy allowed to set a custom filter to filter the reported segment