OpenSubscription returns a *pubsub.Subscription backed by an existing GCP PubSub subscription subscriptionName. See the package documentation for an example.
(client *raw.Client, subscriptionName string, opts *SubscriptionOptions)
| 478 | // OpenSubscription returns a *pubsub.Subscription backed by an existing GCP |
| 479 | // PubSub subscription subscriptionName. See the package documentation for an example. |
| 480 | func OpenSubscription(client *raw.Client, subscriptionName string, opts *SubscriptionOptions) *pubsub.Subscription { |
| 481 | subscriber := client.Subscriber(subscriptionName) |
| 482 | dsub := openSubscription(subscriber, opts) |
| 483 | recvOpts := *defaultRecvBatcherOpts |
| 484 | recvOpts.MaxBatchSize = dsub.options.MaxBatchSize |
| 485 | rbo := recvOpts.NewMergedOptions(&dsub.options.ReceiveBatcherOptions) |
| 486 | abo := ackBatcherOpts.NewMergedOptions(&dsub.options.AckBatcherOptions) |
| 487 | return pubsub.NewSubscription(dsub, rbo, abo) |
| 488 | } |
| 489 | |
| 490 | var subscriptionPathRE = regexp.MustCompile("^projects/.+/subscriptions/(.+)$") |
| 491 |