Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterStatusConsumerWorker ¶
func RegisterStatusConsumerWorker(submissionService *services.SubmissionService, queueService *queue.QueueService) error
func RetentionWorker ¶
func RetentionWorker(databaseService *services.DatabaseService, storageService *services.StorageService)
func SubscriptionDataUsageReportingWorker ¶
func SubscriptionDataUsageReportingWorker(subscriptionService *services.SubscriptionService, databaseService *services.DatabaseService)
Types ¶
type SubsmissionStatusHandler ¶
type SubsmissionStatusHandler struct {
// contains filtered or unexported fields
}
func (*SubsmissionStatusHandler) HandleMessage ¶
func (h *SubsmissionStatusHandler) HandleMessage(m *nsq.Message) error
HandleMessage implements the Handler interface. Returning a non-nil error will automatically send a REQ command to NSQ to re-queue the message.
Source Files
Click to show internal directories.
Click to hide internal directories.