diff --git a/cmd/cart/pool-server.go b/cmd/cart/pool-server.go index 2d8ec6e..eadc3fc 100644 --- a/cmd/cart/pool-server.go +++ b/cmd/cart/pool-server.go @@ -459,8 +459,10 @@ func (s *PoolServer) ProxyHandler(fn func(w http.ResponseWriter, r *http.Request if ownerHost, ok := s.OwnerHost(uint64(cartId)); ok { ctx, span := tracer.Start(r.Context(), "proxy") defer span.End() + span.SetAttributes(attribute.String("cartid", cartId.String())) hostAttr := attribute.String("other host", ownerHost.Name()) span.SetAttributes(hostAttr) + logger.InfoContext(ctx, "cart proxyed", "result", ownerHost.Name()) proxyCalls.Add(ctx, 1, metric.WithAttributes(hostAttr)) handled, err := ownerHost.Proxy(uint64(cartId), w, r) @@ -470,6 +472,7 @@ func (s *PoolServer) ProxyHandler(fn func(w http.ResponseWriter, r *http.Request } } _, span := tracer.Start(r.Context(), "own") + span.SetAttributes(attribute.String("cartid", cartId.String())) defer span.End() return fn(w, r, cartId) @@ -486,6 +489,17 @@ var ( // rollCnt metric.Int64Counter ) +func init() { + var err error + proxyCalls, err = meter.Int64Counter("proxy.calls", + metric.WithDescription("The number of rolls by roll value"), + metric.WithUnit("{roll}")) + if err != nil { + panic(err) + } + +} + type AddVoucherRequest struct { VoucherCode string `json:"code"` }