Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GearmanConsumer ¶
type GearmanConsumer struct {
// contains filtered or unexported fields
}
func NewGearmanConsumer ¶
func NewGearmanConsumer(info constants.ConnectionInfo) *GearmanConsumer
func (*GearmanConsumer) RegisterChannel ¶
func (b *GearmanConsumer) RegisterChannel(channel string, processor constants.TaskProcessor) error
func (*GearmanConsumer) Stop ¶
func (b *GearmanConsumer) Stop()
func (*GearmanConsumer) Work ¶
func (b *GearmanConsumer) Work()
type GearmanProducer ¶
type GearmanProducer struct {
// contains filtered or unexported fields
}
func NewGearmanProducer ¶
func NewGearmanProducer(info constants.ConnectionInfo) *GearmanProducer
func (*GearmanProducer) Stop ¶
func (c *GearmanProducer) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.