queue

Documentation

Index

• Constants
• type PRReviewTaskPayload
• type TaskClient
  • func NewTaskClient(redisAddr string) *TaskClient
  • func (tc *TaskClient) EnqueueTask(payload PRReviewTaskPayload) error

Constants

const QueueName = "pr-review"

const TaskReviewPR = "review:pr"

Types

type PRReviewTaskPayload

type PRReviewTaskPayload struct {
	InstallationID int64  `json:"installation_id"`
	Owner          string `json:"owner"`
	Repo           string `json:"repo"`
	PRNumber       int    `json:"pr_number"`
	Title          string `json:"title"`
	Body           string `json:"body"`
	CommitSHA      string `json:"commit_sha"`
}

type TaskClient

type TaskClient struct {
	// contains filtered or unexported fields
}

func NewTaskClient

func NewTaskClient(redisAddr string) *TaskClient

func (*TaskClient) EnqueueTask

func (tc *TaskClient) EnqueueTask(payload PRReviewTaskPayload) error