OpenSubscription returns a *pubsub.Subscription backed by an existing GCP PubSub subscription subscriptionName in the given projectID. See the package documentation for an example.
(client *raw.SubscriberClient, projectID gcp.ProjectID, subscriptionName string, opts *SubscriptionOptions)
| 483 | // PubSub subscription subscriptionName in the given projectID. See the package |
| 484 | // documentation for an example. |
| 485 | func OpenSubscription(client *raw.SubscriberClient, projectID gcp.ProjectID, subscriptionName string, opts *SubscriptionOptions) *pubsub.Subscription { |
| 486 | path := fmt.Sprintf("projects/%s/subscriptions/%s", projectID, subscriptionName) |
| 487 | |
| 488 | dsub := openSubscription(client, path, opts) |
| 489 | recvOpts := *defaultRecvBatcherOpts |
| 490 | recvOpts.MaxBatchSize = dsub.options.MaxBatchSize |
| 491 | rbo := recvOpts.NewMergedOptions(&dsub.options.ReceiveBatcherOptions) |
| 492 | abo := ackBatcherOpts.NewMergedOptions(&dsub.options.AckBatcherOptions) |
| 493 | return pubsub.NewSubscription(dsub, rbo, abo) |
| 494 | } |
| 495 | |
| 496 | var subscriptionPathRE = regexp.MustCompile("^projects/.+/subscriptions/.+$") |
| 497 |