db

package

v0.2.1 Latest Latest Go to latest Published: Apr 27, 2026 License: AGPL-3.0 Imports: 13 Imported by: 0

Details

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

Repository

github.com/n0rdy/forq

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type ForqRepo
- func NewSQLiteRepo(dbPath string, appConfigs *configs.AppConfigs) (*ForqRepo, error)
type MessageDetails
type MessageForConsuming
type MessageMetadata
type NewMessage
type QueueMetadata

Constants ¶

This section is empty.

Variables ¶

View Source

var MigrationsFS embed.FS

Functions ¶

This section is empty.

Types ¶

type ForqRepo ¶

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

func NewSQLiteRepo ¶

func NewSQLiteRepo(dbPath string, appConfigs *configs.AppConfigs) (*ForqRepo, error)

func (*ForqRepo) Close ¶

func (fr *ForqRepo) Close() error

func (*ForqRepo) DeleteAllMessagesFromQueue ¶

func (fr *ForqRepo) DeleteAllMessagesFromQueue(queueName string, ctx context.Context) (int64, error)

func (*ForqRepo) DeleteExpiredMessagesFromDlq ¶

func (fr *ForqRepo) DeleteExpiredMessagesFromDlq(ctx context.Context) (int64, error)

func (*ForqRepo) DeleteFailedMessagesFromDlq ¶

func (fr *ForqRepo) DeleteFailedMessagesFromDlq(ctx context.Context) (int64, error)

func (*ForqRepo) DeleteMessageFromDlq ¶

func (fr *ForqRepo) DeleteMessageFromDlq(messageId string, queueName string, ctx context.Context) error

func (*ForqRepo) DeleteMessageOnAck ¶

func (fr *ForqRepo) DeleteMessageOnAck(messageId string, queueName string, ctx context.Context) error

func (*ForqRepo) InsertMessage ¶

func (fr *ForqRepo) InsertMessage(newMessage *NewMessage, ctx context.Context) error

func (*ForqRepo) Optimize ¶

func (fr *ForqRepo) Optimize(ctx context.Context) error

func (*ForqRepo) Ping ¶

func (fr *ForqRepo) Ping(ctx context.Context) error

func (*ForqRepo) RequeueDlqMessage ¶

func (fr *ForqRepo) RequeueDlqMessage(messageId string, queueName string, ctx context.Context) error

func (*ForqRepo) RequeueDlqMessages ¶

func (fr *ForqRepo) RequeueDlqMessages(queueName string, ctx context.Context) (int64, error)

func (*ForqRepo) SelectAllQueuesWithStats ¶

func (fr *ForqRepo) SelectAllQueuesWithStats(ctx context.Context) ([]QueueMetadata, error)

func (*ForqRepo) SelectMessageDetails ¶

func (fr *ForqRepo) SelectMessageDetails(messageId string, queueName string, ctx context.Context) (*MessageDetails, error)

func (*ForqRepo) SelectMessageForConsuming ¶

func (fr *ForqRepo) SelectMessageForConsuming(queueName string, ctx context.Context) (*MessageForConsuming, error)

func (*ForqRepo) SelectMessageMetadata ¶

func (fr *ForqRepo) SelectMessageMetadata(messageId string, queueName string, ctx context.Context) (*MessageMetadata, error)

func (*ForqRepo) SelectMessagesForUI ¶

func (fr *ForqRepo) SelectMessagesForUI(queueName string, cursor string, limit int, ctx context.Context) ([]MessageMetadata, error)

func (*ForqRepo) SelectQueueStats ¶

func (fr *ForqRepo) SelectQueueStats(queueName string, ctx context.Context) (*QueueMetadata, error)

func (*ForqRepo) UpdateExpiredMessagesForRegularQueues ¶

func (fr *ForqRepo) UpdateExpiredMessagesForRegularQueues(ctx context.Context) (int64, error)

func (*ForqRepo) UpdateFailedMessagesForRegularQueues ¶

func (fr *ForqRepo) UpdateFailedMessagesForRegularQueues(ctx context.Context) (int64, error)

func (*ForqRepo) UpdateMessageOnConsumingFailure ¶

func (fr *ForqRepo) UpdateMessageOnConsumingFailure(messageId string, queueName string, ctx context.Context) error

func (*ForqRepo) UpdateStaleMessages ¶

func (fr *ForqRepo) UpdateStaleMessages(ctx context.Context) (int64, error)

type MessageDetails ¶

type MessageDetails struct {
	Id                  string
	Content             string
	Status              int
	Attempts            int
	ProcessAfter        int64
	ProcessingStartedAt *int64
	FailureReason       *string
	ReceivedAt          int64
	UpdatedAt           int64
	ExpiresAfter        int64
}

type MessageForConsuming ¶

type MessageForConsuming struct {
	Id      string
	Content string
}

type MessageMetadata ¶

type MessageMetadata struct {
	Id           string
	Status       int
	Attempts     int
	ReceivedAt   int64
	ProcessAfter int64
}

type NewMessage ¶

type NewMessage struct {
	Id           string
	QueueName    string
	Content      string
	ProcessAfter int64
	ReceivedAt   int64
	UpdatedAt    int64
	ExpiresAfter int64
}

type QueueMetadata ¶

type QueueMetadata struct {
	Name          string
	MessagesCount int
	IsDLQ         bool
}

Source Files ¶

View all Source files

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