Function OpenTopic

pubsub/gcppubsubv2/gcppubsub.go:332–339

OpenTopic returns a *pubsub.Topic backed by an existing GCP PubSub topic topicName is the last part of the full topic path, e.g., "foo" from "projects/ /topic/foo". See the package documentation for an example.

(client *raw.Client, topicName string, opts *TopicOptions)

// topicName is the last part of the full topic path, e.g., "foo" from "projects/<projectID>/topic/foo".
// See the package documentation for an example.
func OpenTopic(client *raw.Client, topicName string, opts *TopicOptions) *pubsub.Topic {
	publisher := client.Publisher(topicName)
	if opts == nil {
		opts = &TopicOptions{}
	}
	bo := sendBatcherOpts.NewMergedOptions(&opts.BatcherOptions)
	return pubsub.NewTopic(openTopic(publisher), bo)
}

var topicPathRE = regexp.MustCompile("^projects/.+/topics/(.+)$")