Documentation ¶
Index ¶
- Constants
- type AMQPBroker
- func (b *AMQPBroker) Enqueue(name, messageID string, message proto.Message) error
- func (b *AMQPBroker) EnqueueIn(name, messageID string, message proto.Message, secondsFromNow int64) (string, error)
- func (b *AMQPBroker) GetMessage(jobName string) (*Message, error)
- func (b *AMQPBroker) GetQueueStatus(name string) (Status, error)
- func (b *AMQPBroker) RegisterJob(jobName string) error
- type Message
- type Status
Constants ¶
View Source
const (
NoConsumerQueue = "_%s_worker_delayed_5f345b3c-cab6-498a-9bc5-4de9537f8a5b"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPBroker ¶
type AMQPBroker struct {
// contains filtered or unexported fields
}
func NewBroker ¶
func NewBroker(url string) *AMQPBroker
func (*AMQPBroker) Enqueue ¶
func (b *AMQPBroker) Enqueue(name, messageID string, message proto.Message) error
func (*AMQPBroker) GetMessage ¶
func (b *AMQPBroker) GetMessage(jobName string) (*Message, error)
func (*AMQPBroker) GetQueueStatus ¶
func (b *AMQPBroker) GetQueueStatus(name string) (Status, error)
func (*AMQPBroker) RegisterJob ¶
func (b *AMQPBroker) RegisterJob(jobName string) error
Click to show internal directories.
Click to hide internal directories.