Versions in this module Expand all Collapse all v1 v1.0.0 Jun 21, 2023 Changes in this version + func CallMetricsServerOption(smp ServerMetricsProvider) grpc.ServerOption + func Register(s *grpc.Server, opts ServiceOptions) error + func RegisterOOBListener(sc balancer.SubConn, l OOBListener, opts OOBListenerOptions) (stop func()) + type CallMetricsRecorder interface + DeleteNamedMetric func(name string) + DeleteRequestCost func(name string) + SetNamedMetric func(name string, val float64) + SetRequestCost func(name string, val float64) + func CallMetricsRecorderFromContext(ctx context.Context) CallMetricsRecorder + type OOBListener interface + OnLoadReport func(*v3orcapb.OrcaLoadReport) + type OOBListenerOptions struct + ReportInterval time.Duration + type ServerMetrics struct + AppUtilization float64 + CPUUtilization float64 + EPS float64 + MemUtilization float64 + NamedMetrics map[string]float64 + QPS float64 + RequestCost map[string]float64 + Utilization map[string]float64 + type ServerMetricsProvider interface + ServerMetrics func() *ServerMetrics + type ServerMetricsRecorder interface + DeleteApplicationUtilization func() + DeleteCPUUtilization func() + DeleteEPS func() + DeleteMemoryUtilization func() + DeleteNamedUtilization func(name string) + DeleteQPS func() + SetApplicationUtilization func(float64) + SetCPUUtilization func(float64) + SetEPS func(float64) + SetMemoryUtilization func(float64) + SetNamedUtilization func(name string, val float64) + SetQPS func(float64) + func NewServerMetricsRecorder() ServerMetricsRecorder + type Service struct + func NewService(opts ServiceOptions) (*Service, error) + func (s *Service) StreamCoreMetrics(req *v3orcaservicepb.OrcaLoadReportRequest, ...) error + type ServiceOptions struct + MinReportingInterval time.Duration + ServerMetricsProvider ServerMetricsProvider