in app/pubsub-integration/pubsub/pubsub.go [71:77]
func (*pubsubService) NewClient(ctx context.Context, clientCfg *pubsub.ClientConfig) (Client, error) {
client, err := pubsub.NewClientWithConfig(ctx, config.Config.Project, clientCfg)
if err != nil {
return nil, err
}
return &pubsubClient{client: client}, err
}