Method Stats

queue/sqlite/sqlite.go:505–552

(tenantId int64, queueName string)

}

func (q *SQLiteQueue) Stats(tenantId int64, queueName string) models.QueueStats {
	queue, err := q.getQueue(tenantId, queueName)
	if err != nil {
		return models.QueueStats{}
	}

	now := time.Now().UTC().Unix()

	res := q.DBG.Raw(`
		SELECT
		CASE
			WHEN tries = max_tries AND deliver_at < ? THEN 3
			WHEN delivered_at <= ? AND deliver_at > ? THEN 2
			ELSE 1
		END AS s,
		count(*) FROM messages WHERE queue_id=? AND tenant_id=? GROUP BY s
	`, now, now, now,
		queue.ID, tenantId,
	)

	if res.Error != nil {
		return models.QueueStats{}
	}

	rows, err := res.Rows()
	if err != nil {
		return models.QueueStats{}
	}

	stats := models.QueueStats{
		Counts:        make(map[models.MessageStatus]int),
		TotalMessages: 0,
	}

	for rows.Next() {
		var statusType models.MessageStatus
		var count int

		rows.Scan(&statusType, &count)

		stats.TotalMessages += count
		stats.Counts[statusType] = count
	}

	rows.Close()

	return stats
}

func (q *SQLiteQueue) Filter(tenantId int64, queueName string, filterCriteria models.FilterCriteria) []int64 {
	var rc []int64