broker

Documentation

Index

• type Broker
  • func NewBroker() *Broker
  • func (b *Broker) AddSubscriber(subscriberReq models.AddSubscriber) error
  • func (b *Broker) CreateQueue(name string, bufferSize int) error
  • func (b *Broker) Publish(publishReq models.PublishReq) error
  • func (b *Broker) PublishToAll(queueName, message string) error
  • func (b *Broker) RemoveSubscriber(subscriberId uint, queueName string) error
  • func (b *Broker) Subscribe(queueName string) (string, error)
  • func (b *Broker) SubscribeById(queueName string, subscriberId uint) (string, error)
  • func (b *Broker) SubscriberList(queueName string) ([]*models.SubscriberResp, error)

Types

type Broker

type Broker struct {
	Queues map[string]*queue.Queue
	Mutex  sync.Mutex
}

func NewBroker

func NewBroker() *Broker

func (*Broker) AddSubscriber

func (b *Broker) AddSubscriber(subscriberReq models.AddSubscriber) error

func (*Broker) CreateQueue

func (b *Broker) CreateQueue(name string, bufferSize int) error

func (*Broker) Publish

func (b *Broker) Publish(publishReq models.PublishReq) error

func (*Broker) PublishToAll

func (b *Broker) PublishToAll(queueName, message string) error

func (*Broker) RemoveSubscriber

func (b *Broker) RemoveSubscriber(subscriberId uint, queueName string) error

func (*Broker) Subscribe

func (b *Broker) Subscribe(queueName string) (string, error)

func (*Broker) SubscribeById

func (b *Broker) SubscribeById(queueName string, subscriberId uint) (string, error)

func (*Broker) SubscriberList

func (b *Broker) SubscriberList(queueName string) ([]*models.SubscriberResp, error)