(t *testing.T, topicID string)
| 130 | } |
| 131 | |
| 132 | func createTestTopic(t *testing.T, topicID string) { |
| 133 | ctx := context.Background() |
| 134 | // nolint:exhaustruct // WONTFIX: external struct |
| 135 | topicpb := &pubsubpb.Topic{ |
| 136 | Name: fmt.Sprintf("projects/%s/topics/%s", testProjectID, topicID), |
| 137 | } |
| 138 | _, err := pubsubClient.client.TopicAdminClient.CreateTopic(ctx, topicpb) |
| 139 | if err != nil { |
| 140 | t.Fatalf("failed to create topic: %v", err) |
| 141 | } |
| 142 | } |
| 143 | |
| 144 | func createTestSubscription(t *testing.T, topicID, subID string, seconds int32) { |
| 145 | ctx := context.Background() |
no outgoing calls
no test coverage detected