Function openTopic

pubsub/gcppubsub/gcppubsub.go:367–369

openTopic returns the driver for OpenTopic. This function exists so the test harness can get the driver interface implementation if it needs to.

(client *raw.PublisherClient, topicPath string)

// openTopic returns the driver for OpenTopic. This function exists so the test
// harness can get the driver interface implementation if it needs to.
func openTopic(client *raw.PublisherClient, topicPath string) driver.Topic {
	return &topic{topicPath, client}
}

// SendBatch implements driver.Topic.SendBatch.
func (t *topic) SendBatch(ctx context.Context, dms []*driver.Message) error {