Versions in this module Expand all Collapse all v0 v0.1.0 Aug 4, 2025 Changes in this version + type Config struct + ExpiryCheckInterval time.Duration + MessageTimeout time.Duration + RetryInterval time.Duration + WorkerPoolSize int + func DefaultConfig() Config + type Manager struct + func NewManager(store store.Store, config Config) *Manager + func (m *Manager) AckMessage(ctx context.Context, clientID, messageID string) error + func (m *Manager) CreateQueue(ctx context.Context, queue *types.Queue) error + func (m *Manager) DeleteQueue(ctx context.Context, queueName string) error + func (m *Manager) GetClientInfo(ctx context.Context, clientID string) (*types.Client, error) + func (m *Manager) GetQueueStats(ctx context.Context, queueName string) (*types.QueueStats, error) + func (m *Manager) NackMessage(ctx context.Context, clientID, messageID string, reason string) error + func (m *Manager) ReceiveMessages(ctx context.Context, clientID string, limit int) ([]*types.Message, error) + func (m *Manager) RegisterClient(ctx context.Context, client *types.Client) error + func (m *Manager) SendDirectMessage(ctx context.Context, from, to string, payload []byte, opts ...MessageOption) (*types.Message, error) + func (m *Manager) Start() error + func (m *Manager) Stop() error + func (m *Manager) SubmitTask(ctx context.Context, from, topic string, payload []byte, opts ...MessageOption) (*types.Message, error) + func (m *Manager) SubscribeToTopic(ctx context.Context, clientID, topic string) error + func (m *Manager) UnregisterClient(ctx context.Context, clientID string) error + func (m *Manager) UnsubscribeFromTopic(ctx context.Context, clientID, topic string) error + func (m *Manager) UpdateClientActivity(ctx context.Context, clientID string) error + type MessageOption func(*types.Message) + func WithMaxRetries(maxRetries int) MessageOption + func WithMetadata(key, value string) MessageOption + func WithPriority(priority int) MessageOption + func WithTTL(ttl time.Duration) MessageOption
Go to main page