queue

Documentation

Index

• type BuildRunner
  • func NewBuildRunner(dockerClient *docker.Client, timeout time.Duration) BuildRunner
• type BuildTask
• type Queue
  • func Start(workers int, runner BuildRunner) *Queue
  • func (q *Queue) Add(task *BuildTask)

Types

type BuildRunner

type BuildRunner interface {
	Run(buildScript *script.Build, repo *repo.Repo, key []byte, buildOutput io.Writer) (success bool, err error)
}

func NewBuildRunner

func NewBuildRunner(dockerClient *docker.Client, timeout time.Duration) BuildRunner

type BuildTask

type BuildTask struct {
	Repo   *Repo
	Commit *Commit
	Build  *Build

	// Build instructions from the .drone.yml
	// file, unmarshalled.
	Script *script.Build
}

BuildTasks represents a build that is pending execution.

type Queue

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

A Queue dispatches tasks to workers.

func Start

func Start(workers int, runner BuildRunner) *Queue

Start N workers with the given build runner.

func (*Queue) Add

func (q *Queue) Add(task *BuildTask)

Add adds the task to the build queue.