Documentation
¶
Index ¶
- type BoltQueueService
- func (s *BoltQueueService) AddSubscriber(ctx context.Context, userID string) (*models.Subscriber, error)
- func (r *BoltQueueService) Close() error
- func (s *BoltQueueService) GetSubscriber(ctx context.Context, userID string) (*models.Subscriber, error)
- func (r *BoltQueueService) Publish(topic string, messages ...*message.Message) error
- func (s *BoltQueueService) RemoveSubscriber(ctx context.Context, userID string) error
- func (r *BoltQueueService) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BoltQueueService ¶
type BoltQueueService struct {
// contains filtered or unexported fields
}
BoltQueueService implements QueueEngineInterface using Watermill Bolt Pub/Sub
func GetBoltQueueDriver ¶
func GetBoltQueueDriver(cfg *models.Config) (*BoltQueueService, error)
func (*BoltQueueService) AddSubscriber ¶
func (s *BoltQueueService) AddSubscriber(ctx context.Context, userID string) (*models.Subscriber, error)
AddSubscriber method adds a subscriber to the Pub/Sub service and returns a pointer to the Subscriber object and an error if the operation fails.
func (*BoltQueueService) Close ¶
func (r *BoltQueueService) Close() error
Close implements QueueEngineInterface.Close
func (*BoltQueueService) GetSubscriber ¶
func (s *BoltQueueService) GetSubscriber(ctx context.Context, userID string) (*models.Subscriber, error)
GetSubscriber method retrieves a subscriber from the Pub/Sub service and returns a pointer to the Subscriber object and an error if the operation fails.
func (*BoltQueueService) Publish ¶
func (r *BoltQueueService) Publish(topic string, messages ...*message.Message) error
Publish implements message.Publisher interface
func (*BoltQueueService) RemoveSubscriber ¶
func (s *BoltQueueService) RemoveSubscriber(ctx context.Context, userID string) error
RemoveSubscriber method removes a subscriber from the Pub/Sub service and returns an error if the operation fails.
Source Files
Click to show internal directories.
Click to hide internal directories.