bbolt

Oct 12, 2025

Changes in this version

+ type BoltQueueService struct

+ func GetBoltQueueDriver(cfg *models.Config) (*BoltQueueService, error)

+ func (r *BoltQueueService) Close() error

+ func (r *BoltQueueService) Publish(topic string, messages ...*message.Message) error

+ func (r *BoltQueueService) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)

+ func (s *BoltQueueService) AddSubscriber(ctx context.Context, userID string) (*models.Subscriber, error)

+ func (s *BoltQueueService) GetSubscriber(ctx context.Context, userID string) (*models.Subscriber, error)

+ func (s *BoltQueueService) RemoveSubscriber(ctx context.Context, userID string) error