Trace when we connect to pubsub subscriptions
@@ -95,9 +95,10 @@ func (n Notification) String() string {
//
// More info: https://cloud.google.com/storage/docs/pubsub-notifications#overview
func SendGCS(ctx context.Context, log logrus.FieldLogger, client Subscriber, projectID, subID string, settings *pubsub.ReceiveSettings, receivers chan<- *Notification) error {
+ l := log.WithField("subscription", "pubsub://"+projectID+"/"+subID)
send := client.Subscribe(projectID, subID, settings)
- log = log.WithField("subscription", "pubsub://"+projectID+"/"+subID)
- return sendToReceivers(ctx, log, send, receivers, realAcker{})
+ l.Trace("Subscribing...")
+ return sendToReceivers(ctx, l, send, receivers, realAcker{})
}
type acker interface {
