Documentation
¶
Index ¶
Constants ¶
View Source
const ( // queue group QUEUE_GROUP = "email-logger-service" // consumer config CONSUMER_NAME = "email-logger-consumer" ACK_WAIT = 30 * time.Second MAX_DELIVERY_ATTEMPTS = 5 MAX_ACK_PENDING = 100 FETCH_BATCH_SIZE = 50 MAX_FETCH_WAIT = 500 * time.Millisecond ERR_BACKOFF = 100 * time.Millisecond )
Variables ¶
View Source
var SUBSCRIBED_SUBJECT = "emails.>"
Functions ¶
func NewEventLoggerService ¶
func NewEventLoggerService( natsConn *nats_internal.NATSConnections, repos *repository.Repositories, eventsStorage interfaces.StorageService, ) interfaces.EmailProcessor
Types ¶
type EventLoggerService ¶
type EventLoggerService struct {
// contains filtered or unexported fields
}
func (*EventLoggerService) Close ¶ added in v0.2.7
func (s *EventLoggerService) Close() error
Close gracefully shuts down the service
func (*EventLoggerService) NewEmailEventRecord ¶
func (s *EventLoggerService) NewEmailEventRecord(ctx context.Context) *models.EmailEvent
Source Files
Click to show internal directories.
Click to hide internal directories.