From 4691d02567eef4c68ad3f8b59a9df81baff6d686 Mon Sep 17 00:00:00 2001
From: Yordan Kinkov <yordan.kinkov@vereign.com>
Date: Fri, 1 Jul 2022 09:01:53 +0300
Subject: [PATCH] #19 endpoint for external cache input
---
cmd/cache/main.go | 5 ++++-
internal/clients/event/client.go | 9 ++++-----
2 files changed, 8 insertions(+), 6 deletions(-)
diff --git a/cmd/cache/main.go b/cmd/cache/main.go
index a53f7ad..059172e 100644
--- a/cmd/cache/main.go
+++ b/cmd/cache/main.go
@@ -49,7 +49,10 @@ func main() {
redis := redis.New(cfg.Redis.Addr, cfg.Redis.User, cfg.Redis.Pass, cfg.Redis.DB, cfg.Redis.TTL)
// create event client
- events := event.New(cfg.Nats.Addr, cfg.Nats.Subject)
+ events, err := event.New(cfg.Nats.Addr, cfg.Nats.Subject)
+ if err != nil {
+ log.Fatalf("failed to create events client: %v", err)
+ }
defer events.CLose(context.Background())
// create services
diff --git a/internal/clients/event/client.go b/internal/clients/event/client.go
index 7baf3c1..3e97ae0 100644
--- a/internal/clients/event/client.go
+++ b/internal/clients/event/client.go
@@ -4,7 +4,6 @@ import (
"context"
"fmt"
- "log"
"time"
"github.com/cloudevents/sdk-go/protocol/nats/v2"
@@ -24,24 +23,24 @@ type Data struct {
Key string `json:"key"`
}
-func New(addr, subject string) *Client {
+func New(addr, subject string) (*Client, error) {
// create cloudevents nats sender
// other protocol implementations: https://github.com/cloudevents/sdk-go/tree/main/protocol
sender, err := nats.NewSender(addr, subject, nats.NatsOptions())
if err != nil {
- log.Fatalf("failed to create nats sender, %v", err)
+ return nil, err
}
// create cloudevents client
eventsClient, err := cloudevents.NewClient(sender)
if err != nil {
- log.Fatalf("failed to create cloudevents client, %v", err)
+ return nil, err
}
return &Client{
sender: sender,
events: eventsClient,
- }
+ }, nil
}
func (c *Client) Send(ctx context.Context, key string) error {
--
GitLab