Versions in this module Expand all Collapse all v0 v0.0.10 Jan 6, 2016 Changes in this version + type BuildQueue interface + Push func(context.Context, builder.BuildOptions) error + Subscribe func(chan BuildRequest) error + func NewBuildQueue(buffer int) BuildQueue + type BuildRequest struct + Ctx context.Context + type Builder struct + Reporter reporter.Reporter + Timeout time.Duration + func NewBuilder(b builder.Builder) *Builder + func (b *Builder) Build(ctx context.Context, w io.Writer, opts builder.BuildOptions) (image string, err error) + type SQSBuildQueue struct + Context func() context.Context + ErrHandler func(error) + QueueURL string + func NewSQSBuildQueue(config *aws.Config) *SQSBuildQueue + func (q *SQSBuildQueue) Push(ctx context.Context, options builder.BuildOptions) error + func (q *SQSBuildQueue) Subscribe(ch chan BuildRequest) error + type Worker struct + Logger logs.Logger + func NewWorker(options WorkerOptions) *Worker + func (w *Worker) Shutdown() error + func (w *Worker) Start() error + type WorkerOptions struct + BuildRequests chan BuildRequest + Builder builder.Builder + Logger logs.Logger + type Workers []*Worker + func NewWorkerPool(num int, options WorkerOptions) (workers Workers) + func (w Workers) Shutdown() error + func (w Workers) Start() v0.0.9 Oct 17, 2015 Changes in this version + const DefaultTimeout + type Conveyor struct + Builder builder.Builder + LogFactory builder.LogFactory + Reporter reporter.Reporter + Timeout time.Duration + func New(b builder.Builder) *Conveyor + func (c *Conveyor) Build(ctx context.Context, w io.Writer, opts builder.BuildOptions) (image string, err error) + func (c *Conveyor) Cancel() error + func (c *Conveyor) EnqueueBuild(ctx context.Context, opts builder.BuildOptions) error + type Server struct + func NewServer(c *Conveyor) *Server + func (s *Server) Ping(w http.ResponseWriter, r *http.Request) + func (s *Server) Push(w http.ResponseWriter, r *http.Request) + func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)
Go to main page