CloudTasksClient creates a new instance of cloudtasks.Client
()
| 481 | |
| 482 | // CloudTasksClient creates a new instance of cloudtasks.Client |
| 483 | func (container *Container) CloudTasksClient() (client *cloudtasks.Client) { |
| 484 | container.logger.Debug(fmt.Sprintf("creating %T", client)) |
| 485 | |
| 486 | client, err := cloudtasks.NewClient(context.Background(), option.WithCredentialsJSON(container.FirebaseCredentials())) |
| 487 | if err != nil { |
| 488 | container.logger.Fatal(stacktrace.Propagate(err, "cannot initialize cloud tasks client")) |
| 489 | } |
| 490 | |
| 491 | return client |
| 492 | } |
| 493 | |
| 494 | // EventsQueueConfiguration creates a new instance of services.PushQueueConfig |
| 495 | func (container *Container) EventsQueueConfiguration() (config services.PushQueueConfig) { |
no test coverage detected