api

Feb 24, 2026

Changes in this version

+ type HTTPApiClient struct

+ func NewHTTPApiClient(baseURL string) *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 struct

+ FetchBatch int

+ Name string

+ Paused bool

+ Size int64

+ Weight int

+ type StatsResponse struct

+ ActiveNodes int

+ ActiveRuns int

+ ActiveSchedules int

+ JobCounts map[string]int