queuefs

type DBBackend interface {
	// Open opens a connection to the database
	Open(cfg map[string]interface{}) (*sql.DB, error)

	// GetInitSQL returns the SQL statements to initialize the schema
	GetInitSQL() []string

	// GetDriverName returns the driver name
	GetDriverName() string
}

type MemoryBackend struct {
	// contains filtered or unexported fields
}

type Queue struct {
	// contains filtered or unexported fields
}

type QueueBackend interface {
	// Initialize initializes the backend with configuration
	Initialize(config map[string]interface{}) error

	// Close closes the backend connection
	Close() error

	// GetType returns the backend type name
	GetType() string

	// Enqueue adds a message to a queue
	Enqueue(queueName string, msg QueueMessage) error

	// Dequeue removes and returns the first message from a queue
	Dequeue(queueName string) (QueueMessage, bool, error)

	// Peek returns the first message without removing it
	Peek(queueName string) (QueueMessage, bool, error)

	// Size returns the number of messages in a queue
	Size(queueName string) (int, error)

	// Clear removes all messages from a queue
	Clear(queueName string) error

	// ListQueues returns all queue names (for directory listing)
	ListQueues(prefix string) ([]string, error)

	// GetLastEnqueueTime returns the timestamp of the last enqueued message
	GetLastEnqueueTime(queueName string) (time.Time, error)

	// RemoveQueue removes all messages for a queue and its nested queues
	RemoveQueue(queueName string) error

	// CreateQueue creates an empty queue (for mkdir support)
	CreateQueue(queueName string) error

	// QueueExists checks if a queue exists (even if empty)
	QueueExists(queueName string) (bool, error)
}

type QueueFSPlugin struct {
	// contains filtered or unexported fields
}

type QueueMessage struct {
	ID        string    `json:"id"`
	Data      string    `json:"data"`
	Timestamp time.Time `json:"timestamp"`
}

type SQLiteDBBackend struct{}

type TiDBBackend struct {
	// contains filtered or unexported fields
}

type TiDBDBBackend struct{}