Function subscriptionPath

pubsub/gcppubsubv2/gcppubsub_test.go:65–67

(subName string)

	return fmt.Sprintf("projects/%s/topics/%s", projectID, topicName)
}
func subscriptionPath(subName string) string {
	return fmt.Sprintf("projects/%s/subscriptions/%s", projectID, subName)
}

func createTopic(ctx context.Context, client *raw.Client, topicName string) (dt driver.Topic, cleanup func(), err error) {
	_, err = client.TopicAdminClient.CreateTopic(ctx, &pubsubpb.Topic{Name: topicPath(topicName)})