Documentation
¶
Index ¶
- Constants
- Variables
- type Channel
- type PubSub
- func (r *PubSub) Conn() sabuhp.Conn
- func (r *PubSub) Listen(topic string, handler sabuhp.TransportResponse) sabuhp.Channel
- func (r *PubSub) SendToAll(data *sabuhp.Message, timeout time.Duration) error
- func (r *PubSub) SendToOne(data *sabuhp.Message, timeout time.Duration) error
- func (r *PubSub) Start()
- func (r *PubSub) Stop()
- func (r *PubSub) UnListen(topic string)
- func (r *PubSub) Wait()
- type PubSubConfig
Constants ¶
View Source
const ( GroupExistErrorMsg = "BUSYGROUP Consumer Group name already exists" SubscriptionExistsAlready = "Topic is already subscribed to" )
Variables ¶
View Source
var ( DefaultMessageBatchCount = 200 DefaultMessageBatchWait = 700 * time.Millisecond )
Functions ¶
This section is empty.
Types ¶
type Channel ¶
type Channel struct {
// contains filtered or unexported fields
}
Channel implements the sabuhp.Channel interface.
Click to show internal directories.
Click to hide internal directories.