queue

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 12, 2014 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL