Function createTestSubscription

lib/gcppubsub/client_test.go:144–157

(t *testing.T, topicID, subID string, seconds int32)

}

func createTestSubscription(t *testing.T, topicID, subID string, seconds int32) {
	ctx := context.Background()
	topicName := fmt.Sprintf("projects/%s/topics/%s", testProjectID, topicID)
	// nolint:exhaustruct // WONTFIX: external struct
	subpb := &pubsubpb.Subscription{
		Name:               fmt.Sprintf("projects/%s/subscriptions/%s", testProjectID, subID),
		Topic:              topicName,
		AckDeadlineSeconds: seconds,
	}
	_, err := pubsubClient.client.SubscriptionAdminClient.CreateSubscription(ctx, subpb)
	if err != nil {
		t.Fatalf("failed to create subscription: %v", err)
	}
}

type handlerDetails struct {
	id   string