queue

Documentation

Index

• Constants
• Variables
• type JobMessage
• type Queue
  • func NewQueue(db *sql.DB) *Queue
  • func (q *Queue) Delete(ctx context.Context, id goqite.ID) error
  • func (q *Queue) Inner() *goqite.Queue
  • func (q *Queue) Receive(ctx context.Context) (*goqite.Message, error)
  • func (q *Queue) Send(ctx context.Context, jobType string, repositoryID, issueID int64) error

Constants

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

var ErrSendJob = errors.New("send job")

ErrSendJob is returned when a message cannot be enqueued.

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 NewQueue

func NewQueue(db *sql.DB) *Queue

NewQueue creates a goqite-backed job queue.

func (*Queue) Delete

func (q *Queue) Delete(ctx context.Context, id goqite.ID) error

Delete acknowledges a message, removing it from the queue.

func (*Queue) Inner

func (q *Queue) Inner() *goqite.Queue

Inner returns the underlying goqite.Queue for use by the job processor (#156).

func (*Queue) Receive

func (q *Queue) Receive(ctx context.Context) (*goqite.Message, error)

Receive dequeues the next message from the queue. Returns nil message and nil error when the queue is empty.

func (*Queue) Send

func (q *Queue) Send(ctx context.Context, jobType string, repositoryID, issueID int64) error

Send enqueues a job message for downstream processing. Implements workers.JobQueue.