api

Documentation

Index

• type CreateSecretRequest
• type HTTPServer
  • func NewHTTPServer(addr string, store *db.SQLStore, queue queue.TaskQueue, ...) *HTTPServer
  • func (hs *HTTPServer) CreateJob(w http.ResponseWriter, r *http.Request)
  • func (hs *HTTPServer) CreateJobRun(w http.ResponseWriter, r *http.Request)
  • func (hs *HTTPServer) CreateSecret(w http.ResponseWriter, r *http.Request)
  • func (hs *HTTPServer) DeleteSecret(w http.ResponseWriter, r *http.Request)
  • func (hs *HTTPServer) GetJob(w http.ResponseWriter, r *http.Request)
  • func (hs *HTTPServer) GetJobRun(w http.ResponseWriter, r *http.Request)
  • func (httpServer *HTTPServer) GetLogSystem() *logger.Logger
  • func (hs *HTTPServer) GetPausedJobRuns(w http.ResponseWriter, r *http.Request)
  • func (hs *HTTPServer) ListJobs(w http.ResponseWriter, r *http.Request)
  • func (hs *HTTPServer) ListSecrets(w http.ResponseWriter, r *http.Request)
  • func (hs *HTTPServer) PauseJobRun(w http.ResponseWriter, r *http.Request)
  • func (hs *HTTPServer) ResumeJobRun(w http.ResponseWriter, r *http.Request)
  • func (httpServer *HTTPServer) Start() error
  • func (httpServer *HTTPServer) Stop() error
  • func (hs *HTTPServer) UpdateSecret(w http.ResponseWriter, r *http.Request)
• type JobBodyParams
• type JobRunBody
• type ListSecretsResponse
• type LogsHandler
  • func NewLogsHandler(store *db.SQLStore, streamer *logger.LogStreamer) *LogsHandler
  • func (h *LogsHandler) DownloadJobRunLogs(w http.ResponseWriter, r *http.Request)
  • func (h *LogsHandler) GetJobRunLogs(w http.ResponseWriter, r *http.Request)
  • func (h *LogsHandler) GetLogsByType(w http.ResponseWriter, r *http.Request)
  • func (h *LogsHandler) GetStreamingStatus(w http.ResponseWriter, r *http.Request)
  • func (h *LogsHandler) GetSystemLogs(w http.ResponseWriter, r *http.Request)
  • func (h *LogsHandler) GetTaskRunLogs(w http.ResponseWriter, r *http.Request)
  • func (h *LogsHandler) HandleSSEStream(w http.ResponseWriter, r *http.Request)
  • func (h *LogsHandler) HandleWebSocketStream(w http.ResponseWriter, r *http.Request)
  • func (h *LogsHandler) RegisterLogRoutes(v1 *router.Router)
• type SecretResponse
• type TaskJobBody

Types

type CreateSecretRequest

type CreateSecretRequest struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type HTTPServer

type HTTPServer struct {
	Server *http.Server
	// contains filtered or unexported fields
}

func NewHTTPServer

func NewHTTPServer(addr string, store *db.SQLStore, queue queue.TaskQueue, secretManager *security.SecretManager) *HTTPServer

func (*HTTPServer) CreateJob

func (hs *HTTPServer) CreateJob(w http.ResponseWriter, r *http.Request)

func (*HTTPServer) CreateJobRun

func (hs *HTTPServer) CreateJobRun(w http.ResponseWriter, r *http.Request)

func (*HTTPServer) CreateSecret

func (hs *HTTPServer) CreateSecret(w http.ResponseWriter, r *http.Request)

func (*HTTPServer) DeleteSecret

func (hs *HTTPServer) DeleteSecret(w http.ResponseWriter, r *http.Request)

func (*HTTPServer) GetJob

func (hs *HTTPServer) GetJob(w http.ResponseWriter, r *http.Request)

func (*HTTPServer) GetJobRun

