func()

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
}