Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageQueue ¶
MessageQueue combines both queue and publish-subscribe functionality in a single memory-based implementation. It provides both point-to-point messaging and broadcast messaging capabilities.
func NewMessageQueue ¶
func NewMessageQueue[T any](opt ...Option) *MessageQueue[T]
NewMessageQueue creates a new memory-based message queue that supports both queue and pub/sub operations. The same options apply to both the underlying queue and pub/sub components.
func (*MessageQueue[T]) Close ¶
func (p *MessageQueue[T]) Close() error
type Option ¶
type Option func(*options)
Option defines a function type for configuring memory message queue options.
func WithQueueSize ¶
WithQueueSize sets the buffer size for message channels in the memory queue. A larger size allows more messages to be buffered before blocking publishers.
type PubSub ¶
type PubSub[T any] struct { // contains filtered or unexported fields }
PubSub implements an in-memory publish-subscribe message system with typed message support. It broadcasts messages to all active subscribers of a topic.
func NewPubSub ¶
NewPubSub creates a new memory-based publish-subscribe system with the specified options. The default queue size is 100 messages per subscription.
type Queue ¶
type Queue[T any] struct { // contains filtered or unexported fields }
Queue implements an in-memory point-to-point message queue with typed message support. It provides FIFO message delivery to exactly one consumer per topic.
func NewQueue ¶
NewQueue creates a new memory-based queue with the specified options. The default queue size is 100 messages per topic.
type Subscription ¶
type Subscription[T any] struct { // contains filtered or unexported fields }
Subscription represents an active subscription to a topic with its associated handler and channels.
Source Files