metrics

Documentation

Index

• func Begin(ctx context.Context)
• func End(ctx context.Context)
• func EndWithCause(ctx context.Context, cause error)
• func New(reporter Reporter) services.Service
• type Event
• type Metric
• type Reporter

Functions

func Begin

func Begin(ctx context.Context)

func End

func End(ctx context.Context)

func EndWithCause

func EndWithCause(ctx context.Context, cause error)

func New

func New(reporter Reporter) services.Service

Types

type Event

type Event struct {
	// contains filtered or unexported fields
}

type Metric

type Metric struct {
	Endpoint  string `json:"endpoint" avro:"endpoint"`
	Fn        string `json:"fn" avro:"fn"`
	Latency   int64  `json:"latency" avro:"latency"`
	Succeed   bool   `json:"succeed" avro:"succeed"`
	ErrorCode int    `json:"errorCode" avro:"errorCode"`
	ErrorName string `json:"errorName" avro:"errorName"`
	DeviceId  string `json:"deviceId" avro:"deviceId"`
	DeviceIp  string `json:"deviceIp" avro:"deviceIp"`
	// contains filtered or unexported fields
}

Metric use @metric to enable in fn

type Reporter

type Reporter interface {
	services.Component
	Report(ctx context.Context, metric Metric)
}