Method CloudTaskEventsQueue

api/pkg/di/container.go:529–537

CloudTaskEventsQueue creates a Google cloud task instance of events services.PushQueue

()

// CloudTaskEventsQueue creates a Google cloud task instance of events services.PushQueue
func (container *Container) CloudTaskEventsQueue() (queue services.PushQueue) {
	container.logger.Debug("creating cloud task events services.PushQueue")
	return services.NewGooglePushQueue(
		container.Logger(),
		container.Tracer(),
		container.CloudTasksClient(),
		container.EventsQueueConfiguration(),
	)
}

// FCMClient creates the appropriate FCM client based on configuration.
// When FCM_ENDPOINT is set, it returns an EmulatorFCMClient that sends