keel-hq
/
keel
mirror of https://github.com/keel-hq/keel/tree/master/chart/keel
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

no error handling

pull/93/head
Karolis Rusenas 2017-08-23 08:36:35 +01:00
parent bf0eaca7ce
commit 1f4917559a
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
trigger/pubsub/pubsub.go
View File

@ -5,11 +5,12 @@ import (
"fmt" "fmt"
"time" "time"
"net"
"cloud.google.com/go/pubsub" "cloud.google.com/go/pubsub"
"golang.org/x/net/context" "golang.org/x/net/context"
"google.golang.org/api/option" "google.golang.org/api/option"
"google.golang.org/grpc" "google.golang.org/grpc"
"net"
"github.com/rusenask/keel/provider" "github.com/rusenask/keel/provider"
"github.com/rusenask/keel/types" "github.com/rusenask/keel/types"
@ -106,7 +107,10 @@ func (s *PubsubSubscriber) ensureSubscription(ctx context.Context, subscriptionI
Topic: s.client.Topic(topicID), Topic: s.client.Topic(topicID),
AckDeadline: 10 * time.Second, AckDeadline: 10 * time.Second,
}) })
return fmt.Errorf("failed to create subscription %s, error: %s", subscriptionID, err) if err != nil {
return fmt.Errorf("failed to create subscription %s, error: %s", subscriptionID, err)
}
return nil
} }
// Subscribe - initiate PubsubSubscriber // Subscribe - initiate PubsubSubscriber