queues

package

v1.1.0 Latest Latest Go to latest Published: Sep 10, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Details

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

Repository

github.com/finch-technologies/go-utils

Links

Open Source Insights

Documentation ¶

Index ¶

func Count(ctx context.Context, queue Queue) (int, error)
func Dequeue[T interface{}](ctx context.Context, queue Queue, options ...types.DequeueOptions) ([]T, error)
func Enqueue[T interface{}](ctx context.Context, queue Queue, payload T, options ...types.EnqueueOptions) error
type IMessageQueue
type Queue

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Count ¶

func Count(ctx context.Context, queue Queue) (int, error)

func Dequeue ¶

func Dequeue[T interface{}](ctx context.Context, queue Queue, options ...types.DequeueOptions) ([]T, error)

func Enqueue ¶

func Enqueue[T interface{}](ctx context.Context, queue Queue, payload T, options ...types.EnqueueOptions) error

Types ¶

type IMessageQueue ¶

type IMessageQueue interface {
	Count(ctx context.Context, queue string) (int, error)
	Enqueue(ctx context.Context, queue string, payload string, options ...types.EnqueueOptions) error
	Dequeue(ctx context.Context, queue string, options ...types.DequeueOptions) ([]string, error)
}

type Queue ¶

type Queue string

Source Files ¶

View all Source files

message_queue.go

Directories ¶

Path	Synopsis
redis
sqs
types

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