api

Documentation

Index

• type AuthCredentials
• type HTTPServer
  • func NewServer(auth AuthCredentials, svc JobService) (HTTPServer, error)
• type JobCreateRequest
• type JobHandleResponse
• type JobRunRequest
• type JobService

Types

type AuthCredentials

type AuthCredentials struct {
	AccessKey string
	Secret    string
}

type HTTPServer

type HTTPServer interface {
	ListenAndServe(listenAddr string) error
	ServeHTTP(w http.ResponseWriter, r *http.Request)
	Stop(ctx context.Context) error
}

func NewServer

func NewServer(
	auth AuthCredentials,
	svc JobService,
) (HTTPServer, error)

type JobCreateRequest

type JobCreateRequest struct {
	JobID  string        `json:"jobId"`
	Name   string        `json:"type"`
	Params model.JobSpec `json:"params"`
}

type JobHandleResponse

type JobHandleResponse struct {
	ID string `json:"id"`
}

type JobRunRequest

type JobRunRequest struct {
	JobID  string `json:"jobID"`
	Result string `json:"result"`
}

type JobService

type JobService interface {
	StartJob(jobID string, spec *model.JobSpec) error
	RunJob(jobID, result string) error
	StopJob(jobID string) error
}