Documentation
¶
Index ¶
- type PubSubMutex
- func (p *PubSubMutex) SendReceive(sendTopic string, receiveTopic string, sendMsg interface{}, timeoutMs int) (result interface{})
- func (p *PubSubMutex) Shutdown()
- func (p *PubSubMutex) Start()
- func (p *PubSubMutex) Sub(subTopic string) (result <-chan interface{})
- func (p *PubSubMutex) SubAsync(subTopic string) (result <-chan interface{})
- func (p *PubSubMutex) Use(callback func(*pubsub.PubSub))
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubSubMutex ¶
type PubSubMutex struct {
// contains filtered or unexported fields
}
func New ¶
func New(capacity int) *PubSubMutex
func (*PubSubMutex) SendReceive ¶
func (p *PubSubMutex) SendReceive(sendTopic string, receiveTopic string, sendMsg interface{}, timeoutMs int) (result interface{})
func (*PubSubMutex) Shutdown ¶
func (p *PubSubMutex) Shutdown()
func (*PubSubMutex) Start ¶
func (p *PubSubMutex) Start()
func (*PubSubMutex) Sub ¶
func (p *PubSubMutex) Sub(subTopic string) (result <-chan interface{})
func (*PubSubMutex) SubAsync ¶
func (p *PubSubMutex) SubAsync(subTopic string) (result <-chan interface{})
func (*PubSubMutex) Use ¶
func (p *PubSubMutex) Use(callback func(*pubsub.PubSub))
Source Files
Click to show internal directories.
Click to hide internal directories.