Documentation
¶
Index ¶
Constants ¶
View Source
const ( // QueueName is the single queue used for all AI dispatch jobs. QueueName = "ai-jobs" // Timeout is how long a message stays invisible after Receive. // If the consumer dies, the message reappears after this duration. Timeout = 5 * time.Minute // MaxReceive is how many times a message can be received before // it becomes a dead message and is no longer delivered. MaxReceive = 5 )
Variables ¶
View Source
var ErrSendJob = errors.New("send job")
ErrSendJob is returned when a message cannot be enqueued.
Functions ¶
This section is empty.
Types ¶
type JobMessage ¶
type JobMessage struct {
Type string `json:"type"`
RepositoryID int64 `json:"repositoryId"`
IssueID int64 `json:"issueId"`
}
JobMessage is the payload serialized into the goqite message body.
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue wraps goqite.Queue and implements workers.JobQueue.
func (*Queue) Inner ¶
Inner returns the underlying goqite.Queue for use by the job processor (#156).
Source Files
Click to show internal directories.
Click to hide internal directories.