EventsQueueConfiguration creates a new instance of services.PushQueueConfig
()
| 493 | |
| 494 | // EventsQueueConfiguration creates a new instance of services.PushQueueConfig |
| 495 | func (container *Container) EventsQueueConfiguration() (config services.PushQueueConfig) { |
| 496 | container.logger.Debug(fmt.Sprintf("creating %T", config)) |
| 497 | |
| 498 | return services.PushQueueConfig{ |
| 499 | UserAPIKey: os.Getenv("EVENTS_QUEUE_USER_API_KEY"), |
| 500 | Name: os.Getenv("EVENTS_QUEUE_NAME"), |
| 501 | UserID: entities.UserID(os.Getenv("EVENTS_QUEUE_USER_ID")), |
| 502 | ConsumerEndpoint: os.Getenv("EVENTS_QUEUE_ENDPOINT"), |
| 503 | } |
| 504 | } |
| 505 | |
| 506 | // EventsQueue creates a new instance of services.PushQueue |
| 507 | func (container *Container) EventsQueue() (queue services.PushQueue) { |
no test coverage detected