Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultConfig = Config{ RabbitURI: "amqp://guest:guest@localhost:5672/", RabbitConnectionWaitTimeout: 30 * time.Second, }
DefaultConfig is a Config with default values set. You should not modify this. Instead copy and modify that.
Functions ¶
This section is empty.
Types ¶
type Kuyruk ¶
type Kuyruk struct {
// contains filtered or unexported fields
}
Kuyruk is the main type of this library. It holds a single connection to RabbitMQ server.
type Task ¶
type Task struct {
// contains filtered or unexported fields
}
Task that is going to be run on a Kuyruk worker.
func (*Task) SendToQueue ¶
SendToQueue serializes the task and publishes a message to RabbitMQ server.
Click to show internal directories.
Click to hide internal directories.