batchs

May 27, 2021

Changes in this version

+ type FileQueue struct

+ func (fq *FileQueue) FinishJob(jb *Job) error

+ func (fq *FileQueue) Init() error

+ func (fq *FileQueue) NextJob() (*Job, error)

type RESTServer

+ func (server *RESTServer) DeleteJobIDFileHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (server *RESTServer) DeleteJobIDHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (server *RESTServer) GetJobIDFileHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (server *RESTServer) GetJobIDHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (server *RESTServer) PutJobIDFileHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (server *RESTServer) PutJobIDHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (server *RESTServer) SubmitJobIDHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

May 18, 2017

Changes in this version

+ type JobInfo struct

+ Name string

+ Status string

Sep 15, 2016

Changes in this version

+ func NotImplementedHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ type RESTServer struct

+ PortNumber string

+ QueuePath *fileQueue

+ Version string

+ func (s *RESTServer) DeleteJobIdFileHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (s *RESTServer) DeleteJobIdHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (s *RESTServer) GetJobIdFileHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (s *RESTServer) GetJobIdHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (s *RESTServer) GetJobsHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (s *RESTServer) PutJobIdFileHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (s *RESTServer) PutJobIdHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (s *RESTServer) Run() error

+ func (s *RESTServer) SubmitJobIdHandler(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

+ func (server *RESTServer) WelcomeHandler(writer http.ResponseWriter, request *http.Request, params httprouter.Params)

Nov 19, 2015

Changes in this version

+ var ErrTask = errors.New("error running a task")

+ type Context struct

+ func NewContext(q JobSource, taskpath, version string) *Context

+ func (ctx *Context) Run() error

+ type Job struct

+ Finished []Task

+ Todo []string

+ type JobSource interface

+ FinishJob func(job *Job) error

+ Init func() error

+ NextJob func() (*Job, error)

+ func NewFileQueue(basepath string) JobSource

+ type State int

+ const StateError

+ const StateProcessing

+ const StateQueue

+ const StateSuccess

+ const StateUnknown

+ func (s State) String() string

+ type Task struct

+ Finish time.Time

+ Name string

+ Start time.Time

+ Status string