func (hs *HTTPServer) GetJobRun(w http.ResponseWriter, r *http.Request)

func (*HTTPServer) GetLogSystem

func (httpServer *HTTPServer) GetLogSystem() *logger.Logger

func (*HTTPServer) GetPausedJobRuns

func (hs *HTTPServer) GetPausedJobRuns(w http.ResponseWriter, r *http.Request)

GetPausedJobRuns returns all paused job runs

func (*HTTPServer) ListJobs

func (hs *HTTPServer) ListJobs(w http.ResponseWriter, r *http.Request)

func (*HTTPServer) ListSecrets

func (hs *HTTPServer) ListSecrets(w http.ResponseWriter, r *http.Request)

func (*HTTPServer) PauseJobRun

func (hs *HTTPServer) PauseJobRun(w http.ResponseWriter, r *http.Request)

PauseJobRun pauses a running or queued job run

func (*HTTPServer) ResumeJobRun

func (hs *HTTPServer) ResumeJobRun(w http.ResponseWriter, r *http.Request)

ResumeJobRun resumes a paused job run

func (*HTTPServer) Start

func (httpServer *HTTPServer) Start() error

func (*HTTPServer) Stop

func (httpServer *HTTPServer) Stop() error

func (*HTTPServer) UpdateSecret

func (hs *HTTPServer) UpdateSecret(w http.ResponseWriter, r *http.Request)

type JobBodyParams

type JobBodyParams struct {
	Name           string        `json:"name"`
	Description    string        `json:"description"`
	Source         string        `json:"source"`
	RawPayload     []byte        `json:"raw_payload"`
	Tasks          []TaskJobBody `json:"tasks"`
	RunImmediately bool          `json:"run_immediately"`
}

type JobRunBody

type JobRunBody struct {
	JobID       string `json:"job_id"`
	TriggeredBy string `json:"triggered_by"`
}

type ListSecretsResponse

type ListSecretsResponse struct {
	Secrets []SecretResponse `json:"secrets"`
}

type LogsHandler

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

func NewLogsHandler

func NewLogsHandler(store *db.SQLStore, streamer *logger.LogStreamer) *LogsHandler

func (*LogsHandler) DownloadJobRunLogs

func (h *LogsHandler) DownloadJobRunLogs(w http.ResponseWriter, r *http.Request)

func (*LogsHandler) GetJobRunLogs

func (h *LogsHandler) GetJobRunLogs(w http.ResponseWriter, r *http.Request)

func (*LogsHandler) GetLogsByType

func (h *LogsHandler) GetLogsByType(w http.ResponseWriter, r *http.Request)

func (*LogsHandler) GetStreamingStatus

func (h *LogsHandler) GetStreamingStatus(w http.ResponseWriter, r *http.Request)

func (*LogsHandler) GetSystemLogs

func (h *LogsHandler) GetSystemLogs(w http.ResponseWriter, r *http.Request)

func (*LogsHandler) GetTaskRunLogs

func (h *LogsHandler) GetTaskRunLogs(w http.ResponseWriter, r *http.Request)

func (*LogsHandler) HandleSSEStream

func (h *LogsHandler) HandleSSEStream(w http.ResponseWriter, r *http.Request)

func (*LogsHandler) HandleWebSocketStream

func (h *LogsHandler) HandleWebSocketStream(w http.ResponseWriter, r *http.Request)

func (*LogsHandler) RegisterLogRoutes

func (h *LogsHandler) RegisterLogRoutes(v1 *router.Router)

type SecretResponse

type SecretResponse struct {
	ID        string `json:"id"`
	Name      string `json:"name"`
	CreatedAt string `json:"created_at"`
}

type TaskJobBody

type TaskJobBody struct {
	Name   string         `json:"name"`
	Type   string         `json:"type"`
	Config dto.TaskConfig `json:"config"`
	Order  int32          `json:"order"`
}