memory

package

v0.1.2 Latest Latest Go to latest Published: Jun 3, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	MaxRetries  int
	RetryDelay  time.Duration
	DeadLetter  bool
	QueueBuffer int
}

Config for memory queue implementation

func DefaultConfig() Config

DefaultConfig returns a standard configuration for memory queue

func NamedConfig(name string) Config

NamedConfig returns a named configuration for memory queue

type Message[T any] struct {
	// contains filtered or unexported fields
}

Message implements mbus.Message interface for in-memory queue

func (m *Message[T]) Ack() error

Ack acknowledges the message as processed successfully

func (m *Message[T]) Nack(err error) error

Nack indicates a failure in processing the message

func (m *Message[T]) T() *T

T returns the message payload

type Queue[T any] struct {
	// contains filtered or unexported fields
}

Queue implements an in-memory messaging.Queue

func NewQueue[T any](config Config) *Queue[T]

NewQueue creates a new in-memory queue

func (q *Queue[T]) Consume(ctx context.Context) (messaging.Message[T], error)

Consume retrieves a single item from the queue

func (q *Queue[T]) DLQSize() int

DLQSize returns the number of messages in the dead letter queue

func (q *Queue[T]) Publish(ctx context.Context, t *T) error

Publish adds a new item to the queue

func (q *Queue[T]) Size() int

Size returns the current number of messages in the queue