server

Documentation

Index

• type DateResource
• type HostsExecutionPolicyResource
• type JobHandler
  • func (h *JobHandler) JobList(resp http.ResponseWriter, req *http.Request, _ httprouter.Params)
  • func (h *JobHandler) JobSingle(resp http.ResponseWriter, req *http.Request, params httprouter.Params)
• type JobOwnerResource
• type JobResource
• type LinkResource
• type NodeHandler
  • func (h *NodeHandler) NodeList(resp http.ResponseWriter, req *http.Request, _ httprouter.Params)
  • func (h *NodeHandler) NodeSingle(resp http.ResponseWriter, req *http.Request, param httprouter.Params)
• type NodeResource
• type ReportHandler
  • func (h *ReportHandler) ReportsByJob(resp http.ResponseWriter, req *http.Request, param httprouter.Params)
• type RestServer
  • func NewRestServer(port int, nodes *container.NodeContainer, jobs *container.JobContainer, ...) *RestServer
  • func (h *RestServer) RootHandler(resp http.ResponseWriter, req *http.Request, param httprouter.Params)
  • func (s *RestServer) Start()
• type RoleExecutionPolicyResource
• type RootResource
• type SubHandler

Types

type DateResource

type DateResource struct {
	Timestamp int64  `json:"timestamp"`
	String    string `json:"string"`
}

type HostsExecutionPolicyResource

type HostsExecutionPolicyResource struct {
	Hosts    string   `json:"select"`
	HostList []string `json:"hosts"`
}

type JobHandler

type JobHandler SubHandler

func (*JobHandler) JobList

func (h *JobHandler) JobList(resp http.ResponseWriter, req *http.Request, _ httprouter.Params)

func (*JobHandler) JobSingle

func (h *JobHandler) JobSingle(resp http.ResponseWriter, req *http.Request, params httprouter.Params)

type JobOwnerResource

type JobOwnerResource struct {
	Name         string `json:"name"`
	EmailAddress string `json:"email_address"`
}

type JobResource

type JobResource struct {
	Name          string             `json:"name"`
	Href          string             `json:"href"`
	Links         [1]LinkResource    `json:"links"`
	Description   string             `json:"description"`
	Owners        []JobOwnerResource `json:"owners"`
	Policy        interface{}        `json:"execution_policy"`
	Schedule      string             `json:"execution_schedule"`
	Command       []string           `json:"command"`
	LastExecution *DateResource      `json:"last_execution"`
	NextExecution *DateResource      `json:"next_execution"`
}

type LinkResource

type LinkResource struct {
	Href string `json:"href"`
	Rel  string `json:"rel"`
}

type NodeHandler

type NodeHandler SubHandler

func (*NodeHandler) NodeList

func (h *NodeHandler) NodeList(resp http.ResponseWriter, req *http.Request, _ httprouter.Params)

func (*NodeHandler) NodeSingle

func (h *NodeHandler) NodeSingle(resp http.ResponseWriter, req *http.Request, param httprouter.Params)

type NodeResource

type NodeResource struct {
	Name        string   `json:"name"`
	Href        string   `json:"href"`
	Roles       []string `json:"roles"`
	Status      string   `json:"status"`
	RunningJobs int32    `json:"running_jobs"`
}

type ReportHandler

type ReportHandler SubHandler

func (*ReportHandler) ReportsByJob

func (h *ReportHandler) ReportsByJob(resp http.ResponseWriter, req *http.Request, param httprouter.Params)

type RestServer

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

func NewRestServer

func NewRestServer(port int, nodes *container.NodeContainer, jobs *container.JobContainer, store storage.StorageBackend, logger *logging.Logger) *RestServer

func (*RestServer) RootHandler

func (h *RestServer) RootHandler(resp http.ResponseWriter, req *http.Request, param httprouter.Params)

func (*RestServer) Start

func (s *RestServer) Start()

type RoleExecutionPolicyResource

type RoleExecutionPolicyResource struct {
	Hosts string   `json:"select"`
	Roles []string `json:"roles"`
}

type RootResource

type RootResource struct {
	Links []LinkResource `json:"links"`
}

type SubHandler

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