(ctx context.Context, testName string)
| 55 | } |
| 56 | |
| 57 | func (h *harness) CreateTopic(ctx context.Context, testName string) (dt driver.Topic, cleanup func(), err error) { |
| 58 | topicName := fmt.Sprintf("%s-topic-%d", sanitize(testName), atomic.AddUint32(&h.numTopics, 1)) |
| 59 | return createTopic(ctx, h.client, topicName) |
| 60 | } |
| 61 | |
| 62 | func topicPath(topicName string) string { |
| 63 | return fmt.Sprintf("projects/%s/topics/%s", projectID, topicName) |
nothing calls this directly
no test coverage detected