Versions in this module Expand all Collapse all v0 v0.2.3 Aug 8, 2024 v0.2.2 Aug 3, 2024 v0.2.1 Aug 3, 2024 v0.2.0 Aug 3, 2024 Changes in this version + type KV struct + K string + MessageID int64 + QueueID int64 + TenantID int64 + V string + type Message struct + DeliverAt int64 + DeliveredAt int64 + ID int64 + KV []KV + MaxTries int + Message string + QueueID int64 + TenantID int64 + Tries int + func (message *Message) ToModel() *models.Message + type Queue struct + ID int64 + MaxRetries int + Messages []Message + Name string + RateLimit float64 + TenantID int64 + VisibilityTimeout int + type RateLimit struct + N int + QueueID int64 + TenantID int64 + Ts int64 type SQLiteQueue + DBG *gorm.DB + func (q *SQLiteQueue) GetQueue(tenantId int64, queueName string) (models.QueueProperties, error) + func (q *SQLiteQueue) UpdateQueue(tenantId int64, queueName string, properties models.QueueProperties) error v0.1.6 Jul 30, 2024 v0.1.5 Jul 30, 2024 v0.1.4 Jul 29, 2024 Changes in this version type SQLiteQueue + DB *sqlx.DB + Filename string + Mu *sync.Mutex v0.1.3 Jul 29, 2024 v0.1.2 Jul 29, 2024 v0.1.1 Jul 29, 2024 v0.1.0 Jul 16, 2024 Changes in this version + type SQLiteQueue struct + func NewSQLiteQueue(cfg config.SQLiteConfig) *SQLiteQueue + func (q *SQLiteQueue) CreateQueue(tenantId int64, queue string) error + func (q *SQLiteQueue) Delete(tenantId int64, queue string, messageId int64) error + func (q *SQLiteQueue) DeleteQueue(tenantId int64, queue string) error + func (q *SQLiteQueue) Dequeue(tenantId int64, queue string, numToDequeue int) ([]*models.Message, error) + func (q *SQLiteQueue) Enqueue(tenantId int64, queue string, message string, kv map[string]string, delay int, ...) (int64, error) + func (q *SQLiteQueue) Filter(tenantId int64, queue string, filterCriteria models.FilterCriteria) []int64 + func (q *SQLiteQueue) ListQueues(tenantId int64) ([]string, error) + func (q *SQLiteQueue) Peek(tenantId int64, queue string, messageId int64) *models.Message + func (q *SQLiteQueue) Shutdown() error + func (q *SQLiteQueue) Stats(tenantId int64, queue string) models.QueueStats
Go to main page