storage

package
v0.14.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 17, 2025 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ReadSnapshotItem added in v0.8.0 

func ReadSnapshotItem(r io.Reader) (*pb.SnapshotItem, error)

func ReadSnapshotMessageItem added in v0.8.0 

func ReadSnapshotMessageItem(r io.Reader) (*pb.Message, error)

func ReadSnapshotQueueItem added in v0.8.0 

func ReadSnapshotQueueItem(r io.Reader) (*pb.Queue, error)

func WriteSnapshotItem added in v0.8.0 

func WriteSnapshotItem(sink raft.SnapshotSink, item *pb.SnapshotItem) error

Types

type BadgerStore 

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

func NewBadgerStore added in v0.3.8 

func NewBadgerStore(db *badger.DB) *BadgerStore

func (*BadgerStore) Ack 

func (s *BadgerStore) Ack(queueName string, id uint64) error

func (*BadgerStore) CreateQueue 

func (s *BadgerStore) CreateQueue(queueType, queueName string, settings entity.QueueSettings) error

func (*BadgerStore) Delete 

func (s *BadgerStore) Delete(queueName string, id uint64) (*entity.Message, error)

func (*BadgerStore) DeleteQueue 

func (s *BadgerStore) DeleteQueue(queueName string) error

func (*BadgerStore) Dequeue 

func (s *BadgerStore) Dequeue(queueName string, id uint64, ack bool) (*entity.Message, error)

func (*BadgerStore) Enqueue 

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

func (*BadgerStore) Get 

func (s *BadgerStore) Get(queueName string, id uint64) (*entity.Message, error)

func (*BadgerStore) GetMessagesKey 

func (bpq *BadgerStore) GetMessagesKey(queueName string, id uint64) []byte

func (*BadgerStore) GetQueueKey 

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

func (*BadgerStore) LoadQueue added in v0.3.8 

func (s *BadgerStore) LoadQueue(queueName string) (*entity.QueueConfig, error)

func (*BadgerStore) PersistSnapshot 

func (s *BadgerStore) PersistSnapshot(
	queueConfig *entity.QueueConfig, sink raft.SnapshotSink, txn *badger.Txn,
) error

func (*BadgerStore) UpdateMessage 

func (s *BadgerStore) UpdateMessage(
	queueName string,
	id uint64,
	priority int64,
	content string,
	metadata map[string]string,
) error

func (*BadgerStore) UpdatePriority 

func (s *BadgerStore) UpdatePriority(queueName string, id uint64, priority int64) (*entity.Message, error)

func (*BadgerStore) UpdateQueue added in v0.12.0 

func (s *BadgerStore) UpdateQueue(queueType, queueName string, settings entity.QueueSettings) error

type Store 

type Store interface {
	LoadQueue(queueName string) (*entity.QueueConfig, error)
	CreateQueue(queueType, queueName string, settings entity.QueueSettings) error
	UpdateQueue(queueType, queueName string, settings entity.QueueSettings) error
	DeleteQueue(queueName string) error
	Enqueue(
		queueName string,
		id uint64,
		group string,
		priority int64,
		content string,
		metadata map[string]string,
	) (*entity.Message, error)
	Dequeue(queueName string, id uint64, ack bool) (*entity.Message, error)
	Get(queueName string, id uint64) (*entity.Message, error)
	Delete(queueName string, id uint64) (*entity.Message, error)
	Ack(queueName string, id uint64) error
	UpdatePriority(queueName string, id uint64, priority int64) (*entity.Message, error)
	UpdateMessage(
		queueName string,
		id uint64,
		priority int64,
		content string,
		metadata map[string]string,
	) error
	PersistSnapshot(queueConfig *entity.QueueConfig, sink raft.SnapshotSink, txn *badger.Txn) error
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.