Documentation
¶
Index ¶
- type HTTPApiClient
- func (a *HTTPApiClient) CancelBatch(id string) error
- func (a *HTTPApiClient) CancelJob(id string) error
- func (a *HTTPApiClient) CancelWorkflow(id string) error
- func (a *HTTPApiClient) GetBatch(id string) (*types.BatchInstance, error)
- func (a *HTTPApiClient) GetJob(id string) (*types.Job, error)
- func (a *HTTPApiClient) GetStats() (*StatsResponse, error)
- func (a *HTTPApiClient) GetWorkflow(id string) (*types.WorkflowInstance, error)
- func (a *HTTPApiClient) Health() error
- func (a *HTTPApiClient) ListBatches(status string) ([]*types.BatchInstance, error)
- func (a *HTTPApiClient) ListDLQ(limit int) ([]json.RawMessage, error)
- func (a *HTTPApiClient) ListHistoryRuns(status, jobID string) ([]*types.JobRun, error)
- func (a *HTTPApiClient) ListJobs(status string) ([]*types.Job, error)
- func (a *HTTPApiClient) ListNodes() ([]*types.NodeInfo, error)
- func (a *HTTPApiClient) ListQueues() ([]QueueInfo, error)
- func (a *HTTPApiClient) ListSchedules() ([]*types.ScheduleEntry, error)
- func (a *HTTPApiClient) ListWorkflows(status string) ([]*types.WorkflowInstance, error)
- func (a *HTTPApiClient) PauseQueue(tierName string) error
- func (a *HTTPApiClient) ResumeQueue(tierName string) error
- func (a *HTTPApiClient) RetryBatch(id string) error
- func (a *HTTPApiClient) RetryJob(id string) error
- func (a *HTTPApiClient) RetryWorkflow(id string) error
- type QueueInfo
- type StatsResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HTTPApiClient ¶
type HTTPApiClient struct {
// contains filtered or unexported fields
}
HTTPApiClient talks to the dureq monitoring HTTP API.
func NewHTTPApiClient ¶
func NewHTTPApiClient(baseURL string) *HTTPApiClient
func (*HTTPApiClient) CancelBatch ¶
func (a *HTTPApiClient) CancelBatch(id string) error
func (*HTTPApiClient) CancelJob ¶
func (a *HTTPApiClient) CancelJob(id string) error
func (*HTTPApiClient) CancelWorkflow ¶
func (a *HTTPApiClient) CancelWorkflow(id string) error
func (*HTTPApiClient) GetBatch ¶
func (a *HTTPApiClient) GetBatch(id string) (*types.BatchInstance, error)
func (*HTTPApiClient) GetStats ¶
func (a *HTTPApiClient) GetStats() (*StatsResponse, error)
func (*HTTPApiClient) GetWorkflow ¶
func (a *HTTPApiClient) GetWorkflow(id string) (*types.WorkflowInstance, error)
func (*HTTPApiClient) Health ¶
func (a *HTTPApiClient) Health() error
func (*HTTPApiClient) ListBatches ¶
func (a *HTTPApiClient) ListBatches(status string) ([]*types.BatchInstance, error)
func (*HTTPApiClient) ListDLQ ¶
func (a *HTTPApiClient) ListDLQ(limit int) ([]json.RawMessage, error)
func (*HTTPApiClient) ListHistoryRuns ¶
func (a *HTTPApiClient) ListHistoryRuns(status, jobID string) ([]*types.JobRun, error)
func (*HTTPApiClient) ListJobs ¶
func (a *HTTPApiClient) ListJobs(status string) ([]*types.Job, error)
func (*HTTPApiClient) ListQueues ¶
func (a *HTTPApiClient) ListQueues() ([]QueueInfo, error)
func (*HTTPApiClient) ListSchedules ¶
func (a *HTTPApiClient) ListSchedules() ([]*types.ScheduleEntry, error)
func (*HTTPApiClient) ListWorkflows ¶
func (a *HTTPApiClient) ListWorkflows(status string) ([]*types.WorkflowInstance, error)
func (*HTTPApiClient) PauseQueue ¶
func (a *HTTPApiClient) PauseQueue(tierName string) error
func (*HTTPApiClient) ResumeQueue ¶
func (a *HTTPApiClient) ResumeQueue(tierName string) error
func (*HTTPApiClient) RetryBatch ¶
func (a *HTTPApiClient) RetryBatch(id string) error
func (*HTTPApiClient) RetryJob ¶
func (a *HTTPApiClient) RetryJob(id string) error
func (*HTTPApiClient) RetryWorkflow ¶
func (a *HTTPApiClient) RetryWorkflow(id string) error
Source Files
Click to show internal directories.
Click to hide internal directories.