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 WithCheckInterval(interval time.Duration) GRPCReporterOption
  • func WithInstanceProps(props map[string]string) GRPCReporterOption
  • func WithLogger(logger *log.Logger) GRPCReporterOption
  • func WithMaxSendQueueSize(maxSendQueueSize int) GRPCReporterOption
  • func WithTransportCredentials(creds credentials.TransportCredentials) GRPCReporterOption

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 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 WithLogger

func WithLogger(logger *log.Logger) GRPCReporterOption

WithLogger setup logger for gRPC reporter

func WithMaxSendQueueSize

func WithMaxSendQueueSize(maxSendQueueSize int) GRPCReporterOption

WithMaxSendQueueSize setup send span queue buffer length

func WithTransportCredentials

func WithTransportCredentials(creds credentials.TransportCredentials) GRPCReporterOption

WithTransportCredentials setup transport layer security