Set span status codes.Error.

This commit is contained in:
Владислав Весельский 2025-01-28 15:07:14 +03:00
parent ee64b485cc
commit 07f480582b
1 changed files with 16 additions and 4 deletions

20
fcm.go
View File

@ -139,9 +139,15 @@ func (c *Client) Send(ctx context.Context, message Message) (string, error) {
ValidateOnly: false, ValidateOnly: false,
Message: message, Message: message,
} }
resp, err := c.doSendRequest(ctx, sendRequest, false)
return resp.MessageName, err resp, err := c.doSendRequest(ctx, sendRequest, false)
if err != nil {
span.SetStatus(codes.Error, err.Error())
span.RecordError(err)
return "", err
}
return resp.MessageName, nil
} }
func (c *Client) Validate(ctx context.Context, message Message) (string, error) { func (c *Client) Validate(ctx context.Context, message Message) (string, error) {
@ -153,9 +159,15 @@ func (c *Client) Validate(ctx context.Context, message Message) (string, error)
ValidateOnly: true, ValidateOnly: true,
Message: message, Message: message,
} }
resp, err := c.doSendRequest(ctx, sendRequest, false)
return resp.MessageName, err resp, err := c.doSendRequest(ctx, sendRequest, false)
if err != nil {
span.SetStatus(codes.Error, err.Error())
span.RecordError(err)
return "", err
}
return resp.MessageName, nil
} }
func (c *Client) doSendRequest(ctx context.Context, req SendRequest, loggerEnabled bool) (SendResponse, error) { func (c *Client) doSendRequest(ctx context.Context, req SendRequest, loggerEnabled bool) (SendResponse, error) {