Documentation
¶
Index ¶
- type PubSubManager
- func (m *PubSubManager) Close()
- func (m *PubSubManager) CreateTopic(topic string)
- func (m *PubSubManager) DeleteTopic(topic string)
- func (m *PubSubManager) Dequeue(topic, subscriber string) (string, error)
- func (m *PubSubManager) Enqueue(topic, msg string) error
- func (m *PubSubManager) Subscribe(topic, subscriber string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubSubManager ¶
type PubSubManager struct {
// contains filtered or unexported fields
}
func NewPubSubManager ¶
func NewPubSubManager(buffer_size int) *PubSubManager
func (*PubSubManager) Close ¶
func (m *PubSubManager) Close()
func (*PubSubManager) CreateTopic ¶
func (m *PubSubManager) CreateTopic(topic string)
func (*PubSubManager) DeleteTopic ¶
func (m *PubSubManager) DeleteTopic(topic string)
func (*PubSubManager) Dequeue ¶
func (m *PubSubManager) Dequeue(topic, subscriber string) (string, error)
func (*PubSubManager) Enqueue ¶
func (m *PubSubManager) Enqueue(topic, msg string) error
func (*PubSubManager) Subscribe ¶
func (m *PubSubManager) Subscribe(topic, subscriber string) error
Source Files
Click to show internal directories.
Click to hide internal directories.