telemetry

Documentation

Index

• Variables
• func NewTelemetryAgent(addr string, opts ...Option) (*telemetryAgent, error)
• type Float64Callback
• type Int64Callback
• type ObserverFloat64
• type ObserverInt64
• type Option
  • func GRPCConn(v *grpc.ClientConn) Option
  • func ReportInterval(v time.Duration) Option
  • func ReportTimeout(v time.Duration) Option

Variables

var (
	ErrInvalidMetric = errors.New("metrics meter is invalid")
)

Functions

func NewTelemetryAgent

func NewTelemetryAgent(addr string, opts ...Option) (*telemetryAgent, error)

Types

type Float64Callback

type Float64Callback func() (ObserverFloat64, error)

type Int64Callback

type Int64Callback func() (ObserverInt64, error)

type ObserverFloat64

type ObserverFloat64 struct {
	Value   float64
	Options []api.ObserveOption
}

type ObserverInt64

type ObserverInt64 struct {
	Value   int64
	Options []api.ObserveOption
}

type Option

type Option func(*telemetryAgent)

func GRPCConn

func GRPCConn(v *grpc.ClientConn) Option

func ReportInterval

func ReportInterval(v time.Duration) Option

func ReportTimeout

func ReportTimeout(v time.Duration) Option