Google Pub/Sub 订阅中的共享持续时间数据竞争
作者: aryanmehrotra创建于 2026年9月7日更新于 2026年9月7日
func (g *googleClient) Subscribe(ctx context.Context, topic string) (*gcPubSub.Subscription, error) { // Create a new subscription s, err := g.createSubscription(ctx, topic) if err != nil { return nil, err } // Start the subscription if err := s.start(ctx); err != nil { return nil, err } return s, nil }
```diff
func (g *googleClient)
…内容来源: gofr-dev/gofr