rest

Documentation

Index

• Variables
• type RestServer
  • func (ln RestServer) Accept() (c net.Conn, err error)
  • func (r *RestServer) Start() error
  • func (r *RestServer) Stop()
• type TaskRouter
  • func NewTaskRouter() *TaskRouter
  • func (tr *TaskRouter) CancelTask(params martini.Params, r *http.Request, w http.ResponseWriter)
  • func (tr *TaskRouter) CreateTask(r *http.Request, w http.ResponseWriter)
  • func (tr *TaskRouter) GetAllTasks(r *http.Request, w http.ResponseWriter)
  • func (tr *TaskRouter) GetTask(params martini.Params, r *http.Request, w http.ResponseWriter)
  • func (tr *TaskRouter) Register(r martini.Router)

Variables

var StoppedError = errors.New("Listener stopped")

Types

type RestServer

type RestServer struct {
	Scheduler *service.SchedulerService
	// contains filtered or unexported fields
}

RestServer Holds stuff shared by all the rest services

func (RestServer) Accept

func (ln RestServer) Accept() (c net.Conn, err error)

func (*RestServer) Start

func (r *RestServer) Start() error

func (*RestServer) Stop

func (r *RestServer) Stop()

type TaskRouter

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

func NewTaskRouter

func NewTaskRouter() *TaskRouter

func (*TaskRouter) CancelTask

func (tr *TaskRouter) CancelTask(params martini.Params, r *http.Request, w http.ResponseWriter)

func (*TaskRouter) CreateTask

func (tr *TaskRouter) CreateTask(r *http.Request, w http.ResponseWriter)

func (*TaskRouter) GetAllTasks

func (tr *TaskRouter) GetAllTasks(r *http.Request, w http.ResponseWriter)

func (*TaskRouter) GetTask

func (tr *TaskRouter) GetTask(params martini.Params, r *http.Request, w http.ResponseWriter)

func (*TaskRouter) Register

func (tr *TaskRouter) Register(r martini.Router)