queue

package

v0.3.7 Latest Latest Go to latest Published: Mar 5, 2025 License: MIT Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kgantsov/doq

Links

Open Source Insights

Documentation ¶

Index ¶

type Queue
- func NewQueue(db *badger.DB, cfg *config.Config, promMetrics *metrics.PrometheusMetrics) *Queue
type QueueInfo
type QueueManager
- func NewQueueManager(db *badger.DB, cfg *config.Config, metrics *metrics.PrometheusMetrics) *QueueManager

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Queue ¶

type Queue struct {
	PrometheusMetrics *metrics.PrometheusMetrics
	// contains filtered or unexported fields
}

func NewQueue ¶ added in v0.3.7

func NewQueue(
	db *badger.DB, cfg *config.Config, promMetrics *metrics.PrometheusMetrics,
) *Queue

func (*Queue) Ack ¶ added in v0.3.7

func (bpq *Queue) Ack(id uint64) error

func (*Queue) Create ¶ added in v0.3.7

func (bpq *Queue) Create(queueType, queueName string) error

func (*Queue) Delete ¶ added in v0.3.0

func (bpq *Queue) Delete(id uint64) error

func (*Queue) DeleteQueue ¶ added in v0.3.7

func (bpq *Queue) DeleteQueue() error

func (*Queue) Dequeue ¶

func (bpq *Queue) Dequeue(ack bool) (*entity.Message, error)

func (*Queue) Enqueue ¶

func (bpq *Queue) Enqueue(
	id uint64,
	group string,
	priority int64,
	content string,
	metadata map[string]string,
) (*entity.Message, error)

func (*Queue) Get ¶ added in v0.3.0

func (bpq *Queue) Get(id uint64) (*entity.Message, error)

func (*Queue) GetMessagesKey ¶ added in v0.3.7

func (bpq *Queue) GetMessagesKey(id uint64) []byte

func (*Queue) GetQueueKey ¶ added in v0.3.7

func (bpq *Queue) GetQueueKey(queueName string) []byte

func (*Queue) GetStats ¶ added in v0.3.7

func (bpq *Queue) GetStats() *QueueInfo

func (*Queue) Init ¶ added in v0.3.7

func (bpq *Queue) Init(queueType, queueName string) error

func (*Queue) Len ¶

func (bpq *Queue) Len() int

func (*Queue) Load ¶ added in v0.3.7

func (bpq *Queue) Load(queueName string, loadMessages bool) error

func (*Queue) Nack ¶ added in v0.3.7

func (bpq *Queue) Nack(id uint64, priority int64, metadata map[string]string) error

func (*Queue) PersistSnapshot ¶ added in v0.3.7

func (bpq *Queue) PersistSnapshot(sink raft.SnapshotSink) error

func (*Queue) StartAckQueueMonitoring ¶ added in v0.3.7

func (bpq *Queue) StartAckQueueMonitoring()

func (*Queue) StopAckQueueMonitoring ¶ added in v0.3.7

func (bpq *Queue) StopAckQueueMonitoring()

func (*Queue) UpdatePriority ¶

func (bpq *Queue) UpdatePriority(id uint64, newPriority int64) error

type QueueInfo ¶ added in v0.2.0

type QueueInfo struct {
	Name    string
	Type    string
	Stats   *metrics.Stats
	Ready   int64
	Unacked int64
	Total   int64
}

type QueueManager ¶

type QueueManager struct {
	PrometheusMetrics *metrics.PrometheusMetrics
	// contains filtered or unexported fields
}

func NewQueueManager ¶

func NewQueueManager(db *badger.DB, cfg *config.Config, metrics *metrics.PrometheusMetrics) *QueueManager

func (*QueueManager) CreateQueue ¶ added in v0.3.0

func (qm *QueueManager) CreateQueue(queueType, queueName string) (*Queue, error)

func (*QueueManager) DeleteQueue ¶ added in v0.3.0

func (qm *QueueManager) DeleteQueue(queueName string) error

func (*QueueManager) GetQueue ¶

func (qm *QueueManager) GetQueue(queueName string) (*Queue, error)

func (*QueueManager) GetQueues ¶ added in v0.2.0

func (qm *QueueManager) GetQueues() []*QueueInfo

func (*QueueManager) LoadQueues ¶ added in v0.2.0

func (qm *QueueManager) LoadQueues()

func (*QueueManager) PersistSnapshot ¶ added in v0.3.2

func (qm *QueueManager) PersistSnapshot(sink raft.SnapshotSink) error

func (*QueueManager) RunValueLogGC ¶

func (qm *QueueManager) RunValueLogGC()

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
memory

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL