Help us shape the future of Go! Take the 2026 Go Developer Survey

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