Documentation
¶
Overview ¶
Package queue provides queue implementations for task processing. This package implements the queue.TaskQueue interface using SQLite as the underlying storage. It uses the goqite library for reliable queue operations and maintains a separate table for tracking failed tasks.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SQLiteQueue ¶
type SQLiteQueue struct {
// contains filtered or unexported fields
}
SQLiteQueue implements queue.TaskQueue using goqite
func NewSQLiteQueue ¶
func NewSQLiteQueue(db *sqlx.DB, queueName string) (*SQLiteQueue, error)
NewSQLiteQueue creates a new SQLiteQueue
func (*SQLiteQueue) Complete ¶
func (q *SQLiteQueue) Complete(ctx context.Context, taskID string) error
Complete marks a task as completed
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.