fixup handlers

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
2024-03-12 00:02:48 +03:00
parent 4c3d26c39b
commit 954101f887
3 changed files with 1407 additions and 12 deletions

View File

@@ -9,7 +9,6 @@ import (
"sync"
codecpb "go.unistack.org/micro-proto/v4/codec"
"go.unistack.org/micro/v4/errors"
"go.unistack.org/micro/v4/logger"
"go.unistack.org/micro/v4/metadata"
"go.unistack.org/micro/v4/meter"
@@ -82,7 +81,7 @@ func NewHandler(opts ...Option) *Handler {
func (h *Handler) Metrics(ctx context.Context, req *codecpb.Frame, rsp *codecpb.Frame) error {
log, ok := logger.FromContext(ctx)
if !ok {
log = logger.DefaultLogger()
log = logger.DefaultLogger
}
buf := bufPool.Get().(*bytes.Buffer)
@@ -103,7 +102,7 @@ func (h *Handler) Metrics(ctx context.Context, req *codecpb.Frame, rsp *codecpb.
}
if err := h.opts.Meter.Write(w, h.opts.MeterOptions...); err != nil {
log.Error(ctx, errors.InternalServerError(h.opts.Name, "%v", err))
log.Error(ctx, "http/meter: write failed", err)
return nil
}