func StreamServerInterceptor(sm *StreamMetrics) grpc.StreamServerInterceptor
func UnaryServerInterceptor(um *UnaryMetrics) grpc.UnaryServerInterceptor
type StreamMetrics struct {
RequestDuration metrics.Histogram
RequestsReceived metrics.Counter
RequestsCompleted metrics.Counter
MessagesSent metrics.Counter
MessagesReceived metrics.Counter
}
func NewStreamMetrics(p metrics.Provider) *StreamMetrics
type UnaryMetrics struct {
RequestDuration metrics.Histogram
RequestsReceived metrics.Counter
RequestsCompleted metrics.Counter
}
func NewUnaryMetrics(p metrics.Provider) *UnaryMetrics