task_handler

package
v0.2.1 Latest Latest
Warning

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

Go to latest
Published: Mar 24, 2015 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source
const MAX_RETRIES = 3
View Source
const POOL_SIZE = 20

Variables

View Source
var ErrWatchFailed = errors.New("watching for completed tasks failed")

Functions

func New

func New(enqueue chan<- models.Task, logger lager.Logger) http.Handler

func NewHandler

func NewHandler(enqueue chan<- models.Task, logger lager.Logger) http.Handler

func NewTaskWorkerPool

func NewTaskWorkerPool(bbs Bbs.ReceptorBBS, logger lager.Logger) (ifrit.Runner, chan<- models.Task)

Types

type TaskHandler

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

func (*TaskHandler) ServeHTTP

func (t *TaskHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

Jump to

Keyboard shortcuts

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