mats/go-cart-actor
1
0
Fork 0
Code Issues Pull Requests 1 Actions 3 Packages Projects Releases Wiki Activity

better metrics
All checks were successful
Build and Publish / Metadata (push) Successful in 10s
Details
Build and Publish / BuildAndDeployAmd64 (push) Successful in 49s
Details
Build and Publish / BuildAndDeployArm64 (push) Successful in 4m34s
Details

Browse Source
This commit is contained in:
matst80
2025-11-07 14:44:15 +01:00
parent 43fcf69139
commit b272282b1f
2 changed files with 17 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
pkg/actor/grpc_server.go
View File

@@ -81,6 +81,7 @@ func (s *ControlServer[V]) AnnounceOwnership(ctx context.Context, req *messages.
ctx, span := tracer.Start(ctx, "grpc_announce_ownership") ctx, span := tracer.Start(ctx, "grpc_announce_ownership")
defer span.End() defer span.End()
span.SetAttributes( span.SetAttributes(
attribute.String("component", "controlplane"),
attribute.String("host", req.Host), attribute.String("host", req.Host),
attribute.Int("id_count", len(req.Ids)), attribute.Int("id_count", len(req.Ids)),
) )
@@ -107,6 +108,7 @@ func (s *ControlServer[V]) AnnounceExpiry(ctx context.Context, req *messages.Exp
ctx, span := tracer.Start(ctx, "grpc_announce_expiry") ctx, span := tracer.Start(ctx, "grpc_announce_expiry")
defer span.End() defer span.End()
span.SetAttributes( span.SetAttributes(
attribute.String("component", "controlplane"),
attribute.String("host", req.Host), attribute.String("host", req.Host),
attribute.Int("id_count", len(req.Ids)), attribute.Int("id_count", len(req.Ids)),
) )
@@ -125,11 +127,9 @@ func (s *ControlServer[V]) AnnounceExpiry(ctx context.Context, req *messages.Exp
// ControlPlane: Ping // ControlPlane: Ping
func (s *ControlServer[V]) Ping(ctx context.Context, _ *messages.Empty) (*messages.PingReply, error) { func (s *ControlServer[V]) Ping(ctx context.Context, _ *messages.Empty) (*messages.PingReply, error) {
ctx, span := tracer.Start(ctx, "grpc_ping")
defer span.End()
host := s.pool.Hostname() host := s.pool.Hostname()
span.SetAttributes(attribute.String("host", host))
logger.InfoContext(ctx, "ping received", "host", host)
pingCalls.Add(ctx, 1, metric.WithAttributes(attribute.String("host", host))) pingCalls.Add(ctx, 1, metric.WithAttributes(attribute.String("host", host)))
// log.Printf("got ping") // log.Printf("got ping")
@@ -143,7 +143,10 @@ func (s *ControlServer[V]) Ping(ctx context.Context, _ *messages.Empty) (*messag
func (s *ControlServer[V]) Negotiate(ctx context.Context, req *messages.NegotiateRequest) (*messages.NegotiateReply, error) { func (s *ControlServer[V]) Negotiate(ctx context.Context, req *messages.NegotiateRequest) (*messages.NegotiateReply, error) {
ctx, span := tracer.Start(ctx, "grpc_negotiate") ctx, span := tracer.Start(ctx, "grpc_negotiate")
defer span.End() defer span.End()
span.SetAttributes(attribute.Int("known_hosts_count", len(req.KnownHosts))) span.SetAttributes(
attribute.String("component", "controlplane"),
attribute.Int("known_hosts_count", len(req.KnownHosts)),
)
logger.InfoContext(ctx, "negotiate", "known_hosts_count", len(req.KnownHosts)) logger.InfoContext(ctx, "negotiate", "known_hosts_count", len(req.KnownHosts))
negotiateCalls.Add(ctx, 1) negotiateCalls.Add(ctx, 1)
@@ -156,7 +159,10 @@ func (s *ControlServer[V]) GetLocalActorIds(ctx context.Context, _ *messages.Emp
ctx, span := tracer.Start(ctx, "grpc_get_local_actor_ids") ctx, span := tracer.Start(ctx, "grpc_get_local_actor_ids")
defer span.End() defer span.End()
ids := s.pool.GetLocalIds() ids := s.pool.GetLocalIds()
span.SetAttributes(attribute.Int("id_count", len(ids))) span.SetAttributes(
attribute.String("component", "controlplane"),
attribute.Int("id_count", len(ids)),
)
logger.InfoContext(ctx, "get local actor ids", "id_count", len(ids)) logger.InfoContext(ctx, "get local actor ids", "id_count", len(ids))
getLocalActorIdsCalls.Add(ctx, 1) getLocalActorIdsCalls.Add(ctx, 1)
@@ -168,7 +174,10 @@ func (s *ControlServer[V]) Closing(ctx context.Context, req *messages.ClosingNot
ctx, span := tracer.Start(ctx, "grpc_closing") ctx, span := tracer.Start(ctx, "grpc_closing")
defer span.End() defer span.End()
host := req.GetHost() host := req.GetHost()
span.SetAttributes(attribute.String("host", host)) span.SetAttributes(
attribute.String("component", "controlplane"),
attribute.String("host", host),
)
logger.InfoContext(ctx, "closing notice", "host", host) logger.InfoContext(ctx, "closing notice", "host", host)
closingCalls.Add(ctx, 1, metric.WithAttributes(attribute.String("host", host))) closingCalls.Add(ctx, 1, metric.WithAttributes(attribute.String("host", host)))

1
pkg/proxy/remotehost.go
View File

@@ -162,6 +162,7 @@ func (h *RemoteHost) Proxy(id uint64, w http.ResponseWriter, r *http.Request) (b
ctx, span := tracer.Start(r.Context(), "remote_proxy") ctx, span := tracer.Start(r.Context(), "remote_proxy")
defer span.End() defer span.End()
span.SetAttributes( span.SetAttributes(
attribute.String("component", "proxy"),
attribute.String("cartid", fmt.Sprintf("%d", id)), attribute.String("cartid", fmt.Sprintf("%d", id)),
attribute.String("host", h.host), attribute.String("host", h.host),
attribute.String("method", r.Method), attribute.String("method", r.Method),