From c56f0f695ebc4656e6157884fc24432e64753dd8 Mon Sep 17 00:00:00 2001
From: Yordan Kinkov <yordan.kinkov@vereign.com>
Date: Wed, 29 Jun 2022 14:09:56 +0300
Subject: [PATCH] #19 endpoint for external cache input
---
internal/clients/queue/client.go | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/internal/clients/queue/client.go b/internal/clients/queue/client.go
index 5a42482..966198b 100644
--- a/internal/clients/queue/client.go
+++ b/internal/clients/queue/client.go
@@ -8,8 +8,6 @@ import (
cloudevents "github.com/cloudevents/sdk-go/v2"
"github.com/cloudevents/sdk-go/v2/event"
"github.com/google/uuid"
-
- "code.vereign.com/gaiax/tsa/golib/errors"
)
const eventType = "External cache input"
@@ -35,7 +33,7 @@ func (c *Client) Send(ctx context.Context, key string, data interface{}) error {
res := c.eventClient.Send(ctx, *e)
if cloudevents.IsUndelivered(res) {
- return errors.New(fmt.Sprintf("failed to send event for key: %s, reason: %v", key, res))
+ return fmt.Errorf("failed to send event for key: %s, reason: %v", key, res)
}
return nil
--
GitLab