events

type PubSubNotifierInput struct {
	Logger           *zap.SugaredLogger
	ProjectID        string
	SubscriptionName string
}

type Subscription interface {
	// Receive sends outstanding pubsub messages to event channel. It blocks until ctx is done, or the pubsub returns a non-retryable error.
	Receive(ctx context.Context, event chan<- *gcppubsub.Message)
}