Struct PubSub

pkg/events/cloud/cloud.go:56–66

PubSub with Go Cloud backend.

// PubSub with Go Cloud backend.
type PubSub struct {
	events.PubSub

	taskStarter task.Starter
	ctx         context.Context
	cancel      context.CancelFunc
	contentType string
	subURL      string
	topic       *pubsub.Topic
	subOnce     sync.Once
}

// Close the Go Cloud publisher.
func (ps *PubSub) Close(ctx context.Context) error {